generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-13 10:52:56 +01:00
Code Issues Projects Releases Wiki Activity

fix assert error on late-joining subscriber after publisher has filled NORM buffer

Browse Source
This commit is contained in:
Jeffery Weston 2023-07-21 14:34:53 -04:00 committed by Luca Boccassi
parent ecc63d0d3b
commit ec013f3a17
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/norm_engine.cpp
View File

@ -557,8 +557,7 @@ void zmq::norm_engine_t::recv_data (NormObjectHandle object)
char syncFlag; char syncFlag;
unsigned int numBytes = 1; unsigned int numBytes = 1;
if (!NormStreamRead (stream, &syncFlag, &numBytes)) { if (!NormStreamRead (stream, &syncFlag, &numBytes)) {
// broken stream (shouldn't happen after seek msg start?) // broken stream (can happen on late-joining subscriber)
zmq_assert (false);
continue; continue;
} }
if (0 == numBytes) { if (0 == numBytes) {