src · 311fb0d852374e769d8ff791c9df38f0464960c6 · submodule / libzmq

Subscription matching moved from XSUB to SUB socket · 311fb0d8

Martin Sustrik authored May 28, 2011

This patch will prevent duplicate matching in devices in the future.
Instead of matching in both XPUB and XSUB, it'll happen only
in XPUB. Receiver endpoint will still filter messages via SUB
socket.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

311fb0d8

Name	Last commit	Last update
..
Makefile.am		Loading commit data...
array.hpp		Loading commit data...
atomic_counter.hpp		Loading commit data...
atomic_ptr.hpp		Loading commit data...
blob.hpp		Loading commit data...
clock.cpp		Loading commit data...
clock.hpp		Loading commit data...
command.cpp		Loading commit data...
command.hpp		Loading commit data...
config.hpp		Loading commit data...
connect_session.cpp		Loading commit data...
connect_session.hpp		Loading commit data...
ctx.cpp		Loading commit data...
ctx.hpp		Loading commit data...
decoder.cpp		Loading commit data...
decoder.hpp		Loading commit data...
devpoll.cpp		Loading commit data...
devpoll.hpp		Loading commit data...
dist.cpp		Loading commit data...
dist.hpp		Loading commit data...
encoder.cpp		Loading commit data...
encoder.hpp		Loading commit data...
epoll.cpp		Loading commit data...
epoll.hpp		Loading commit data...
err.cpp		Loading commit data...
err.hpp		Loading commit data...
fd.hpp		Loading commit data...
fq.cpp		Loading commit data...
fq.hpp		Loading commit data...
i_engine.hpp		Loading commit data...
i_inout.hpp		Loading commit data...
i_poll_events.hpp		Loading commit data...
io_object.cpp		Loading commit data...
io_object.hpp		Loading commit data...
io_thread.cpp		Loading commit data...
io_thread.hpp		Loading commit data...
ip.cpp		Loading commit data...
ip.hpp		Loading commit data...
kqueue.cpp		Loading commit data...
kqueue.hpp		Loading commit data...
lb.cpp		Loading commit data...
lb.hpp		Loading commit data...
libzmq.pc.in		Loading commit data...
likely.hpp		Loading commit data...
mailbox.cpp		Loading commit data...
mailbox.hpp		Loading commit data...
msg.cpp		Loading commit data...
msg.hpp		Loading commit data...
mutex.hpp		Loading commit data...
named_session.cpp		Loading commit data...
named_session.hpp		Loading commit data...
object.cpp		Loading commit data...
object.hpp		Loading commit data...
options.cpp		Loading commit data...
options.hpp		Loading commit data...
own.cpp		Loading commit data...
own.hpp		Loading commit data...
pair.cpp		Loading commit data...
pair.hpp		Loading commit data...
pgm_receiver.cpp		Loading commit data...
pgm_receiver.hpp		Loading commit data...
pgm_sender.cpp		Loading commit data...
pgm_sender.hpp		Loading commit data...
pgm_socket.cpp		Loading commit data...
pgm_socket.hpp		Loading commit data...
pipe.cpp		Loading commit data...
pipe.hpp		Loading commit data...
poll.cpp		Loading commit data...
poll.hpp		Loading commit data...
poller.hpp		Loading commit data...
poller_base.cpp		Loading commit data...
poller_base.hpp		Loading commit data...
pub.cpp		Loading commit data...
pub.hpp		Loading commit data...
pull.cpp		Loading commit data...
pull.hpp		Loading commit data...
push.cpp		Loading commit data...
push.hpp		Loading commit data...
reaper.cpp		Loading commit data...
reaper.hpp		Loading commit data...
rep.cpp		Loading commit data...
rep.hpp		Loading commit data...
req.cpp		Loading commit data...
req.hpp		Loading commit data...
select.cpp		Loading commit data...
select.hpp		Loading commit data...
semaphore.hpp		Loading commit data...
session.cpp		Loading commit data...
session.hpp		Loading commit data...
socket_base.cpp		Loading commit data...
socket_base.hpp		Loading commit data...
stdint.hpp		Loading commit data...
sub.cpp		Loading commit data...
sub.hpp		Loading commit data...
tcp_connecter.cpp		Loading commit data...
tcp_connecter.hpp		Loading commit data...
tcp_listener.cpp		Loading commit data...
tcp_listener.hpp		Loading commit data...
tcp_socket.cpp		Loading commit data...
tcp_socket.hpp		Loading commit data...
thread.cpp		Loading commit data...
thread.hpp		Loading commit data...
transient_session.cpp		Loading commit data...
transient_session.hpp		Loading commit data...
trie.cpp		Loading commit data...
trie.hpp		Loading commit data...
uuid.cpp		Loading commit data...
uuid.hpp		Loading commit data...
windows.hpp		Loading commit data...
wire.hpp		Loading commit data...
xpub.cpp		Loading commit data...
xpub.hpp		Loading commit data...
xrep.cpp		Loading commit data...
xrep.hpp		Loading commit data...
xreq.cpp		Loading commit data...
xreq.hpp		Loading commit data...
xsub.cpp		Loading commit data...
xsub.hpp		Loading commit data...
ypipe.hpp		Loading commit data...
yqueue.hpp		Loading commit data...
zmq.cpp		Loading commit data...
zmq_connecter.cpp		Loading commit data...
zmq_connecter.hpp		Loading commit data...
zmq_engine.cpp		Loading commit data...
zmq_engine.hpp		Loading commit data...
zmq_init.cpp		Loading commit data...
zmq_init.hpp		Loading commit data...
zmq_listener.cpp		Loading commit data...
zmq_listener.hpp		Loading commit data...
zmq_utils.cpp		Loading commit data...