coffee/cpp-ipc
1
0
Fork 0
mirror of https://github.com/mutouyun/cpp-ipc.git synced 2025-12-06 16:56:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

send之前还是应该简单检查连接个数

Browse Source
This commit is contained in:
mutouyun 2021-01-03 13:12:49 +08:00
parent 6163618433
commit f2335bb38b
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/ipc.cpp
View File

@ -435,6 +435,10 @@ static bool send(F&& gen_push, ipc::handle_t h, void const * data, std::size_t s
ipc::error("fail: send, que->ready_sending() == false\n"); ipc::error("fail: send, que->ready_sending() == false\n");
return false; return false;
} }
if (que->elems()->connections(std::memory_order_relaxed) == 0) {
ipc::error("fail: send, there is no receiver on this connection.\n");
return false;
}
// calc a new message id // calc a new message id
auto acc = info_of(h)->acc(); auto acc = info_of(h)->acc();
if (acc == nullptr) { if (acc == nullptr) {