summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--AUTHORS2
-rw-r--r--Makefile.am4
-rw-r--r--builds/msvc/libzmq/libzmq.vcproj84
-rw-r--r--builds/msvc/platform.hpp4
-rw-r--r--configure.in4
-rw-r--r--doc/zmq_cpp.txt2
-rw-r--r--include/zmq.h70
-rw-r--r--perf/remote_thr.cpp8
-rw-r--r--src/Makefile.am43
-rw-r--r--src/app_thread.cpp195
-rw-r--r--src/app_thread.hpp88
-rw-r--r--src/array.hpp (renamed from src/yarray.hpp)66
-rw-r--r--src/command.hpp17
-rw-r--r--src/config.hpp9
-rw-r--r--src/connect_session.cpp111
-rw-r--r--src/connect_session.hpp60
-rw-r--r--src/ctx.cpp285
-rw-r--r--src/ctx.hpp109
-rw-r--r--src/decoder.cpp (renamed from src/zmq_decoder.cpp)37
-rw-r--r--src/decoder.hpp47
-rw-r--r--src/encoder.cpp (renamed from src/zmq_encoder.cpp)24
-rw-r--r--src/encoder.hpp39
-rw-r--r--src/forwarder.cpp17
-rw-r--r--src/fq.cpp56
-rw-r--r--src/fq.hpp26
-rw-r--r--src/i_engine.hpp17
-rw-r--r--src/i_inout.hpp21
-rw-r--r--src/i_terminate_events.hpp (renamed from src/zmq_encoder.hpp)35
-rw-r--r--src/io_object.cpp22
-rw-r--r--src/io_object.hpp10
-rw-r--r--src/io_thread.cpp5
-rw-r--r--src/io_thread.hpp2
-rw-r--r--src/lb.cpp36
-rw-r--r--src/lb.hpp24
-rw-r--r--src/named_session.cpp88
-rw-r--r--src/named_session.hpp (renamed from src/zmq_decoder.hpp)41
-rw-r--r--src/object.cpp118
-rw-r--r--src/object.hpp48
-rw-r--r--src/own.cpp203
-rw-r--r--src/own.hpp135
-rw-r--r--src/owned.cpp71
-rw-r--r--src/owned.hpp89
-rw-r--r--src/pair.cpp87
-rw-r--r--src/pair.hpp29
-rw-r--r--src/pgm_receiver.cpp14
-rw-r--r--src/pgm_receiver.hpp13
-rw-r--r--src/pgm_sender.cpp12
-rw-r--r--src/pgm_sender.hpp11
-rw-r--r--src/pipe.cpp407
-rw-r--r--src/pipe.hpp147
-rw-r--r--src/pub.cpp77
-rw-r--r--src/pub.hpp29
-rw-r--r--src/pull.cpp50
-rw-r--r--src/pull.hpp21
-rw-r--r--src/push.cpp52
-rw-r--r--src/push.hpp21
-rw-r--r--src/queue.cpp15
-rw-r--r--src/rep.cpp238
-rw-r--r--src/rep.hpp43
-rw-r--r--src/req.cpp234
-rw-r--r--src/req.hpp48
-rw-r--r--src/semaphore.hpp186
-rw-r--r--src/session.cpp232
-rw-r--r--src/session.hpp93
-rw-r--r--src/socket_base.cpp749
-rw-r--r--src/socket_base.hpp171
-rw-r--r--src/streamer.cpp17
-rw-r--r--src/sub.cpp42
-rw-r--r--src/sub.hpp22
-rw-r--r--src/swap.cpp (renamed from src/msg_store.cpp)33
-rw-r--r--src/swap.hpp (renamed from src/msg_store.hpp)28
-rw-r--r--src/thread.cpp20
-rw-r--r--src/thread.hpp9
-rw-r--r--src/transient_session.cpp36
-rw-r--r--src/transient_session.hpp (renamed from src/i_endpoint.hpp)30
-rw-r--r--src/trie.cpp (renamed from src/prefix_tree.cpp)36
-rw-r--r--src/trie.hpp (renamed from src/prefix_tree.hpp)17
-rw-r--r--src/xrep.cpp84
-rw-r--r--src/xrep.hpp30
-rw-r--r--src/xreq.cpp40
-rw-r--r--src/xreq.hpp19
-rw-r--r--src/yarray_item.hpp64
-rw-r--r--src/zmq.cpp373
-rw-r--r--src/zmq_connecter.cpp50
-rw-r--r--src/zmq_connecter.hpp25
-rw-r--r--src/zmq_engine.cpp55
-rw-r--r--src/zmq_engine.hpp23
-rw-r--r--src/zmq_init.cpp140
-rw-r--r--src/zmq_init.hpp33
-rw-r--r--src/zmq_listener.cpp24
-rw-r--r--src/zmq_listener.hpp13
-rw-r--r--tests/Makefile.am19
-rw-r--r--tests/test_pair_inproc.cpp30
-rw-r--r--tests/test_pair_ipc.cpp30
-rw-r--r--tests/test_pair_tcp.cpp30
-rw-r--r--tests/test_reqrep_inproc.cpp30
-rw-r--r--tests/test_reqrep_ipc.cpp30
-rw-r--r--tests/test_reqrep_tcp.cpp30
-rw-r--r--tests/testutil.hpp129
99 files changed, 3691 insertions, 3251 deletions
diff --git a/AUTHORS b/AUTHORS
index dd4e69a..aba4e77 100644
--- a/AUTHORS
+++ b/AUTHORS
@@ -15,6 +15,8 @@ Erik Rigtorp <erik@rigtorp.com>
Frank Denis <zeromq@pureftpd.org>
George Neill <georgen@neillnet.com>
Gonzalo Diethelm <gdiethelm@dcv.cl>
+Guido Goldstein <zmq@a-nugget.de>
+Ivo Danihelka <ivo@danihelka.net>
Joe Thornber <joe.thornber@gmail.com>
Jon Dyte <jon@totient.co.uk>
Kamil Shakirov <kamils80@gmail.com>
diff --git a/Makefile.am b/Makefile.am
index 18775fd..1236874 100644
--- a/Makefile.am
+++ b/Makefile.am
@@ -1,7 +1,7 @@
ACLOCAL_AMFLAGS = -I config
-SUBDIRS = src doc perf devices
-DIST_SUBDIRS = src doc perf devices builds/msvc
+SUBDIRS = src doc perf devices tests
+DIST_SUBDIRS = src doc perf devices tests builds/msvc
EXTRA_DIST = \
$(top_srcdir)/foreign/openpgm/@pgm_basename@.tar.gz \
diff --git a/builds/msvc/libzmq/libzmq.vcproj b/builds/msvc/libzmq/libzmq.vcproj
index 95db1df..c7b256a 100644
--- a/builds/msvc/libzmq/libzmq.vcproj
+++ b/builds/msvc/libzmq/libzmq.vcproj
@@ -170,11 +170,11 @@
UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}"
>
<File
- RelativePath="..\..\..\src\app_thread.cpp"
+ RelativePath="..\..\..\src\command.cpp"
>
</File>
<File
- RelativePath="..\..\..\src\command.cpp"
+ RelativePath="..\..\..\src\connect_session.cpp"
>
</File>
<File
@@ -182,11 +182,15 @@
>
</File>
<File
+ RelativePath="..\..\..\src\decoder.cpp"
+ >
+ </File>
+ <File
RelativePath="..\..\..\src\devpoll.cpp"
>
</File>
<File
- RelativePath="..\..\..\src\push.cpp"
+ RelativePath="..\..\..\src\encoder.cpp"
>
</File>
<File
@@ -226,7 +230,7 @@
>
</File>
<File
- RelativePath="..\..\..\src\msg_store.cpp"
+ RelativePath="..\..\..\src\named_session.cpp"
>
</File>
<File
@@ -238,7 +242,7 @@
>
</File>
<File
- RelativePath="..\..\..\src\owned.cpp"
+ RelativePath="..\..\..\src\own.cpp"
>
</File>
<File
@@ -266,11 +270,15 @@
>
</File>
<File
- RelativePath="..\..\..\src\prefix_tree.cpp"
+ RelativePath="..\..\..\src\pub.cpp"
>
</File>
<File
- RelativePath="..\..\..\src\pub.cpp"
+ RelativePath="..\..\..\src\pull.cpp"
+ >
+ </File>
+ <File
+ RelativePath="..\..\..\src\push.cpp"
>
</File>
<File
@@ -310,6 +318,10 @@
>
</File>
<File
+ RelativePath="..\..\..\src\swap.cpp"
+ >
+ </File>
+ <File
RelativePath="..\..\..\src\tcp_connecter.cpp"
>
</File>
@@ -326,7 +338,11 @@
>
</File>
<File
- RelativePath="..\..\..\src\pull.cpp"
+ RelativePath="..\..\..\src\transient_session.cpp"
+ >
+ </File>
+ <File
+ RelativePath="..\..\..\src\trie.cpp"
>
</File>
<File
@@ -350,14 +366,6 @@
>
</File>
<File
- RelativePath="..\..\..\src\zmq_decoder.cpp"
- >
- </File>
- <File
- RelativePath="..\..\..\src\zmq_encoder.cpp"
- >
- </File>
- <File
RelativePath="..\..\..\src\zmq_engine.cpp"
>
</File>
@@ -376,10 +384,6 @@
UniqueIdentifier="{93995380-89BD-4b04-88EB-625FBE52EBFB}"
>
<File
- RelativePath="..\..\..\src\app_thread.hpp"
- >
- </File>
- <File
RelativePath="..\..\..\src\atomic_counter.hpp"
>
</File>
@@ -396,19 +400,19 @@
>
</File>
<File
- RelativePath="..\..\..\src\ctx.hpp"
+ RelativePath="..\..\..\src\connect_session.hpp"
>
</File>
<File
- RelativePath="..\..\..\src\decoder.hpp"
+ RelativePath="..\..\..\src\ctx.hpp"
>
</File>
<File
- RelativePath="..\..\..\src\devpoll.hpp"
+ RelativePath="..\..\..\src\decoder.hpp"
>
</File>
<File
- RelativePath="..\..\..\src\push.hpp"
+ RelativePath="..\..\..\src\devpoll.hpp"
>
</File>
<File
@@ -476,11 +480,11 @@
>
</File>
<File
- RelativePath="..\..\..\src\msg_store.hpp"
+ RelativePath="..\..\..\src\mutex.hpp"
>
</File>
<File
- RelativePath="..\..\..\src\mutex.hpp"
+ RelativePath="..\..\..\src\named_session.hpp"
>
</File>
<File
@@ -492,7 +496,7 @@
>
</File>
<File
- RelativePath="..\..\..\src\owned.hpp"
+ RelativePath="..\..\..\src\own.hpp"
>
</File>
<File
@@ -524,11 +528,15 @@
>
</File>
<File
- RelativePath="..\..\..\src\prefix_tree.hpp"
+ RelativePath="..\..\..\src\pub.hpp"
>
</File>
<File
- RelativePath="..\..\..\src\pub.hpp"
+ RelativePath="..\..\..\src\pull.hpp"
+ >
+ </File>
+ <File
+ RelativePath="..\..\..\src\push.hpp"
>
</File>
<File
@@ -572,6 +580,10 @@
>
</File>
<File
+ RelativePath="..\..\..\src\swap.hpp"
+ >
+ </File>
+ <File
RelativePath="..\..\..\src\tcp_connecter.hpp"
>
</File>
@@ -588,7 +600,11 @@
>
</File>
<File
- RelativePath="..\..\..\src\pull.hpp"
+ RelativePath="..\..\..\src\transient_session.hpp"
+ >
+ </File>
+ <File
+ RelativePath="..\..\..\src\trie.hpp"
>
</File>
<File
@@ -624,14 +640,6 @@
>
</File>
<File
- RelativePath="..\..\..\src\zmq_decoder.hpp"
- >
- </File>
- <File
- RelativePath="..\..\..\src\zmq_encoder.hpp"
- >
- </File>
- <File
RelativePath="..\..\..\src\zmq_engine.hpp"
>
</File>
diff --git a/builds/msvc/platform.hpp b/builds/msvc/platform.hpp
index 77428a1..4c9cd3a 100644
--- a/builds/msvc/platform.hpp
+++ b/builds/msvc/platform.hpp
@@ -27,8 +27,8 @@
// 0MQ version information
#define PACKAGE_VERSION_MAJOR 2
-#define PACKAGE_VERSION_MINOR 0
-#define PACKAGE_VERSION_PATCH 9
+#define PACKAGE_VERSION_MINOR 1
+#define PACKAGE_VERSION_PATCH 0
#define ZMQ_HAVE_WINDOWS
diff --git a/configure.in b/configure.in
index c365778..61d22da 100644
--- a/configure.in
+++ b/configure.in
@@ -6,7 +6,7 @@ AC_PREREQ(2.61)
# The version in git should reflect the *next* version planned.
# Version must be MAJOR.MINOR.PATCH otherwise things will break.
#
-AC_INIT([zeromq],[2.0.9],[zeromq-dev@lists.zeromq.org])
+AC_INIT([zeromq],[2.1.0],[zeromq-dev@lists.zeromq.org])
AC_CONFIG_AUX_DIR(config)
AC_CONFIG_MACRO_DIR(config)
@@ -374,7 +374,7 @@ AC_OUTPUT(Makefile src/Makefile doc/Makefile
perf/Makefile src/libzmq.pc \
devices/Makefile devices/zmq_forwarder/Makefile \
devices/zmq_streamer/Makefile devices/zmq_queue/Makefile \
- builds/msvc/Makefile)
+ builds/msvc/Makefile tests/Makefile)
# On Linux patch libtool to delete hardcoded paths (rpath).
case "${host_os}" in
diff --git a/doc/zmq_cpp.txt b/doc/zmq_cpp.txt
index e25f460..668eff5 100644
--- a/doc/zmq_cpp.txt
+++ b/doc/zmq_cpp.txt
@@ -102,11 +102,13 @@ Maps to the _zmq_connect()_ function, as described in linkzmq:zmq_connect[3].
*bool socket_t::send(message_t '&msg', int 'flags' = 0)*
Maps to the _zmq_send()_ function, as described in linkzmq:zmq_send[3].
+Returns true if message is successfully sent, false if it is not.
[verse]
*bool socket_t::recv(message_t '*msg', int 'flags' = 0)*