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

Viewing changes to src/xsub.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/xsub.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_XSUB_HPP_INCLUDED__

#define __ZMQ_XSUB_HPP_INCLUDED__

#include "../include/zmq.h"

#include "trie.hpp"

#include "socket_base.hpp"

#include "fq.hpp"

namespace zmq

{

class xsub_t : public socket_base_t

{

public:

xsub_t (class ctx_t *parent_, uint32_t tid_);

~xsub_t ();

protected:

// Overloads of functions from socket_base_t.

void xattach_pipes (class reader_t *inpipe_, class writer_t *outpipe_,

const blob_t &peer_identity_);

int xsend (zmq_msg_t *msg_, int options_);

bool xhas_out ();

int xrecv (zmq_msg_t *msg_, int flags_);

bool xhas_in ();

private:

// Hook into the termination process.

void process_term (int linger_);

// Check whether the message matches at least one subscription.

bool match (zmq_msg_t *msg_);

// Fair queueing object for inbound pipes.

fq_t fq;

// The repository of subscriptions.

trie_t subscriptions;

// If true, 'message' contains a matching message to return on the

// next recv call.

bool has_message;

zmq_msg_t message;

// If true, part of a multipart message was already received, but

// there are following parts still waiting.

bool more;

xsub_t (const xsub_t&);

const xsub_t &operator = (const xsub_t&);

};

}

#endif

Older »