summaryrefslogtreecommitdiff
path: root/src/dist.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/dist.hpp')
-rw-r--r--src/dist.hpp32
1 files changed, 16 insertions, 16 deletions
diff --git a/src/dist.hpp b/src/dist.hpp
index be86ab2..a16ca7b 100644
--- a/src/dist.hpp
+++ b/src/dist.hpp
@@ -1,15 +1,15 @@
/*
- Copyright (c) 2011 250bpm s.r.o.
+ Copyright (c) 2011-2012 250bpm s.r.o.
Copyright (c) 2011 Other contributors as noted in the AUTHORS file
- This file is part of 0MQ.
+ This file is part of Crossroads project.
- 0MQ is free software; you can redistribute it and/or modify it under
+ Crossroads is free software; you can redistribute it and/or modify it under
the terms of the GNU Lesser General Public License as published by
the Free Software Foundation; either version 3 of the License, or
(at your option) any later version.
- 0MQ is distributed in the hope that it will be useful,
+ Crossroads is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Lesser General Public License for more details.
@@ -18,15 +18,15 @@
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
-#ifndef __ZMQ_DIST_HPP_INCLUDED__
-#define __ZMQ_DIST_HPP_INCLUDED__
+#ifndef __XS_DIST_HPP_INCLUDED__
+#define __XS_DIST_HPP_INCLUDED__
#include <vector>
#include "array.hpp"
#include "pipe.hpp"
-namespace zmq
+namespace xs
{
class pipe_t;
@@ -42,26 +42,26 @@ namespace zmq
~dist_t ();
// Adds the pipe to the distributor object.
- void attach (zmq::pipe_t *pipe_);
+ void attach (xs::pipe_t *pipe_);
// Activates pipe that have previously reached high watermark.
- void activated (zmq::pipe_t *pipe_);
+ void activated (xs::pipe_t *pipe_);
// Mark the pipe as matching. Subsequent call to send_to_matching
// will send message also to this pipe.
- void match (zmq::pipe_t *pipe_);
+ void match (xs::pipe_t *pipe_);
// Mark all pipes as non-matching.
void unmatch ();
// Removes the pipe from the distributor object.
- void terminated (zmq::pipe_t *pipe_);
+ void terminated (xs::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 (xs::msg_t *msg_, int flags_);
// Send the message to all the outbound pipes.
- int send_to_all (zmq::msg_t *msg_, int flags_);
+ int send_to_all (xs::msg_t *msg_, int flags_);
bool has_out ();
@@ -69,13 +69,13 @@ namespace zmq
// 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_);
+ bool write (xs::pipe_t *pipe_, xs::msg_t *msg_);
// Put the message to all active pipes.
- void distribute (zmq::msg_t *msg_, int flags_);
+ void distribute (xs::msg_t *msg_, int flags_);
// List of outbound pipes.
- typedef array_t <zmq::pipe_t, 2> pipes_t;
+ typedef array_t <xs::pipe_t, 2> pipes_t;
pipes_t pipes;
// Number of all the pipes to send the next message to.