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) {
