src · f78d9b6bfca13e298c29fadabbbc870b37a0a573 · submodule / libzmq

Session class separated into socket-type-specific sessions · f78d9b6b

Martin Sustrik authored Sep 15, 2011

This is a preliminary patch allowing for socket-type-specific
functionality in the I/O thread. For example, message format
can be checked asynchronously and misbehaved connections dropped
straight away.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

f78d9b6b

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...
clock.cpp		Loading commit data...
clock.hpp		Loading commit data...
command.hpp		Loading commit data...
config.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_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...
ipc_address.cpp		Loading commit data...
ipc_address.hpp		Loading commit data...
ipc_connecter.cpp		Loading commit data...
ipc_connecter.hpp		Loading commit data...
ipc_listener.cpp		Loading commit data...
ipc_listener.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...
mtrie.cpp		Loading commit data...
mtrie.hpp		Loading commit data...
mutex.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...
random.cpp		Loading commit data...
random.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...
router.cpp		Loading commit data...
router.hpp		Loading commit data...
select.cpp		Loading commit data...
select.hpp		Loading commit data...
session_base.cpp		Loading commit data...
session_base.hpp		Loading commit data...
signaler.cpp		Loading commit data...
signaler.hpp		Loading commit data...
socket_base.cpp		Loading commit data...
socket_base.hpp		Loading commit data...
stdint.hpp		Loading commit data...
stream_engine.cpp		Loading commit data...
stream_engine.hpp		Loading commit data...
sub.cpp		Loading commit data...
sub.hpp		Loading commit data...
tcp_address.cpp		Loading commit data...
tcp_address.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...
thread.cpp		Loading commit data...
thread.hpp		Loading commit data...
trie.cpp		Loading commit data...
trie.hpp		Loading commit data...
vtcp_connecter.cpp		Loading commit data...
vtcp_connecter.hpp		Loading commit data...
vtcp_listener.cpp		Loading commit data...
vtcp_listener.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_utils.cpp		Loading commit data...