diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-02-27 12:23:22 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-02-27 12:23:22 +0100 |
commit | 45414b5444db0a1f7e325c7dce92fbe84667d093 (patch) | |
tree | 440e38ef6726daaf22c3093f6323faf86af3325f | |
parent | efefa069b2ce407a7da4328ab024c47920a76960 (diff) |
python binding removed
-rw-r--r-- | bindings/Makefile.am | 8 | ||||
-rw-r--r-- | bindings/python/Makefile.am | 7 | ||||
-rw-r--r-- | bindings/python/pyzmq.cpp | 556 | ||||
-rw-r--r-- | bindings/python/setup.py.in | 14 | ||||
-rw-r--r-- | configure.in | 65 | ||||
-rw-r--r-- | doc/Makefile.am | 2 | ||||
-rw-r--r-- | doc/zmq.txt | 3 | ||||
-rw-r--r-- | doc/zmq_python.txt | 27 | ||||
-rw-r--r-- | perf/Makefile.am | 9 | ||||
-rw-r--r-- | perf/python/Makefile.am | 1 | ||||
-rw-r--r-- | perf/python/local_lat.py | 49 | ||||
-rw-r--r-- | perf/python/local_thr.py | 70 | ||||
-rw-r--r-- | perf/python/remote_lat.py | 61 | ||||
-rw-r--r-- | perf/python/remote_thr.py | 53 |
14 files changed, 11 insertions, 914 deletions
diff --git a/bindings/Makefile.am b/bindings/Makefile.am index 77b4ec2..bb51360 100644 --- a/bindings/Makefile.am +++ b/bindings/Makefile.am @@ -2,14 +2,10 @@ if BUILD_JAVA DIR_J = java endif -if BUILD_PYTHON -DIR_P = python -endif - if BUILD_RUBY DIR_R = ruby endif -SUBDIRS = $(DIR_J) $(DIR_P) $(DIR_R) -DIST_SUBDIRS = java python ruby +SUBDIRS = $(DIR_J) $(DIR_R) +DIST_SUBDIRS = java ruby diff --git a/bindings/python/Makefile.am b/bindings/python/Makefile.am deleted file mode 100644 index effe8b9..0000000 --- a/bindings/python/Makefile.am +++ /dev/null @@ -1,7 +0,0 @@ -INCLUDES = -I$(top_builddir) -I$(top_srcdir) -I$(top_srcdir)/libzmq \ --I$(top_builddir)/libzmq $(PYTHON_INCLUDES) - -pyexec_LTLIBRARIES = libpyzmq.la -libpyzmq_la_SOURCES = pyzmq.cpp -libpyzmq_la_LIBADD = $(top_builddir)/src/libzmq.la -libpyzmq_la_LDFLAGS = -avoid-version diff --git a/bindings/python/pyzmq.cpp b/bindings/python/pyzmq.cpp deleted file mode 100644 index 7a1905a..0000000 --- a/bindings/python/pyzmq.cpp +++ /dev/null @@ -1,556 +0,0 @@ -/* - Copyright (c) 2007-2010 iMatix Corporation - - This file is part of 0MQ. - - 0MQ is free software; you can redistribute it and/or modify it under - the terms of the Lesser 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 - Lesser GNU General Public License for more details. - - You should have received a copy of the Lesser GNU General Public License - along with this program. If not, see <http://www.gnu.org/licenses/>. -*/ - -#include <Python.h> -#include <stddef.h> -#include <assert.h> -#include <errno.h> -#include <string.h> - -#include "../c/zmq.h" - -#if defined _MSC_VER -#pragma warning (push) -#pragma warning (disable:4996) -#endif - -extern PyTypeObject context_type; - -struct context_t -{ - PyObject_HEAD - void *handle; -}; - -PyObject *context_new (PyTypeObject *type, PyObject *args, PyObject *kwds) -{ - context_t *self = (context_t*) type->tp_alloc (type, 0); - - if (self) - self->handle = NULL; - - return (PyObject*) self; -} - - -int context_init (context_t *self, PyObject *args, PyObject *kwdict) -{ - int app_threads; - int io_threads; - int flags = 0; - static const char *kwlist [] = {"app_threads", "io_threads", "flags", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "ii|i", (char**) kwlist, - &app_threads, &io_threads, &flags)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return -1; - } - - assert (!self->handle); - self->handle = zmq_init (app_threads, io_threads, flags); - if (!self->handle) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return -1; - } - - return 0; -} - -void context_dealloc (context_t *self) -{ - if (self->handle) { - int rc = zmq_term (self->handle); - if (rc != 0) - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - } - - self->ob_type->tp_free ((PyObject*) self); -} - -extern PyTypeObject socket_type; - -struct socket_t -{ - PyObject_HEAD - void *handle; -}; - -PyObject *socket_new (PyTypeObject *type, PyObject *args, PyObject *kwds) -{ - socket_t *self = (socket_t*) type->tp_alloc (type, 0); - - if (self) - self->handle = NULL; - - return (PyObject*) self; -} - -int socket_init (socket_t *self, PyObject *args, PyObject *kwdict) -{ - context_t *context; - int socket_type; - static const char *kwlist [] = {"context", "type", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "O!i", (char**) kwlist, - &context_type, &context, &socket_type)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return -1; - } - - assert (!self->handle); - self->handle = zmq_socket (context->handle, socket_type); - if (!self->handle) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return -1; - } - - return 0; -} - -void socket_dealloc (socket_t *self) -{ - if (self->handle) { - int rc = zmq_close (self->handle); - if (rc != 0) - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - } - - self->ob_type->tp_free ((PyObject*) self); -} - -PyObject *socket_setsockopt (socket_t *self, PyObject *args, PyObject *kwdict) -{ - int option; - PyObject* optval; - static const char *kwlist [] = {"option", "optval", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "iO", (char**) kwlist, - &option, &optval)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - int rc = 0; - - switch (option) { - case ZMQ_HWM: - case ZMQ_LWM: - case ZMQ_SWAP: - case ZMQ_AFFINITY: - case ZMQ_RATE: - case ZMQ_RECOVERY_IVL: - case ZMQ_MCAST_LOOP: - { - int val = PyInt_AsLong (optval); - rc = zmq_setsockopt (self->handle, option, &val, sizeof (int)); - break; - } - case ZMQ_IDENTITY: - case ZMQ_SUBSCRIBE: - case ZMQ_UNSUBSCRIBE: - rc = zmq_setsockopt (self->handle, option, PyString_AsString (optval), - PyString_Size (optval)); - break; - - default: - rc = -1; - errno = EINVAL; - } - - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return NULL; - } - - Py_INCREF (Py_None); - return Py_None; -} - -PyObject *socket_bind (socket_t *self, PyObject *args, PyObject *kwdict) -{ - char const *addr; - static const char *kwlist [] = {"addr", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "s", (char**) kwlist, - &addr)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - int rc = zmq_bind (self->handle, addr); - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return NULL; - } - - Py_INCREF (Py_None); - return Py_None; -} - -PyObject *socket_connect (socket_t *self, PyObject *args, PyObject *kwdict) -{ - char const *addr; - static const char *kwlist [] = {"addr", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "s", (char**) kwlist, - &addr)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - int rc = zmq_connect (self->handle, addr); - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return NULL; - } - - Py_INCREF (Py_None); - return Py_None; -} - -PyObject *socket_send (socket_t *self, PyObject *args, PyObject *kwdict) -{ - PyObject *msg; /* = PyString_FromStringAndSize (NULL, 0); */ - int flags = 0; - static const char *kwlist [] = {"msg", "flags", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "S|i", (char**) kwlist, - &msg, &flags)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - zmq_msg_t data; - int rc = zmq_msg_init_size (&data, PyString_Size (msg)); - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return NULL; - } - memcpy (zmq_msg_data (&data), PyString_AsString (msg), - zmq_msg_size (&data)); - - Py_BEGIN_ALLOW_THREADS - rc = zmq_send (self->handle, &data, flags); - Py_END_ALLOW_THREADS - - int rc2 = zmq_msg_close (&data); - assert (rc2 == 0); - - if (rc != 0 && errno == EAGAIN) - return PyBool_FromLong (0); - - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return NULL; - } - - return PyBool_FromLong (1); -} - -PyObject *socket_flush (socket_t *self, PyObject *args, PyObject *kwdict) -{ - static const char *kwlist [] = {NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "", (char**) kwlist)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - int rc = zmq_flush (self->handle); - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, zmq_strerror (errno)); - return NULL; - } - - Py_INCREF (Py_None); - return Py_None; -} - -PyObject *socket_recv (socket_t *self, PyObject *args, PyObject *kwdict) -{ - int flags = 0; - static const char *kwlist [] = {"flags", NULL}; - if (!PyArg_ParseTupleAndKeywords (args, kwdict, "|i", (char**) kwlist, - &flags)) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - zmq_msg_t msg; - int rc = zmq_msg_init (&msg); - assert (rc == 0); - - Py_BEGIN_ALLOW_THREADS - rc = zmq_recv (self->handle, &msg, flags); - Py_END_ALLOW_THREADS - - if (rc != 0 && errno == EAGAIN) { - Py_INCREF (Py_None); - return Py_None; - } - - if (rc != 0) { - PyErr_SetString (PyExc_SystemError, "invalid arguments"); - return NULL; - } - - PyObject *result = PyString_FromStringAndSize ((char*) zmq_msg_data (&msg), - zmq_msg_size (&msg)); - rc = zmq_msg_close (&msg); - assert (rc == 0); - return result; -} - -static PyMethodDef context_methods [] = -{ - { - NULL - } -}; - -PyTypeObject context_type = -{ - PyObject_HEAD_INIT (NULL) - 0, - "libpyzmq.Context", /* tp_name */ - sizeof (context_t), /* tp_basicsize */ - 0, /* tp_itemsize */ - (destructor) context_dealloc, /* tp_dealloc */ - 0, /* tp_print */ - 0, /* tp_getattr */ - 0, /* tp_setattr */ - 0, /* tp_compare */ - 0, /* tp_repr */ - 0, /* tp_as_number */ - 0, /* tp_as_sequence */ - 0, /* tp_as_mapping */ - 0, /* tp_hash */ - 0, /* tp_call */ - 0, /* tp_str */ - 0, /* tp_getattro */ - 0, /* tp_setattro */ - 0, /* tp_as_buffer */ - Py_TPFLAGS_DEFAULT, /* tp_flags */ - "", /* tp_doc */ - 0, /* tp_traverse */ - 0, /* tp_clear */ - 0, /* tp_richcompare */ - 0, /* tp_weaklistoffset */ - 0, /* tp_iter */ - 0, /* tp_iternext */ - context_methods, /* tp_methods */ - 0, /* tp_members */ - 0, /* tp_getset */ - 0, /* tp_base */ - 0, /* tp_dict */ - 0, /* tp_descr_get */ - 0, /* tp_descr_set */ - 0, /* tp_dictoffset */ - (initproc) context_init, /* tp_init */ - 0, /* tp_alloc */ - context_new /* tp_new */ -}; - -static PyMethodDef socket_methods [] = -{ - { - "setsockopt", - (PyCFunction) socket_setsockopt, - METH_VARARGS | METH_KEYWORDS, - "setsockopt (option, optval) -> None\n\n" - }, - { - "bind", - (PyCFunction) socket_bind, - METH_VARARGS | METH_KEYWORDS, - "bind (addr) -> None\n\n" - }, - { - "connect", - (PyCFunction) socket_connect, - METH_VARARGS | METH_KEYWORDS, - "connect (addr) -> None\n\n" - }, - { - "send", - (PyCFunction) socket_send, - METH_VARARGS | METH_KEYWORDS, - "send (msg, [flags]) -> Bool\n\n" - }, - { - "flush", - (PyCFunction) socket_flush, - METH_VARARGS | METH_KEYWORDS, - "flush () -> None\n\n" - }, - { - "recv", - (PyCFunction) socket_recv, - METH_VARARGS | METH_KEYWORDS, - "recv ([flags]) -> String\n\n" - }, - { - NULL - } -}; - -PyTypeObject socket_type = -{ - PyObject_HEAD_INIT (NULL) - 0, - "libpyzmq.Socket", /* tp_name */ - sizeof (socket_t), /* tp_basicsize */ - 0, /* tp_itemsize */ - (destructor) socket_dealloc, /* tp_dealloc */ - 0, /* tp_print */ - 0, /* tp_getattr */ - 0, /* tp_setattr */ - 0, /* tp_compare */ - 0, /* tp_repr */ - 0, /* tp_as_number */ - 0, /* tp_as_sequence */ - 0, /* tp_as_mapping */ - 0, /* tp_hash */ - 0, /* tp_call */ - 0, /* tp_str */ - 0, /* tp_getattro */ - 0, /* tp_setattro */ - 0, /* tp_as_buffer */ - Py_TPFLAGS_DEFAULT, /* tp_flags */ - "", /* tp_doc */ - 0, /* tp_traverse */ - 0, /* tp_clear */ - 0, /* tp_richcompare */ - 0, /* tp_weaklistoffset */ - 0, /* tp_iter */ - 0, /* tp_iternext */ - socket_methods, /* tp_methods */ - 0, /* tp_members */ - 0, /* tp_getset */ - 0, /* tp_base */ - 0, /* tp_dict */ - 0, /* tp_descr_get */ - 0, /* tp_descr_set */ - 0, /* tp_dictoffset */ - (initproc) socket_init, /* tp_init */ - 0, /* tp_alloc */ - socket_new /* tp_new */ -}; - -static PyMethodDef module_methods [] = {{ NULL, NULL, 0, NULL }}; - -static const char* libpyzmq_doc = - "Python API for 0MQ lightweight messaging kernel.\n" - "For more information see http://www.zeromq.org.\n" - "0MQ is distributed under GNU Lesser General Public License v3.\n"; - -#ifndef PyMODINIT_FUNC -#define PyMODINIT_FUNC void -#endif - -PyMODINIT_FUNC initlibpyzmq () -{ - int rc = PyType_Ready (&context_type); - assert (rc == 0); - rc = PyType_Ready (&socket_type); - assert (rc == 0); - - PyObject *module = Py_InitModule3 ("libpyzmq", module_methods, - (char*) libpyzmq_doc); - if (!module) - return; - - Py_INCREF (&context_type); - PyModule_AddObject (module, "Context", (PyObject*) &context_type); - Py_INCREF (&socket_type); - PyModule_AddObject (module, "Socket", (PyObject*) &socket_type); - - PyObject *dict = PyModule_GetDict (module); - assert (dict); - PyObject *t; - t = PyInt_FromLong (ZMQ_NOBLOCK); - PyDict_SetItemString (dict, "NOBLOCK", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_NOFLUSH); - PyDict_SetItemString (dict, "NOFLUSH", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_P2P); - PyDict_SetItemString (dict, "P2P", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_PUB); - PyDict_SetItemString (dict, "PUB", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_SUB); - PyDict_SetItemString (dict, "SUB", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_REQ); - PyDict_SetItemString (dict, "REQ", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_REP); - PyDict_SetItemString (dict, "REP", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_XREQ); - PyDict_SetItemString (dict, "XREQ", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_XREP); - PyDict_SetItemString (dict, "XREP", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_UPSTREAM); - PyDict_SetItemString (dict, "UPSTREAM", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_DOWNSTREAM); - PyDict_SetItemString (dict, "DOWNSTREAM", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_HWM); - PyDict_SetItemString (dict, "HWM", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_LWM); - PyDict_SetItemString (dict, "LWM", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_SWAP); - PyDict_SetItemString (dict, "SWAP", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_AFFINITY); - PyDict_SetItemString (dict, "AFFINITY", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_IDENTITY); - PyDict_SetItemString (dict, "IDENTITY", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_SUBSCRIBE); - PyDict_SetItemString (dict, "SUBSCRIBE", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_UNSUBSCRIBE); - PyDict_SetItemString (dict, "UNSUBSCRIBE", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_RATE); - PyDict_SetItemString (dict, "RATE", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_RECOVERY_IVL); - PyDict_SetItemString (dict, "RECOVERY_IVL", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_MCAST_LOOP); - PyDict_SetItemString (dict, "MCAST_LOOP", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_SNDBUF); - PyDict_SetItemString (dict, "SNDBUF", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_RCVBUF); - PyDict_SetItemString (dict, "RCVBUF", t); - Py_DECREF (t); - t = PyInt_FromLong (ZMQ_POLL); - PyDict_SetItemString (dict, "POLL", t); - Py_DECREF (t); -} - -#if defined _MSC_VER -#pragma warning (pop) -#endif diff --git a/bindings/python/setup.py.in b/bindings/python/setup.py.in deleted file mode 100644 index f7055d5..0000000 --- a/bindings/python/setup.py.in +++ /dev/null @@ -1,14 +0,0 @@ -from distutils.core import setup, Extension - -module1 = Extension('libpyzmq', - libraries = ['zmq'], - library_dirs = ['@prefix@/lib'], - include_dirs = ['@PYTHON_SETUP_INCLUDES@','@prefix@/include'], - sources = ['pyzmq.cpp']) - -setup (name = 'libyzmq', - version = '@VERSION@', - description = '0MQ Python library', - ext_modules = [module1]) - - diff --git a/configure.in b/configure.in index 8e45f89..4876674 100644 --- a/configure.in +++ b/configure.in @@ -313,46 +313,6 @@ if test "x$cpp" != "xno"; then cppzmq="yes" fi -# Python -pyzmq="no" -AC_ARG_WITH(python_headersdir, - AS_HELP_STRING([--with-python-headersdir], [Python.h header file location]), - [python_headersdir="$withval"], [python_headersdir="no"]) - -AC_ARG_WITH([python], [AS_HELP_STRING([--with-python], [build Python language binding [default=no]])], [with_python=yes], [with_python=no]) -if test "x$with_python" != "xno"; then - AM_PATH_PYTHON([2.4], , [:]) - if test "x$PYTHON" = "x:"; then - AC_MSG_ERROR([the --with-python option requires that python be installled.]); - fi - - if test "x$python_headersdir" != "xno"; then - PYTHON_INCLUDES="-I${python_headersdir}" - PYTHON_SETUP_INCLUDES="${python_headersdir}" - - AC_CHECK_HEADERS($python_headersdir/Python.h, [] , - [AC_MSG_ERROR([cannot find a usable Python.h in ${python_headersdir}.])]) - - else - py_prefix=`$PYTHON -c "import sys; print sys.prefix"` - py_exec_prefix=`$PYTHON -c "import sys; print sys.exec_prefix"` - PYTHON_INCLUDES="-I${py_prefix}/include/python${PYTHON_VERSION}" - PYTHON_SETUP_INCLUDES="${py_prefix}/include/python${PYTHON_VERSION}" - - if test "$py_prefix" != "$py_exec_prefix"; then - PYTHON_INCLUDES="${PYTHON_INCLUDES} -I${py_exec_prefix}/include/python${PYTHON_VERSION}" - fi - - AC_CHECK_HEADERS($py_prefix/include/python${PYTHON_VERSION}/Python.h, [] , - [AC_MSG_ERROR([cannot find a usable Python.h in $py_prefix/include/python${PYTHON_VERSION}.])]) - fi - - AC_SUBST(PYTHON_INCLUDES) - AC_SUBST(PYTHON_SETUP_INCLUDES) - - pyzmq="yes" -fi - # RUBY rbzmq="no" AC_ARG_WITH(ruby_headersdir, @@ -394,13 +354,6 @@ fi RUBYDIR="$rubydir" AC_SUBST([RUBYDIR]) - -if test "x$pyzmq" = "xyes"; then - AC_CHECK_PROG(have_python, python, yes, no) - if test "x$have_python" != "xyes"; then - AC_MSG_ERROR([the --with-python option requires that python be installed.]) - fi -fi # Java language binding jzmq="no" @@ -523,11 +476,9 @@ if test "x$with_pgm_ext" != "xno"; then if test "x$have_perl" != "xyes"; then AC_MSG_ERROR([perl is required for building the PGM extension.]) fi - if test "x$pyzmq" != "xyes"; then - AC_CHECK_PROG(have_python, python, yes, no) - if test "x$have_python" != "xyes"; then - AC_MSG_ERROR([python is required for building the PGM extension.]) - fi + AC_CHECK_PROG(have_python, python, yes, no) + if test "x$have_python" != "xyes"; then + AC_MSG_ERROR([python is required for building the PGM extension.]) fi # Unpack libpgm @@ -586,7 +537,7 @@ AC_ARG_WITH([perf], [AS_HELP_STRING([--with-perf], if test "x$with_perf" != "xno"; then perf="yes" - if test "x$czmq" = "xno" -a "x$cppzmq" = "xno" -a "x$pyzmq" = "xno" -a \ + if test "x$czmq" = "xno" -a "x$cppzmq" = "xno" -a \ "x$jzmq" = "xno" -a "x$rbzmq" = "xno"; then AC_MSG_ERROR([the --with-perf option requires at least one language binding.]); fi @@ -596,9 +547,7 @@ if test "x$with_perf" = "xno" -a "x$with_pgm_examples" = "xyes"; then AC_MSG_ERROR([cannot configure --with-pgm-examples without --with-perf.]); fi -AM_CONDITIONAL(BUILD_PYTHON, test "x$pyzmq" = "xyes") AM_CONDITIONAL(BUILD_JAVA, test "x$jzmq" = "xyes") -AM_CONDITIONAL(BUILD_PYTHON, test "x$pyzmq" = "xyes") AM_CONDITIONAL(BUILD_RUBY, test "x$rbzmq" = "xyes") AM_CONDITIONAL(BUILD_C, test "x$czmq" = "xyes") AM_CONDITIONAL(BUILD_CPP, test "x$cppzmq" = "xyes") @@ -625,10 +574,9 @@ AC_SUBST(LIBZMQ_EXTRA_LDFLAGS) AC_TYPE_SIGNAL AC_CHECK_FUNCS(perror gettimeofday memset socket getifaddrs freeifaddrs) -AC_OUTPUT(Makefile src/Makefile doc/Makefile bindings/python/Makefile \ - bindings/python/setup.py bindings/ruby/Makefile \ +AC_OUTPUT(Makefile src/Makefile doc/Makefile bindings/ruby/Makefile \ bindings/java/Makefile perf/Makefile perf/c/Makefile perf/cpp/Makefile \ - perf/python/Makefile perf/ruby/Makefile perf/java/Makefile src/libzmq.pc \ + perf/ruby/Makefile perf/java/Makefile src/libzmq.pc \ devices/Makefile devices/zmq_forwarder/Makefile \ devices/zmq_streamer/Makefile devices/zmq_queue/Makefile bindings/Makefile) @@ -657,7 +605,6 @@ AC_MSG_RESULT([ Language bindings:]) AC_MSG_RESULT([ C: $czmq]) AC_MSG_RESULT([ C++: $cppzmq]) AC_MSG_RESULT([ Java: $jzmq]) -AC_MSG_RESULT([ Python: $pyzmq]) AC_MSG_RESULT([ Ruby: $rbzmq]) if test "x$rbzmq" = "xyes"; then AC_MSG_RESULT([ Ruby library install dir: $rubydir]) diff --git a/doc/Makefile.am b/doc/Makefile.am index a6fce0c..1158243 100644 --- a/doc/Makefile.am +++ b/doc/Makefile.am @@ -5,7 +5,7 @@ MAN3 = zmq_bind.3 zmq_close.3 zmq_connect.3 zmq_flush.3 zmq_init.3 \ zmq_poll.3 zmq_recv.3 zmq_send.3 zmq_setsockopt.3 zmq_socket.3 \ zmq_strerror.3 zmq_term.3 zmq_version.3 MAN7 = zmq.7 zmq_tcp.7 zmq_udp.7 zmq_pgm.7 zmq_inproc.7 zmq_ipc.7 \ - zmq_cpp.7 zmq_java.7 zmq_python.7 + zmq_cpp.7 zmq_java.7 MAN_DOC = $(MAN1) $(MAN3) $(MAN7) MAN_TXT = $(MAN1:%.1=%.txt) diff --git a/doc/zmq.txt b/doc/zmq.txt index 0c911c3..bc2571b 100644 --- a/doc/zmq.txt +++ b/doc/zmq.txt @@ -166,9 +166,6 @@ $$C++$$:: Java:: linkzmq:zmq_java[7] -Python:: - linkzmq:zmq_python[7] - AUTHOR ------ diff --git a/doc/zmq_python.txt b/doc/zmq_python.txt deleted file mode 100644 index 7ad19a3..0000000 --- a/doc/zmq_python.txt +++ /dev/null @@ -1,27 +0,0 @@ -zmq_python(7) -============= - - -NAME ----- -zmq_python - interface between 0MQ and Python applications - - -SYNOPSIS --------- -* - - -DESCRIPTION ------------ -* - - -SEE ALSO --------- -* - - -AUTHOR ------- -Martin Sustrik <sustrik at 250bpm dot com> diff --git a/perf/Makefile.am b/perf/Makefile.am index a3c13ad..96dc19e 100644 --- a/perf/Makefile.am +++ b/perf/Makefile.am @@ -6,10 +6,6 @@ if BUILD_CPP PERF_DIR_CPP = cpp endif -if BUILD_PYTHON -PERF_DIR_P = python -endif - if BUILD_JAVA PERF_DIR_J = java endif @@ -18,6 +14,5 @@ if BUILD_RUBY PERF_DIR_R = ruby endif -SUBDIRS = $(PERF_DIR_C) $(PERF_DIR_CPP) $(PERF_DIR_P) \ - $(PERF_DIR_J) $(PERF_DIR_R) -DIST_SUBDIRS = c cpp python java ruby +SUBDIRS = $(PERF_DIR_C) $(PERF_DIR_CPP) $(PERF_DIR_J) $(PERF_DIR_R) +DIST_SUBDIRS = c cpp java ruby diff --git a/perf/python/Makefile.am b/perf/python/Makefile.am deleted file mode 100644 index c504159..0000000 --- a/perf/python/Makefile.am +++ /dev/null @@ -1 +0,0 @@ -EXTRA_DIST = *.py diff --git a/perf/python/local_lat.py b/perf/python/local_lat.py deleted file mode 100644 index bc1d804..0000000 --- a/perf/python/local_lat.py +++ /dev/null @@ -1,49 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser 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 -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. -# - -import sys -import time -import libpyzmq - -def main (): - if len (sys.argv) != 4: - print 'usage: local_lat <bind-to> <message-size> <roundtrip-count>' - sys.exit (1) - - try: - bind_to = sys.argv [1] - message_size = int (sys.argv [2]) - roundtrip_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and roundtrip-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.REP) - s.bind (bind_to) - - for i in range (0, roundtrip_count): - msg = s.recv () - assert len (msg) == message_size - s.send (msg) - - time.sleep (1) - -if __name__ == "__main__": - main () diff --git a/perf/python/local_thr.py b/perf/python/local_thr.py deleted file mode 100644 index 9a45294..0000000 --- a/perf/python/local_thr.py +++ /dev/null @@ -1,70 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser 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 -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. -# - -import sys -import time -import libpyzmq - -def main (): - if len (sys.argv) != 4: - print 'usage: local_thr <bind-to> <message-size> <message-count>' - sys.exit (1) - - try: - bind_to = sys.argv [1] - message_size = int (sys.argv [2]) - message_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and message-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.SUB) - - s.setsockopt (libpyzmq.SUBSCRIBE , ""); - - # Add your socket options here. - # For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM. - - s.bind (bind_to) - - msg = s.recv () - assert len (msg) == message_size - - start = time.clock () - - for i in range (1, message_count): - msg = s.recv () - assert len (msg) == message_size - - end = time.clock () - - elapsed = (end - start) * 1000000 - if elapsed == 0: - elapsed = 1 - throughput = (1000000.0 * float (message_count)) / float (elapsed) - megabits = float (throughput * message_size * 8) / 1000000 - - print "message size: %.0f [B]" % (message_size, ) - print "message count: %.0f" % (message_count, ) - print "mean throughput: %.0f [msg/s]" % (throughput, ) - print "mean throughput: %.3f [Mb/s]" % (megabits, ) - -if __name__ == "__main__": - main () diff --git a/perf/python/remote_lat.py b/perf/python/remote_lat.py deleted file mode 100644 index 52ab061..0000000 --- a/perf/python/remote_lat.py +++ /dev/null @@ -1,61 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser 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 -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. -# - -import sys -import time -import libpyzmq - -def main (): - if len(sys.argv) != 4: - print 'usage: remote_lat <connect-to> <message-size> <roundtrip-count>' - sys.exit (1) - - try: - connect_to = sys.argv [1] - message_size = int (sys.argv [2]) - roundtrip_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and message-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.REQ) - s.connect (connect_to) - - msg = ''.join ([' ' for n in range (0, message_size)]) - - start = time.clock () - - for i in range (0, roundtrip_count): - s.send (msg) - msg = s.recv () - assert len (msg) == message_size - - end = time.clock () - - elapsed = (end - start) * 1000000 - latency = elapsed / roundtrip_count / 2 - - print "message size: %.0f [B]" % (message_size, ) - print "roundtrip count: %.0f" % (roundtrip_count, ) - print "mean latency: %.3f [us]" % (latency, ) - -if __name__ == "__main__": - main () - diff --git a/perf/python/remote_thr.py b/perf/python/remote_thr.py deleted file mode 100644 index 5fb8a2b..0000000 --- a/perf/python/remote_thr.py +++ /dev/null @@ -1,53 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser 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 -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. -# - -import sys -import libpyzmq -import time - -def main (): - if len (sys.argv) != 4: - print 'usage: remote_thr <connect-to> <message-size> <message-count>' - sys.exit (1) - - try: - connect_to = sys.argv [1] - message_size = int (sys.argv [2]) - message_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and message-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.PUB) - - # Add your socket options here. - # For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM. - - s.connect (connect_to) - - msg = ''.join ([' ' for n in range (0, message_size)]) - - for i in range (0, message_count): - s.send (msg) - - time.sleep (10) - -if __name__ == "__main__": - main () |