Fixes

resetius · Nov 28, 2023 · 20ce097 · 20ce097
1 parent 2c2b530
commit 20ce097
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/src/messages.h b/src/messages.h
@@ -85,11 +85,15 @@ struct TCommandRequest: public TMessage {
     char Data[0];
 };
 
+static_assert(sizeof(TCommandRequest) == sizeof(TMessage));
+
 struct TCommandResponse: public TMessage {
     static constexpr EMessageType MessageType = EMessageType::COMMAND_RESPONSE;
     uint64_t Index;
 };
 
+static_assert(sizeof(TCommandResponse) == sizeof(TMessage) + 8);
+
 struct TTimeout: public TMessage {
     static constexpr EMessageType MessageType = EMessageType::TIMEOUT;
     static constexpr std::chrono::milliseconds Election = std::chrono::milliseconds(5000);

diff --git a/src/raft.cpp b/src/raft.cpp
@@ -450,7 +450,8 @@ void TRaft::ApplyResult(ITimeSource::Time now, std::unique_ptr<TResult> result,
 void TRaft::ProcessWaiting() {
     auto commitIndex = VolatileState->CommitIndex;
     while (!waiting.empty() && waiting.top().Index <= commitIndex) {
-        auto&& w = std::move(waiting.top()); waiting.pop();
-        w.ReplyTo->Send(std::move(w.Message));
+        auto w = waiting.top(); waiting.pop();
+        w.ReplyTo->Send(w.Message);
     }
 }
+