Fix duplicated message

2023-03-06 19:41:01 +08:00 · 2023-03-06 19:41:01 +08:00 · 2e9cf595ee
commit 2e9cf595ee
parent c8e6558cb6
1 changed files with 2 additions and 1 deletions
--- a/spy/rpc_server.cpp
+++ b/spy/rpc_server.cpp
@ -306,6 +306,7 @@ static void PushMessage()
                rsp.msg.wxmsg.content  = (char *)wxmsg.content.c_str();
                gMsgQueue.pop();
                LOG_DEBUG("Recv msg: {}", wxmsg.content);
+                pb_ostream_t stream = pb_ostream_from_buffer(buffer, G_BUF_SIZE);
                if (!pb_encode(&stream, Response_fields, &rsp)) {
                    LOG_ERROR("Encoding failed: {}", PB_GET_ERROR(&stream));
                    continue;