ext/zeromq/src/dist.hpp in rbczmq-1.7.1 vs ext/zeromq/src/dist.hpp in rbczmq-1.7.2

- old
+ new

@@ -1,8 +1,7 @@ /* - Copyright (c) 2011 250bpm s.r.o. - Copyright (c) 2011 Other contributors as noted in the AUTHORS file + Copyright (c) 2007-2013 Contributors as noted in the AUTHORS file This file is part of 0MQ. 0MQ is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by @@ -53,27 +52,27 @@ // Mark all pipes as non-matching. void unmatch (); // Removes the pipe from the distributor object. - void terminated (zmq::pipe_t *pipe_); + void pipe_terminated (zmq::pipe_t *pipe_); // Send the message to the matching outbound pipes. - int send_to_matching (zmq::msg_t *msg_, int flags_); + int send_to_matching (zmq::msg_t *msg_); // Send the message to all the outbound pipes. - int send_to_all (zmq::msg_t *msg_, int flags_); + int send_to_all (zmq::msg_t *msg_); bool has_out (); private: // Write the message to the pipe. Make the pipe inactive if writing // fails. In such a case false is returned. bool write (zmq::pipe_t *pipe_, zmq::msg_t *msg_); // Put the message to all active pipes. - void distribute (zmq::msg_t *msg_, int flags_); + void distribute (zmq::msg_t *msg_); // List of outbound pipes. typedef array_t <zmq::pipe_t, 2> pipes_t; pipes_t pipes;