33 #include "platform.hpp" 35 #ifdef ZMQ_HAVE_WINDOWS 39 #include "../include/zmq.h" 100 std::string group = std::string (group_);
128 int rc2 = msg.
close ();
137 std::string group = std::string (group_);
164 int rc2 = msg.
close ();
290 int rc = msg_->
init ();
329 int group_length = (
int) strlen (msg_->
group ());
335 rc = command.
init_size (group_length + 5);
338 memcpy (command.
data (),
"\4JOIN", 5);
341 rc = command.
init_size (group_length + 6);
344 memcpy (command.
data (),
"\5LEAVE", 6);
348 char* command_data = (
char*)command.
data ();
351 memcpy (command_data + offset, msg_->
group (), group_length);
void xpipe_terminated(zmq::pipe_t *pipe_)
int set_group(const char *group_)
blob_t get_credential() const
int send_to_all(zmq::msg_t *msg_)
virtual int push_msg(msg_t *msg_)
void activated(zmq::pipe_t *pipe_)
subscriptions_t subscriptions
void xread_activated(zmq::pipe_t *pipe_)
#define ZMQ_GROUP_MAX_LENGTH
int xleave(const char *group_)
void xwrite_activated(zmq::pipe_t *pipe_)
void pipe_terminated(pipe_t *pipe_)
void xhiccuped(pipe_t *pipe_)
int pull_msg(msg_t *msg_)
int xrecv(zmq::msg_t *msg_)
int xsend(zmq::msg_t *msg_)
int init_size(size_t size_)
#define LIBZMQ_UNUSED(object)
void attach(zmq::pipe_t *pipe_)
void attach(pipe_t *pipe_)
std::basic_string< unsigned char > blob_t
virtual int pull_msg(msg_t *msg_)
blob_t get_credential() const
void set_flags(unsigned char flags_)
void activated(pipe_t *pipe_)
int push_msg(msg_t *msg_)
void send_subscriptions(pipe_t *pipe_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
unsigned char data[max_vsm_size]
void pipe_terminated(zmq::pipe_t *pipe_)
dish_session_t(zmq::io_thread_t *io_thread_, bool connect_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_)
dish_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
int xjoin(const char *group_)
enum zmq::dish_session_t::@35 state