From 1484e3c0c083b3dbbb3a34b352c7dc16b5e96c3f Mon Sep 17 00:00:00 2001 From: Marcin Copik Date: Thu, 17 Oct 2024 23:28:08 +0200 Subject: [PATCH] [process] Fix a very nasty bug in processing messages In some cases, we could have forgotten to parse the incoming message. We would have 2x messages in the TCP stream, we would consume the first one but forgot about the second one --- process/controller/src/remote.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/process/controller/src/remote.cpp b/process/controller/src/remote.cpp index a025742..f964557 100644 --- a/process/controller/src/remote.cpp +++ b/process/controller/src/remote.cpp @@ -199,7 +199,7 @@ namespace praas::process::remote { // Three types of messages require long payloads: // invoke // put - std::visit( + consumed = std::visit( common::message::overloaded{ [this, buffer, conn = conn.get()](common::message::InvocationRequestPtr& invoc ) mutable -> bool { return _handle_invocation(*conn, invoc, buffer); },