3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-17 08:34:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Problem: metadata is stored for PUB sockets and never processed

Browse Source 
Solution: do not store user messages when the socket type is PUB, they
will never be processed
This commit is contained in:
Luca Boccassi 2020-05-25 15:48:05 +01:00
parent 821ab88f96
commit cf9ccbbd37
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/xpub.cpp
View File

@ -131,8 +131,10 @@ void zmq::xpub_t::xread_activated (pipe_t *pipe_)
_process_subscribe = _process_subscribe =
!_only_first_subscribe || is_subscribe_or_cancel; !_only_first_subscribe || is_subscribe_or_cancel;
if (!is_subscribe_or_cancel) { if (!is_subscribe_or_cancel && options.type != ZMQ_PUB) {
// Process user message coming upstream from xsub socket // Process user message coming upstream from xsub socket,
// but not if the type is PUB, which never processes user
// messages
_pending_data.push_back (blob_t (msg_data, msg.size ())); _pending_data.push_back (blob_t (msg_data, msg.size ()));
if (metadata) if (metadata)
metadata->add_ref (); metadata->add_ref ();