From 00fb1747bb7633aa5bb3f7b13201d81dededfd49 Mon Sep 17 00:00:00 2001 From: Dmitry Vyukov 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 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'pkg/rpcserver/rpcserver.go') 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() }) } -- cgit mrf-deployment