From ec013f3a17beaa475c18e8cf5e93970800e2f94a Mon Sep 17 00:00:00 2001 From: Jeffery Weston Date: Fri, 21 Jul 2023 14:34:53 -0400 Subject: [PATCH] fix assert error on late-joining subscriber after publisher has filled NORM buffer --- src/norm_engine.cpp | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/norm_engine.cpp b/src/norm_engine.cpp index fbda2f3f..1e3ae179 100644 --- a/src/norm_engine.cpp +++ b/src/norm_engine.cpp @@ -557,8 +557,7 @@ void zmq::norm_engine_t::recv_data (NormObjectHandle object) char syncFlag; unsigned int numBytes = 1; if (!NormStreamRead (stream, &syncFlag, &numBytes)) { - // broken stream (shouldn't happen after seek msg start?) - zmq_assert (false); + // broken stream (can happen on late-joining subscriber) continue; } if (0 == numBytes) {