From 55a5e900b47474528fd6a04ee632164143b05380 Mon Sep 17 00:00:00 2001 From: Micah Anderson Date: Tue, 11 Nov 2014 13:28:03 -0500 Subject: prepare for upgrade --- src/dist.hpp | 104 ----------------------------------------------------------- 1 file changed, 104 deletions(-) delete mode 100644 src/dist.hpp (limited to 'src/dist.hpp') diff --git a/src/dist.hpp b/src/dist.hpp deleted file mode 100644 index 6ad8b85..0000000 --- a/src/dist.hpp +++ /dev/null @@ -1,104 +0,0 @@ -/* - 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 - 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, - 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. - - You should have received a copy of the GNU Lesser General Public License - along with this program. If not, see . -*/ - -#ifndef __ZMQ_DIST_HPP_INCLUDED__ -#define __ZMQ_DIST_HPP_INCLUDED__ - -#include - -#include "array.hpp" -#include "pipe.hpp" - -namespace zmq -{ - - class pipe_t; - class msg_t; - - // Class manages a set of outbound pipes. It sends each messages to - // each of them. - class dist_t - { - public: - - dist_t (); - ~dist_t (); - - // Adds the pipe to the distributor object. - void attach (zmq::pipe_t *pipe_); - - // Activates pipe that have previously reached high watermark. - void activated (zmq::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_); - - // Mark all pipes as non-matching. - void unmatch (); - - // Removes the pipe from the distributor object. - void pipe_terminated (zmq::pipe_t *pipe_); - - // Send the message to the matching outbound pipes. - int send_to_matching (zmq::msg_t *msg_); - - // Send the message to all the outbound pipes. - 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_); - - // List of outbound pipes. - typedef array_t pipes_t; - pipes_t pipes; - - // Number of all the pipes to send the next message to. - pipes_t::size_type matching; - - // Number of active pipes. All the active pipes are located at the - // beginning of the pipes array. These are the pipes the messages - // can be sent to at the moment. - pipes_t::size_type active; - - // Number of pipes eligible for sending messages to. This includes all - // the active pipes plus all the pipes that we can in theory send - // messages to (the HWM is not yet reached), but sending a message - // to them would result in partial message being delivered, ie. message - // with initial parts missing. - pipes_t::size_type eligible; - - // True if last we are in the middle of a multipart message. - bool more; - - dist_t (const dist_t&); - const dist_t &operator = (const dist_t&); - }; - -} - -#endif -- cgit v1.2.3