File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -99,29 +99,30 @@ class multipart_t
99
99
return m_parts.empty ();
100
100
}
101
101
102
- bool recv (socket_t & socket)
102
+ bool recv (socket_t & socket, int flags = 0 )
103
103
{
104
104
clear ();
105
105
bool more = true ;
106
106
while (more)
107
107
{
108
108
message_t message;
109
- if (!socket.recv (&message))
109
+ if (!socket.recv (&message, flags ))
110
110
return false ;
111
111
more = message.more ();
112
112
add (std::move (message));
113
113
}
114
114
return true ;
115
115
}
116
116
117
- bool send (socket_t & socket)
117
+ bool send (socket_t & socket, int flags = 0 )
118
118
{
119
+ flags &= ~(ZMQ_SNDMORE);
119
120
bool more = size () > 0 ;
120
121
while (more)
121
122
{
122
123
message_t message = pop ();
123
124
more = size () > 0 ;
124
- if (!socket.send (message, more ? ZMQ_SNDMORE : 0 ))
125
+ if (!socket.send (message, ( more ? ZMQ_SNDMORE : 0 ) | flags ))
125
126
return false ;
126
127
}
127
128
clear ();
You can’t perform that action at this time.
0 commit comments