summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/Makefile.am244
-rw-r--r--src/Makefile.in1510
-rw-r--r--src/app_thread.cpp195
-rw-r--r--src/app_thread.hpp88
-rw-r--r--src/atomic_counter.hpp163
-rw-r--r--src/atomic_ptr.hpp158
-rw-r--r--src/blob.hpp33
-rw-r--r--src/command.cpp38
-rw-r--r--src/command.hpp127
-rw-r--r--src/config.hpp86
-rw-r--r--src/ctx.cpp316
-rw-r--r--src/ctx.hpp156
-rw-r--r--src/decoder.hpp156
-rw-r--r--src/devpoll.cpp222
-rw-r--r--src/devpoll.hpp110
-rw-r--r--src/downstream.cpp101
-rw-r--r--src/downstream.hpp61
-rw-r--r--src/encoder.hpp160
-rw-r--r--src/epoll.cpp213
-rw-r--r--src/epoll.hpp106
-rw-r--r--src/err.cpp190
-rw-r--r--src/err.hpp123
-rw-r--r--src/fd.hpp44
-rw-r--r--src/forwarder.cpp38
-rw-r--r--src/forwarder.hpp31
-rw-r--r--src/fq.cpp130
-rw-r--r--src/fq.hpp68
-rw-r--r--src/i_endpoint.hpp43
-rw-r--r--src/i_engine.hpp49
-rw-r--r--src/i_inout.hpp60
-rw-r--r--src/i_poll_events.hpp45
-rw-r--r--src/io_object.cpp92
-rw-r--r--src/io_object.hpp77
-rw-r--r--src/io_thread.cpp105
-rw-r--r--src/io_thread.hpp85
-rw-r--r--src/ip.cpp335
-rw-r--r--src/ip.hpp69
-rw-r--r--src/kqueue.cpp226
-rw-r--r--src/kqueue.hpp113
-rw-r--r--src/lb.cpp123
-rw-r--r--src/lb.hpp65
-rw-r--r--src/libzmq.pc.in10
-rw-r--r--src/likely.hpp32
-rw-r--r--src/msg_content.hpp51
-rw-r--r--src/mutex.hpp120
-rw-r--r--src/object.cpp374
-rw-r--r--src/object.hpp118
-rw-r--r--src/options.cpp225
-rw-r--r--src/options.hpp68
-rw-r--r--src/owned.cpp71
-rw-r--r--src/owned.hpp89
-rw-r--r--src/pair.cpp139
-rw-r--r--src/pair.hpp63
-rw-r--r--src/pgm_receiver.cpp217
-rw-r--r--src/pgm_receiver.hpp122
-rw-r--r--src/pgm_sender.cpp160
-rw-r--r--src/pgm_sender.hpp95
-rw-r--r--src/pgm_socket.cpp538
-rw-r--r--src/pgm_socket.hpp105
-rw-r--r--src/pipe.cpp281
-rw-r--r--src/pipe.hpp169
-rw-r--r--src/platform.hpp.in228
-rw-r--r--src/poll.cpp207
-rw-r--r--src/poll.hpp113
-rw-r--r--src/poller.hpp72
-rw-r--r--src/prefix_tree.cpp180
-rw-r--r--src/prefix_tree.hpp55
-rw-r--r--src/pub.cpp177
-rw-r--r--src/pub.hpp70
-rw-r--r--src/queue.cpp101
-rw-r--r--src/queue.hpp31
-rw-r--r--src/rep.cpp280
-rw-r--r--src/rep.hpp85
-rw-r--r--src/req.cpp286
-rw-r--r--src/req.hpp93
-rw-r--r--src/select.cpp234
-rw-r--r--src/select.hpp123
-rw-r--r--src/session.cpp291
-rw-r--r--src/session.hpp104
-rw-r--r--src/signaler.cpp339
-rw-r--r--src/signaler.hpp71
-rw-r--r--src/socket_base.cpp681
-rw-r--r--src/socket_base.hpp177
-rw-r--r--src/stdint.hpp70
-rw-r--r--src/streamer.cpp38
-rw-r--r--src/streamer.hpp31
-rw-r--r--src/sub.cpp191
-rw-r--r--src/sub.hpp81
-rw-r--r--src/tcp_connecter.cpp307
-rw-r--r--src/tcp_connecter.hpp80
-rw-r--r--src/tcp_listener.cpp352
-rw-r--r--src/tcp_listener.hpp68
-rw-r--r--src/tcp_socket.cpp226
-rw-r--r--src/tcp_socket.hpp71
-rw-r--r--src/thread.cpp108
-rw-r--r--src/thread.hpp86
-rw-r--r--src/upstream.cpp98
-rw-r--r--src/upstream.hpp62
-rw-r--r--src/uuid.cpp235
-rw-r--r--src/uuid.hpp110
-rw-r--r--src/windows.hpp78
-rw-r--r--src/wire.hpp98
-rw-r--r--src/xrep.cpp271
-rw-r--r--src/xrep.hpp95
-rw-r--r--src/xreq.cpp118
-rw-r--r--src/xreq.hpp67
-rw-r--r--src/yarray.hpp110
-rw-r--r--src/yarray_item.hpp62
-rw-r--r--src/ypipe.hpp191
-rw-r--r--src/yqueue.hpp197
-rw-r--r--src/zmq.cpp663
-rw-r--r--src/zmq_connecter.cpp136
-rw-r--r--src/zmq_connecter.hpp88
-rw-r--r--src/zmq_decoder.cpp107
-rw-r--r--src/zmq_decoder.hpp59
-rw-r--r--src/zmq_encoder.cpp89
-rw-r--r--src/zmq_encoder.hpp55
-rw-r--r--src/zmq_engine.cpp195
-rw-r--r--src/zmq_engine.hpp86
-rw-r--r--src/zmq_init.cpp195
-rw-r--r--src/zmq_init.hpp89
-rw-r--r--src/zmq_listener.cpp75
-rw-r--r--src/zmq_listener.hpp67
123 files changed, 18804 insertions, 0 deletions
diff --git a/src/Makefile.am b/src/Makefile.am
new file mode 100644
index 0000000..fa97ca3
--- /dev/null
+++ b/src/Makefile.am
@@ -0,0 +1,244 @@
+lib_LTLIBRARIES = libzmq.la
+
+pkgconfigdir = $(libdir)/pkgconfig
+pkgconfig_DATA = libzmq.pc
+
+include_HEADERS = ../include/zmq.h ../include/zmq.hpp
+
+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 \
+ atomic_counter.hpp \
+ atomic_ptr.hpp \
+ blob.hpp \
+ command.hpp \
+ config.hpp \
+ ctx.hpp \
+ decoder.hpp \
+ devpoll.hpp \
+ downstream.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 \
+ lb.hpp \
+ likely.hpp \
+ msg_content.hpp \
+ mutex.hpp \
+ object.hpp \
+ options.hpp \
+ owned.hpp \
+ pgm_receiver.hpp \
+ pgm_sender.hpp \
+ pgm_socket.hpp \
+ pipe.hpp \
+ platform.hpp \
+ poll.hpp \
+ poller.hpp \
+ pair.hpp \
+ prefix_tree.hpp \
+ pub.hpp \
+ queue.hpp \
+ rep.hpp \
+ req.hpp \
+ select.hpp \
+ session.hpp \
+ signaler.hpp \
+ socket_base.hpp \
+ stdint.hpp \
+ streamer.hpp \
+ sub.hpp \
+ tcp_connecter.hpp \
+ tcp_listener.hpp \
+ tcp_socket.hpp \
+ thread.hpp \
+ upstream.hpp \
+ uuid.hpp \
+ windows.hpp \
+ wire.hpp \
+ xrep.hpp \
+ xreq.hpp \
+ yarray.hpp \
+ yarray_item.hpp \
+ ypipe.hpp \
+ yqueue.hpp \
+ zmq_connecter.hpp \
+ zmq_decoder.hpp \
+ zmq_encoder.hpp \
+ zmq_engine.hpp \
+ zmq_init.hpp \
+ zmq_listener.hpp \
+ app_thread.cpp \
+ command.cpp \
+ ctx.cpp \
+ devpoll.cpp \
+ downstream.cpp \
+ epoll.cpp \
+ err.cpp \
+ forwarder.cpp \
+ fq.cpp \
+ io_object.cpp \
+ io_thread.cpp \
+ ip.cpp \
+ kqueue.cpp \
+ lb.cpp \
+ object.cpp \
+ options.cpp \
+ owned.cpp \
+ pgm_receiver.cpp \
+ pgm_sender.cpp \
+ pgm_socket.cpp \
+ pair.cpp \
+ prefix_tree.cpp \
+ pipe.cpp \
+ poll.cpp \
+ pub.cpp \
+ queue.cpp \
+ rep.cpp \
+ req.cpp \
+ select.cpp \
+ session.cpp \
+ signaler.cpp \
+ socket_base.cpp \
+ streamer.cpp \
+ sub.cpp \
+ tcp_connecter.cpp \
+ tcp_listener.cpp \
+ tcp_socket.cpp \
+ thread.cpp \
+ upstream.cpp \
+ uuid.cpp \
+ xrep.cpp \
+ xreq.cpp \
+ zmq.cpp \
+ zmq_connecter.cpp \
+ zmq_decoder.cpp \