From 94a455aba299af5ffe476560d859dfd007cd5467 Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期五, 16 四月 2021 12:13:43 +0800 Subject: [PATCH] fix crash by using normal timeout; add sendq todo. --- src/sendq.cpp | 5 +++++ 1 files changed, 5 insertions(+), 0 deletions(-) diff --git a/src/sendq.cpp b/src/sendq.cpp index 242f8de..ad293c3 100644 --- a/src/sendq.cpp +++ b/src/sendq.cpp @@ -19,6 +19,11 @@ #include "shm_queue.h" #include <chrono> +//TODO change to save head, body, instead of MsgI. +// as MsgI which is in shm, but head, body are in current process. +// Then if node crashes, shm will not be affected by msgs in sendq. +// but pulishing ref-counted msg need some work. + int SendQ::DoSend1Remote(bhome_shm::ShmMsgQueue &mq, const Remote &remote, Array &arr) { auto FirstNotExpired = [](Array &l) { -- Gitblit v1.8.0