~ubuntu-branches/ubuntu/precise/zeromq/precise

Viewing changes to src/dist.hpp

Committer: Bazaar Package Importer
Author(s): Martin Lucina
Date: 2011-05-13 12:43:09 UTC
mfrom: (7.2.1 sid)
Revision ID: james.westby@ubuntu.com-20110513124309-m3gdt964ga67rcwu

Tags: 2.1.7-1

http://bugs.debian.org/619374

* New upstream version. (closes: #619374)
* --with-system-pgm is now used instead of the embedded OpenPGM library.
* Added Debian watch file.

files added:
INSTALL

acinclude.m4

builds/redhat

builds/redhat/zeromq.spec.in

debian/libzmq1.docs

debian/libzmq1.install

debian/libzmq1.lintian-overrides

debian/watch

doc/zmq_device.3

doc/zmq_device.html

doc/zmq_device.txt

foreign/openpgm/Makefile.am

foreign/openpgm/Makefile.in

foreign/openpgm/libpgm-5.1.115~dfsg.tar.gz

perf/inproc_lat.cpp

perf/inproc_thr.cpp

src/array.hpp

src/clock.cpp

src/clock.hpp

src/connect_session.cpp

src/connect_session.hpp

src/decoder.cpp

src/device.cpp

src/device.hpp

src/dist.cpp

src/dist.hpp

src/encoder.cpp

src/mailbox.cpp

src/mailbox.hpp

src/named_session.cpp

src/named_session.hpp

src/own.cpp

src/own.hpp

src/poller_base.cpp

src/poller_base.hpp

src/reaper.cpp

src/reaper.hpp

src/semaphore.hpp

src/swap.cpp

src/swap.hpp

src/transient_session.cpp

src/transient_session.hpp

src/trie.cpp

src/trie.hpp

src/xpub.cpp

src/xpub.hpp

src/xsub.cpp

src/xsub.hpp

tests

tests/Makefile.am

tests/Makefile.in

tests/test_hwm.cpp

tests/test_pair_inproc.cpp

tests/test_pair_ipc.cpp

tests/test_pair_tcp.cpp

tests/test_reqrep_inproc.cpp

tests/test_reqrep_ipc.cpp

tests/test_reqrep_tcp.cpp

tests/test_shutdown_stress.cpp

tests/testutil.hpp

files removed:
builds/msvc/zmq_forwarder

builds/msvc/zmq_forwarder/zmq_forwarder.vcproj

builds/msvc/zmq_queue

builds/msvc/zmq_queue/zmq_queue.vcproj

builds/msvc/zmq_streamer

builds/msvc/zmq_streamer/zmq_streamer.vcproj

debian/libzmq0.docs

debian/libzmq0.install

debian/libzmq0.lintian-overrides

debian/zeromq-bin.install

debian/zeromq-bin.lintian-overrides

debian/zeromq-bin.manpages

devices

devices/Makefile.am

devices/Makefile.in

devices/zmq_forwarder

devices/zmq_forwarder/Makefile.am

devices/zmq_forwarder/Makefile.in

devices/zmq_forwarder/zmq_forwarder.cpp

devices/zmq_queue

devices/zmq_queue/Makefile.am

devices/zmq_queue/Makefile.in

devices/zmq_queue/zmq_queue.cpp

devices/zmq_streamer

devices/zmq_streamer/Makefile.am

devices/zmq_streamer/Makefile.in

devices/zmq_streamer/zmq_streamer.cpp

doc/zmq_forwarder.1

doc/zmq_forwarder.html

doc/zmq_forwarder.txt

doc/zmq_queue.1

doc/zmq_queue.html

doc/zmq_queue.txt

doc/zmq_streamer.1

doc/zmq_streamer.html

doc/zmq_streamer.txt

foreign/openpgm/libpgm-2-1-28~dfsg.tar.gz

src/app_thread.cpp

src/app_thread.hpp

src/forwarder.cpp

src/forwarder.hpp

src/i_endpoint.hpp

src/msg_store.cpp

src/msg_store.hpp

src/owned.cpp

src/owned.hpp

src/prefix_tree.cpp

src/prefix_tree.hpp

src/queue.cpp

src/queue.hpp

src/signaler.cpp

src/signaler.hpp

src/streamer.cpp

src/streamer.hpp

src/yarray.hpp

src/yarray_item.hpp

src/zmq_decoder.cpp

src/zmq_decoder.hpp

src/zmq_encoder.cpp

src/zmq_encoder.hpp

files modified:
AUTHORS

ChangeLog

MAINTAINERS

Makefile.am

Makefile.in

NEWS

README

aclocal.m4

autogen.sh

builds/msvc/Makefile.am

builds/msvc/Makefile.in

builds/msvc/libzmq/libzmq.vcproj

builds/msvc/msvc.sln

builds/msvc/platform.hpp

config/config.guess

config/config.sub

configure

configure.in

debian/changelog

debian/control

debian/rules

doc/Makefile.am

doc/Makefile.in

doc/zmq.7

doc/zmq.html

doc/zmq.txt

doc/zmq_bind.3

doc/zmq_bind.html

doc/zmq_bind.txt

doc/zmq_close.3

doc/zmq_close.html

doc/zmq_close.txt

doc/zmq_connect.3

doc/zmq_connect.html

doc/zmq_connect.txt

doc/zmq_cpp.7

doc/zmq_cpp.html

doc/zmq_cpp.txt

doc/zmq_epgm.7

doc/zmq_epgm.html

doc/zmq_epgm.txt

doc/zmq_errno.3

doc/zmq_errno.html

doc/zmq_errno.txt

doc/zmq_getsockopt.3

doc/zmq_getsockopt.html

doc/zmq_getsockopt.txt

doc/zmq_init.3

doc/zmq_init.html

doc/zmq_init.txt

doc/zmq_inproc.7

doc/zmq_inproc.html

doc/zmq_inproc.txt

doc/zmq_ipc.7

doc/zmq_ipc.html

doc/zmq_ipc.txt

doc/zmq_msg_close.3

doc/zmq_msg_close.html

doc/zmq_msg_close.txt

doc/zmq_msg_copy.3

doc/zmq_msg_copy.html

doc/zmq_msg_copy.txt

doc/zmq_msg_data.3

doc/zmq_msg_data.html

doc/zmq_msg_data.txt

doc/zmq_msg_init.3

doc/zmq_msg_init.html

doc/zmq_msg_init.txt

doc/zmq_msg_init_data.3

doc/zmq_msg_init_data.html

doc/zmq_msg_init_data.txt

doc/zmq_msg_init_size.3

doc/zmq_msg_init_size.html

doc/zmq_msg_init_size.txt

doc/zmq_msg_move.3

doc/zmq_msg_move.html

doc/zmq_msg_move.txt

doc/zmq_msg_size.3

doc/zmq_msg_size.html

doc/zmq_msg_size.txt

doc/zmq_pgm.7

doc/zmq_pgm.html

doc/zmq_pgm.txt

doc/zmq_poll.3

doc/zmq_poll.html

doc/zmq_poll.txt

doc/zmq_recv.3

doc/zmq_recv.html

doc/zmq_recv.txt

doc/zmq_send.3

doc/zmq_send.html

doc/zmq_send.txt

doc/zmq_setsockopt.3

doc/zmq_setsockopt.html

doc/zmq_setsockopt.txt

doc/zmq_socket.3

doc/zmq_socket.html

doc/zmq_socket.txt

doc/zmq_strerror.3

doc/zmq_strerror.html

doc/zmq_strerror.txt

doc/zmq_tcp.7

doc/zmq_tcp.html

doc/zmq_tcp.txt

doc/zmq_term.3

doc/zmq_term.html

doc/zmq_term.txt

doc/zmq_version.3

doc/zmq_version.html

doc/zmq_version.txt

include/zmq.h

include/zmq.hpp

include/zmq_utils.h

perf/Makefile.am

perf/Makefile.in

perf/local_lat.cpp

perf/local_thr.cpp

perf/remote_lat.cpp

perf/remote_thr.cpp

src/Makefile.am

src/Makefile.in

src/atomic_counter.hpp

src/atomic_ptr.hpp

src/blob.hpp

src/command.cpp

src/command.hpp

src/config.hpp

src/ctx.cpp

src/ctx.hpp

src/decoder.hpp

src/devpoll.cpp

src/devpoll.hpp

src/encoder.hpp

src/epoll.cpp

src/epoll.hpp

src/err.cpp

src/err.hpp

src/fd.hpp

src/fq.cpp

src/fq.hpp

src/i_engine.hpp

src/i_inout.hpp

src/i_poll_events.hpp

src/io_object.cpp

src/io_object.hpp

src/io_thread.cpp

src/io_thread.hpp

src/ip.cpp

src/ip.hpp

src/kqueue.cpp

src/kqueue.hpp

src/lb.cpp

src/lb.hpp

src/likely.hpp

src/msg_content.hpp

src/mutex.hpp

src/object.cpp

src/object.hpp

src/options.cpp

src/options.hpp

src/pair.cpp

src/pair.hpp

src/pgm_receiver.cpp

src/pgm_receiver.hpp

src/pgm_sender.cpp

src/pgm_sender.hpp

src/pgm_socket.cpp

src/pgm_socket.hpp

src/pipe.cpp

src/pipe.hpp

src/platform.hpp.in

src/poll.cpp

src/poll.hpp

src/poller.hpp

src/pub.cpp

src/pub.hpp

src/pull.cpp

src/pull.hpp

src/push.cpp

src/push.hpp

src/rep.cpp

src/rep.hpp

src/req.cpp

src/req.hpp

src/select.cpp

src/select.hpp

src/session.cpp

src/session.hpp

src/socket_base.cpp

src/socket_base.hpp

src/stdint.hpp

src/sub.cpp

src/sub.hpp

src/tcp_connecter.cpp

src/tcp_connecter.hpp

src/tcp_listener.cpp

src/tcp_listener.hpp

src/tcp_socket.cpp

src/tcp_socket.hpp

src/thread.cpp

src/thread.hpp

src/uuid.cpp

src/uuid.hpp

src/windows.hpp

src/wire.hpp

src/xrep.cpp

src/xrep.hpp

src/xreq.cpp

src/xreq.hpp

src/ypipe.hpp

src/yqueue.hpp

src/zmq.cpp

src/zmq_connecter.cpp

src/zmq_connecter.hpp

src/zmq_engine.cpp

src/zmq_engine.hpp

src/zmq_init.cpp

src/zmq_init.hpp

src/zmq_listener.cpp

src/zmq_listener.hpp

version.sh

zeromq.spec

Show diffs side-by-side

added added

removed removed

src/dist.hpp

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 <http://www.gnu.org/licenses/>.

#ifndef __ZMQ_DIST_HPP_INCLUDED__

#define __ZMQ_DIST_HPP_INCLUDED__

#include <vector>

#include "array.hpp"

#include "pipe.hpp"

namespace zmq

{

// Class manages a set of outbound pipes. It sends each messages to

// each of them.

class dist_t : public i_writer_events

{

public:

dist_t (class own_t *sink_);

~dist_t ();

void attach (writer_t *pipe_);

void terminate ();

int send (zmq_msg_t *msg_, int flags_);

bool has_out ();

// i_writer_events interface implementation.

void activated (writer_t *pipe_);

void terminated (writer_t *pipe_);

private:

// Write the message to the pipe. Make the pipe inactive if writing

// fails. In such a case false is returned.

bool write (class writer_t *pipe_, zmq_msg_t *msg_);

// Put the message to all active pipes.

void distribute (zmq_msg_t *msg_, int flags_);

// List of outbound pipes.

typedef array_t <class writer_t> pipes_t;

pipes_t pipes;

// 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;

// Object to send events to.

class own_t *sink;

// If true, termination process is already underway.

bool terminating;

dist_t (const dist_t&);

const dist_t &operator = (const dist_t&);

};

}

#endif

Older »