summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/Makefile.am149
-rw-r--r--src/app_thread.cpp197
-rw-r--r--src/app_thread.hpp88
-rw-r--r--src/array.hpp (renamed from src/yarray.hpp)72
-rw-r--r--src/atomic_counter.hpp6
-rw-r--r--src/atomic_ptr.hpp6
-rw-r--r--src/blob.hpp6
-rw-r--r--src/clock.cpp112
-rw-r--r--src/clock.hpp59
-rw-r--r--src/command.cpp6
-rw-r--r--src/command.hpp27
-rw-r--r--src/config.hpp34
-rw-r--r--src/connect_session.cpp117
-rw-r--r--src/connect_session.hpp64
-rw-r--r--src/ctx.cpp310
-rw-r--r--src/ctx.hpp121
-rw-r--r--src/decoder.cpp (renamed from src/zmq_decoder.cpp)60
-rw-r--r--src/decoder.hpp76
-rw-r--r--src/devpoll.cpp63
-rw-r--r--src/devpoll.hpp26
-rw-r--r--src/encoder.cpp (renamed from src/zmq_encoder.cpp)30
-rw-r--r--src/encoder.hpp47
-rw-r--r--src/epoll.cpp61
-rw-r--r--src/epoll.hpp21
-rw-r--r--src/err.cpp47
-rw-r--r--src/err.hpp15
-rw-r--r--src/fd.hpp6
-rw-r--r--src/forwarder.cpp6
-rw-r--r--src/forwarder.hpp6
-rw-r--r--src/fq.cpp72
-rw-r--r--src/fq.hpp33
-rw-r--r--src/i_endpoint.hpp43
-rw-r--r--src/i_engine.hpp23
-rw-r--r--src/i_inout.hpp27
-rw-r--r--src/i_poll_events.hpp34
-rw-r--r--src/io_object.cpp38
-rw-r--r--src/io_object.hpp22
-rw-r--r--src/io_thread.cpp31
-rw-r--r--src/io_thread.hpp25
-rw-r--r--src/ip.cpp6
-rw-r--r--src/ip.hpp6
-rw-r--r--src/kqueue.cpp61
-rw-r--r--src/kqueue.hpp21
-rw-r--r--src/lb.cpp46
-rw-r--r--src/lb.hpp30
-rw-r--r--src/likely.hpp6
-rw-r--r--src/mailbox.cpp381
-rw-r--r--src/mailbox.hpp61
-rw-r--r--src/msg_content.hpp6
-rw-r--r--src/mutex.hpp6
-rw-r--r--src/named_session.cpp84
-rw-r--r--src/named_session.hpp56
-rw-r--r--src/object.cpp136
-rw-r--r--src/object.hpp60
-rw-r--r--src/options.cpp76
-rw-r--r--src/options.hpp18
-rw-r--r--src/own.cpp213
-rw-r--r--src/own.hpp139
-rw-r--r--src/owned.cpp71
-rw-r--r--src/owned.hpp89
-rw-r--r--src/pair.cpp104
-rw-r--r--src/pair.hpp36
-rw-r--r--src/pgm_receiver.cpp51
-rw-r--r--src/pgm_receiver.hpp38
-rw-r--r--src/pgm_sender.cpp72
-rw-r--r--src/pgm_sender.hpp25
-rw-r--r--src/pgm_socket.cpp692
-rw-r--r--src/pgm_socket.hpp19
-rw-r--r--src/pipe.cpp420
-rw-r--r--src/pipe.hpp158
-rw-r--r--src/poll.cpp51
-rw-r--r--src/poll.hpp21
-rw-r--r--src/poller.hpp6
-rw-r--r--src/poller_base.cpp98
-rw-r--r--src/poller_base.hpp83
-rw-r--r--src/pub.cpp84
-rw-r--r--src/pub.hpp35
-rw-r--r--src/pull.cpp58
-rw-r--r--src/pull.hpp21
-rw-r--r--src/push.cpp60
-rw-r--r--src/push.hpp21
-rw-r--r--src/queue.cpp6
-rw-r--r--src/queue.hpp6
-rw-r--r--src/rep.cpp245
-rw-r--r--src/rep.hpp49
-rw-r--r--src/req.cpp240
-rw-r--r--src/req.hpp54
-rw-r--r--src/select.cpp75
-rw-r--r--src/select.hpp24
-rw-r--r--src/semaphore.hpp186
-rw-r--r--src/session.cpp354
-rw-r--r--src/session.hpp121
-rw-r--r--src/signaler.cpp351
-rw-r--r--src/signaler.hpp71
-rw-r--r--src/socket_base.cpp754
-rw-r--r--src/socket_base.hpp178
-rw-r--r--src/stdint.hpp6
-rw-r--r--src/streamer.cpp6
-rw-r--r--src/streamer.hpp6
-rw-r--r--src/sub.cpp50
-rw-r--r--src/sub.hpp22
-rw-r--r--src/swap.cpp (renamed from src/msg_store.cpp)39
-rw-r--r--src/swap.hpp (renamed from src/msg_store.hpp)34
-rw-r--r--src/tcp_connecter.cpp6
-rw-r--r--src/tcp_connecter.hpp6
-rw-r--r--src/tcp_listener.cpp18
-rw-r--r--src/tcp_listener.hpp9
-rw-r--r--src/tcp_socket.cpp6
-rw-r--r--src/tcp_socket.hpp6
-rw-r--r--src/thread.cpp26
-rw-r--r--src/thread.hpp15
-rw-r--r--src/transient_session.cpp40
-rw-r--r--src/transient_session.hpp51
-rw-r--r--src/trie.cpp (renamed from src/prefix_tree.cpp)42
-rw-r--r--src/trie.hpp (renamed from src/prefix_tree.hpp)23
-rw-r--r--src/uuid.cpp13
-rw-r--r--src/uuid.hpp6
-rw-r--r--src/windows.hpp6
-rw-r--r--src/wire.hpp6
-rw-r--r--src/xrep.cpp145
-rw-r--r--src/xrep.hpp37
-rw-r--r--src/xreq.cpp48
-rw-r--r--src/xreq.hpp19
-rw-r--r--src/yarray_item.hpp64
-rw-r--r--src/ypipe.hpp6
-rw-r--r--src/yqueue.hpp6
-rw-r--r--src/zmq.cpp592
-rw-r--r--src/zmq_connecter.cpp86
-rw-r--r--src/zmq_connecter.hpp43
-rw-r--r--src/zmq_decoder.hpp59
-rw-r--r--src/zmq_encoder.hpp55
-rw-r--r--src/zmq_engine.cpp93
-rw-r--r--src/zmq_engine.hpp29