diff options
| author | Dmitry Vyukov <dvyukov@google.com> | 2024-07-01 11:18:41 +0200 |
|---|---|---|
| committer | Dmitry Vyukov <dvyukov@google.com> | 2024-07-01 10:13:03 +0000 |
| commit | 00fb1747bb7633aa5bb3f7b13201d81dededfd49 (patch) | |
| tree | 524890674969d7ec78a0dbeecd9d23cc5578d90a /pkg/rpcserver | |
| parent | 714041c90b9b0efe7fb63d39fa6b0aa643f2450c (diff) | |
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.
Diffstat (limited to 'pkg/rpcserver')
| -rw-r--r-- | pkg/rpcserver/rpcserver.go | 4 | ||||
| -rw-r--r-- | pkg/rpcserver/runner.go | 6 |
2 files changed, 5 insertions, 5 deletions
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) |