From 66fcb0a84fcd55ad8e1444cdd0bc0ad6592f7329 Mon Sep 17 00:00:00 2001 From: Dmitry Vyukov Date: Mon, 1 Jul 2024 14:26:05 +0200 Subject: pkg/fuzzer: try to triage on different VMs Distribute triage requests to different VMs. --- executor/executor.cc | 2 +- executor/executor_runner.h | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) (limited to 'executor') diff --git a/executor/executor.cc b/executor/executor.cc index 055957e9f..b550fc0cf 100644 --- a/executor/executor.cc +++ b/executor/executor.cc @@ -1334,7 +1334,7 @@ flatbuffers::span finish_output(OutputData* output, int proc_id, uint64 flatbuffers::Offset> output_off = 0; if (process_output) output_off = fbb.CreateVector(*process_output); - auto exec_off = rpc::CreateExecResultRaw(fbb, req_id, output_off, error_off, prog_info_off); + auto exec_off = rpc::CreateExecResultRaw(fbb, req_id, proc_id, output_off, error_off, prog_info_off); auto msg_off = rpc::CreateExecutorMessageRaw(fbb, rpc::ExecutorMessagesRaw::ExecResult, flatbuffers::Offset(exec_off.o)); fbb.FinishSizePrefixed(msg_off); diff --git a/executor/executor_runner.h b/executor/executor_runner.h index 96fcc9b44..5229fa1a7 100644 --- a/executor/executor_runner.h +++ b/executor/executor_runner.h @@ -55,6 +55,8 @@ public: { if (state_ != State::Started && state_ != State::Idle) return false; + if (msg.avoid & (1ull << id_)) + return false; if (msg_) fail("already have pending msg"); if (wait_start_) -- cgit mrf-deployment