summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--AUTHORS0
-rw-r--r--ChangeLog0
-rw-r--r--Makefile.am4
-rw-r--r--NEWS0
-rw-r--r--README0
-rwxr-xr-xautogen.sh29
-rw-r--r--configure.in188
-rw-r--r--examples/Makefile.am2
-rw-r--r--examples/chat/Makefile.am15
-rw-r--r--examples/chat/chatroom.cpp74
-rw-r--r--examples/chat/display.cpp56
-rw-r--r--examples/chat/prompt.cpp61
-rw-r--r--include/zs.h206
-rw-r--r--include/zs.hpp231
-rw-r--r--src/Makefile.am120
-rw-r--r--src/app_thread.cpp221
-rw-r--r--src/app_thread.hpp95
-rw-r--r--src/atomic.hpp310
-rw-r--r--src/atomic_bitmap.hpp286
-rw-r--r--src/atomic_counter.hpp197
-rw-r--r--src/atomic_ptr.hpp189
-rw-r--r--src/command.hpp98
-rw-r--r--src/config.hpp71
-rw-r--r--src/connecter.cpp189
-rw-r--r--src/connecter.hpp99
-rw-r--r--src/data_distributor.cpp155
-rw-r--r--src/data_distributor.hpp70
-rw-r--r--src/decoder.hpp101
-rw-r--r--src/devpoll.cpp224
-rw-r--r--src/devpoll.hpp110
-rw-r--r--src/dispatcher.cpp266
-rw-r--r--src/dispatcher.hpp170
-rw-r--r--src/dummy_aggregator.cpp111
-rw-r--r--src/dummy_aggregator.hpp73
-rw-r--r--src/dummy_distributor.cpp85
-rw-r--r--src/dummy_distributor.hpp68
-rw-r--r--src/encoder.hpp108
-rw-r--r--src/epoll.cpp214
-rw-r--r--src/epoll.hpp107
-rw-r--r--src/err.cpp146
-rw-r--r--src/err.hpp90
-rw-r--r--src/fair_aggregator.cpp143
-rw-r--r--src/fair_aggregator.hpp77
-rw-r--r--src/fd.hpp44
-rw-r--r--src/fd_signaler.cpp278
-rw-r--r--src/fd_signaler.hpp92
-rw-r--r--src/i_api.hpp39
-rw-r--r--src/i_demux.hpp56
-rw-r--r--src/i_engine.hpp53
-rw-r--r--src/i_mux.hpp59
-rw-r--r--src/i_poll_events.hpp45
-rw-r--r--src/i_poller.hpp89
-rw-r--r--src/i_session.hpp37
-rw-r--r--src/i_signaler.hpp38
-rw-r--r--src/i_thread.hpp38
-rw-r--r--src/io_object.cpp37
-rw-r--r--src/io_object.hpp51
-rw-r--r--src/io_thread.cpp177
-rw-r--r--src/io_thread.hpp99
-rw-r--r--src/ip.cpp310
-rw-r--r--src/ip.hpp47
-rw-r--r--src/kqueue.cpp214
-rw-r--r--src/kqueue.hpp112
-rw-r--r--src/listener.cpp170
-rw-r--r--src/listener.hpp110
-rw-r--r--src/load_balancer.cpp130
-rw-r--r--src/load_balancer.hpp73
-rw-r--r--src/msg.hpp49
-rw-r--r--src/mutex.hpp116
-rw-r--r--src/object.cpp294
-rw-r--r--src/object.hpp105
-rw-r--r--src/p2p.cpp29
-rw-r--r--src/p2p.hpp42
-rw-r--r--src/pipe.cpp47
-rw-r--r--src/pipe.hpp57
-rw-r--r--src/pipe_reader.cpp118
-rw-r--r--src/pipe_reader.hpp89
-rw-r--r--src/pipe_writer.cpp120
-rw-r--r--src/pipe_writer.hpp88
-rw-r--r--src/platform.hpp.in210
-rw-r--r--src/poll.cpp205
-rw-r--r--src/poll.hpp112
-rw-r--r--src/pub.cpp38
-rw-r--r--src/pub.hpp45
-rw-r--r--src/rep.cpp29
-rw-r--r--src/rep.hpp42
-rw-r--r--src/req.cpp29
-rw-r--r--src/req.hpp42
-rw-r--r--src/safe_object.cpp76
-rw-r--r--src/safe_object.hpp68
-rw-r--r--src/select.cpp236
-rw-r--r--src/select.hpp122
-rw-r--r--src/session.cpp273
-rw-r--r--src/session.hpp107
-rw-r--r--src/session_stub.cpp110
-rw-r--r--src/session_stub.hpp83
-rw-r--r--src/simple_semaphore.hpp188
-rw-r--r--src/socket_base.cpp267
-rw-r--r--src/socket_base.hpp96
-rw-r--r--src/stdint.hpp70
-rw-r--r--src/sub.cpp45
-rw-r--r--src/sub.hpp46
-rw-r--r--src/tcp_connecter.cpp138
-rw-r--r--src/tcp_connecter.hpp65
-rw-r--r--src/tcp_listener.cpp165
-rw-r--r--src/tcp_listener.hpp65
-rw-r--r--src/tcp_socket.cpp116
-rw-r--r--src/tcp_socket.hpp70
-rw-r--r--src/thread.cpp88
-rw-r--r--src/thread.hpp77
-rw-r--r--src/uuid.cpp136
-rw-r--r--src/uuid.hpp82
-rw-r--r--src/windows.hpp56
-rw-r--r--src/wire.hpp98
-rw-r--r--src/ypipe.hpp209
-rw-r--r--src/ypollset.cpp56
-rw-r--r--src/ypollset.hpp74
-rw-r--r--src/yqueue.hpp138
-rw-r--r--src/zmq_decoder.cpp78
-rw-r--r--src/zmq_decoder.hpp57
-rw-r--r--src/zmq_encoder.cpp75
-rw-r--r--src/zmq_encoder.hpp54
-rw-r--r--src/zmq_tcp_engine.cpp185
-rw-r--r--src/zmq_tcp_engine.hpp92
-rw-r--r--src/zs.cpp222
125 files changed, 13546 insertions, 0 deletions
diff --git a/AUTHORS b/AUTHORS
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/AUTHORS
diff --git a/ChangeLog b/ChangeLog
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/ChangeLog
diff --git a/Makefile.am b/Makefile.am
new file mode 100644
index 0000000..cc77307
--- /dev/null
+++ b/Makefile.am
@@ -0,0 +1,4 @@
+include_HEADERS = include/zs.h include/zs.hpp
+
+SUBDIRS = src examples
+DIST_SUBDIRS = src examples
diff --git a/NEWS b/NEWS
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/NEWS
diff --git a/README b/README
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/README
diff --git a/autogen.sh b/autogen.sh
new file mode 100755
index 0000000..19f2174
--- /dev/null
+++ b/autogen.sh
@@ -0,0 +1,29 @@
+#!/bin/sh
+# Copyright (c) 2007 FastMQ Inc.
+#
+# This file is part of 0MQ.
+#
+# 0MQ is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 3 of the License, or
+# (at your option) any later version.
+
+# 0MQ is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+# Script to generate all required files from fresh svn checkout.
+
+
+
+autoreconf --install --force --verbose -I config
+
+if [ $? -ne 0 ]; then
+ echo
+ echo "Could not run autoreconf, check autotools installation."
+ echo
+fi
diff --git a/configure.in b/configure.in
new file mode 100644
index 0000000..e75ab11
--- /dev/null
+++ b/configure.in
@@ -0,0 +1,188 @@
+# -*- Autoconf -*-
+# Process this file with autoconf to produce a configure script.
+AC_PREREQ(2.61)
+AC_INIT([zsock],[dev])
+AC_CONFIG_AUX_DIR(config)
+AM_CONFIG_HEADER(src/platform.hpp)
+AM_INIT_AUTOMAKE(AC_PACKAGE_NAME, AC_PACKAGE_VERSION)
+
+AM_PROG_CC_C_O
+
+# Checks for programs.
+AC_PROG_CXX
+AC_PROG_LIBTOOL
+
+# Checks for libraries.
+AC_CHECK_LIB(pthread, pthread_create)
+
+# Host speciffic checks
+AC_CANONICAL_HOST
+
+case "${host_os}" in
+ *linux*)
+ AC_DEFINE(ZS_HAVE_LINUX, 1, [Have Linux OS])
+ CPPFLAGS="-D_REENTRANT $CPPFLAGS"
+ sed < libtool > libtool-2 \
+ 's/^hardcode_libdir_flag_spec.*$'/'hardcode_libdir_flag_spec=" "/'
+ mv libtool-2 libtool
+ chmod 755 libtool
+ AC_CHECK_LIB(uuid, uuid_generate)
+ ;;
+ *solaris*)
+ AC_DEFINE(ZS_HAVE_SOLARIS, 1, [Have Solaris OS])
+ AC_CHECK_LIB(socket, main)
+ AC_CHECK_LIB(nsl, main)
+ AC_CHECK_LIB(rt, main)
+ CPPFLAGS="-D_REENTRANT -D_PTHREADS $CPPFLAGS"
+ AC_MSG_CHECKING([wheter atomic operations can be used])
+ AC_COMPILE_IFELSE([AC_LANG_PROGRAM(
+ [[#include <atomic.h>]],
+ [[uint32_t value;
+ atomic_cas_32 (&value, 0, 0);
+ return 0;]])],
+ [solaris_has_atomic=yes],
+ [solaris_has_atomic=no])
+ 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])
+ fi
+ ;;
+ *freebsd*)
+ AC_DEFINE(ZS_HAVE_FREEBSD, 1, [Have FreeBSD OS])
+ CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
+ LIBS="-pthread"
+ ;;
+ *darwin*)
+ AC_DEFINE(ZS_HAVE_OSX, 1, [Have DarwinOSX OS])
+ LIBS="-pthread"
+ ZS_EXTRA_CXXFLAGS+="-Wno-uninitialized"
+ ;;
+ *openbsd*)
+ AC_DEFINE(ZS_HAVE_OPENBSD, 1, [Have OpenBSD OS])
+ CPPFLAGS="-pthread $CPPFLAGS"
+ LIBS="-pthread"
+ ;;
+ *nto-qnx*)
+ AC_DEFINE(ZS_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])
+ if test "x$GXX" = "xyes"; then
+ CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
+ fi
+ ;;
+ *hpux*)
+ AC_DEFINE(ZS_HAVE_HPUX, 1, [Have HPUX OS])
+ if test "x$GXX" = "xyes"; then
+ CPPFLAGS="-D_THREAD_SAFE $CPPFLAGS"
+ fi
+ AC_CHECK_LIB(rt, main)
+ sed < libtool > libtool-2 \
+ 's/^hardcode_libdir_flag_spec.*$'/'hardcode_libdir_flag_spec=" "/'
+ mv libtool-2 libtool
+ chmod 755 libtool
+ ;;
+ *mingw32*)
+ AC_DEFINE(ZS_HAVE_WINDOWS, 1, [Have Windows OS])
+ AC_DEFINE(ZS_HAVE_MINGW32, 1, [Have MinGW32])
+ AC_CHECK_HEADERS(windows.h)
+ LIBS="-lwsock32 -lws2_32 -no-undefined"
+ CFLAGS="-std=c99"
+ install_man="no"
+ ;;
+ *)
+ AC_MSG_ERROR([Not supported os: $host.])
+ ;;
+esac
+
+# Check if we are running at sparc harware
+AC_MSG_CHECKING([wheter __sparc__ is defined])
+AC_COMPILE_IFELSE([AC_LANG_PROGRAM(
+ [[#if defined __sparc__
+ //OK we are on sparc
+ #else
+ error: we are not on sparc
+ #endif
+ ]])],
+ [sparc=yes],
+ [sparc=no])
+
+AC_MSG_RESULT([$sparc])
+
+if test "x$sparc" = "xyes"; then
+ CPPFLAGS="$CPPFLAGS -mcpu=v9"
+fi
+
+# Checks for header files.
+AC_HEADER_STDC
+AC_CHECK_HEADERS(errno.h arpa/inet.h netinet/tcp.h netinet/in.h stddef.h \
+stdlib.h string.h sys/socket.h sys/time.h unistd.h limits.h)
+
+# Check if we have eventfd.h header file.
+AC_CHECK_HEADERS(sys/eventfd.h, [AC_DEFINE(ZS_HAVE_EVENTFD, 1, [Have eventfd extension.])])
+
+# Check if we have ifaddrs.h header file.
+AC_CHECK_HEADERS(ifaddrs.h, [AC_DEFINE(ZS_HAVE_IFADDRS, 1, [Have ifaddrs.h header.])])
+
+# Use c++ in subsequent tests
+AC_LANG(C++)