fix compile error

lkpworkspace · Jun 20, 2024 · 1f8e35b · 1f8e35b
1 parent d68936a
commit 1f8e35b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/myframe/app.cpp b/myframe/app.cpp
@@ -542,7 +542,7 @@ void App::CheckStopWorkers() {
       << " dispatch msg to "
       << *worker_ctx;
     auto actor_mailbox = actor_ctx->GetMailbox();
-    int actor_ctx_recv_sz = actor_mailbox->RecvSize();
+    std::size_t actor_ctx_recv_sz = actor_mailbox->RecvSize();
     if (!actor_mailbox->RecvEmpty()) {
       LOG_IF(WARNING,
         actor_ctx_recv_sz > warning_msg_size_.load())

diff --git a/myframe/worker_context_manager.cpp b/myframe/worker_context_manager.cpp
@@ -166,7 +166,7 @@ void WorkerContextManager::DispatchWorkerMsg(
     return;
   }
   worker_ctx->GetMailbox()->Recv(std::move(msg));
-  int recv_size = worker_ctx->GetMailbox()->RecvSize();
+  std::size_t recv_size = worker_ctx->GetMailbox()->RecvSize();
   LOG_IF(WARNING, recv_size > warning_msg_size_.load())
       << *worker_ctx << " has " << recv_size
       << " msg not process!!!";