From 00fb1747bb7633aa5bb3f7b13201d81dededfd49 Mon Sep 17 00:00:00 2001
From: Dmitry Vyukov <dvyukov@google.com>
Date: Mon, 1 Jul 2024 11:18:41 +0200
Subject: pkg/flatrpc: rename StartLeakChecks to CorpusTriaged

It's a more general name that says what happened
rather than a detail of what excutor should do.
We can use this notification for other things as well.
---
 pkg/rpcserver/rpcserver.go | 4 ++--
 pkg/rpcserver/runner.go    | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

(limited to 'pkg/rpcserver')

diff --git a/pkg/rpcserver/rpcserver.go b/pkg/rpcserver/rpcserver.go
index e2a321803..1a9140537 100644
--- a/pkg/rpcserver/rpcserver.go
+++ b/pkg/rpcserver/rpcserver.go
@@ -220,7 +220,7 @@ func (serv *Server) handleConn(conn *flatrpc.Conn) {
 	defer close(runner.finished)
 
 	if serv.triagedCorpus.Load() {
-		if err := runner.sendStartLeakChecks(); err != nil {
+		if err := runner.sendCorpusTriaged(); err != nil {
 			log.Logf(2, "%v", err)
 			return
 		}
@@ -477,7 +477,7 @@ func (serv *Server) DistributeSignalDelta(plus, minus signal.Signal) {
 func (serv *Server) TriagedCorpus() {
 	serv.triagedCorpus.Store(true)
 	serv.foreachRunnerAsync(func(runner *Runner) {
-		runner.sendStartLeakChecks()
+		runner.sendCorpusTriaged()
 	})
 }
 
diff --git a/pkg/rpcserver/runner.go b/pkg/rpcserver/runner.go
index 22d85f0c6..0c41346ee 100644
--- a/pkg/rpcserver/runner.go
+++ b/pkg/rpcserver/runner.go
@@ -281,11 +281,11 @@ func (runner *Runner) sendSignalUpdate(plus, minus []uint64) error {
 	return flatrpc.Send(runner.conn, msg)
 }
 
-func (runner *Runner) sendStartLeakChecks() error {
+func (runner *Runner) sendCorpusTriaged() error {
 	msg := &flatrpc.HostMessage{
 		Msg: &flatrpc.HostMessages{
-			Type:  flatrpc.HostMessagesRawStartLeakChecks,
-			Value: &flatrpc.StartLeakChecks{},
+			Type:  flatrpc.HostMessagesRawCorpusTriaged,
+			Value: &flatrpc.CorpusTriaged{},
 		},
 	}
 	return flatrpc.Send(runner.conn, msg)
-- 
cgit mrf-deployment