Commit 842b4dd2 authored by Martin Sustrik's avatar Martin Sustrik

muti-part message functionality available via API

parent 8d8e0857
...@@ -181,6 +181,7 @@ ZMQ_EXPORT int zmq_term (void *context); ...@@ -181,6 +181,7 @@ ZMQ_EXPORT int zmq_term (void *context);
#define ZMQ_RCVBUF 12 #define ZMQ_RCVBUF 12
#define ZMQ_NOBLOCK 1 #define ZMQ_NOBLOCK 1
#define ZMQ_TBC 2
ZMQ_EXPORT void *zmq_socket (void *context, int type); ZMQ_EXPORT void *zmq_socket (void *context, int type);
ZMQ_EXPORT int zmq_close (void *s); ZMQ_EXPORT int zmq_close (void *s);
......
...@@ -311,6 +311,11 @@ int zmq::socket_base_t::connect (const char *addr_) ...@@ -311,6 +311,11 @@ int zmq::socket_base_t::connect (const char *addr_)
int zmq::socket_base_t::send (::zmq_msg_t *msg_, int flags_) int zmq::socket_base_t::send (::zmq_msg_t *msg_, int flags_)
{ {
// ZMQ_TBC is actually a message flag, not a real send-flag
// such as ZMQ_NOBLOCK. At this point we impose it on the message.
if (flags_ & ZMQ_TBC)
msg_->flags |= ZMQ_MSG_TBC;
// Process pending commands, if any. // Process pending commands, if any.
app_thread->process_commands (false, true); app_thread->process_commands (false, true);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment