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

fix: the receiver of channel will hang after disconnect

Browse Source
This commit is contained in:
木头云 2023-05-14 14:11:54 +08:00 committed by GitHub
parent 2a2b626210
commit 6111722534
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/libipc/ipc.cpp
View File

@ -533,7 +533,7 @@ static ipc::buff_t recv(ipc::handle_t h, std::uint64_t tm) {
auto& rc = info_of(h)->recv_cache(); auto& rc = info_of(h)->recv_cache();
for (;;) { for (;;) {
// pop a new message // pop a new message
typename queue_t::value_t msg; typename queue_t::value_t msg {};
if (!wait_for(info_of(h)->rd_waiter_, [que, &msg] { if (!wait_for(info_of(h)->rd_waiter_, [que, &msg] {
return !que->pop(msg); return !que->pop(msg);
}, tm)) { }, tm)) {