diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/Makefile.am | 175 | ||||
| -rw-r--r-- | src/Makefile.in | 1119 | ||||
| -rw-r--r-- | src/app_thread.cpp | 197 | ||||
| -rw-r--r-- | src/app_thread.hpp | 88 | ||||
| -rw-r--r-- | src/array.hpp (renamed from src/yarray.hpp) | 75 | ||||
| -rw-r--r-- | src/atomic_counter.hpp | 11 | ||||
| -rw-r--r-- | src/atomic_ptr.hpp | 11 | ||||
| -rw-r--r-- | src/blob.hpp | 9 | ||||
| -rw-r--r-- | src/clock.cpp | 118 | ||||
| -rw-r--r-- | src/clock.hpp | 60 | ||||
| -rw-r--r-- | src/command.cpp | 9 | ||||
| -rw-r--r-- | src/command.hpp | 50 | ||||
| -rw-r--r-- | src/config.hpp | 36 | ||||
| -rw-r--r-- | src/connect_session.cpp | 119 | ||||
| -rw-r--r-- | src/connect_session.hpp | 65 | ||||
| -rw-r--r-- | src/ctx.cpp | 340 | ||||
| -rw-r--r-- | src/ctx.hpp | 141 | ||||
| -rw-r--r-- | src/decoder.cpp (renamed from src/zmq_decoder.cpp) | 67 | ||||
| -rw-r--r-- | src/decoder.hpp | 85 | ||||
| -rw-r--r-- | src/device.cpp (renamed from src/queue.cpp) | 46 | ||||
| -rw-r--r-- | src/device.hpp (renamed from src/streamer.hpp) | 15 | ||||
| -rw-r--r-- | src/devpoll.cpp | 86 | ||||
| -rw-r--r-- | src/devpoll.hpp | 34 | ||||
| -rw-r--r-- | src/dist.cpp | 196 | ||||
| -rw-r--r-- | src/dist.hpp | 92 | ||||
| -rw-r--r-- | src/encoder.cpp (renamed from src/zmq_encoder.cpp) | 33 | ||||
| -rw-r--r-- | src/encoder.hpp | 54 | ||||
| -rw-r--r-- | src/epoll.cpp | 70 | ||||
| -rw-r--r-- | src/epoll.hpp | 26 | ||||
| -rw-r--r-- | src/err.cpp | 50 | ||||
| -rw-r--r-- | src/err.hpp | 38 | ||||
| -rw-r--r-- | src/fd.hpp | 9 | ||||
| -rw-r--r-- | src/forwarder.cpp | 60 | ||||
| -rw-r--r-- | src/forwarder.hpp | 31 | ||||
| -rw-r--r-- | src/fq.cpp | 75 | ||||
| -rw-r--r-- | src/fq.hpp | 38 | ||||
| -rw-r--r-- | src/i_endpoint.hpp | 43 | ||||
| -rw-r--r-- | src/i_engine.hpp | 26 | ||||
| -rw-r--r-- | src/i_inout.hpp | 30 | ||||
| -rw-r--r-- | src/i_poll_events.hpp | 35 | ||||
| -rw-r--r-- | src/io_object.cpp | 41 | ||||
| -rw-r--r-- | src/io_object.hpp | 27 | ||||
| -rw-r--r-- | src/io_thread.cpp | 34 | ||||
| -rw-r--r-- | src/io_thread.hpp | 31 | ||||
| -rw-r--r-- | src/ip.cpp | 29 | ||||
| -rw-r--r-- | src/ip.hpp | 11 | ||||
| -rw-r--r-- | src/kqueue.cpp | 68 | ||||
| -rw-r--r-- | src/kqueue.hpp | 26 | ||||
| -rw-r--r-- | src/lb.cpp | 83 | ||||
| -rw-r--r-- | src/lb.hpp | 38 | ||||
| -rw-r--r-- | src/likely.hpp | 9 | ||||
| -rw-r--r-- | src/mailbox.cpp | 382 | ||||
| -rw-r--r-- | src/mailbox.hpp | 62 | ||||
| -rw-r--r-- | src/msg_content.hpp | 9 | ||||
| -rw-r--r-- | src/mutex.hpp | 11 | ||||
| -rw-r--r-- | src/named_session.cpp | 85 | ||||
| -rw-r--r-- | src/named_session.hpp | 57 | ||||
| -rw-r--r-- | src/object.cpp | 203 | ||||
| -rw-r--r-- | src/object.hpp | 71 | ||||
| -rw-r--r-- | src/options.cpp | 121 | ||||
| -rw-r--r-- | src/options.hpp | 27 | ||||
| -rw-r--r-- | src/own.cpp | 214 | ||||
| -rw-r--r-- | src/own.hpp | 140 | ||||
| -rw-r--r-- | src/owned.cpp | 71 | ||||
| -rw-r--r-- | src/owned.hpp | 89 | ||||
| -rw-r--r-- | src/pair.cpp | 112 | ||||
| -rw-r--r-- | src/pair.hpp | 41 | ||||
| -rw-r--r-- | src/pgm_receiver.cpp | 68 | ||||
| -rw-r--r-- | src/pgm_receiver.hpp | 43 | ||||
| -rw-r--r-- | src/pgm_sender.cpp | 77 | ||||
| -rw-r--r-- | src/pgm_sender.hpp | 30 | ||||
| -rw-r--r-- | src/pgm_socket.cpp | 719 | ||||
| -rw-r--r-- | src/pgm_socket.hpp | 29 | ||||
| -rw-r--r-- | src/pipe.cpp | 426 | ||||
| -rw-r--r-- | src/pipe.hpp | 169 | ||||
| -rw-r--r-- | src/platform.hpp.in | 24 | ||||
| -rw-r--r-- | src/poll.cpp | 74 | ||||
| -rw-r--r-- | src/poll.hpp | 29 | ||||
| -rw-r--r-- | src/poller.hpp | 9 | ||||
| -rw-r--r-- | src/poller_base.cpp | 99 | ||||
| -rw-r--r-- | src/poller_base.hpp | 84 | ||||
| -rw-r--r-- | src/pub.cpp | 162 | ||||
| -rw-r--r-- | src/pub.hpp | 44 | ||||
| -rw-r--r-- | src/pull.cpp | 61 | ||||
| -rw-r--r-- | src/pull.hpp | 26 | ||||
| -rw-r--r-- | src/push.cpp | 63 | ||||
| -rw-r--r-- | src/push.hpp | 26 | ||||
| -rw-r--r-- | src/queue.hpp | 31 | ||||
| -rw-r--r-- | src/reaper.cpp | 121 | ||||
| -rw-r--r-- | src/reaper.hpp | 77 | ||||
| -rw-r--r-- | src/rep.cpp | 248 | ||||
| -rw-r--r-- | src/rep.hpp | 54 | ||||
| -rw-r--r-- | src/req.cpp | 243 | ||||
| -rw-r--r-- | src/req.hpp | 59 | ||||
| -rw-r--r-- | src/select.cpp | 82 | ||||
| -rw-r--r-- | src/select.hpp | 29 | ||||
| -rw-r--r-- | src/semaphore.hpp | 189 | ||||
| -rw-r--r-- | src/session.cpp | 360 | ||||
| -rw-r--r-- | src/session.hpp | 126 | ||||
| -rw-r--r-- | src/signaler.cpp | 351 | ||||
| -rw-r--r-- | src/signaler.hpp | 71 | ||||
| -rw-r--r-- | src/socket_base.cpp | 814 | ||||
| -rw-r--r-- | src/socket_base.hpp | 206 | ||||
| -rw-r--r-- | src/stdint.hpp | 19 | ||||
| -rw-r--r-- | src/streamer.cpp | 60 | ||||
| -rw-r--r-- | src/sub.cpp | 182 | ||||
| -rw-r--r-- | src/sub.hpp | 53 | ||||
| -rw-r--r-- | src/swap.cpp (renamed from src/msg_store.cpp) | 70 | ||||
| -rw-r--r-- | src/swap.hpp (renamed from src/msg_store.hpp) | 47 | ||||
| -rw-r--r-- | src/tcp_connecter.cpp | 9 | ||||
| -rw-r--r-- | src/tcp_connecter.hpp | 11 | ||||
| -rw-r--r-- | src/tcp_listener.cpp | 48 | ||||
| -rw-r--r-- | src/tcp_listener.hpp | 17 | ||||
| -rw-r--r-- | src/tcp_socket.cpp | 9 | ||||
| -rw-r--r-- | src/tcp_socket.hpp | 11 | ||||
| -rw-r--r-- | src/thread.cpp | 83 | ||||
| -rw-r--r-- | src/thread.hpp | 28 | ||||
| -rw-r--r-- | src/transient_session.cpp | 41 | ||||
| -rw-r--r-- | src/transient_session.hpp | 52 | ||||
| -rw-r--r-- | src/trie.cpp (renamed from src/prefix_tree.cpp) | 51 | ||||
| -rw-r--r-- | src/trie.hpp (renamed from src/prefix_tree.hpp) | 26 | ||||
| -rw-r--r-- | src/uuid.cpp | 16 | ||||
| -rw-r--r-- | src/uuid.hpp | 9 | ||||
| -rw-r--r-- | src/windows.hpp | 9 | ||||
| -rw-r--r-- | src/wire.hpp | 9 | ||||
| -rw-r--r-- | src/xpub.cpp | 76 | ||||
| -rw-r--r-- | src/xpub.hpp | 61 | ||||
| -rw-r--r-- | src/xrep.cpp | 168 | ||||
| -rw-r--r-- | src/xrep.hpp | 42 | ||||
| -rw-r--r-- | src/xreq.cpp | 51 | ||||
| -rw-r--r-- | src/xreq.hpp | 25 | ||||
| -rw-r--r-- | src/xsub.cpp | 172 | ||||
| -rw-r--r-- | src/xsub.hpp | 80 | ||||
| -rw-r--r-- | src/yarray_item.hpp | 64 | ||||
| -rw-r--r-- | src/ypipe.hpp | 11 | ||||
| -rw-r--r-- | src/yqueue.hpp | 15 | ||||
| -rw-r--r-- | src/zmq.cpp | 708 | ||||
| -rw-r--r-- | src/zmq_connecter.cpp | 118 | ||||
| -rw-r--r-- | src/zmq_connecter.hpp | 54 | ||||
| -rw-r--r-- | src/zmq_decoder.hpp | 59 | ||||
| -rw-r--r-- | src/zmq_encoder.hpp | 55 | ||||
| -rw-r--r-- | src/zmq_engine.cpp | 119 | ||||
| -rw-r--r-- | src/zmq_engine.hpp | 37 | ||||
| -rw-r--r-- | src/zmq_init.cpp | 185 | ||||
| -rw-r--r-- | src/zmq_init.hpp | 52 | ||||
| -rw-r--r-- | src/zmq_listener.cpp | 41 | ||||
| -rw-r--r-- | src/zmq_listener.hpp | 26 |
147 files changed, 7887 insertions, 6469 deletions
diff --git a/src/Makefile.am b/src/Makefile.am index 19a80d0..ce20225 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -5,82 +5,41 @@ pkgconfig_DATA = libzmq.pc include_HEADERS = ../include/zmq.h ../include/zmq.hpp ../include/zmq_utils.h -if BUILD_PGM -pgm_sources = ../foreign/openpgm/@pgm_basename@/openpgm/pgm/packet.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/time.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/if.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/getifaddrs.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/getnodeaddr.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/indextoaddr.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/indextoname.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/nametoindex.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/inet_network.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/md5.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/gsi.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/tsi.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/signal.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/txwi.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/rxwi.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/transport.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/source.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/receiver.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/recv.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/pgm.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/timer.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/net.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/rate_control.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/async.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/checksum.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/reed_solomon.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/galois_tables.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/wsastrerror.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/glib-compat.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/backtrace.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/log.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/sockaddr.c \ - ../foreign/openpgm/@pgm_basename@/openpgm/pgm/version.c - -../foreign/openpgm/@pgm_basename@/openpgm/pgm/version.c: ../foreign/openpgm/@pgm_basename@/openpgm/pgm/version_generator.py - python ../foreign/openpgm/@pgm_basename@/openpgm/pgm/version_generator.py > $@ - -../foreign/openpgm/@pgm_basename@/openpgm/pgm/galois_tables.c: ../foreign/openpgm/@pgm_basename@/openpgm/pgm/galois_generator.pl - perl ../foreign/openpgm/@pgm_basename@/openpgm/pgm/galois_generator.pl > $@ -endif - -nodist_libzmq_la_SOURCES = $(pgm_sources) - -libzmq_la_SOURCES = app_thread.hpp \ +libzmq_la_SOURCES = \ + array.hpp \ atomic_counter.hpp \ atomic_ptr.hpp \ blob.hpp \ + clock.hpp \ command.hpp \ config.hpp \ + connect_session.hpp \ ctx.hpp \ decoder.hpp \ + device.hpp \ devpoll.hpp \ - push.hpp \ + dist.hpp \ encoder.hpp \ epoll.hpp \ err.hpp \ fd.hpp \ - forwarder.hpp \ fq.hpp \ i_inout.hpp \ io_object.hpp \ io_thread.hpp \ ip.hpp \ - i_endpoint.hpp \ i_engine.hpp \ i_poll_events.hpp \ kqueue.hpp \ |