summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--.gitignore3
-rw-r--r--Makefile.am2
-rw-r--r--configure.in38
-rw-r--r--examples/chat/Makefile.am6
-rw-r--r--examples/chat/chatroom.cpp12
-rw-r--r--examples/chat/display.cpp10
-rw-r--r--examples/chat/prompt.cpp8
-rw-r--r--include/zmq.h (renamed from include/zs.h)103
-rw-r--r--include/zmq.hpp (renamed from include/zs.hpp)64
-rw-r--r--src/Makefile.am10
-rw-r--r--src/app_thread.cpp70
-rw-r--r--src/app_thread.hpp8
-rw-r--r--src/atomic.hpp62
-rw-r--r--src/atomic_bitmap.hpp82
-rw-r--r--src/atomic_counter.hpp72
-rw-r--r--src/atomic_ptr.hpp72
-rw-r--r--src/command.hpp6
-rw-r--r--src/config.hpp6
-rw-r--r--src/connecter.cpp48
-rw-r--r--src/connecter.hpp12
-rw-r--r--src/data_distributor.cpp42
-rw-r--r--src/data_distributor.hpp10
-rw-r--r--src/decoder.hpp6
-rw-r--r--src/devpoll.cpp38
-rw-r--r--src/devpoll.hpp8
-rw-r--r--src/dispatcher.cpp52
-rw-r--r--src/dispatcher.hpp8
-rw-r--r--src/dummy_aggregator.cpp34
-rw-r--r--src/dummy_aggregator.hpp8
-rw-r--r--src/dummy_distributor.cpp28
-rw-r--r--src/dummy_distributor.hpp8
-rw-r--r--src/encoder.hpp6
-rw-r--r--src/epoll.cpp36
-rw-r--r--src/epoll.hpp8
-rw-r--r--src/err.cpp8
-rw-r--r--src/err.hpp16
-rw-r--r--src/fair_aggregator.cpp30
-rw-r--r--src/fair_aggregator.hpp8
-rw-r--r--src/fd.hpp8
-rw-r--r--src/fd_signaler.cpp54
-rw-r--r--src/fd_signaler.hpp8
-rw-r--r--src/i_api.hpp14
-rw-r--r--src/i_demux.hpp11
-rw-r--r--src/i_engine.hpp8
-rw-r--r--src/i_mux.hpp11
-rw-r--r--src/i_poll_events.hpp6
-rw-r--r--src/i_poller.hpp6
-rw-r--r--src/i_session.hpp10
-rw-r--r--src/i_signaler.hpp6
-rw-r--r--src/i_thread.hpp6
-rw-r--r--src/io_object.cpp6
-rw-r--r--src/io_object.hpp6
-rw-r--r--src/io_thread.cpp72
-rw-r--r--src/io_thread.hpp8
-rw-r--r--src/ip.cpp36
-rw-r--r--src/ip.hpp8
-rw-r--r--src/kqueue.cpp40
-rw-r--r--src/kqueue.hpp8
-rw-r--r--src/listener.cpp42
-rw-r--r--src/listener.hpp6
-rw-r--r--src/load_balancer.cpp32
-rw-r--r--src/load_balancer.hpp10
-rw-r--r--src/msg.hpp16
-rw-r--r--src/mutex.hpp10
-rw-r--r--src/object.cpp88
-rw-r--r--src/object.hpp6
-rw-r--r--src/p2p.cpp4
-rw-r--r--src/p2p.hpp6
-rw-r--r--src/pipe.cpp14
-rw-r--r--src/pipe.hpp10
-rw-r--r--src/pipe_reader.cpp26
-rw-r--r--src/pipe_reader.hpp8
-rw-r--r--src/pipe_writer.cpp30
-rw-r--r--src/pipe_writer.hpp8
-rw-r--r--src/platform.hpp.in26
-rw-r--r--src/poll.cpp40
-rw-r--r--src/poll.hpp14
-rw-r--r--src/pub.cpp6
-rw-r--r--src/pub.hpp8
-rw-r--r--src/rep.cpp4
-rw-r--r--src/rep.hpp6
-rw-r--r--src/req.cpp4
-rw-r--r--src/req.hpp6
-rw-r--r--src/safe_object.cpp14
-rw-r--r--src/safe_object.hpp6
-rw-r--r--src/select.cpp40
-rw-r--r--src/select.hpp10
-rw-r--r--src/session.cpp46
-rw-r--r--src/session.hpp10
-rw-r--r--src/session_stub.cpp30
-rw-r--r--src/session_stub.hpp10
-rw-r--r--src/simple_semaphore.hpp12
-rw-r--r--src/socket_base.cpp56
-rw-r--r--src/socket_base.hpp14
-rw-r--r--src/stdint.hpp6
-rw-r--r--src/sub.cpp8
-rw-r--r--src/sub.hpp8
-rw-r--r--src/tcp_connecter.cpp20
-rw-r--r--src/tcp_connecter.hpp6
-rw-r--r--src/tcp_listener.cpp20
-rw-r--r--src/tcp_listener.hpp6
-rw-r--r--src/tcp_socket.cpp18
-rw-r--r--src/tcp_socket.hpp6
-rw-r--r--src/thread.cpp14
-rw-r--r--src/thread.hpp10
-rw-r--r--src/uuid.cpp40
-rw-r--r--src/uuid.hpp18
-rw-r--r--src/windows.hpp4
-rw-r--r--src/wire.hpp6
-rw-r--r--src/ypipe.hpp8
-rw-r--r--src/ypollset.cpp10
-rw-r--r--src/ypollset.hpp6
-rw-r--r--src/yqueue.hpp10
-rw-r--r--src/zmq.cpp (renamed from src/zs.cpp)113
-rw-r--r--src/zmq_decoder.cpp25
-rw-r--r--src/zmq_decoder.hpp10
-rw-r--r--src/zmq_encoder.cpp18
-rw-r--r--src/zmq_encoder.hpp10
-rw-r--r--src/zmq_tcp_engine.cpp44
-rw-r--r--src/zmq_tcp_engine.hpp6
120 files changed, 1258 insertions, 1250 deletions
diff --git a/.gitignore b/.gitignore
index e69de29..cf19bd8 100644
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1,3 @@
+*.o
+*.lo
+*.la
diff --git a/Makefile.am b/Makefile.am
index cc77307..156c97e 100644
--- a/Makefile.am
+++ b/Makefile.am
@@ -1,4 +1,4 @@
-include_HEADERS = include/zs.h include/zs.hpp
+include_HEADERS = include/zmq.h include/zmq.hpp
SUBDIRS = src examples
DIST_SUBDIRS = src examples
diff --git a/configure.in b/configure.in
index e75ab11..932b4dd 100644
--- a/configure.in
+++ b/configure.in
@@ -1,7 +1,7 @@
# -*- Autoconf -*-
# Process this file with autoconf to produce a configure script.
AC_PREREQ(2.61)
-AC_INIT([zsock],[dev])
+AC_INIT([zeromq],[dev])
AC_CONFIG_AUX_DIR(config)
AM_CONFIG_HEADER(src/platform.hpp)
AM_INIT_AUTOMAKE(AC_PACKAGE_NAME, AC_PACKAGE_VERSION)
@@ -20,7 +20,7 @@ AC_CANONICAL_HOST
case "${host_os}" in
*linux*)
- AC_DEFINE(ZS_HAVE_LINUX, 1, [Have Linux OS])
+ AC_DEFINE(ZMQ_HAVE_LINUX, 1, [Have Linux OS])
CPPFLAGS="-D_REENTRANT $CPPFLAGS"
sed < libtool > libtool-2 \
's/^hardcode_libdir_flag_spec.*$'/'hardcode_libdir_flag_spec=" "/'
@@ -29,7 +29,7 @@ case "${host_os}" in
AC_CHECK_LIB(uuid, uuid_generate)
;;
*solaris*)
- AC_DEFINE(ZS_HAVE_SOLARIS, 1, [Have Solaris OS])
+ AC_DEFINE(ZMQ_HAVE_SOLARIS, 1, [Have Solaris OS])
AC_CHECK_LIB(socket, main)
AC_CHECK_LIB(nsl, main)
AC_CHECK_LIB(rt, main)
@@ -45,37 +45,37 @@ case "${host_os}" in
AC_MSG_RESULT([$solaris_has_atomic])
# Solaris 8 does not have atomic operations exported to user space.
if test "x$solaris_has_atomic" = "xno"; then
- AC_DEFINE(ZS_FORCE_MUTEXES, 1, [Force to use mutexes])
+ AC_DEFINE(ZMQ_FORCE_MUTEXES, 1, [Force to use mutexes])
fi
;;
*freebsd*)
- AC_DEFINE(ZS_HAVE_FREEBSD, 1, [Have FreeBSD OS])
+ AC_DEFINE(ZMQ_HAVE_FREEBSD, 1, [Have FreeBSD OS])
CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
LIBS="-pthread"
;;
*darwin*)
- AC_DEFINE(ZS_HAVE_OSX, 1, [Have DarwinOSX OS])
+ AC_DEFINE(ZMQ_HAVE_OSX, 1, [Have DarwinOSX OS])
LIBS="-pthread"
- ZS_EXTRA_CXXFLAGS+="-Wno-uninitialized"
+ ZMQ_EXTRA_CXXFLAGS+="-Wno-uninitialized"
;;
*openbsd*)
- AC_DEFINE(ZS_HAVE_OPENBSD, 1, [Have OpenBSD OS])
+ AC_DEFINE(ZMQ_HAVE_OPENBSD, 1, [Have OpenBSD OS])
CPPFLAGS="-pthread $CPPFLAGS"
LIBS="-pthread"
;;
*nto-qnx*)
- AC_DEFINE(ZS_HAVE_QNXNTO, 1, [Have QNX Neutrino OS])
+ AC_DEFINE(ZMQ_HAVE_QNXNTO, 1, [Have QNX Neutrino OS])
CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
AC_CHECK_LIB(socket,main)
;;
*aix*)
- AC_DEFINE(ZS_HAVE_AIX, 1, [Have AIX OS])
+ AC_DEFINE(ZMQ_HAVE_AIX, 1, [Have AIX OS])
if test "x$GXX" = "xyes"; then
CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
fi
;;
*hpux*)
- AC_DEFINE(ZS_HAVE_HPUX, 1, [Have HPUX OS])
+ AC_DEFINE(ZMQ_HAVE_HPUX, 1, [Have HPUX OS])
if test "x$GXX" = "xyes"; then
CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
fi
@@ -86,8 +86,8 @@ case "${host_os}" in
chmod 755 libtool
;;
*mingw32*)
- AC_DEFINE(ZS_HAVE_WINDOWS, 1, [Have Windows OS])
- AC_DEFINE(ZS_HAVE_MINGW32, 1, [Have MinGW32])
+ AC_DEFINE(ZMQ_HAVE_WINDOWS, 1, [Have Windows OS])
+ AC_DEFINE(ZMQ_HAVE_MI