|
[-]
[+]
|
Changed |
php5-zmq.changes
|
|
|
|
[-]
[+]
|
Changed |
php5-zmq.spec
^
|
|
|
|
[-]
[+]
|
Deleted |
zmq-1.1.1.tgz/zmq-1.1.1/php-zmq.spec
^
|
| @@ -1,94 +0,0 @@
-# Define version and release number
-%global version 1.1.1
-
-Name: php-zmq
-Version: %{version}
-Release: %{release}%{?dist}
-Summary: PHP 0MQ/zmq/zeromq extension
-# See https://github.com/mkoppanen/php-zmq/pull/58 for discussion
-License: BSD
-Group: Development/Libraries
-URL: http://github.com/mkoppanen/php-zmq
-# Get the source files from https://github.com/mkoppanen/php-zmq/tags
-Source: %{name}-%{version}.tar.gz
-Buildroot: %{_tmppath}/%{name}-%{version}-%{release}-root
-
-BuildRequires: php-devel
-BuildRequires: php-cli
-BuildRequires: zeromq-devel >= 2.0.7
-
-Requires: zeromq >= 2.0.7
-
-%{?filter_setup:
-%filter_from_provides /^zmq.so/d
-%filter_setup
-}
-
-%description
-PHP extension for the 0MQ/zmq/zeromq messaging system
-
-%prep
-%setup -q -n %{name}-%{version}
-
-%build
-/usr/bin/phpize
-%configure
-%{__make} %{?_smp_mflags}
-
-%install
-%{__make} install INSTALL_ROOT=%{buildroot}
-
-# Create the ini location
-%{__mkdir} -p %{buildroot}/%{_sysconfdir}/php.d
-
-# Preliminary extension ini
-echo "extension=zmq.so" > %{buildroot}/%{_sysconfdir}/php.d/zmq.ini
-
-%check
-echo "n" | make test
-
-%clean
-[ "%{buildroot}" != "/" ] && %{__rm} -rf %{buildroot}
-
-%files
-%doc README LICENSE
-%{_libdir}/php/modules/zmq.so
-%config(noreplace) %{_sysconfdir}/php.d/zmq.ini
-
-%changelog
-* Thu Dec 20 2012 Adrian Siminiceanu <adrian.siminiceanu@gmail.com>
- - Fixed the %filter_from_provides and %filter_setup macros error in EPEL5.
- - Use the version define globally in all the places.
- - Fixed the release number match the number of changes the spec file suffered.
- - Fixed the source to work with the archive files from https://github.com/mkoppanen/php-zmq/tags
- - Added back the cleanup section
- - Added back the buildroot since it does not build anymore on a RH system
-* Mon Jul 09 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-5.20120613git516bd6f
- - Fixed the license field back to just "BSD". The files thought to be
- PHP-licensed were in fact generated by "phpize" in the %%build section.
-* Thu Jun 14 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-4.20120613git516bd6f
- - Fixed the private-shared-object-provides for reals with John Ciesla's help.
-* Wed Jun 13 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-3.20120613git516bd6f
- - Updated License to BSD and PHP.
- - Removed spurious gcc BuildRequires.
- - Fixed private-shared-object-provides.
-* Wed Jun 13 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-2.20120613git516bd6f
- - Using tarball of git checkout since the 0.6.0 release won't build anymore.
- - Using valid shortname for BSD license.
- - Added README and LICENSE to the doc
- - Use %%global instead of %%define.
- - Changed 0MQ to 0MQ/zmq/zeromq in Summary and Description to help with
- search.
- - Fully qualified Source URL.
- - Updated to modern BuildRequires.
- - Separated %%build out into %%build and %%install.
- - Removed unnecessary references to buildroot.
- - Removed unnecessary %%defattr.
- - Changed Group from Web/Applications to Development/Libraries.
- - Removed hardcoded Packager tag.
- - Added %%check section.
- - Marked /etc/php.d/zmq.ini as a config file.
-* Wed Jun 15 2011 Rick Moran <moran@morangroup.org>
- - Minor Changes.
-* Thu Apr 8 2010 Mikko Koppanen <mkoppanen@php.net>
- - Initial spec file
|
|
[-]
[+]
|
Deleted |
zmq-1.1.1.tgz/zmq-1.1.1/php_zmq.h
^
|
| @@ -1,50 +0,0 @@
-/*
-+-----------------------------------------------------------------------------------+
-| ZMQ extension for PHP |
-| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
-| All rights reserved. |
-+-----------------------------------------------------------------------------------+
-| Redistribution and use in source and binary forms, with or without |
-| modification, are permitted provided that the following conditions are met: |
-| * Redistributions of source code must retain the above copyright |
-| notice, this list of conditions and the following disclaimer. |
-| * Redistributions in binary form must reproduce the above copyright |
-| notice, this list of conditions and the following disclaimer in the |
-| documentation and/or other materials provided with the distribution. |
-| * Neither the name of the copyright holder nor the |
-| names of its contributors may be used to endorse or promote products |
-| derived from this software without specific prior written permission. |
-+-----------------------------------------------------------------------------------+
-| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
-| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
-| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
-| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
-| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
-| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
-| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
-| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
-| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
-| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
-+-----------------------------------------------------------------------------------+
-*/
-
-#ifndef _PHP_ZMQ_H_
-# define _PHP_ZMQ_H_
-
-#define PHP_ZMQ_EXTNAME "zmq"
-#define PHP_ZMQ_VERSION "1.1.1"
-
-#ifdef HAVE_CONFIG_H
-# include "config.h"
-#endif
-
-#ifdef ZTS
-# include "TSRM.h"
-#endif
-
-#include "php.h"
-
-extern zend_module_entry zmq_module_entry;
-#define phpext_zmq_ptr &zmq_module_entry
-
-#endif /* _PHP_ZMQ_H_ */
|
|
[-]
[+]
|
Deleted |
zmq-1.1.1.tgz/zmq-1.1.1/php_zmq_private.h
^
|
| @@ -1,262 +0,0 @@
-/*
-+-----------------------------------------------------------------------------------+
-| ZMQ extension for PHP |
-| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
-| All rights reserved. |
-+-----------------------------------------------------------------------------------+
-| Redistribution and use in source and binary forms, with or without |
-| modification, are permitted provided that the following conditions are met: |
-| * Redistributions of source code must retain the above copyright |
-| notice, this list of conditions and the following disclaimer. |
-| * Redistributions in binary form must reproduce the above copyright |
-| notice, this list of conditions and the following disclaimer in the |
-| documentation and/or other materials provided with the distribution. |
-| * Neither the name of the copyright holder nor the |
-| names of its contributors may be used to endorse or promote products |
-| derived from this software without specific prior written permission. |
-+-----------------------------------------------------------------------------------+
-| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
-| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
-| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
-| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
-| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
-| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
-| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
-| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
-| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
-| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
-+-----------------------------------------------------------------------------------+
-*/
-
-#ifndef _PHP_ZMQ_PRIVATE_H_
-# define _PHP_ZMQ_PRIVATE_H_
-
-#include "ext/standard/info.h"
-#include "Zend/zend_exceptions.h"
-#include "main/php_ini.h"
-
-#include <zmq.h>
-
-#ifdef PHP_WIN32
-# include "win32/php_stdint.h"
-#else
-# include <stdint.h>
-#endif
-
-/* {{{ typedef struct _php_zmq_pollitem
-*/
-typedef struct _php_zmq_pollitem {
- int events;
- zval *entry;
- char key[35];
- int key_len;
-
- /* convenience pointer containing fd or socket */
- void *socket;
- int fd;
-} php_zmq_pollitem;
-/* }}} */
-
-/* {{{ typedef struct _php_zmq_pollset
-*/
-typedef struct _php_zmq_pollset {
- php_zmq_pollitem *php_items;
- int num_php_items;
-
- /* items and a count */
- zmq_pollitem_t *items;
- int num_items;
-
- /* How many allocated */
- int alloc_size;
-
- /* Errors in the last poll */
- zval *errors;
-} php_zmq_pollset;
-/* }}} */
-
-/* {{{ typedef struct _php_zmq_context
-*/
-typedef struct _php_zmq_context {
- /* zmq context */
- void *z_ctx;
-
- /* Amount of io-threads */
- int io_threads;
-
- /* Is this a persistent context */
- zend_bool is_persistent;
-
- /* Who created me */
- int pid;
-} php_zmq_context;
-/* }}} */
-
-/* {{{ typedef struct _php_zmq_socket
-*/
-typedef struct _php_zmq_socket {
- void *z_socket;
- php_zmq_context *ctx;
-
- HashTable connect;
- HashTable bind;
-
- zend_bool is_persistent;
-
- /* Who created me */
- int pid;
-} php_zmq_socket;
-/* }}} */
-
-/* {{{ typedef struct _php_zmq_context_object
-*/
-typedef struct _php_zmq_context_object {
- zend_object zo;
- php_zmq_context *context;
-} php_zmq_context_object;
-/* }}} */
-
-/* {{{ typedef struct _php_zmq_socket_object
-*/
-typedef struct _php_zmq_socket_object {
- zend_object zo;
- php_zmq_socket *socket;
-
- /* options for the context */
- char *persistent_id;
-
- /* zval of the context */
- zval *context_obj;
-} php_zmq_socket_object;
-/* }}} */
-
-/* {{{ typedef struct _php_zmq_poll_object
-*/
-typedef struct _php_zmq_poll_object {
- zend_object zo;
- php_zmq_pollset set;
-} php_zmq_poll_object;
-/* }}} */
-
-typedef struct _php_zmq_device_cb_t {
- zend_bool initialized;
- long timeout;
- zend_fcall_info fci;
- zend_fcall_info_cache fci_cache;
- zval *user_data;
- uint64_t scheduled_at;
-} php_zmq_device_cb_t;
-
-/* {{{ typedef struct _php_zmq_device_object
-*/
-typedef struct _php_zmq_device_object {
- zend_object zo;
-
- php_zmq_device_cb_t idle_cb;
- php_zmq_device_cb_t timer_cb;
-
- zval *front;
- zval *back;
- zval *capture;
-} php_zmq_device_object;
-/* }}} */
-
-#ifdef ZTS
-# define ZMQ_G(v) TSRMG(php_zmq_globals_id, zend_php_zmq_globals *, v)
-#else
-# define ZMQ_G(v) (php_zmq_globals.v)
-#endif
-
-#define PHP_ZMQ_CONTEXT_OBJECT (php_zmq_context_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
-
-#define PHP_ZMQ_SOCKET_OBJECT (php_zmq_socket_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
-
-#define PHP_ZMQ_POLL_OBJECT (php_zmq_poll_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
-
-#define PHP_ZMQ_DEVICE_OBJECT (php_zmq_device_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
-
-#define ZMQ_RETURN_THIS RETURN_ZVAL(getThis(), 1, 0);
-
-#ifndef Z_ADDREF_P
-# define Z_ADDREF_P(pz) (pz)->refcount++
-#endif
-
-#ifndef Z_DELREF_P
-# define Z_DELREF_P(pz) (pz)->refcount--
-#endif
-
-#ifndef Z_REFCOUNT_P
-# define Z_REFCOUNT_P(pz) (pz)->refcount
-#endif
-
-#if ZEND_MODULE_API_NO > 20060613
-
-#define PHP_ZMQ_ERROR_HANDLING_INIT() zend_error_handling error_handling;
-
-#define PHP_ZMQ_ERROR_HANDLING_THROW() zend_replace_error_handling(EH_THROW, php_zmq_socket_exception_sc_entry, &error_handling TSRMLS_CC);
-
-#define PHP_ZMQ_ERROR_HANDLING_RESTORE() zend_restore_error_handling(&error_handling TSRMLS_CC);
-
-#else
-
-#define PHP_ZMQ_ERROR_HANDLING_INIT()
-
-#define PHP_ZMQ_ERROR_HANDLING_THROW() php_set_error_handling(EH_THROW, php_zmq_socket_exception_sc_entry TSRMLS_CC);
-
-#define PHP_ZMQ_ERROR_HANDLING_RESTORE() php_set_error_handling(EH_NORMAL, NULL TSRMLS_CC);
-
-#endif
-
-/* Compatibility macros between zeromq 2.x and 3.x */
-#ifndef ZMQ_DONTWAIT
-# define ZMQ_DONTWAIT ZMQ_NOBLOCK
-#endif
-#ifndef ZMQ_HWM
-# define ZMQ_HWM (ZMQ_DONTWAIT + 200)
-#endif
-#ifndef ZMQ_FORWARDER
-# define ZMQ_FORWARDER 0
-#endif
-#ifndef ZMQ_QUEUE
-# define ZMQ_QUEUE 0
-#endif
-#ifndef ZMQ_STREAMER
-# define ZMQ_STREAMER 0
-#endif
-#if ZMQ_VERSION_MAJOR == 2
-# define zmq_sendmsg zmq_send
-# define zmq_recvmsg zmq_recv
-# define PHP_ZMQ_TIMEOUT 1000
-#else
-# define PHP_ZMQ_TIMEOUT 1
-#endif
-
-#define PHP_ZMQ_INTERNAL_ERROR -99
-
-#define PHP_ZMQ_VERSION_LEN 24
-
-PHP_METHOD(zmqsocket, getsockopt);
-PHP_METHOD(zmqsocket, setsockopt);
-zend_bool php_zmq_device(php_zmq_device_object *intern TSRMLS_DC);
-
-zend_class_entry *php_zmq_socket_exception_sc_entry_get ();
-zend_class_entry *php_zmq_device_exception_sc_entry_get ();
-
-php_stream *php_zmq_create_zmq_fd(zval *obj TSRMLS_DC);
-
-void php_zmq_register_sockopt_constants (zend_class_entry *ce TSRMLS_DC);
-
-typedef struct _php_zmq_clock_ctx_t php_zmq_clock_ctx_t;
-
-php_zmq_clock_ctx_t *php_zmq_clock_init ();
-
-uint64_t php_zmq_clock (php_zmq_clock_ctx_t *clock_ctx);
-
-void php_zmq_clock_destroy (php_zmq_clock_ctx_t **clock_ctx);
-
-ZEND_BEGIN_MODULE_GLOBALS(php_zmq)
- php_zmq_clock_ctx_t *clock_ctx;
-ZEND_END_MODULE_GLOBALS(php_zmq)
-
-
-#endif /* _PHP_ZMQ_PRIVATE_H_ */
|
|
[-]
[+]
|
Deleted |
zmq-1.1.1.tgz/zmq-1.1.1/tests/036-device.phpt
^
|
| @@ -1,90 +0,0 @@
---TEST--
-Test device callbacks
---SKIPIF--
-<?php
- require_once(dirname(__FILE__) . '/skipif.inc');
-?>
---FILE--
-<?php
-
-function proper_microtime () {
- return round ((microtime (true) * 1000));
-}
-
-class CbStateData
-{
- protected $_counter = 0;
- protected $_name;
-
- public function __construct ($name) {
- $this->name = $name;
- }
-
- public function getName () {
- return $this->name;
- }
-
- public function increment ()
- {
- return ++$this->_counter;
- }
-
- public function getCount () {
- return $this->_counter;
- }
-
- public function reset () {
- $this->_counter = 0;
- }
-}
-
-$ctx = new ZMQContext ();
-$device = new ZMQDevice($ctx->getSocket(ZMQ::SOCKET_SUB), $ctx->getSocket(ZMQ::SOCKET_PUB));
-
-$last_called = proper_microtime ();
-$user_data = new CbStateData ('timer');
-
-// Setup callback and user data for callback
-$device->setTimerCallback (function ($user_data) use (&$last_called, $device) {
- echo "Triggered for {$device->getTimerTimeout ()}ms timeout" . PHP_EOL;
-
- $time_elapsed = (proper_microtime () - $last_called) + 1;
-
- if ($time_elapsed < $device->getTimerTimeout ()) {
- echo "Called too early, only ${time_elapsed}ms elapsed, expected {$device->getTimerTimeout ()}" . PHP_EOL;
- }
-
- $device->setTimerTimeout ($device->getTimerTimeout () + 50);
- $last_called = proper_microtime ();
-
- echo "{$user_data->getName ()} function called {$user_data->increment ()} times\n";
- return $user_data->getCount() < 3 ? true : false;
- },
- 100,
- $user_data);
-
-// Run first time
-$device->run ();
-
-// Run second time
-$user_data->reset ();
-$device->setTimerTimeout (110);
-
-$device->run ();
-
-echo "OK";
-?>
---EXPECT--
-Triggered for 100ms timeout
-timer function called 1 times
-Triggered for 150ms timeout
-timer function called 2 times
-Triggered for 200ms timeout
-timer function called 3 times
-Triggered for 110ms timeout
-timer function called 1 times
-Triggered for 160ms timeout
-timer function called 2 times
-Triggered for 210ms timeout
-timer function called 3 times
-OK
\ No newline at end of file
|
|
[-]
[+]
|
Deleted |
zmq-1.1.1.tgz/zmq-1.1.1/zmq.c
^
|
| @@ -1,2150 +0,0 @@
-/*
-+-----------------------------------------------------------------------------------+
-| ZMQ extension for PHP |
-| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
-| All rights reserved. |
-+-----------------------------------------------------------------------------------+
-| Redistribution and use in source and binary forms, with or without |
-| modification, are permitted provided that the following conditions are met: |
-| * Redistributions of source code must retain the above copyright |
-| notice, this list of conditions and the following disclaimer. |
-| * Redistributions in binary form must reproduce the above copyright |
-| notice, this list of conditions and the following disclaimer in the |
-| documentation and/or other materials provided with the distribution. |
-| * Neither the name of the copyright holder nor the |
-| names of its contributors may be used to endorse or promote products |
-| derived from this software without specific prior written permission. |
-+-----------------------------------------------------------------------------------+
-| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
-| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
-| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
-| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
-| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
-| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
-| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
-| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
-| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
-| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
-+-----------------------------------------------------------------------------------+
-*/
-
-#include "php_zmq.h"
-#include "php_zmq_private.h"
-#include "php_zmq_pollset.h"
-
-ZEND_DECLARE_MODULE_GLOBALS(php_zmq)
-
-zend_class_entry *php_zmq_sc_entry;
-zend_class_entry *php_zmq_context_sc_entry;
-zend_class_entry *php_zmq_socket_sc_entry;
-zend_class_entry *php_zmq_poll_sc_entry;
-zend_class_entry *php_zmq_device_sc_entry;
-
-zend_class_entry *php_zmq_exception_sc_entry;
-zend_class_entry *php_zmq_context_exception_sc_entry;
-zend_class_entry *php_zmq_socket_exception_sc_entry;
-zend_class_entry *php_zmq_poll_exception_sc_entry;
-zend_class_entry *php_zmq_device_exception_sc_entry;
-
-static zend_object_handlers zmq_object_handlers;
-static zend_object_handlers zmq_socket_object_handlers;
-static zend_object_handlers zmq_context_object_handlers;
-static zend_object_handlers zmq_poll_object_handlers;
-static zend_object_handlers zmq_device_object_handlers;
-
-#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
-static const zend_fcall_info empty_fcall_info = { 0, NULL, NULL, NULL, NULL, 0, NULL, NULL, 0 };
-#endif
-
-zend_class_entry *php_zmq_context_exception_sc_entry_get ()
-{
- return php_zmq_context_exception_sc_entry;
-}
-
-zend_class_entry *php_zmq_socket_exception_sc_entry_get ()
-{
- return php_zmq_socket_exception_sc_entry;
-}
-
-zend_class_entry *php_zmq_device_exception_sc_entry_get ()
-{
- return php_zmq_device_exception_sc_entry;
-}
-
-/* list entries */
-static int le_zmq_socket, le_zmq_context;
-
-/** {{{ static void php_zmq_get_lib_version(char buffer[PHP_ZMQ_VERSION_LEN])
-*/
-static void php_zmq_get_lib_version(char buffer[PHP_ZMQ_VERSION_LEN])
-{
- int major = 0, minor = 0, patch = 0;
- zmq_version(&major, &minor, &patch);
- (void) snprintf(buffer, PHP_ZMQ_VERSION_LEN - 1, "%d.%d.%d", major, minor, patch);
-}
-/* }}} */
-
-/** {{{ static int php_zmq_socket_list_entry(void)
-*/
-static int php_zmq_socket_list_entry(void)
-{
- return le_zmq_socket;
-}
-/* }}} */
-
-/* {{{ static int php_zmq_context_list_entry(void)
-*/
-static int php_zmq_context_list_entry(void)
-{
- return le_zmq_context;
-}
-/* }}} */
-
-/* {{{ static void php_zmq_context_destroy(php_zmq_context *context)
- Destroy the context
-*/
-static void php_zmq_context_destroy(php_zmq_context *context)
-{
- if(context->pid == getpid())
- (void) zmq_term(context->z_ctx);
-
- pefree(context, context->is_persistent);
-}
-/* }}} */
-
-/* {{{ static void php_zmq_socket_destroy(php_zmq_socket *zmq_sock)
- Destroy the socket (note: does not touch context)
-*/
-static void php_zmq_socket_destroy(php_zmq_socket *zmq_sock)
-{
- zend_hash_destroy(&(zmq_sock->connect));
- zend_hash_destroy(&(zmq_sock->bind));
-
- if (zmq_sock->pid == getpid ())
- (void) zmq_close(zmq_sock->z_socket);
-
- pefree(zmq_sock, zmq_sock->is_persistent);
-}
-/* }}} */
-
-/* --- START ZMQContext --- */
-
-/* {{{ static php_zmq_context *php_zmq_context_new(long io_threads, zend_bool is_persistent TSRMLS_DC)
- Create a new zmq context
-*/
-static php_zmq_context *php_zmq_context_new(long io_threads, zend_bool is_persistent TSRMLS_DC)
-{
- php_zmq_context *context;
-
- context = pecalloc(1, sizeof(php_zmq_context), is_persistent);
- context->z_ctx = zmq_init(io_threads);
-
- if (!context->z_ctx) {
- pefree(context, is_persistent);
- return NULL;
- }
-
- context->io_threads = io_threads;
- context->is_persistent = is_persistent;
- context->pid = getpid();
- return context;
-}
-/* }}} */
-
-/* {{{ static php_zmq_context *php_zmq_context_get(long io_threads, zend_bool is_persistent TSRMLS_DC)
-*/
-static php_zmq_context *php_zmq_context_get(long io_threads, zend_bool is_persistent TSRMLS_DC)
-{
- php_zmq_context *context;
-
- char plist_key[48];
- int plist_key_len;
- zend_rsrc_list_entry le, *le_p = NULL;
-
- if (is_persistent) {
- plist_key_len = snprintf(plist_key, 48, "zmq_context:[%d]", io_threads);
- plist_key_len += 1;
-
- if (zend_hash_find(&EG(persistent_list), plist_key, plist_key_len, (void *)&le_p) == SUCCESS) {
- if (le_p->type == php_zmq_context_list_entry()) {
- return (php_zmq_context *) le_p->ptr;
- }
- }
- }
-
- context = php_zmq_context_new(io_threads, is_persistent TSRMLS_CC);
-
- if (!context) {
- return NULL;
- }
-
- if (is_persistent) {
- le.type = php_zmq_context_list_entry();
- le.ptr = context;
-
- if (zend_hash_update(&EG(persistent_list), (char *)plist_key, plist_key_len, (void *)&le, sizeof(le), NULL) == FAILURE) {
- php_error_docref(NULL TSRMLS_CC, E_ERROR, "Could not register persistent entry for the context");
- }
- }
- return context;
-}
-/* }}} */
-
-/* {{{ proto ZMQ ZMQ::__construct()
- Private constructor
-*/
-PHP_METHOD(zmq, __construct) {}
-/* }}} */
-
-/* {{{ proto integer ZMQ::clock()
- A monotonic clock
-*/
-PHP_METHOD(zmq, clock)
-{
- if (zend_parse_parameters_none() == FAILURE) {
- return;
- }
- RETURN_LONG((long) php_zmq_clock (ZMQ_G (clock_ctx)));
-}
-/* }}} */
-
-/* {{{ proto ZMQContext ZMQContext::__construct(integer $io_threads[, boolean $is_persistent = true])
- Build a new ZMQContext object
-*/
-PHP_METHOD(zmqcontext, __construct)
-{
- php_zmq_context_object *intern;
- long io_threads = 1;
- zend_bool is_persistent = 1;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|lb", &io_threads, &is_persistent) == FAILURE) {
- return;
- }
- intern = PHP_ZMQ_CONTEXT_OBJECT;
- intern->context = php_zmq_context_get(io_threads, is_persistent TSRMLS_CC);
-
- if (!intern->context) {
- zend_throw_exception_ex(php_zmq_context_exception_sc_entry, errno TSRMLS_CC, "Error creating context: %s", zmq_strerror(errno));
- return;
- }
- return;
-}
-/* }}} */
-
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
-/* {{{ proto ZMQContext ZMQContext::setOpt(int option, int value)
- Set a context option
-*/
-PHP_METHOD(zmqcontext, setOpt)
-{
- php_zmq_context_object *intern;
- long option, value;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ll", &option, &value) == FAILURE) {
- return;
- }
- intern = PHP_ZMQ_CONTEXT_OBJECT;
-
- switch (option) {
- case ZMQ_MAX_SOCKETS:
- {
- if (zmq_ctx_set(intern->context->z_ctx, option, value) != 0) {
- zend_throw_exception_ex(php_zmq_context_exception_sc_entry_get (), errno TSRMLS_CC, "Failed to set the option ZMQ::CTXOPT_MAX_SOCKETS value: %s", zmq_strerror(errno));
- return;
- }
- }
- break;
-
- default:
- {
- zend_throw_exception(php_zmq_context_exception_sc_entry_get (), "Unknown option key", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
- }
- return;
-}
-/* }}} */
-
-/* {{{ proto ZMQContext ZMQContext::getOpt(int option)
- Set a context option
-*/
-PHP_METHOD(zmqcontext, getOpt)
-{
- php_zmq_context_object *intern;
- long option;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &option) == FAILURE) {
- return;
- }
- intern = PHP_ZMQ_CONTEXT_OBJECT;
-
- switch (option) {
-
- case ZMQ_MAX_SOCKETS:
- {
- int value = zmq_ctx_get(intern->context->z_ctx, option);
- RETURN_LONG(value);
- }
- break;
-
- default:
- {
- zend_throw_exception(php_zmq_context_exception_sc_entry_get (), "Unknown option key", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
- }
- return;
-}
-/* }}} */
-#endif
-
-
-/* {{{ static php_zmq_socket *php_zmq_socket_new(php_zmq_context *context, int type, zend_bool is_persistent TSRMLS_DC)
- Create a new zmq socket
-*/
-static php_zmq_socket *php_zmq_socket_new(php_zmq_context *context, int type, zend_bool is_persistent TSRMLS_DC)
-{
- php_zmq_socket *zmq_sock;
-
- zmq_sock = pecalloc(1, sizeof(php_zmq_socket), is_persistent);
- zmq_sock->z_socket = zmq_socket(context->z_ctx, type);
- zmq_sock->pid = getpid();
-
- if (!zmq_sock->z_socket) {
- pefree(zmq_sock, is_persistent);
- return NULL;
- }
-
- zmq_sock->is_persistent = is_persistent;
-
- zend_hash_init(&(zmq_sock->connect), 0, NULL, NULL, is_persistent);
- zend_hash_init(&(zmq_sock->bind), 0, NULL, NULL, is_persistent);
- return zmq_sock;
-}
-/* }}} */
-
-static char *php_zmq_socket_plist_key(int type, const char *persistent_id, int *plist_key_len)
-{
- char *plist_key = NULL;
- *plist_key_len = spprintf(&plist_key, 0, "zmq_socket:[%d]-[%s]", type, persistent_id);
- return plist_key;
-}
-
-static void php_zmq_socket_store(php_zmq_socket *zmq_sock_p, int type, const char *persistent_id TSRMLS_DC)
-{
- zend_rsrc_list_entry le;
-
- char *plist_key = NULL;
- int plist_key_len = 0;
-
- plist_key = php_zmq_socket_plist_key(type, persistent_id, &plist_key_len);
-
- le.type = php_zmq_socket_list_entry();
- le.ptr = zmq_sock_p;
-
- if (zend_hash_update(&EG(persistent_list), plist_key, plist_key_len + 1, (void *)&le, sizeof(le), NULL) == FAILURE) {
- php_error_docref(NULL TSRMLS_CC, E_ERROR, "Could not register persistent entry for the socket");
- }
- efree(plist_key);
-}
-
-/* {{{ static php_zmq_socket *php_zmq_socket_get(php_zmq_context *context, int type, const char *persistent_id, zend_bool *is_new TSRMLS_DC)
- Tries to get context from plist and allocates a new context if context does not exist
-*/
-static php_zmq_socket *php_zmq_socket_get(php_zmq_context *context, int type, const char *persistent_id, zend_bool *is_new TSRMLS_DC)
-{
- php_zmq_socket *zmq_sock_p;
- zend_bool is_persistent;
-
- is_persistent = (context->is_persistent && persistent_id) ? 1 : 0;
- *is_new = 0;
-
- if (is_persistent) {
- char *plist_key = NULL;
- int plist_key_len = 0;
-
- zend_rsrc_list_entry *le = NULL;
-
- plist_key = php_zmq_socket_plist_key(type, persistent_id, &plist_key_len);
-
- if (zend_hash_find(&EG(persistent_list), plist_key, plist_key_len + 1, (void *)&le) == SUCCESS) {
- if (le->type == php_zmq_socket_list_entry()) {
- efree(plist_key);
- return (php_zmq_socket *) le->ptr;
- }
- }
- efree(plist_key);
- }
-
- zmq_sock_p = php_zmq_socket_new(context, type, is_persistent TSRMLS_CC);
-
- if (!zmq_sock_p) {
- return NULL;
- }
-
- *is_new = 1;
- return zmq_sock_p;
-}
-/* }}} */
-
-static zend_bool php_zmq_connect_callback(zval *socket, zend_fcall_info *fci, zend_fcall_info_cache *fci_cache, const char *persistent_id TSRMLS_DC)
-{
- zval *retval_ptr, *pid_z;
- zval **params[2];
- zend_bool retval = 1;
-
- ALLOC_INIT_ZVAL(pid_z);
-
- if (persistent_id) {
- ZVAL_STRING(pid_z, persistent_id, 1);
- } else {
- ZVAL_NULL(pid_z);
- }
-
- /* Call the cb */
- params[0] = &socket;
- params[1] = &pid_z;
-
- fci->params = params;
- fci->param_count = 2;
- fci->retval_ptr_ptr = &retval_ptr;
- fci->no_separation = 1;
-
- if (zend_call_function(fci, fci_cache TSRMLS_CC) == FAILURE) {
- if (!EG(exception)) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, 0 TSRMLS_CC, "Failed to invoke 'on_new_socket' callback %s()", Z_STRVAL_P(fci->function_name));
- }
- retval = 0;
- }
- zval_ptr_dtor(&pid_z);
-
- if (retval_ptr) {
- zval_ptr_dtor(&retval_ptr);
- }
-
- if (EG(exception)) {
- retval = 0;
- }
-
- return retval;
-}
-
-/* {{{ proto ZMQContext ZMQContext::getSocket(integer $type[, string $persistent_id = null[, callback $on_new_socket = null]])
- Build a new ZMQContext object
-*/
-PHP_METHOD(zmqcontext, getsocket)
-{
- php_zmq_socket *socket;
- php_zmq_socket_object *interns;
- php_zmq_context_object *intern;
- long type;
- char *persistent_id = NULL;
- int rc, persistent_id_len;
- zend_bool is_new;
-
- zend_fcall_info fci;
- zend_fcall_info_cache fci_cache;
-
- PHP_ZMQ_ERROR_HANDLING_INIT()
- PHP_ZMQ_ERROR_HANDLING_THROW()
-
- fci.size = 0;
- rc = zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l|s!f!", &type, &persistent_id, &persistent_id_len, &fci, &fci_cache);
-
- PHP_ZMQ_ERROR_HANDLING_RESTORE()
-
- if (rc == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_CONTEXT_OBJECT;
- socket = php_zmq_socket_get(intern->context, type, persistent_id, &is_new TSRMLS_CC);
-
- if (!socket) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Error creating socket: %s", zmq_strerror(errno));
- return;
- }
-
- object_init_ex(return_value, php_zmq_socket_sc_entry);
- interns = (php_zmq_socket_object *)zend_object_store_get_object(return_value TSRMLS_CC);
- interns->socket = socket;
-
- /* Need to add refcount if context is not persistent */
- if (!intern->context->is_persistent) {
- zend_objects_store_add_ref(getThis() TSRMLS_CC);
- interns->context_obj = getThis();
- Z_ADDREF_P(interns->context_obj);
- }
-
- if (is_new) {
- if(fci.size) {
- if (!php_zmq_connect_callback(return_value, &fci, &fci_cache, persistent_id TSRMLS_CC)) {
- php_zmq_socket_destroy(socket);
- interns->socket = NULL;
- zval_dtor(return_value);
- return;
- }
- }
- if (socket->is_persistent) {
- php_zmq_socket_store(socket, type, persistent_id TSRMLS_CC);
- }
- }
- if (socket->is_persistent) {
- interns->persistent_id = estrdup(persistent_id);
- }
- return;
-}
-/* }}} */
-
-/* {{{ proto ZMQContext ZMQContext::isPersistent()
- Whether the context is persistent
-*/
-PHP_METHOD(zmqcontext, ispersistent)
-{
- php_zmq_context_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_CONTEXT_OBJECT;
- RETURN_BOOL(intern->context->is_persistent);
-}
-/* }}} */
-
-/* {{{ proto ZMQContext ZMQContext::__clone()
- Clones the instance of the ZMQContext class
-*/
-PHP_METHOD(zmqcontext, __clone) { }
-/* }}} */
-
-/* --- END ZMQContext --- */
-
-/* --- START ZMQSocket --- */
-
-/* {{{ proto ZMQSocket ZMQSocket::__construct(ZMQContext $context, integer $type[, string $persistent_id = null[, callback $on_new_socket = null]])
- Build a new ZMQSocket object
-*/
-PHP_METHOD(zmqsocket, __construct)
-{
- php_zmq_socket *socket;
- php_zmq_socket_object *intern;
- php_zmq_context_object *internc;
- long type;
- char *persistent_id = NULL;
- int rc, persistent_id_len;
- zval *obj;
- zend_bool is_new;
-
- zend_fcall_info fci;
- zend_fcall_info_cache fci_cache;
-
- PHP_ZMQ_ERROR_HANDLING_INIT()
- PHP_ZMQ_ERROR_HANDLING_THROW()
-
- fci.size = 0;
- rc = zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "Ol|s!f!", &obj, php_zmq_context_sc_entry, &type, &persistent_id, &persistent_id_len, &fci, &fci_cache);
-
- PHP_ZMQ_ERROR_HANDLING_RESTORE()
-
- if (rc == FAILURE) {
- return;
- }
-
- internc = (php_zmq_context_object *) zend_object_store_get_object(obj TSRMLS_CC);
- socket = php_zmq_socket_get(internc->context, type, persistent_id, &is_new TSRMLS_CC);
-
- if (!socket) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Error creating socket: %s", zmq_strerror(errno));
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
- intern->socket = socket;
-
- /* Need to add refcount if context is not persistent */
- if (!internc->context->is_persistent) {
- intern->context_obj = obj;
- zend_objects_store_add_ref(intern->context_obj TSRMLS_CC);
- Z_ADDREF_P(intern->context_obj);
- }
-
- if (is_new) {
- if (fci.size) {
- if (!php_zmq_connect_callback(getThis(), &fci, &fci_cache, persistent_id TSRMLS_CC)) {
- php_zmq_socket_destroy(socket);
- intern->socket = NULL;
- return;
- }
- }
- if (socket->is_persistent) {
- php_zmq_socket_store(socket, type, persistent_id TSRMLS_CC);
- }
- }
- if (socket->is_persistent) {
- intern->persistent_id = estrdup(persistent_id);
- }
-
- return;
-}
-/* }}} */
-
-/* {{{ static zend_bool php_zmq_send(php_zmq_socket_object *intern, char *message_param, int message_param_len, long flags TSRMLS_DC)
-*/
-static zend_bool php_zmq_send(php_zmq_socket_object *intern, char *message_param, int message_param_len, long flags TSRMLS_DC)
-{
- int rc, errno_;
- zmq_msg_t message;
-
- if (zmq_msg_init_size(&message, message_param_len) != 0) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to initialize message structure: %s", zmq_strerror(errno));
- return 0;
- }
- memcpy(zmq_msg_data(&message), message_param, message_param_len);
-
- rc = zmq_sendmsg(intern->socket->z_socket, &message, flags);
- errno_ = errno;
-
- zmq_msg_close(&message);
-
- if (rc == -1) {
- if (errno_ == EAGAIN) {
- return 0;
- }
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno_ TSRMLS_CC, "Failed to send message: %s", zmq_strerror(errno_));
- return 0;
- }
-
- return 1;
-}
-/* }}} */
-
-static void php_zmq_sendmsg_impl(INTERNAL_FUNCTION_PARAMETERS)
-{
- php_zmq_socket_object *intern;
- char *message_param;
- int message_param_len;
- long flags = 0;
- zend_bool ret;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|l", &message_param, &message_param_len, &flags) == FAILURE) {
- return;
- }
- intern = PHP_ZMQ_SOCKET_OBJECT;
- ret = php_zmq_send(intern, message_param, message_param_len, flags TSRMLS_CC);
-
- if (ret) {
- ZMQ_RETURN_THIS;
- } else {
- RETURN_FALSE;
- }
-}
-
-/* {{{ proto ZMQSocket ZMQSocket::send(string $message[, integer $flags = 0])
- Send a message. Return true if message was sent and false on EAGAIN
-*/
-PHP_METHOD(zmqsocket, send)
-{
- php_zmq_sendmsg_impl(INTERNAL_FUNCTION_PARAM_PASSTHRU);
-}
-/* }}} */
-
-#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
-static int php_zmq_send_cb(zval **ppzval, int num_args, va_list args, zend_hash_key *hash_key)
-{
- TSRMLS_FETCH();
-#else
-static int php_zmq_send_cb(zval **ppzval TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
-{
-#endif
- zval tmpcopy;
- php_zmq_socket_object *intern;
- int flags, *rc, *to_send;
-
- intern = va_arg(args, php_zmq_socket_object *);
- flags = va_arg(args, int);
- to_send = va_arg(args, int *);
- rc = va_arg(args, int *);
-
- if (--(*to_send)) {
- flags = flags | ZMQ_SNDMORE;
- } else {
- flags = flags & ~ZMQ_SNDMORE;
- }
-
- tmpcopy = **ppzval;
- zval_copy_ctor(&tmpcopy);
- INIT_PZVAL(&tmpcopy);
-
- if (Z_TYPE(tmpcopy) != IS_STRING) {
- convert_to_string(&tmpcopy);
- }
-
- *rc = php_zmq_send(intern, Z_STRVAL(tmpcopy), Z_STRLEN(tmpcopy), flags TSRMLS_CC);
-
- zval_dtor(&tmpcopy);
-
- if (!*rc) {
- return ZEND_HASH_APPLY_STOP;
- }
- return ZEND_HASH_APPLY_KEEP;
-}
-
-/* {{{ proto ZMQSocket ZMQSocket::sendmulti(arrays $messages[, integer $flags = 0])
- Send a multipart message. Return true if message was sent and false on EAGAIN
-*/
-PHP_METHOD(zmqsocket, sendmulti)
-{
- zval *messages;
- php_zmq_socket_object *intern;
- int to_send, ret = 0;
- long flags = 0;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a|l", &messages, &flags) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
- to_send = zend_hash_num_elements(Z_ARRVAL_P(messages));
-
-#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
- zend_hash_apply_with_arguments(Z_ARRVAL_P(messages), (apply_func_args_t) php_zmq_send_cb, 4, intern, flags, &to_send, &ret);
-#else
- zend_hash_apply_with_arguments(Z_ARRVAL_P(messages) TSRMLS_CC, (apply_func_args_t) php_zmq_send_cb, 4, intern, flags, &to_send, &ret);
-#endif
-
- if (ret) {
- ZMQ_RETURN_THIS;
- } else {
- RETURN_FALSE;
- }
-}
-
-/* {{{ static zend_bool php_zmq_recv(php_zmq_socket_object *intern, long flags, zval *return_value TSRMLS_DC)
-*/
-static zend_bool php_zmq_recv(php_zmq_socket_object *intern, long flags, zval *return_value TSRMLS_DC)
-{
- int rc, errno_;
- zmq_msg_t message;
-
- if (zmq_msg_init(&message) != 0) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to initialize message structure: %s", zmq_strerror(errno));
- return 0;
- }
-
- rc = zmq_recvmsg(intern->socket->z_socket, &message, flags);
- errno_ = errno;
-
- if (rc == -1) {
- zmq_msg_close(&message);
- if (errno == EAGAIN) {
- return 0;
- }
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno_ TSRMLS_CC, "Failed to receive message: %s", zmq_strerror(errno_));
- return 0;
- }
-
- ZVAL_STRINGL(return_value, zmq_msg_data(&message), zmq_msg_size(&message), 1);
- zmq_msg_close(&message);
- return 1;
-}
-/* }}} */
-
-static void php_zmq_recvmsg_impl(INTERNAL_FUNCTION_PARAMETERS)
-{
- php_zmq_socket_object *intern;
- zend_bool retval;
- long flags = 0;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|l", &flags) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
- retval = php_zmq_recv(intern, flags, return_value TSRMLS_CC);
-
- if (retval == 0) {
- RETURN_FALSE;
- }
- return;
-}
-
-/* {{{ proto string ZMQ::recv([integer $flags = 0])
- Receive a message
-*/
-PHP_METHOD(zmqsocket, recv)
-{
- php_zmq_recvmsg_impl(INTERNAL_FUNCTION_PARAM_PASSTHRU);
-}
-/* }}} */
-
-/* {{{ proto array ZMQ::recvmulti([integer $flags = 0])
- Receive an array of message parts
-*/
-PHP_METHOD(zmqsocket, recvmulti)
-{
- php_zmq_socket_object *intern;
- size_t value_len;
- long flags = 0;
- zend_bool retval;
- zval *msg;
-#if ZMQ_VERSION_MAJOR < 3
- int64_t value;
-#else
- int value;
-#endif
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|l", &flags) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
- array_init(return_value);
- value_len = sizeof (value);
-
- do {
- MAKE_STD_ZVAL(msg);
- retval = php_zmq_recv(intern, flags, msg TSRMLS_CC);
- if (retval == 0) {
- FREE_ZVAL(msg);
- zval_dtor(return_value);
- RETURN_FALSE;
- }
- add_next_index_zval(return_value, msg);
- zmq_getsockopt(intern->socket->z_socket, ZMQ_RCVMORE, &value, &value_len);
- } while (value > 0);
-
- return;
-}
-/* }}} */
-
-/** {{{ string ZMQ::getPersistentId()
- Returns the persistent id of the object
-*/
-PHP_METHOD(zmqsocket, getpersistentid)
-{
- php_zmq_socket_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
-
- if (intern->socket->is_persistent && intern->persistent_id) {
- RETURN_STRING(intern->persistent_id, 1);
- }
- RETURN_NULL();
-}
-/* }}} */
-
-/* {{{ proto ZMQSocket ZMQSocket::bind(string $dsn[, boolean $force = false])
- Bind the socket to an endpoint
-*/
-PHP_METHOD(zmqsocket, bind)
-{
- php_zmq_socket_object *intern;
- char *dsn;
- int dsn_len;
- zend_bool force = 0;
- void *dummy = (void *)1;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &dsn, &dsn_len, &force) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
-
- /* already connected ? */
- if (!force && zend_hash_exists(&(intern->socket->bind), dsn, dsn_len + 1)) {
- ZMQ_RETURN_THIS;
- }
-
- if (zmq_bind(intern->socket->z_socket, dsn) != 0) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to bind the ZMQ: %s", zmq_strerror(errno));
- return;
- }
-
- zend_hash_add(&(intern->socket->bind), dsn, dsn_len + 1, (void *)&dummy, sizeof(void *), NULL);
- ZMQ_RETURN_THIS;
-}
-/* }}} */
-
-/* {{{ proto ZMQSocket ZMQSocket::connect(string $dsn[, boolean $force = false])
- Connect the socket to an endpoint
-*/
-PHP_METHOD(zmqsocket, connect)
-{
- php_zmq_socket_object *intern;
- char *dsn;
- int dsn_len;
- zend_bool force = 0;
- void *dummy = (void *)1;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &dsn, &dsn_len, &force) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
-
- /* already connected ? */
- if (!force && zend_hash_exists(&(intern->socket->connect), dsn, dsn_len + 1)) {
- ZMQ_RETURN_THIS;
- }
-
- if (zmq_connect(intern->socket->z_socket, dsn) != 0) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to connect the ZMQ: %s", zmq_strerror(errno));
- return;
- }
-
- (void) zend_hash_add(&(intern->socket->connect), dsn, dsn_len + 1, (void *)&dummy, sizeof(void *), NULL);
- ZMQ_RETURN_THIS;
-}
-/* }}} */
-
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
-/* {{{ proto ZMQSocket ZMQSocket::unbind(string $dsn)
- Unbind the socket from an endpoint
-*/
-PHP_METHOD(zmqsocket, unbind)
-{
- php_zmq_socket_object *intern;
- char *dsn;
- int dsn_len;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &dsn, &dsn_len) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
-
- if (zmq_unbind(intern->socket->z_socket, dsn) != 0) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to unbind the ZMQ socket: %s", zmq_strerror(errno));
- return;
- }
-
- zend_hash_del(&(intern->socket->bind), dsn, dsn_len + 1);
- ZMQ_RETURN_THIS;
-}
-/* }}} */
-
-/* {{{ proto ZMQSocket ZMQSocket::disconnect(string $dsn)
- Disconnect the socket from an endpoint
-*/
-PHP_METHOD(zmqsocket, disconnect)
-{
- php_zmq_socket_object *intern;
- char *dsn;
- int dsn_len;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &dsn, &dsn_len) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
-
- if (zmq_disconnect(intern->socket->z_socket, dsn) != 0) {
- zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to disconnect the ZMQ socket: %s", zmq_strerror(errno));
- return;
- }
-
- zend_hash_del(&(intern->socket->connect), dsn, dsn_len + 1);
- ZMQ_RETURN_THIS;
-}
-/* }}} */
-#endif
-
-#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
-static int php_zmq_get_keys(zval **ppzval, int num_args, va_list args, zend_hash_key *hash_key)
-{
- TSRMLS_FETCH();
-#else
-static int php_zmq_get_keys(zval **ppzval TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
-{
-#endif
- zval *retval;
-
- if (num_args != 1) {
- /* Incorrect args ? */
- return ZEND_HASH_APPLY_KEEP;
- }
-
- retval = va_arg(args, zval *);
-
- if (hash_key->nKeyLength == 0) {
- /* Should not happen */
- return ZEND_HASH_APPLY_REMOVE;
- }
-
- add_next_index_stringl(retval, hash_key->arKey, hash_key->nKeyLength - 1, 1);
- return ZEND_HASH_APPLY_KEEP;
-}
-/* }}} */
-
-/* {{{ proto array ZMQ::getEndpoints()
- Returns endpoints where this socket is connected/bound to. Contains two keys ('bind', 'connect')
-*/
-PHP_METHOD(zmqsocket, getendpoints)
-{
- php_zmq_socket_object *intern;
- zval *connect, *bind;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
- array_init(return_value);
-
- MAKE_STD_ZVAL(connect);
- MAKE_STD_ZVAL(bind);
-
- array_init(connect);
- array_init(bind);
-
-#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
- zend_hash_apply_with_arguments(&(intern->socket->connect), (apply_func_args_t) php_zmq_get_keys, 1, connect);
- zend_hash_apply_with_arguments(&(intern->socket->bind), (apply_func_args_t) php_zmq_get_keys, 1, bind);
-#else
- zend_hash_apply_with_arguments(&(intern->socket->connect) TSRMLS_CC, (apply_func_args_t) php_zmq_get_keys, 1, connect);
- zend_hash_apply_with_arguments(&(intern->socket->bind) TSRMLS_CC, (apply_func_args_t) php_zmq_get_keys, 1, bind);
-#endif
-
- add_assoc_zval(return_value, "connect", connect);
- add_assoc_zval(return_value, "bind", bind);
- return;
-}
-/* }}} */
-
-/* {{{ proto integer ZMQSocket::getSocketType()
- Returns the socket type
-*/
-PHP_METHOD(zmqsocket, getsockettype)
-{
- int type;
- size_t type_siz;
- php_zmq_socket_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
- intern = PHP_ZMQ_SOCKET_OBJECT;
- type_siz = sizeof (int);
-
- if (zmq_getsockopt(intern->socket->z_socket, ZMQ_TYPE, &type, &type_siz) != -1) {
- RETURN_LONG(type);
- }
- RETURN_LONG(-1);
-}
-/* }}} */
-
-/* {{{ proto boolean ZMQSocket::isPersistent()
- Whether the socket is persistent
-*/
-PHP_METHOD(zmqsocket, ispersistent)
-{
- php_zmq_socket_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_SOCKET_OBJECT;
- RETURN_BOOL(intern->socket->is_persistent);
-}
-/* }}} */
-
-/* {{{ proto ZMQSocket ZMQSocket::__clone()
- Clones the instance of the ZMQSocket class
-*/
-PHP_METHOD(zmqsocket, __clone) { }
-/* }}} */
-
-/* -- END ZMQSocket--- */
-
-/* -- START ZMQPoll --- */
-
-/* {{{ proto integer ZMQPoll::add(ZMQSocket $object, integer $events)
- Add a ZMQSocket object into the pollset
-*/
-PHP_METHOD(zmqpoll, add)
-{
- php_zmq_poll_object *intern;
- zval *object;
- long events;
- int pos, key_len = 35;
- char key[35];
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "zl", &object, &events) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_POLL_OBJECT;
-
- switch (Z_TYPE_P(object)) {
- case IS_OBJECT:
- if (!instanceof_function(Z_OBJCE_P(object), php_zmq_socket_sc_entry TSRMLS_CC)) {
- zend_throw_exception(php_zmq_poll_exception_sc_entry, "The first argument must be an instance of ZMQSocket or a resource", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
- break;
-
- case IS_RESOURCE:
- /* noop */
- break;
-
- default:
- zend_throw_exception(php_zmq_poll_exception_sc_entry, "The first argument must be an instance of ZMQSocket or a resource", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- break;
- }
-
- pos = php_zmq_pollset_add(&(intern->set), object, events TSRMLS_CC);
-
- if (pos < 0) {
- const char *message = NULL;
-
- switch (pos) {
- case PHP_ZMQ_POLLSET_ERR_NO_STREAM:
- message = "The supplied resource is not a valid stream resource";
- break;
-
- case PHP_ZMQ_POLLSET_ERR_CANNOT_CAST:
- message = "The supplied resource is not castable";
- break;
-
- case PHP_ZMQ_POLLSET_ERR_CAST_FAILED:
- message = "Failed to cast the supplied stream resource";
- break;
-
- case PHP_ZMQ_POLLSET_ERR_NO_INIT:
- message = "The ZMQSocket object has not been initialized properly";
- break;
-
- case PHP_ZMQ_POLLSET_ERR_NO_POLL:
- message = "The ZMQSocket object has not been initialized with polling";
- break;
-
- default:
- message = "Unknown error";
- break;
- }
-
- zend_throw_exception(php_zmq_poll_exception_sc_entry, message, PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
-
- if (!php_zmq_pollset_get_key(&(intern->set), pos, key, &key_len TSRMLS_CC)) {
- zend_throw_exception(php_zmq_poll_exception_sc_entry, "Failed to get the item key", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
-
- RETURN_STRINGL(key, key_len, 1);
-}
-/* }}} */
-
-/* {{{ proto boolean ZMQPoll::remove(mixed $item)
- Remove item from poll set
-*/
-PHP_METHOD(zmqpoll, remove)
-{
- php_zmq_poll_object *intern;
- zval *item;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &item) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_POLL_OBJECT;
-
- if (intern->set.num_items == 0) {
- zend_throw_exception(php_zmq_poll_exception_sc_entry, "No sockets assigned to the ZMQPoll", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
-
- switch (Z_TYPE_P(item)) {
-
- case IS_OBJECT:
- if (!instanceof_function(Z_OBJCE_P(item), php_zmq_socket_sc_entry TSRMLS_CC)) {
- zend_throw_exception(php_zmq_poll_exception_sc_entry, "The object must be an instanceof ZMQSocket", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
- /* break intentionally missing */
- case IS_RESOURCE:
- RETVAL_BOOL(php_zmq_pollset_delete(&(intern->set), item TSRMLS_CC));
- break;
-
- default:
- convert_to_string(item);
- RETVAL_BOOL(php_zmq_pollset_delete_by_key(&(intern->set), Z_STRVAL_P(item), Z_STRLEN_P(item) TSRMLS_CC));
- break;
- }
-
- return;
-}
-/* }}} */
-
-/* {{{ proto integer ZMQPoll::poll(array &$readable, array &$writable[, integer $timeout = -1])
- Poll the sockets
-*/
-PHP_METHOD(zmqpoll, poll)
-{
- php_zmq_poll_object *intern;
- zval *r_array, *w_array;
-
- long timeout = -1;
- int rc;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a!a!|l", &r_array, &w_array, &timeout) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_POLL_OBJECT;
-
- if (intern->set.num_items == 0) {
- zend_throw_exception(php_zmq_poll_exception_sc_entry, "No sockets assigned to the ZMQPoll", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
- return;
- }
-
- rc = php_zmq_pollset_poll(&(intern->set), timeout * PHP_ZMQ_TIMEOUT, r_array, w_array, intern->set.errors);
-
- if (rc == -1) {
- zend_throw_exception_ex(php_zmq_poll_exception_sc_entry, errno TSRMLS_CC, "Poll failed: %s", zmq_strerror(errno));
- return;
- }
- RETURN_LONG(rc);
-}
-/* }}} */
-
-/* {{{ proto integer ZMQPoll::count()
- Returns the number of items in the set
-*/
-PHP_METHOD(zmqpoll, count)
-{
- php_zmq_poll_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_POLL_OBJECT;
- RETURN_LONG(intern->set.num_items);
-}
-/* }}} */
-
-/* {{{ proto ZMQPoll ZMQPoll::clear()
- Clear the pollset
-*/
-PHP_METHOD(zmqpoll, clear)
-{
- php_zmq_poll_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_POLL_OBJECT;
-
- php_zmq_pollset_delete_all(&(intern->set) TSRMLS_CC);
- ZMQ_RETURN_THIS;
-}
-/* }}} */
-
-/* {{{ proto array ZMQPoll::getLastErrors()
- Returns last errors
-*/
-PHP_METHOD(zmqpoll, getlasterrors)
-{
- php_zmq_poll_object *intern;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_POLL_OBJECT;
-
- Z_ADDREF_P(intern->set.errors);
- RETVAL_ZVAL(intern->set.errors, 1, 0);
- return;
-}
-/* }}} */
-
-/* {{{ proto ZMQPoll ZMQPoll::__clone()
- Clones the instance of the ZMQPoll class
-*/
-PHP_METHOD(zmqpoll, __clone) { }
-/* }}} */
-
-/* -- END ZMQPoll */
-
-/* {{{ proto void ZMQDevice::__construct(ZMQSocket frontend, ZMQSocket backend)
- Construct a device
-*/
-PHP_METHOD(zmqdevice, __construct)
-{
- php_zmq_device_object *intern;
- zval *f, *b, *c = NULL;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "OO|O!", &f, php_zmq_socket_sc_entry, &b, php_zmq_socket_sc_entry, &c, php_zmq_socket_sc_entry) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
-
- intern->front = f;
- intern->back = b;
- if (c) {
- intern->capture = c;
- zend_objects_store_add_ref(c TSRMLS_CC);
- Z_ADDREF_P(c);
- } else
- intern->capture = NULL;
-
- zend_objects_store_add_ref(f TSRMLS_CC);
- Z_ADDREF_P(f);
-
- zend_objects_store_add_ref(b TSRMLS_CC);
- Z_ADDREF_P(b);
-}
-/* }}} */
-
-/* {{{ proto void ZMQDevice::run()
- Start a device
-*/
-PHP_METHOD(zmqdevice, run)
-{
- php_zmq_device_object *intern;
- zend_bool rc;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
- rc = php_zmq_device (intern TSRMLS_CC);
-
- if (!rc && !EG (exception)) {
- zend_throw_exception_ex(php_zmq_device_exception_sc_entry, errno TSRMLS_CC, "Failed to start the device: %s", zmq_strerror (errno));
- return;
- }
- return;
-}
-/* }}} */
-
-static
-void s_clear_device_callback (php_zmq_device_cb_t *cb)
-{
- if (cb->initialized) {
- zval_ptr_dtor(&cb->fci.function_name);
-
- if (cb->user_data) {
- zval_ptr_dtor(&cb->user_data);
- }
- memset (&cb->fci_cache, 0, sizeof (zend_fcall_info_cache));
- memset (cb, 0, sizeof (php_zmq_device_cb_t));
- cb->initialized = 0;
- }
-}
-
-/* {{{ proto void ZMQDevice::setIdleTimeout (int $milliseconds)
- Set the idle timeout value
-*/
-PHP_METHOD(zmqdevice, setidletimeout)
-{
- php_zmq_device_object *intern;
- long timeout;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &timeout) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
- intern->idle_cb.timeout = timeout;
- ZMQ_RETURN_THIS;
-
-}
-/* }}} */
-
-PHP_METHOD(zmqdevice, getidletimeout)
-{
- php_zmq_device_object *intern;
-
- if (zend_parse_parameters_none() == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
- RETURN_LONG(intern->idle_cb.timeout);
-}
-
-
-PHP_METHOD(zmqdevice, settimertimeout)
-{
- php_zmq_device_object *intern;
- long timeout;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &timeout) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
- intern->timer_cb.timeout = timeout;
- ZMQ_RETURN_THIS;
-}
-
-PHP_METHOD(zmqdevice, gettimertimeout)
-{
- php_zmq_device_object *intern;
-
- if (zend_parse_parameters_none() == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
- RETURN_LONG(intern->timer_cb.timeout);
-}
-
-
-static
-void s_init_device_callback (php_zmq_device_cb_t *cb, zend_fcall_info *fci, zend_fcall_info_cache *fci_cache, long timeout, zval *user_data TSRMLS_DC)
-{
- if (user_data) {
- cb->user_data = user_data;
- Z_ADDREF_P(user_data);
- } else {
- MAKE_STD_ZVAL (user_data);
- ZVAL_NULL(user_data);
- Z_ADDREF_P(user_data);
-
- cb->user_data = user_data;
- }
-
- cb->fci = empty_fcall_info;
- cb->fci.size = sizeof (zend_fcall_info);
- cb->fci.function_table = EG (function_table);
- cb->fci.param_count = 0;
-
- MAKE_STD_ZVAL(cb->fci.function_name);
- ZVAL_ZVAL(cb->fci.function_name, fci->function_name, 1, 0);
-
- memset (&(cb->fci_cache), 0, sizeof(zend_fcall_info_cache));
- cb->initialized = 1;
- cb->scheduled_at = php_zmq_clock (ZMQ_G (clock_ctx)) + timeout;
- cb->timeout = timeout;
-}
-
-/* {{{ proto void ZMQDevice::setIdleCallback (callable $function, integer timeout [, mixed $userdata])
- Set the idle timeout value
-*/
-PHP_METHOD(zmqdevice, setidlecallback)
-{
- php_zmq_device_object *intern;
- zval *user_data = NULL;
- zend_fcall_info fci;
- zend_fcall_info_cache fci_cache;
- long timeout = 0;
-
- if (ZEND_NUM_ARGS() == 2) {
- php_error_docref(NULL TSRMLS_CC, E_DEPRECATED, "The signature for setIdleCallback has changed, please update your code");
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "f|z!", &fci, &fci_cache, &user_data) == FAILURE) {
- return;
- }
- }
- else {
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "fl|z!", &fci, &fci_cache, &timeout, &user_data) == FAILURE) {
- return;
- }
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
-
- /* Hack for backwards compatible behaviour */
- if (!timeout) {
- if (intern->idle_cb.timeout) {
- timeout = intern->idle_cb.timeout;
- }
- }
-
- s_clear_device_callback (&intern->idle_cb);
- s_init_device_callback (&intern->idle_cb, &fci, &fci_cache, timeout, user_data TSRMLS_CC);
- ZMQ_RETURN_THIS;
-
-}
-/* }}} */
-
-/* {{{ proto void ZMQDevice::setTimerCallback (callable $function, integer timeout [, mixed $userdata])
- Set the timer function
-*/
-PHP_METHOD(zmqdevice, settimercallback)
-{
- php_zmq_device_object *intern;
- zval *user_data = NULL;
- zend_fcall_info fci;
- zend_fcall_info_cache fci_cache;
- long timeout;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "fl|z!", &fci, &fci_cache, &timeout, &user_data) == FAILURE) {
- return;
- }
-
- intern = PHP_ZMQ_DEVICE_OBJECT;
-
- s_clear_device_callback (&intern->timer_cb);
- s_init_device_callback (&intern->timer_cb, &fci, &fci_cache, timeout, user_data TSRMLS_CC);
- ZMQ_RETURN_THIS;
-}
-/* }}} */
-
-/* {{{ proto ZMQDevice ZMQDevice::__clone()
- Clones the instance of the ZMQDevice class
-*/
-PHP_METHOD(zmqdevice, __clone) { }
-/* }}} */
-
-/* -- END ZMQPoll */
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_construct_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_clock_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-static zend_function_entry php_zmq_class_methods[] = {
- PHP_ME(zmq, __construct, zmq_construct_args, ZEND_ACC_PRIVATE|ZEND_ACC_CTOR)
- PHP_ME(zmq, clock, zmq_clock_args, ZEND_ACC_PUBLIC|ZEND_ACC_STATIC)
- {NULL, NULL, NULL}
-};
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_context_construct_args, 0, 0, 0)
- ZEND_ARG_INFO(0, io_threads)
- ZEND_ARG_INFO(0, persistent)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_context_getsocket_args, 0, 0, 2)
- ZEND_ARG_INFO(0, type)
- ZEND_ARG_INFO(0, dsn)
- ZEND_ARG_INFO(0, on_new_socket)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_context_ispersistent_args, 0, 0, 2)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_context_clone_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
-ZEND_BEGIN_ARG_INFO_EX(zmq_context_setopt_args, 0, 0, 2)
- ZEND_ARG_INFO(0, option)
- ZEND_ARG_INFO(0, value)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_context_getopt_args, 0, 0, 2)
- ZEND_ARG_INFO(0, option)
-ZEND_END_ARG_INFO()
-#endif
-
-static zend_function_entry php_zmq_context_class_methods[] = {
- PHP_ME(zmqcontext, __construct, zmq_context_construct_args, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR|ZEND_ACC_FINAL)
- PHP_ME(zmqcontext, getsocket, zmq_context_getsocket_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqcontext, ispersistent, zmq_context_ispersistent_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqcontext, __clone, zmq_context_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
- PHP_ME(zmqcontext, setOpt, zmq_context_setopt_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqcontext, getOpt, zmq_context_getopt_args, ZEND_ACC_PUBLIC)
-#endif
- {NULL, NULL, NULL}
-};
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_construct_args, 0, 0, 2)
- ZEND_ARG_OBJ_INFO(0, ZMQContext, ZMQContext, 0)
- ZEND_ARG_INFO(0, type)
- ZEND_ARG_INFO(0, persistent_id)
- ZEND_ARG_INFO(0, on_new_socket)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_bind_args, 0, 0, 1)
- ZEND_ARG_INFO(0, dsn)
- ZEND_ARG_INFO(0, force)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_connect_args, 0, 0, 1)
- ZEND_ARG_INFO(0, dsn)
- ZEND_ARG_INFO(0, force)
-ZEND_END_ARG_INFO()
-
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_unbind_args, 0, 0, 1)
- ZEND_ARG_INFO(0, dsn)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_disconnect_args, 0, 0, 1)
- ZEND_ARG_INFO(0, dsn)
-ZEND_END_ARG_INFO()
-#endif
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_setsockopt_args, 0, 0, 2)
- ZEND_ARG_INFO(0, key)
- ZEND_ARG_INFO(0, value)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getendpoints_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getsockettype_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_send_args, 0, 0, 1)
- ZEND_ARG_INFO(0, message)
- ZEND_ARG_INFO(0, mode)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_recv_args, 0, 0, 0)
- ZEND_ARG_INFO(0, mode)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getpersistentid_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getsockopt_args, 0, 0, 1)
- ZEND_ARG_INFO(0, key)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_ispersistent_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_socket_clone_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-static zend_function_entry php_zmq_socket_class_methods[] = {
- PHP_ME(zmqsocket, __construct, zmq_socket_construct_args, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR|ZEND_ACC_FINAL)
- PHP_ME(zmqsocket, send, zmq_socket_send_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, recv, zmq_socket_recv_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, sendmulti, zmq_socket_send_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, recvmulti, zmq_socket_recv_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, bind, zmq_socket_bind_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, connect, zmq_socket_connect_args, ZEND_ACC_PUBLIC)
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
- PHP_ME(zmqsocket, unbind, zmq_socket_unbind_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, disconnect, zmq_socket_disconnect_args, ZEND_ACC_PUBLIC)
-#endif
- PHP_ME(zmqsocket, setsockopt, zmq_socket_setsockopt_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, getendpoints, zmq_socket_getendpoints_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, getsockettype, zmq_socket_getsockettype_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, ispersistent, zmq_socket_ispersistent_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, getpersistentid, zmq_socket_getpersistentid_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, getsockopt, zmq_socket_getsockopt_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqsocket, __clone, zmq_socket_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
- PHP_MALIAS(zmqsocket, sendmsg, send, zmq_socket_send_args, ZEND_ACC_PUBLIC)
- PHP_MALIAS(zmqsocket, recvmsg, recv, zmq_socket_recv_args, ZEND_ACC_PUBLIC)
- {NULL, NULL, NULL}
-};
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_add_args, 0, 0, 2)
- ZEND_ARG_INFO(0, entry)
- ZEND_ARG_INFO(0, type)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_poll_args, 0, 0, 2)
- ZEND_ARG_INFO(1, readable)
- ZEND_ARG_INFO(1, writable)
- ZEND_ARG_INFO(0, timeout)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_getlasterrors_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_remove_args, 0, 0, 2)
- ZEND_ARG_INFO(0, remove)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_count_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_clear_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_poll_clone_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-static zend_function_entry php_zmq_poll_class_methods[] = {
- PHP_ME(zmqpoll, add, zmq_poll_add_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqpoll, poll, zmq_poll_poll_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqpoll, getlasterrors, zmq_poll_getlasterrors_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqpoll, remove, zmq_poll_remove_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqpoll, count, zmq_poll_count_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqpoll, clear, zmq_poll_clear_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqpoll, __clone, zmq_poll_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
- {NULL, NULL, NULL}
-};
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_construct_args, 0, 0, 2)
- ZEND_ARG_OBJ_INFO(0, frontend, ZMQSocket, 0)
- ZEND_ARG_OBJ_INFO(0, backend, ZMQSocket, 0)
- ZEND_ARG_OBJ_INFO(0, capture, ZMQSocket, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_run_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_setidlecallback_args, 0, 0, 2)
- ZEND_ARG_INFO(0, idle_callback)
- ZEND_ARG_INFO(0, timeout)
- ZEND_ARG_INFO(0, user_data)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_settimercallback_args, 0, 0, 2)
- ZEND_ARG_INFO(0, idle_callback)
- ZEND_ARG_INFO(0, timeout)
- ZEND_ARG_INFO(0, user_data)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_setidletimeout_args, 0, 0, 1)
- ZEND_ARG_INFO(0, timeout)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_settimertimeout_args, 0, 0, 1)
- ZEND_ARG_INFO(0, timeout)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_getidletimeout_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_gettimertimeout_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-ZEND_BEGIN_ARG_INFO_EX(zmq_device_clone_args, 0, 0, 0)
-ZEND_END_ARG_INFO()
-
-static zend_function_entry php_zmq_device_class_methods[] = {
- PHP_ME(zmqdevice, __construct, zmq_device_construct_args, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR|ZEND_ACC_FINAL)
- PHP_ME(zmqdevice, run, zmq_device_run_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, setidlecallback, zmq_device_setidlecallback_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, setidletimeout, zmq_device_setidletimeout_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, getidletimeout, zmq_device_getidletimeout_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, settimercallback, zmq_device_settimercallback_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, settimertimeout, zmq_device_settimertimeout_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, gettimertimeout, zmq_device_gettimertimeout_args, ZEND_ACC_PUBLIC)
- PHP_ME(zmqdevice, __clone, zmq_device_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
- {NULL, NULL, NULL}
-};
-
-zend_function_entry zmq_functions[] = {
- {NULL, NULL, NULL}
-};
-
-static void php_zmq_context_object_free_storage(void *object TSRMLS_DC)
-{
- php_zmq_context_object *intern = (php_zmq_context_object *)object;
-
- if (!intern) {
- return;
- }
-
- if (intern->context) {
- if (!intern->context->is_persistent) {
- php_zmq_context_destroy(intern->context);
- }
- }
-
- zend_object_std_dtor(&intern->zo TSRMLS_CC);
- efree(intern);
-}
-
-static void php_zmq_socket_object_free_storage(void *object TSRMLS_DC)
-{
- php_zmq_socket_object *intern = (php_zmq_socket_object *)object;
-
- if (!intern) {
- return;
- }
-
- if (intern->socket) {
- if (intern->socket->is_persistent && intern->persistent_id) {
- efree(intern->persistent_id);
- }
-
- if (!intern->socket->is_persistent) {
- php_zmq_socket_destroy(intern->socket);
- }
- }
-
- if (intern->context_obj) {
- zend_objects_store_del_ref(intern->context_obj TSRMLS_CC);
- Z_DELREF_P(intern->context_obj);
- }
-
- zend_object_std_dtor(&intern->zo TSRMLS_CC);
- efree(intern);
-}
-
-static void php_zmq_poll_object_free_storage(void *object TSRMLS_DC)
-{
- php_zmq_poll_object *intern = (php_zmq_poll_object *)object;
-
- if (!intern) {
- return;
- }
-
- php_zmq_pollset_deinit(&(intern->set) TSRMLS_CC);
- zend_object_std_dtor(&intern->zo TSRMLS_CC);
- efree(intern);
-}
-
-static void php_zmq_device_object_free_storage(void *object TSRMLS_DC)
-{
- php_zmq_device_object *intern = (php_zmq_device_object *)object;
-
- if (!intern) {
- return;
- }
-
- s_clear_device_callback (&intern->idle_cb);
- s_clear_device_callback (&intern->timer_cb);
-
- if (intern->front) {
- zend_objects_store_del_ref(intern->front TSRMLS_CC);
- zval_ptr_dtor (&intern->front);
- }
-
- if (intern->back) {
- zend_objects_store_del_ref(intern->back TSRMLS_CC);
- zval_ptr_dtor (&intern->back);
- }
-
- if (intern->capture) {
- zend_objects_store_del_ref(intern->capture TSRMLS_CC);
- zval_ptr_dtor (&intern->capture);
- }
-
- zend_object_std_dtor(&intern->zo TSRMLS_CC);
- efree(intern);
-}
-
-/* PHP 5.4 */
-#if PHP_VERSION_ID < 50399
-# define object_properties_init(zo, class_type) { \
- zval *tmp; \
- zend_hash_copy((*zo).properties, \
- &class_type->default_properties, \
- (copy_ctor_func_t) zval_add_ref, \
- (void *) &tmp, \
- sizeof(zval *)); \
- }
-#endif
-
-static zend_object_value php_zmq_context_object_new_ex(zend_class_entry *class_type, php_zmq_context_object **ptr TSRMLS_DC)
-{
- zend_object_value retval;
- php_zmq_context_object *intern;
-
- /* Allocate memory for it */
- intern = (php_zmq_context_object *) emalloc(sizeof(php_zmq_context_object));
- memset(&intern->zo, 0, sizeof(zend_object));
-
- /* Context is initialized in the constructor */
- intern->context = NULL;
-
- if (ptr) {
- *ptr = intern;
- }
-
- zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
- object_properties_init(&intern->zo, class_type);
-
- retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_context_object_free_storage, NULL TSRMLS_CC);
- retval.handlers = (zend_object_handlers *) &zmq_context_object_handlers;
- return retval;
-}
-
-static zend_object_value php_zmq_socket_object_new_ex(zend_class_entry *class_type, php_zmq_socket_object **ptr TSRMLS_DC)
-{
- zend_object_value retval;
- php_zmq_socket_object *intern;
-
- /* Allocate memory for it */
- intern = (php_zmq_socket_object *) emalloc(sizeof(php_zmq_socket_object));
- memset(&intern->zo, 0, sizeof(zend_object));
-
- intern->socket = NULL;
- intern->persistent_id = NULL;
- intern->context_obj = NULL;
-
- if (ptr) {
- *ptr = intern;
- }
-
- zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
- object_properties_init(&intern->zo, class_type);
-
- retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_socket_object_free_storage, NULL TSRMLS_CC);
- retval.handlers = (zend_object_handlers *) &zmq_socket_object_handlers;
- return retval;
-}
-
-static zend_object_value php_zmq_poll_object_new_ex(zend_class_entry *class_type, php_zmq_poll_object **ptr TSRMLS_DC)
-{
- zend_object_value retval;
- php_zmq_poll_object *intern;
-
- /* Allocate memory for it */
- intern = (php_zmq_poll_object *) emalloc(sizeof(php_zmq_poll_object));
- memset(&intern->zo, 0, sizeof(zend_object));
-
- php_zmq_pollset_init(&(intern->set));
-
- if (ptr) {
- *ptr = intern;
- }
-
- zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
- object_properties_init(&intern->zo, class_type);
-
- retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_poll_object_free_storage, NULL TSRMLS_CC);
- retval.handlers = (zend_object_handlers *) &zmq_poll_object_handlers;
- return retval;
-}
-
-static zend_object_value php_zmq_device_object_new_ex(zend_class_entry *class_type, php_zmq_device_object **ptr TSRMLS_DC)
-{
- zend_object_value retval;
- php_zmq_device_object *intern;
-
- /* Allocate memory for it */
- intern = (php_zmq_device_object *) emalloc(sizeof(php_zmq_device_object));
- memset(&intern->zo, 0, sizeof(zend_object));
-
- memset (&intern->idle_cb, 0, sizeof (php_zmq_device_cb_t));
- memset (&intern->timer_cb, 0, sizeof (php_zmq_device_cb_t));
-
- intern->front = NULL;
- intern->back = NULL;
- intern->capture = NULL;
-
- if (ptr) {
- *ptr = intern;
- }
-
- zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
- object_properties_init(&intern->zo, class_type);
-
- retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_device_object_free_storage, NULL TSRMLS_CC);
- retval.handlers = (zend_object_handlers *) &zmq_device_object_handlers;
- return retval;
-}
-
-static zend_object_value php_zmq_context_object_new(zend_class_entry *class_type TSRMLS_DC)
-{
- return php_zmq_context_object_new_ex(class_type, NULL TSRMLS_CC);
-}
-
-static zend_object_value php_zmq_socket_object_new(zend_class_entry *class_type TSRMLS_DC)
-{
- return php_zmq_socket_object_new_ex(class_type, NULL TSRMLS_CC);
-}
-
-static zend_object_value php_zmq_poll_object_new(zend_class_entry *class_type TSRMLS_DC)
-{
- return php_zmq_poll_object_new_ex(class_type, NULL TSRMLS_CC);
-}
-
-static zend_object_value php_zmq_device_object_new(zend_class_entry *class_type TSRMLS_DC)
-{
- return php_zmq_device_object_new_ex(class_type, NULL TSRMLS_CC);
-}
-
-ZEND_RSRC_DTOR_FUNC(php_zmq_context_dtor)
-{
- if (rsrc->ptr) {
- php_zmq_context *ctx = (php_zmq_context *)rsrc->ptr;
- php_zmq_context_destroy(ctx);
- rsrc->ptr = NULL;
- }
-}
-
-ZEND_RSRC_DTOR_FUNC(php_zmq_socket_dtor)
-{
- if (rsrc->ptr) {
- php_zmq_socket *zms = (php_zmq_socket *)rsrc->ptr;
- php_zmq_socket_destroy(zms);
- rsrc->ptr = NULL;
- }
-}
-
-static
-void php_zmq_init_globals (zend_php_zmq_globals *zmq_globals)
-{
- zmq_globals->clock_ctx = NULL;
-}
-
-PHP_MINIT_FUNCTION(zmq)
-{
- char version[PHP_ZMQ_VERSION_LEN];
- zend_class_entry ce, ce_context, ce_socket, ce_poll, ce_device;
- zend_class_entry ce_exception, ce_context_exception, ce_socket_exception, ce_poll_exception, ce_device_exception;
-
- le_zmq_context = zend_register_list_destructors_ex(NULL, php_zmq_context_dtor, "ZMQ persistent context", module_number);
- le_zmq_socket = zend_register_list_destructors_ex(NULL, php_zmq_socket_dtor, "ZMQ persistent socket", module_number);
-
- memcpy(&zmq_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
- memcpy(&zmq_context_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
- memcpy(&zmq_socket_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
- memcpy(&zmq_poll_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
- memcpy(&zmq_device_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
-
- INIT_CLASS_ENTRY(ce, "ZMQ", php_zmq_class_methods);
- ce.create_object = NULL;
- zmq_object_handlers.clone_obj = NULL;
- php_zmq_sc_entry = zend_register_internal_class(&ce TSRMLS_CC);
-
- INIT_CLASS_ENTRY(ce_context, "ZMQContext", php_zmq_context_class_methods);
- ce_context.create_object = php_zmq_context_object_new;
- zmq_context_object_handlers.clone_obj = NULL;
- php_zmq_context_sc_entry = zend_register_internal_class(&ce_context TSRMLS_CC);
-
- INIT_CLASS_ENTRY(ce_socket, "ZMQSocket", php_zmq_socket_class_methods);
- ce_socket.create_object = php_zmq_socket_object_new;
- zmq_socket_object_handlers.clone_obj = NULL;
- php_zmq_socket_sc_entry = zend_register_internal_class(&ce_socket TSRMLS_CC);
-
- INIT_CLASS_ENTRY(ce_poll, "ZMQPoll", php_zmq_poll_class_methods);
- ce_poll.create_object = php_zmq_poll_object_new;
- zmq_poll_object_handlers.clone_obj = NULL;
- php_zmq_poll_sc_entry = zend_register_internal_class(&ce_poll TSRMLS_CC);
-
- INIT_CLASS_ENTRY(ce_device, "ZMQDevice", php_zmq_device_class_methods);
- ce_device.create_object = php_zmq_device_object_new;
- zmq_device_object_handlers.clone_obj = NULL;
- php_zmq_device_sc_entry = zend_register_internal_class(&ce_device TSRMLS_CC);
-
- INIT_CLASS_ENTRY(ce_exception, "ZMQException", NULL);
- php_zmq_exception_sc_entry = zend_register_internal_class_ex(&ce_exception, zend_exception_get_default(TSRMLS_C), NULL TSRMLS_CC);
- php_zmq_exception_sc_entry->ce_flags &= ~ZEND_ACC_FINAL_CLASS;
-
- INIT_CLASS_ENTRY(ce_context_exception, "ZMQContextException", NULL);
- php_zmq_context_exception_sc_entry = zend_register_internal_class_ex(&ce_context_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
- php_zmq_context_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
-
- INIT_CLASS_ENTRY(ce_socket_exception, "ZMQSocketException", NULL);
- php_zmq_socket_exception_sc_entry = zend_register_internal_class_ex(&ce_socket_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
- php_zmq_socket_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
-
- INIT_CLASS_ENTRY(ce_poll_exception, "ZMQPollException", NULL);
- php_zmq_poll_exception_sc_entry = zend_register_internal_class_ex(&ce_poll_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
- php_zmq_poll_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
-
- INIT_CLASS_ENTRY(ce_device_exception, "ZMQDeviceException", NULL);
- php_zmq_device_exception_sc_entry = zend_register_internal_class_ex(&ce_device_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
- php_zmq_device_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
-
- ZEND_INIT_MODULE_GLOBALS(php_zmq, php_zmq_init_globals, NULL);
-
- ZMQ_G(clock_ctx) = php_zmq_clock_init ();
-
- if (!ZMQ_G(clock_ctx)) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed to initialise clock");
- return FAILURE;
- }
-
-#define PHP_ZMQ_REGISTER_CONST_LONG(const_name, value) \
- zend_declare_class_constant_long(php_zmq_sc_entry, const_name, sizeof(const_name)-1, (long)value TSRMLS_CC);
-#define PHP_ZMQ_REGISTER_CONST_STRING(const_name, value) \
- zend_declare_class_constant_string (php_zmq_sc_entry, const_name, sizeof(const_name)-1, value TSRMLS_CC);
-
- /* Socket constants */
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PAIR", ZMQ_PAIR);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PUB", ZMQ_PUB);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_SUB", ZMQ_SUB);
-#if ZMQ_VERSION_MAJOR >= 3
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XSUB", ZMQ_XSUB);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XPUB", ZMQ_XPUB);
-#endif
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_REQ", ZMQ_REQ);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_REP", ZMQ_REP);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XREQ", ZMQ_XREQ);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XREP", ZMQ_XREP);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PUSH", ZMQ_PUSH);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PULL", ZMQ_PULL);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_DEALER", ZMQ_DEALER);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_ROUTER", ZMQ_ROUTER);
-#if ZMQ_MAJOR_VERSION >= 4
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_STREAM", ZMQ_STREAM);
-#endif
-
- /* 2.0? */
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_UPSTREAM", ZMQ_PULL);
- PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_DOWNSTREAM", ZMQ_PUSH);
-
-#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
- PHP_ZMQ_REGISTER_CONST_LONG("MODE_SNDLABEL", ZMQ_SNDLABEL);
-#endif
-
- PHP_ZMQ_REGISTER_CONST_LONG("POLL_IN", ZMQ_POLLIN);
- PHP_ZMQ_REGISTER_CONST_LONG("POLL_OUT", ZMQ_POLLOUT);
-
- PHP_ZMQ_REGISTER_CONST_LONG("MODE_SNDMORE", ZMQ_SNDMORE);
- PHP_ZMQ_REGISTER_CONST_LONG("MODE_NOBLOCK", ZMQ_DONTWAIT);
- PHP_ZMQ_REGISTER_CONST_LONG("MODE_DONTWAIT", ZMQ_DONTWAIT);
-
- PHP_ZMQ_REGISTER_CONST_LONG("DEVICE_FORWARDER", ZMQ_FORWARDER);
- PHP_ZMQ_REGISTER_CONST_LONG("DEVICE_QUEUE", ZMQ_QUEUE);
- PHP_ZMQ_REGISTER_CONST_LONG("DEVICE_STREAMER", ZMQ_STREAMER);
-
- PHP_ZMQ_REGISTER_CONST_LONG("ERR_INTERNAL", PHP_ZMQ_INTERNAL_ERROR);
- PHP_ZMQ_REGISTER_CONST_LONG("ERR_EAGAIN", EAGAIN);
- PHP_ZMQ_REGISTER_CONST_LONG("ERR_ENOTSUP", ENOTSUP);
- PHP_ZMQ_REGISTER_CONST_LONG("ERR_EFSM", EFSM);
- PHP_ZMQ_REGISTER_CONST_LONG("ERR_ETERM", ETERM);
-
- php_zmq_get_lib_version(version);
- PHP_ZMQ_REGISTER_CONST_STRING("LIBZMQ_VER", version);
-
- php_zmq_register_sockopt_constants (php_zmq_sc_entry TSRMLS_CC);
-
-#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
- PHP_ZMQ_REGISTER_CONST_LONG("CTXOPT_MAX_SOCKETS", ZMQ_MAX_SOCKETS);
-#endif
-
-#undef PHP_ZMQ_REGISTER_CONST_LONG
-#undef PHP_ZMQ_REGISTER_CONST_STRING
-
- return SUCCESS;
-}
-
-PHP_MSHUTDOWN_FUNCTION(zmq)
-{
- php_zmq_clock_destroy (&ZMQ_G (clock_ctx));
- return SUCCESS;
-}
-
-PHP_MINFO_FUNCTION(zmq)
-{
- char version[PHP_ZMQ_VERSION_LEN];
- php_zmq_get_lib_version(version);
-
- php_info_print_table_start();
-
- php_info_print_table_header(2, "ZMQ extension", "enabled");
- php_info_print_table_row(2, "ZMQ extension version", PHP_ZMQ_VERSION);
- php_info_print_table_row(2, "libzmq version", version);
-
- php_info_print_table_end();
- DISPLAY_INI_ENTRIES();
-}
-
-zend_module_entry zmq_module_entry =
-{
- STANDARD_MODULE_HEADER,
- PHP_ZMQ_EXTNAME,
- zmq_functions, /* Functions */
- PHP_MINIT(zmq), /* MINIT */
- PHP_MSHUTDOWN(zmq), /* MSHUTDOWN */
- NULL, /* RINIT */
- NULL, /* RSHUTDOWN */
- PHP_MINFO(zmq), /* MINFO */
- PHP_ZMQ_VERSION, /* version */
- STANDARD_MODULE_PROPERTIES
-};
-
-#ifdef COMPILE_DL_ZMQ
-ZEND_GET_MODULE(zmq)
-#endif /* COMPILE_DL_ZMQ */
|
|
[-]
[+]
|
Deleted |
zmq-1.1.1.tgz/zmq-1.1.1/zmq_device.c
^
|
| @@ -1,337 +0,0 @@
-/*
-+-----------------------------------------------------------------------------------+
-| ZMQ extension for PHP |
-| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
-| All rights reserved. |
-+-----------------------------------------------------------------------------------+
-| Redistribution and use in source and binary forms, with or without |
-| modification, are permitted provided that the following conditions are met: |
-| * Redistributions of source code must retain the above copyright |
-| notice, this list of conditions and the following disclaimer. |
-| * Redistributions in binary form must reproduce the above copyright |
-| notice, this list of conditions and the following disclaimer in the |
-| documentation and/or other materials provided with the distribution. |
-| * Neither the name of the copyright holder nor the |
-| names of its contributors may be used to endorse or promote products |
-| derived from this software without specific prior written permission. |
-+-----------------------------------------------------------------------------------+
-| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
-| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
-| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
-| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
-| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
-| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
-| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
-| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
-| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
-| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
-+-----------------------------------------------------------------------------------+
-*/
-
-/*
- Based on zeromq 2.1.x devices, which is:
- Copyright (c) 2007-2011 iMatix Corporation
- Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file
-*/
-
-#include "php_zmq.h"
-#include "php_zmq_private.h"
-
-ZEND_EXTERN_MODULE_GLOBALS(php_zmq)
-
-static
-zend_bool s_invoke_device_cb (php_zmq_device_cb_t *cb, uint64_t current_ts TSRMLS_DC)
-{
- zend_bool retval = 0;
- zval **params[1];
- zval *retval_ptr = NULL;
-
- params [0] = &cb->user_data;
- cb->fci.params = params;
- cb->fci.param_count = 1;
-
- /* Call the cb */
- cb->fci.no_separation = 1;
- cb->fci.retval_ptr_ptr = &retval_ptr;
-
- if (zend_call_function(&(cb->fci), &(cb->fci_cache) TSRMLS_CC) == FAILURE) {
- if (!EG(exception)) {
- zend_throw_exception_ex(php_zmq_device_exception_sc_entry_get (), 0 TSRMLS_CC, "Failed to invoke callback %s()", Z_STRVAL_P(cb->fci.function_name));
- }
- }
- if (retval_ptr) {
- convert_to_boolean(retval_ptr);
- if (Z_BVAL_P(retval_ptr)) {
- retval = 1;
- }
- zval_ptr_dtor(&retval_ptr);
- }
- cb->scheduled_at = current_ts + cb->timeout;
- return retval;
-}
-
-static
-int s_capture_message (void *socket, zmq_msg_t *msg, int more)
-{
- int rc;
- zmq_msg_t msg_cp;
- rc = zmq_msg_init (&msg_cp);
- if (rc == -1)
- return -1;
-
- rc = zmq_msg_copy (&msg_cp, msg);
- if (rc == -1) {
- zmq_msg_close (&msg_cp);
- return -1;
- }
-
- return
- zmq_sendmsg (socket, &msg_cp, more ? ZMQ_SNDMORE : 0);
-}
-
-static
-int s_calculate_timeout (php_zmq_device_object *intern TSRMLS_DC)
-{
- int timeout = -1;
- uint64_t current = php_zmq_clock (ZMQ_G (clock_ctx));
-
- /* Do we have timer? */
- if (intern->timer_cb.initialized && intern->timer_cb.timeout) {
- /* This is when we need to launch timer */
- timeout = (int) (intern->timer_cb.scheduled_at - current);
-
- /* If we are tiny bit late, make sure it's asap */
- if (timeout <= 0) {
- return 1 * PHP_ZMQ_TIMEOUT;
- }
- }
-
- /* Do we have idle callback? */
- if (intern->idle_cb.initialized && intern->idle_cb.timeout) {
- /* Do we need to reduce next timing? */
- int idle_timeout = (int) (intern->idle_cb.scheduled_at - current);
-
- /* Might happen if we get scheduled tiny bit late */
- if (idle_timeout <= 0) {
- return 1 * PHP_ZMQ_TIMEOUT;
- }
-
- if (timeout == -1 || idle_timeout < timeout)
- timeout = idle_timeout;
- }
-
- if (timeout > 0)
- timeout *= PHP_ZMQ_TIMEOUT;
-
- return timeout;
-}
-
-
-zend_bool php_zmq_device (php_zmq_device_object *intern TSRMLS_DC)
-{
- int errno_;
- uint64_t last_message_received;
- void *capture_sock;
- php_zmq_socket_object *front, *back;
-
- zmq_msg_t msg;
-#if ZMQ_VERSION_MAJOR >= 3
- int more;
-#else
- int64_t more;
-#endif
-
-#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
- int label;
- size_t labelsz = sizeof(label);
-#endif
-
- size_t moresz;
- zmq_pollitem_t items [2];
-
- int rc = zmq_msg_init (&msg);
-
- if (rc != 0) {
- return 0;
- }
-
- front = (php_zmq_socket_object *)zend_object_store_get_object(intern->front TSRMLS_CC);
- back = (php_zmq_socket_object *)zend_object_store_get_object(intern->back TSRMLS_CC);
-
- items [0].socket = front->socket->z_socket;
- items [0].fd = 0;
- items [0].events = ZMQ_POLLIN;
- items [0].revents = 0;
- items [1].socket = back->socket->z_socket;
- items [1].fd = 0;
- items [1].events = ZMQ_POLLIN;
- items [1].revents = 0;
-
- capture_sock = NULL;
- if (intern->capture) {
- php_zmq_socket_object *capture = (php_zmq_socket_object *)zend_object_store_get_object(intern->capture TSRMLS_CC);
- capture_sock = capture->socket->z_socket;
- }
-
- last_message_received = php_zmq_clock (ZMQ_G (clock_ctx));
-
- while (1) {
- uint64_t current_ts = 0;
-
- /* Calculate poll_timeout based on idle / timer cb */
- int timeout = s_calculate_timeout (intern TSRMLS_CC);
-
- rc = zmq_poll(&items [0], 2, timeout);
- if (rc < 0) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- current_ts = php_zmq_clock (ZMQ_G (clock_ctx));
-
- if (rc > 0)
- last_message_received = current_ts;
-
- /* Do we have a timer callback? */
- if (intern->timer_cb.initialized && intern->timer_cb.timeout > 0) {
- /* Is it timer to call the timer ? */
- if (intern->timer_cb.scheduled_at <= current_ts) {
- if (!s_invoke_device_cb (&intern->timer_cb, current_ts TSRMLS_CC)) {
- zmq_msg_close (&msg);
- return 1;
- }
- }
- }
-
- /* Do we have a idle callback? */
- if (rc == 0 && intern->idle_cb.initialized && intern->idle_cb.timeout > 0) {
- /* Is it timer to call the idle callback ? */
- if ((current_ts - last_message_received) >= intern->idle_cb.timeout &&
- intern->idle_cb.scheduled_at <= current_ts) {
- if (!s_invoke_device_cb (&intern->idle_cb, current_ts TSRMLS_CC)) {
- zmq_msg_close (&msg);
- return 1;
- }
- }
- continue;
- }
-
- if (items [0].revents & ZMQ_POLLIN) {
- while (1) {
-
- rc = zmq_recvmsg(items [0].socket, &msg, 0);
- if (rc == -1) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- moresz = sizeof(more);
- rc = zmq_getsockopt(items [0].socket, ZMQ_RCVMORE, &more, &moresz);
- if (rc < 0) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
-#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
- labelsz = sizeof(label);
-
- rc = zmq_getsockopt(items [0].socket, ZMQ_RCVLABEL, &label, &labelsz);
- if (rc < 0) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- rc = zmq_sendmsg (items [1].socket, &msg, label ? ZMQ_SNDLABEL : (more ? ZMQ_SNDMORE : 0));
- more = more | label;
-#else
- if (capture_sock) {
- rc = s_capture_message (capture_sock, &msg, more);
-
- if (rc == -1) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
- }
- rc = zmq_sendmsg (items [1].socket, &msg, more ? ZMQ_SNDMORE : 0);
-#endif
- if (rc == -1) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- if (!more)
- break;
- }
- }
-
- if (items [1].revents & ZMQ_POLLIN) {
- while (1) {
- rc = zmq_recvmsg(items [1].socket, &msg, 0);
- if (rc == -1) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- moresz = sizeof (more);
- rc = zmq_getsockopt(items [1].socket, ZMQ_RCVMORE, &more, &moresz);
- if (rc < 0) {
- errno_ = errno;
- zmq_msg_close (&msg);
- return errno_;
- }
-
-#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
- labelsz = sizeof(label);
- rc = zmq_getsockopt(items [1].socket, ZMQ_RCVLABEL, &label, &labelsz);
- if (rc < 0) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- rc = zmq_sendmsg (items [0].socket, &msg, label ? ZMQ_SNDLABEL : (more ? ZMQ_SNDMORE : 0));
- more = more | label;
-#else
- if (capture_sock) {
- rc = s_capture_message (capture_sock, &msg, more);
-
- if (rc == -1) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
- }
- rc = zmq_sendmsg (items [0].socket, &msg, more ? ZMQ_SNDMORE : 0);
-#endif
- if (rc == -1) {
- errno_ = errno;
- zmq_msg_close (&msg);
- errno = errno_;
- return 0;
- }
-
- if (!more)
- break;
- }
- }
- }
- zmq_msg_close (&msg);
- return 0;
-}
-
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/package.xml
^
|
| @@ -10,10 +10,10 @@
<email>mkoppanen@php.net</email>
<active>yes</active>
</lead>
- <date>2013-11-02</date>
- <time>09:27:04</time>
+ <date>2013-11-25</date>
+ <time>16:26:11</time>
<version>
- <release>1.1.1</release>
+ <release>1.1.2</release>
<api>1.1.0</api>
</version>
<stability>
@@ -22,7 +22,7 @@
</stability>
<license>BSD License</license>
<notes>
-- Missing zmq_clock.c from the archive
+- Fixes a bug where device callback was invoked too early
</notes>
<contents>
<dir name="/">
@@ -61,7 +61,7 @@
<file md5sum="79fa234351afae4485c1870a79cc1ec3" name="tests/033-disconnect.phpt" role="test" />
<file md5sum="814b44eab7e4a16e62e95c2ac69bb984" name="tests/034-unbind.phpt" role="test" />
<file md5sum="3f89e22339557a6aa644851dd20febab" name="tests/035-capture.phpt" role="test" />
- <file md5sum="776a48485e26f03ec37ed60bf3fc79db" name="tests/036-device.phpt" role="test" />
+ <file md5sum="2b18b653f2dab5f6a6318dfd22aaea84" name="tests/036-device.phpt" role="test" />
<file md5sum="54fa6b043e9205afdb992e6493bee702" name="tests/037-device-deprecated.phpt" role="test" />
<file md5sum="e7e22dbfa9852d7c67a83fdab3ec8e9d" name="tests/bug_gh_43.phpt" role="test" />
<file md5sum="94450fb75836a1eff4a90a2e5c452646" name="tests/bug_gh_49.phpt" role="test" />
@@ -73,16 +73,16 @@
<file md5sum="2b12068874abc496899622ab77099629" name="tests/zeromq_test_helper.inc" role="test" />
<file md5sum="a213189650b100ef3f2c97c63ef42f65" name="config.m4" role="src" />
<file md5sum="f35e7c721d3433cea79c8363b0252308" name="config.w32" role="src" />
- <file md5sum="c6fd66bd9ab9213a3de2c11eedc66cd7" name="php-zmq.spec" role="src">
+ <file md5sum="d90fc4bd682389326413c09a1fdbe28d" name="php-zmq.spec" role="src">
<tasks:replace from="@PACKAGE_VERSION@" to="version" type="package-info" />
</file>
- <file md5sum="c8656f59187488d410aa2a604bc38a99" name="php_zmq.h" role="src">
+ <file md5sum="ee52fad34e256a37ab8c1c4682c21cde" name="php_zmq.h" role="src">
<tasks:replace from="@PACKAGE_VERSION@" to="version" type="package-info" />
</file>
- <file md5sum="9fef9ee9374c74eb2961b4244b921c69" name="php_zmq_private.h" role="src" />
+ <file md5sum="c124040b48b1970610115438efef2e90" name="php_zmq_private.h" role="src" />
<file md5sum="721ad02952ff68b2f0a1eb212858c949" name="php_zmq_pollset.h" role="src" />
- <file md5sum="8c368120a169e3fae3710cc2c405de5a" name="zmq.c" role="src" />
- <file md5sum="16da8c79770c4888fb350a6a295405ab" name="zmq_device.c" role="src" />
+ <file md5sum="8964d047931edd7790c5ee9c5e78e726" name="zmq.c" role="src" />
+ <file md5sum="bc4270a5920b1c76498857a9bd87ecde" name="zmq_device.c" role="src" />
<file md5sum="e14ab58caf6d233c08223448ef9554ce" name="zmq_fd_stream.c" role="src" />
<file md5sum="004daef053ad7ec91b23203fdc5852df" name="zmq_pollset.c" role="src" />
<file md5sum="4c2926f084eb9b9fba335f5c0306b0db" name="zmq_sockopt.c" role="src" />
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/LICENSE
^
|
| (renamed from zmq-1.1.1/LICENSE)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/LICENSE
^
|
| (renamed from zmq-1.1.1/LICENSE)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/README.md
^
|
| (renamed from zmq-1.1.1/README.md)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/README.md
^
|
| (renamed from zmq-1.1.1/README.md)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/config.m4
^
|
| (renamed from zmq-1.1.1/config.m4)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/config.m4
^
|
| (renamed from zmq-1.1.1/config.m4)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/config.w32
^
|
| (renamed from zmq-1.1.1/config.w32)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/config.w32
^
|
| (renamed from zmq-1.1.1/config.w32)
|
|
[-]
[+]
|
Added |
zmq-1.1.2.tgz/zmq-1.1.2/php-zmq.spec
^
|
| @@ -0,0 +1,94 @@
+# Define version and release number
+%global version 1.1.2
+
+Name: php-zmq
+Version: %{version}
+Release: %{release}%{?dist}
+Summary: PHP 0MQ/zmq/zeromq extension
+# See https://github.com/mkoppanen/php-zmq/pull/58 for discussion
+License: BSD
+Group: Development/Libraries
+URL: http://github.com/mkoppanen/php-zmq
+# Get the source files from https://github.com/mkoppanen/php-zmq/tags
+Source: %{name}-%{version}.tar.gz
+Buildroot: %{_tmppath}/%{name}-%{version}-%{release}-root
+
+BuildRequires: php-devel
+BuildRequires: php-cli
+BuildRequires: zeromq-devel >= 2.0.7
+
+Requires: zeromq >= 2.0.7
+
+%{?filter_setup:
+%filter_from_provides /^zmq.so/d
+%filter_setup
+}
+
+%description
+PHP extension for the 0MQ/zmq/zeromq messaging system
+
+%prep
+%setup -q -n %{name}-%{version}
+
+%build
+/usr/bin/phpize
+%configure
+%{__make} %{?_smp_mflags}
+
+%install
+%{__make} install INSTALL_ROOT=%{buildroot}
+
+# Create the ini location
+%{__mkdir} -p %{buildroot}/%{_sysconfdir}/php.d
+
+# Preliminary extension ini
+echo "extension=zmq.so" > %{buildroot}/%{_sysconfdir}/php.d/zmq.ini
+
+%check
+echo "n" | make test
+
+%clean
+[ "%{buildroot}" != "/" ] && %{__rm} -rf %{buildroot}
+
+%files
+%doc README LICENSE
+%{_libdir}/php/modules/zmq.so
+%config(noreplace) %{_sysconfdir}/php.d/zmq.ini
+
+%changelog
+* Thu Dec 20 2012 Adrian Siminiceanu <adrian.siminiceanu@gmail.com>
+ - Fixed the %filter_from_provides and %filter_setup macros error in EPEL5.
+ - Use the version define globally in all the places.
+ - Fixed the release number match the number of changes the spec file suffered.
+ - Fixed the source to work with the archive files from https://github.com/mkoppanen/php-zmq/tags
+ - Added back the cleanup section
+ - Added back the buildroot since it does not build anymore on a RH system
+* Mon Jul 09 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-5.20120613git516bd6f
+ - Fixed the license field back to just "BSD". The files thought to be
+ PHP-licensed were in fact generated by "phpize" in the %%build section.
+* Thu Jun 14 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-4.20120613git516bd6f
+ - Fixed the private-shared-object-provides for reals with John Ciesla's help.
+* Wed Jun 13 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-3.20120613git516bd6f
+ - Updated License to BSD and PHP.
+ - Removed spurious gcc BuildRequires.
+ - Fixed private-shared-object-provides.
+* Wed Jun 13 2012 Ralph Bean <rbean@redhat.com> - 0.6.0-2.20120613git516bd6f
+ - Using tarball of git checkout since the 0.6.0 release won't build anymore.
+ - Using valid shortname for BSD license.
+ - Added README and LICENSE to the doc
+ - Use %%global instead of %%define.
+ - Changed 0MQ to 0MQ/zmq/zeromq in Summary and Description to help with
+ search.
+ - Fully qualified Source URL.
+ - Updated to modern BuildRequires.
+ - Separated %%build out into %%build and %%install.
+ - Removed unnecessary references to buildroot.
+ - Removed unnecessary %%defattr.
+ - Changed Group from Web/Applications to Development/Libraries.
+ - Removed hardcoded Packager tag.
+ - Added %%check section.
+ - Marked /etc/php.d/zmq.ini as a config file.
+* Wed Jun 15 2011 Rick Moran <moran@morangroup.org>
+ - Minor Changes.
+* Thu Apr 8 2010 Mikko Koppanen <mkoppanen@php.net>
+ - Initial spec file
|
|
[-]
[+]
|
Added |
zmq-1.1.2.tgz/zmq-1.1.2/php_zmq.h
^
|
| @@ -0,0 +1,50 @@
+/*
++-----------------------------------------------------------------------------------+
+| ZMQ extension for PHP |
+| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
+| All rights reserved. |
++-----------------------------------------------------------------------------------+
+| Redistribution and use in source and binary forms, with or without |
+| modification, are permitted provided that the following conditions are met: |
+| * Redistributions of source code must retain the above copyright |
+| notice, this list of conditions and the following disclaimer. |
+| * Redistributions in binary form must reproduce the above copyright |
+| notice, this list of conditions and the following disclaimer in the |
+| documentation and/or other materials provided with the distribution. |
+| * Neither the name of the copyright holder nor the |
+| names of its contributors may be used to endorse or promote products |
+| derived from this software without specific prior written permission. |
++-----------------------------------------------------------------------------------+
+| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
+| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
+| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
+| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
+| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
+| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
+| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
+| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
+| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
+| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
++-----------------------------------------------------------------------------------+
+*/
+
+#ifndef _PHP_ZMQ_H_
+# define _PHP_ZMQ_H_
+
+#define PHP_ZMQ_EXTNAME "zmq"
+#define PHP_ZMQ_VERSION "1.1.2"
+
+#ifdef HAVE_CONFIG_H
+# include "config.h"
+#endif
+
+#ifdef ZTS
+# include "TSRM.h"
+#endif
+
+#include "php.h"
+
+extern zend_module_entry zmq_module_entry;
+#define phpext_zmq_ptr &zmq_module_entry
+
+#endif /* _PHP_ZMQ_H_ */
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/php_zmq_pollset.h
^
|
| (renamed from zmq-1.1.1/php_zmq_pollset.h)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/php_zmq_pollset.h
^
|
| (renamed from zmq-1.1.1/php_zmq_pollset.h)
|
|
[-]
[+]
|
Added |
zmq-1.1.2.tgz/zmq-1.1.2/php_zmq_private.h
^
|
| @@ -0,0 +1,264 @@
+/*
++-----------------------------------------------------------------------------------+
+| ZMQ extension for PHP |
+| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
+| All rights reserved. |
++-----------------------------------------------------------------------------------+
+| Redistribution and use in source and binary forms, with or without |
+| modification, are permitted provided that the following conditions are met: |
+| * Redistributions of source code must retain the above copyright |
+| notice, this list of conditions and the following disclaimer. |
+| * Redistributions in binary form must reproduce the above copyright |
+| notice, this list of conditions and the following disclaimer in the |
+| documentation and/or other materials provided with the distribution. |
+| * Neither the name of the copyright holder nor the |
+| names of its contributors may be used to endorse or promote products |
+| derived from this software without specific prior written permission. |
++-----------------------------------------------------------------------------------+
+| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
+| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
+| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
+| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
+| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
+| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
+| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
+| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
+| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
+| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
++-----------------------------------------------------------------------------------+
+*/
+
+#ifndef _PHP_ZMQ_PRIVATE_H_
+# define _PHP_ZMQ_PRIVATE_H_
+
+#include "ext/standard/info.h"
+#include "Zend/zend_exceptions.h"
+#include "main/php_ini.h"
+
+#include <zmq.h>
+
+#ifdef PHP_WIN32
+# include "win32/php_stdint.h"
+#else
+# include <stdint.h>
+#endif
+
+/* {{{ typedef struct _php_zmq_pollitem
+*/
+typedef struct _php_zmq_pollitem {
+ int events;
+ zval *entry;
+ char key[35];
+ int key_len;
+
+ /* convenience pointer containing fd or socket */
+ void *socket;
+ int fd;
+} php_zmq_pollitem;
+/* }}} */
+
+/* {{{ typedef struct _php_zmq_pollset
+*/
+typedef struct _php_zmq_pollset {
+ php_zmq_pollitem *php_items;
+ int num_php_items;
+
+ /* items and a count */
+ zmq_pollitem_t *items;
+ int num_items;
+
+ /* How many allocated */
+ int alloc_size;
+
+ /* Errors in the last poll */
+ zval *errors;
+} php_zmq_pollset;
+/* }}} */
+
+/* {{{ typedef struct _php_zmq_context
+*/
+typedef struct _php_zmq_context {
+ /* zmq context */
+ void *z_ctx;
+
+ /* Amount of io-threads */
+ int io_threads;
+
+ /* Is this a persistent context */
+ zend_bool is_persistent;
+
+ /* Who created me */
+ int pid;
+} php_zmq_context;
+/* }}} */
+
+/* {{{ typedef struct _php_zmq_socket
+*/
+typedef struct _php_zmq_socket {
+ void *z_socket;
+ php_zmq_context *ctx;
+
+ HashTable connect;
+ HashTable bind;
+
+ zend_bool is_persistent;
+
+ /* Who created me */
+ int pid;
+} php_zmq_socket;
+/* }}} */
+
+/* {{{ typedef struct _php_zmq_context_object
+*/
+typedef struct _php_zmq_context_object {
+ zend_object zo;
+ php_zmq_context *context;
+} php_zmq_context_object;
+/* }}} */
+
+/* {{{ typedef struct _php_zmq_socket_object
+*/
+typedef struct _php_zmq_socket_object {
+ zend_object zo;
+ php_zmq_socket *socket;
+
+ /* options for the context */
+ char *persistent_id;
+
+ /* zval of the context */
+ zval *context_obj;
+} php_zmq_socket_object;
+/* }}} */
+
+/* {{{ typedef struct _php_zmq_poll_object
+*/
+typedef struct _php_zmq_poll_object {
+ zend_object zo;
+ php_zmq_pollset set;
+} php_zmq_poll_object;
+/* }}} */
+
+typedef struct _php_zmq_device_cb_t {
+ zend_bool initialized;
+ long timeout;
+ zend_fcall_info fci;
+ zend_fcall_info_cache fci_cache;
+ zval *user_data;
+ uint64_t scheduled_at;
+} php_zmq_device_cb_t;
+
+/* {{{ typedef struct _php_zmq_device_object
+*/
+typedef struct _php_zmq_device_object {
+ zend_object zo;
+
+ php_zmq_device_cb_t idle_cb;
+ php_zmq_device_cb_t timer_cb;
+
+ zval *front;
+ zval *back;
+ zval *capture;
+} php_zmq_device_object;
+/* }}} */
+
+#ifdef ZTS
+# define ZMQ_G(v) TSRMG(php_zmq_globals_id, zend_php_zmq_globals *, v)
+#else
+# define ZMQ_G(v) (php_zmq_globals.v)
+#endif
+
+#define PHP_ZMQ_CONTEXT_OBJECT (php_zmq_context_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
+
+#define PHP_ZMQ_SOCKET_OBJECT (php_zmq_socket_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
+
+#define PHP_ZMQ_POLL_OBJECT (php_zmq_poll_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
+
+#define PHP_ZMQ_DEVICE_OBJECT (php_zmq_device_object *)zend_object_store_get_object(getThis() TSRMLS_CC);
+
+#define ZMQ_RETURN_THIS RETURN_ZVAL(getThis(), 1, 0);
+
+#ifndef Z_ADDREF_P
+# define Z_ADDREF_P(pz) (pz)->refcount++
+#endif
+
+#ifndef Z_DELREF_P
+# define Z_DELREF_P(pz) (pz)->refcount--
+#endif
+
+#ifndef Z_REFCOUNT_P
+# define Z_REFCOUNT_P(pz) (pz)->refcount
+#endif
+
+#if ZEND_MODULE_API_NO > 20060613
+
+#define PHP_ZMQ_ERROR_HANDLING_INIT() zend_error_handling error_handling;
+
+#define PHP_ZMQ_ERROR_HANDLING_THROW() zend_replace_error_handling(EH_THROW, php_zmq_socket_exception_sc_entry, &error_handling TSRMLS_CC);
+
+#define PHP_ZMQ_ERROR_HANDLING_RESTORE() zend_restore_error_handling(&error_handling TSRMLS_CC);
+
+#else
+
+#define PHP_ZMQ_ERROR_HANDLING_INIT()
+
+#define PHP_ZMQ_ERROR_HANDLING_THROW() php_set_error_handling(EH_THROW, php_zmq_socket_exception_sc_entry TSRMLS_CC);
+
+#define PHP_ZMQ_ERROR_HANDLING_RESTORE() php_set_error_handling(EH_NORMAL, NULL TSRMLS_CC);
+
+#endif
+
+/* Compatibility macros between zeromq 2.x and 3.x */
+#ifndef ZMQ_DONTWAIT
+# define ZMQ_DONTWAIT ZMQ_NOBLOCK
+#endif
+#ifndef ZMQ_HWM
+# define ZMQ_HWM (ZMQ_DONTWAIT + 200)
+#endif
+#ifndef ZMQ_FORWARDER
+# define ZMQ_FORWARDER 0
+#endif
+#ifndef ZMQ_QUEUE
+# define ZMQ_QUEUE 0
+#endif
+#ifndef ZMQ_STREAMER
+# define ZMQ_STREAMER 0
+#endif
+#if ZMQ_VERSION_MAJOR == 2
+# define zmq_sendmsg zmq_send
+# define zmq_recvmsg zmq_recv
+# define PHP_ZMQ_TIMEOUT 1000
+#else
+# define PHP_ZMQ_TIMEOUT 1
+#endif
+
+#define PHP_ZMQ_INTERNAL_ERROR -99
+
+#define PHP_ZMQ_VERSION_LEN 24
+
+PHP_METHOD(zmqsocket, getsockopt);
+PHP_METHOD(zmqsocket, setsockopt);
+zend_bool php_zmq_device(php_zmq_device_object *intern TSRMLS_DC);
+
+zend_class_entry *php_zmq_socket_exception_sc_entry_get ();
+zend_class_entry *php_zmq_device_exception_sc_entry_get ();
+
+php_stream *php_zmq_create_zmq_fd(zval *obj TSRMLS_DC);
+
+void php_zmq_register_sockopt_constants (zend_class_entry *ce TSRMLS_DC);
+
+typedef struct _php_zmq_clock_ctx_t php_zmq_clock_ctx_t;
+
+php_zmq_clock_ctx_t *php_zmq_clock_init ();
+
+uint64_t php_zmq_clock (php_zmq_clock_ctx_t *clock_ctx);
+
+void php_zmq_clock_destroy (php_zmq_clock_ctx_t **clock_ctx);
+
+char *php_zmq_printable_func (zend_fcall_info *fci, zend_fcall_info_cache *fci_cache TSRMLS_DC);
+
+ZEND_BEGIN_MODULE_GLOBALS(php_zmq)
+ php_zmq_clock_ctx_t *clock_ctx;
+ZEND_END_MODULE_GLOBALS(php_zmq)
+
+
+#endif /* _PHP_ZMQ_PRIVATE_H_ */
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/001-send.phpt
^
|
| (renamed from zmq-1.1.1/tests/001-send.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/001-send.phpt
^
|
| (renamed from zmq-1.1.1/tests/001-send.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/002-test-binary.phpt
^
|
| (renamed from zmq-1.1.1/tests/002-test-binary.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/002-test-binary.phpt
^
|
| (renamed from zmq-1.1.1/tests/002-test-binary.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/003-getpersistentid.phpt
^
|
| (renamed from zmq-1.1.1/tests/003-getpersistentid.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/003-getpersistentid.phpt
^
|
| (renamed from zmq-1.1.1/tests/003-getpersistentid.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/004-getendpoints.phpt
^
|
| (renamed from zmq-1.1.1/tests/004-getendpoints.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/004-getendpoints.phpt
^
|
| (renamed from zmq-1.1.1/tests/004-getendpoints.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/005-forceconnectarg.phpt
^
|
| (renamed from zmq-1.1.1/tests/005-forceconnectarg.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/005-forceconnectarg.phpt
^
|
| (renamed from zmq-1.1.1/tests/005-forceconnectarg.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/006-sockopt.phpt
^
|
| (renamed from zmq-1.1.1/tests/006-sockopt.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/006-sockopt.phpt
^
|
| (renamed from zmq-1.1.1/tests/006-sockopt.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/007-addremovepoll.phpt
^
|
| (renamed from zmq-1.1.1/tests/007-addremovepoll.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/007-addremovepoll.phpt
^
|
| (renamed from zmq-1.1.1/tests/007-addremovepoll.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/008-twowaystoconstruct.phpt
^
|
| (renamed from zmq-1.1.1/tests/008-twowaystoconstruct.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/008-twowaystoconstruct.phpt
^
|
| (renamed from zmq-1.1.1/tests/008-twowaystoconstruct.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/009-ispersistent.phpt
^
|
| (renamed from zmq-1.1.1/tests/009-ispersistent.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/009-ispersistent.phpt
^
|
| (renamed from zmq-1.1.1/tests/009-ispersistent.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/010-pollsetinvalidargs.phpt
^
|
| (renamed from zmq-1.1.1/tests/010-pollsetinvalidargs.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/010-pollsetinvalidargs.phpt
^
|
| (renamed from zmq-1.1.1/tests/010-pollsetinvalidargs.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/011-exceptions.phpt
^
|
| (renamed from zmq-1.1.1/tests/011-exceptions.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/011-exceptions.phpt
^
|
| (renamed from zmq-1.1.1/tests/011-exceptions.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/012-pollsetremoveinvalid.phpt
^
|
| (renamed from zmq-1.1.1/tests/012-pollsetremoveinvalid.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/012-pollsetremoveinvalid.phpt
^
|
| (renamed from zmq-1.1.1/tests/012-pollsetremoveinvalid.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/013-pollclearandreuse.phpt
^
|
| (renamed from zmq-1.1.1/tests/013-pollclearandreuse.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/013-pollclearandreuse.phpt
^
|
| (renamed from zmq-1.1.1/tests/013-pollclearandreuse.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/014-setsockoptparam.phpt
^
|
| (renamed from zmq-1.1.1/tests/014-setsockoptparam.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/014-setsockoptparam.phpt
^
|
| (renamed from zmq-1.1.1/tests/014-setsockoptparam.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/015-callback.phpt
^
|
| (renamed from zmq-1.1.1/tests/015-callback.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/015-callback.phpt
^
|
| (renamed from zmq-1.1.1/tests/015-callback.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/016-callbackinvalidargs.phpt
^
|
| (renamed from zmq-1.1.1/tests/016-callbackinvalidargs.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/016-callbackinvalidargs.phpt
^
|
| (renamed from zmq-1.1.1/tests/016-callbackinvalidargs.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/017-callbackonlyonnewsocket.phpt
^
|
| (renamed from zmq-1.1.1/tests/017-callbackonlyonnewsocket.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/017-callbackonlyonnewsocket.phpt
^
|
| (renamed from zmq-1.1.1/tests/017-callbackonlyonnewsocket.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/018-callbackpersistent.phpt
^
|
| (renamed from zmq-1.1.1/tests/018-callbackpersistent.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/018-callbackpersistent.phpt
^
|
| (renamed from zmq-1.1.1/tests/018-callbackpersistent.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/019-callbackinvalidsignature.phpt
^
|
| (renamed from zmq-1.1.1/tests/019-callbackinvalidsignature.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/019-callbackinvalidsignature.phpt
^
|
| (renamed from zmq-1.1.1/tests/019-callbackinvalidsignature.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/020-exceptionincallback.phpt
^
|
| (renamed from zmq-1.1.1/tests/020-exceptionincallback.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/020-exceptionincallback.phpt
^
|
| (renamed from zmq-1.1.1/tests/020-exceptionincallback.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/021-callbackwarning.phpt
^
|
| (renamed from zmq-1.1.1/tests/021-callbackwarning.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/021-callbackwarning.phpt
^
|
| (renamed from zmq-1.1.1/tests/021-callbackwarning.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/022-highwatermark.phpt
^
|
| (renamed from zmq-1.1.1/tests/022-highwatermark.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/022-highwatermark.phpt
^
|
| (renamed from zmq-1.1.1/tests/022-highwatermark.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/023-failedcallback.phpt
^
|
| (renamed from zmq-1.1.1/tests/023-failedcallback.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/023-failedcallback.phpt
^
|
| (renamed from zmq-1.1.1/tests/023-failedcallback.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/024-versionconstant.phpt
^
|
| (renamed from zmq-1.1.1/tests/024-versionconstant.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/024-versionconstant.phpt
^
|
| (renamed from zmq-1.1.1/tests/024-versionconstant.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/025-sendrecvmulti.phpt
^
|
| (renamed from zmq-1.1.1/tests/025-sendrecvmulti.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/025-sendrecvmulti.phpt
^
|
| (renamed from zmq-1.1.1/tests/025-sendrecvmulti.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/026-sockettype.phpt
^
|
| (renamed from zmq-1.1.1/tests/026-sockettype.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/026-sockettype.phpt
^
|
| (renamed from zmq-1.1.1/tests/026-sockettype.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/027-getset.phpt
^
|
| (renamed from zmq-1.1.1/tests/027-getset.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/027-getset.phpt
^
|
| (renamed from zmq-1.1.1/tests/027-getset.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/028-xpub.phpt
^
|
| (renamed from zmq-1.1.1/tests/028-xpub.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/028-xpub.phpt
^
|
| (renamed from zmq-1.1.1/tests/028-xpub.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/029-xrepxreqdevice.phpt
^
|
| (renamed from zmq-1.1.1/tests/029-xrepxreqdevice.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/029-xrepxreqdevice.phpt
^
|
| (renamed from zmq-1.1.1/tests/029-xrepxreqdevice.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/030-xrepmanualqueue.phpt
^
|
| (renamed from zmq-1.1.1/tests/030-xrepmanualqueue.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/030-xrepmanualqueue.phpt
^
|
| (renamed from zmq-1.1.1/tests/030-xrepmanualqueue.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/031-lastendpoint.phpt
^
|
| (renamed from zmq-1.1.1/tests/031-lastendpoint.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/031-lastendpoint.phpt
^
|
| (renamed from zmq-1.1.1/tests/031-lastendpoint.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/032-contextopt.phpt
^
|
| (renamed from zmq-1.1.1/tests/032-contextopt.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/032-contextopt.phpt
^
|
| (renamed from zmq-1.1.1/tests/032-contextopt.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/033-disconnect.phpt
^
|
| (renamed from zmq-1.1.1/tests/033-disconnect.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/033-disconnect.phpt
^
|
| (renamed from zmq-1.1.1/tests/033-disconnect.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/034-unbind.phpt
^
|
| (renamed from zmq-1.1.1/tests/034-unbind.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/034-unbind.phpt
^
|
| (renamed from zmq-1.1.1/tests/034-unbind.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/035-capture.phpt
^
|
| (renamed from zmq-1.1.1/tests/035-capture.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/035-capture.phpt
^
|
| (renamed from zmq-1.1.1/tests/035-capture.phpt)
|
|
[-]
[+]
|
Added |
zmq-1.1.2.tgz/zmq-1.1.2/tests/036-device.phpt
^
|
| @@ -0,0 +1,103 @@
+--TEST--
+Test device callbacks
+--SKIPIF--
+<?php
+ require_once(dirname(__FILE__) . '/skipif.inc');
+?>
+--FILE--
+<?php
+
+function proper_microtime () {
+ return round ((microtime (true) * 1000));
+}
+
+class CbStateData
+{
+ protected $_counter = 0;
+ protected $_name;
+
+ public function __construct ($name) {
+ $this->name = $name;
+ }
+
+ public function getName () {
+ return $this->name;
+ }
+
+ public function increment ()
+ {
+ return ++$this->_counter;
+ }
+
+ public function getCount () {
+ return $this->_counter;
+ }
+
+ public function reset () {
+ $this->_counter = 0;
+ }
+}
+
+class test {
+ function foo ($user_data) {
+ return false;
+ }
+}
+
+$test = new test ();
+
+$ctx = new ZMQContext ();
+$device = new ZMQDevice($ctx->getSocket(ZMQ::SOCKET_SUB), $ctx->getSocket(ZMQ::SOCKET_PUB));
+
+$last_called = proper_microtime ();
+$user_data = new CbStateData ('timer');
+
+$orig_cb = function ($user_data) use (&$last_called, $device) {
+ echo "Triggered for {$device->getTimerTimeout ()}ms timeout" . PHP_EOL;
+
+ $time_elapsed = (proper_microtime () - $last_called) + 1;
+
+ if ($time_elapsed < $device->getTimerTimeout ()) {
+ echo "Called too early, only ${time_elapsed}ms elapsed, expected {$device->getTimerTimeout ()}" . PHP_EOL;
+ }
+
+ $device->setTimerTimeout ($device->getTimerTimeout () + 50);
+ $last_called = proper_microtime ();
+
+ echo "{$user_data->getName ()} function called {$user_data->increment ()} times\n";
+ return $user_data->getCount() < 3 ? true : false;
+ };
+
+// Setup callback and user data for callback
+$device->setTimerCallback ($orig_cb, 100, $user_data);
+
+// Run first time
+$device->run ();
+
+$device->setTimerCallback (array ($test, 'foo'), 100, $user_data);
+$device->setTimerCallback (array ($test, 'foo'), 100, $user_data);
+$device->setTimerCallback ($orig_cb, 100, $user_data);
+sleep (1);
+
+// Run second time
+$user_data->reset ();
+$device->setTimerTimeout (110);
+
+$device->run ();
+
+echo "OK";
+?>
+--EXPECT--
+Triggered for 100ms timeout
+timer function called 1 times
+Triggered for 150ms timeout
+timer function called 2 times
+Triggered for 200ms timeout
+timer function called 3 times
+Triggered for 110ms timeout
+timer function called 1 times
+Triggered for 160ms timeout
+timer function called 2 times
+Triggered for 210ms timeout
+timer function called 3 times
+OK
\ No newline at end of file
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/037-device-deprecated.phpt
^
|
| (renamed from zmq-1.1.1/tests/037-device-deprecated.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/037-device-deprecated.phpt
^
|
| (renamed from zmq-1.1.1/tests/037-device-deprecated.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_43.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_43.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_43.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_43.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_49.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_49.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_49.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_49.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_50.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_50.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_50.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_50.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_59.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_59.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_59.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_59.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_59_2.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_59_2.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/bug_gh_59_2.phpt
^
|
| (renamed from zmq-1.1.1/tests/bug_gh_59_2.phpt)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/rose.jpg
^
|
| (renamed from zmq-1.1.1/tests/rose.jpg)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/rose.jpg
^
|
| (renamed from zmq-1.1.1/tests/rose.jpg)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/skipif.inc
^
|
| (renamed from zmq-1.1.1/tests/skipif.inc)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/skipif.inc
^
|
| (renamed from zmq-1.1.1/tests/skipif.inc)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/zeromq_test_helper.inc
^
|
| (renamed from zmq-1.1.1/tests/zeromq_test_helper.inc)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/tests/zeromq_test_helper.inc
^
|
| (renamed from zmq-1.1.1/tests/zeromq_test_helper.inc)
|
|
[-]
[+]
|
Added |
zmq-1.1.2.tgz/zmq-1.1.2/zmq.c
^
|
| @@ -0,0 +1,2175 @@
+/*
++-----------------------------------------------------------------------------------+
+| ZMQ extension for PHP |
+| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
+| All rights reserved. |
++-----------------------------------------------------------------------------------+
+| Redistribution and use in source and binary forms, with or without |
+| modification, are permitted provided that the following conditions are met: |
+| * Redistributions of source code must retain the above copyright |
+| notice, this list of conditions and the following disclaimer. |
+| * Redistributions in binary form must reproduce the above copyright |
+| notice, this list of conditions and the following disclaimer in the |
+| documentation and/or other materials provided with the distribution. |
+| * Neither the name of the copyright holder nor the |
+| names of its contributors may be used to endorse or promote products |
+| derived from this software without specific prior written permission. |
++-----------------------------------------------------------------------------------+
+| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
+| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
+| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
+| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
+| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
+| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
+| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
+| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
+| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
+| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
++-----------------------------------------------------------------------------------+
+*/
+
+#include "php_zmq.h"
+#include "php_zmq_private.h"
+#include "php_zmq_pollset.h"
+
+ZEND_DECLARE_MODULE_GLOBALS(php_zmq)
+
+zend_class_entry *php_zmq_sc_entry;
+zend_class_entry *php_zmq_context_sc_entry;
+zend_class_entry *php_zmq_socket_sc_entry;
+zend_class_entry *php_zmq_poll_sc_entry;
+zend_class_entry *php_zmq_device_sc_entry;
+
+zend_class_entry *php_zmq_exception_sc_entry;
+zend_class_entry *php_zmq_context_exception_sc_entry;
+zend_class_entry *php_zmq_socket_exception_sc_entry;
+zend_class_entry *php_zmq_poll_exception_sc_entry;
+zend_class_entry *php_zmq_device_exception_sc_entry;
+
+static zend_object_handlers zmq_object_handlers;
+static zend_object_handlers zmq_socket_object_handlers;
+static zend_object_handlers zmq_context_object_handlers;
+static zend_object_handlers zmq_poll_object_handlers;
+static zend_object_handlers zmq_device_object_handlers;
+
+#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
+static const zend_fcall_info empty_fcall_info = { 0, NULL, NULL, NULL, NULL, 0, NULL, NULL, 0 };
+#endif
+
+zend_class_entry *php_zmq_context_exception_sc_entry_get ()
+{
+ return php_zmq_context_exception_sc_entry;
+}
+
+zend_class_entry *php_zmq_socket_exception_sc_entry_get ()
+{
+ return php_zmq_socket_exception_sc_entry;
+}
+
+zend_class_entry *php_zmq_device_exception_sc_entry_get ()
+{
+ return php_zmq_device_exception_sc_entry;
+}
+
+/* list entries */
+static int le_zmq_socket, le_zmq_context;
+
+/** {{{ static void php_zmq_get_lib_version(char buffer[PHP_ZMQ_VERSION_LEN])
+*/
+static void php_zmq_get_lib_version(char buffer[PHP_ZMQ_VERSION_LEN])
+{
+ int major = 0, minor = 0, patch = 0;
+ zmq_version(&major, &minor, &patch);
+ (void) snprintf(buffer, PHP_ZMQ_VERSION_LEN - 1, "%d.%d.%d", major, minor, patch);
+}
+/* }}} */
+
+/** {{{ static int php_zmq_socket_list_entry(void)
+*/
+static int php_zmq_socket_list_entry(void)
+{
+ return le_zmq_socket;
+}
+/* }}} */
+
+/* {{{ static int php_zmq_context_list_entry(void)
+*/
+static int php_zmq_context_list_entry(void)
+{
+ return le_zmq_context;
+}
+/* }}} */
+
+/* {{{ static void php_zmq_context_destroy(php_zmq_context *context)
+ Destroy the context
+*/
+static void php_zmq_context_destroy(php_zmq_context *context)
+{
+ if(context->pid == getpid())
+ (void) zmq_term(context->z_ctx);
+
+ pefree(context, context->is_persistent);
+}
+/* }}} */
+
+/* {{{ static void php_zmq_socket_destroy(php_zmq_socket *zmq_sock)
+ Destroy the socket (note: does not touch context)
+*/
+static void php_zmq_socket_destroy(php_zmq_socket *zmq_sock)
+{
+ zend_hash_destroy(&(zmq_sock->connect));
+ zend_hash_destroy(&(zmq_sock->bind));
+
+ if (zmq_sock->pid == getpid ())
+ (void) zmq_close(zmq_sock->z_socket);
+
+ pefree(zmq_sock, zmq_sock->is_persistent);
+}
+/* }}} */
+
+/* --- START ZMQContext --- */
+
+/* {{{ static php_zmq_context *php_zmq_context_new(long io_threads, zend_bool is_persistent TSRMLS_DC)
+ Create a new zmq context
+*/
+static php_zmq_context *php_zmq_context_new(long io_threads, zend_bool is_persistent TSRMLS_DC)
+{
+ php_zmq_context *context;
+
+ context = pecalloc(1, sizeof(php_zmq_context), is_persistent);
+ context->z_ctx = zmq_init(io_threads);
+
+ if (!context->z_ctx) {
+ pefree(context, is_persistent);
+ return NULL;
+ }
+
+ context->io_threads = io_threads;
+ context->is_persistent = is_persistent;
+ context->pid = getpid();
+ return context;
+}
+/* }}} */
+
+/* {{{ static php_zmq_context *php_zmq_context_get(long io_threads, zend_bool is_persistent TSRMLS_DC)
+*/
+static php_zmq_context *php_zmq_context_get(long io_threads, zend_bool is_persistent TSRMLS_DC)
+{
+ php_zmq_context *context;
+
+ char plist_key[48];
+ int plist_key_len;
+ zend_rsrc_list_entry le, *le_p = NULL;
+
+ if (is_persistent) {
+ plist_key_len = snprintf(plist_key, 48, "zmq_context:[%d]", io_threads);
+ plist_key_len += 1;
+
+ if (zend_hash_find(&EG(persistent_list), plist_key, plist_key_len, (void *)&le_p) == SUCCESS) {
+ if (le_p->type == php_zmq_context_list_entry()) {
+ return (php_zmq_context *) le_p->ptr;
+ }
+ }
+ }
+
+ context = php_zmq_context_new(io_threads, is_persistent TSRMLS_CC);
+
+ if (!context) {
+ return NULL;
+ }
+
+ if (is_persistent) {
+ le.type = php_zmq_context_list_entry();
+ le.ptr = context;
+
+ if (zend_hash_update(&EG(persistent_list), (char *)plist_key, plist_key_len, (void *)&le, sizeof(le), NULL) == FAILURE) {
+ php_error_docref(NULL TSRMLS_CC, E_ERROR, "Could not register persistent entry for the context");
+ }
+ }
+ return context;
+}
+/* }}} */
+
+/* {{{ proto ZMQ ZMQ::__construct()
+ Private constructor
+*/
+PHP_METHOD(zmq, __construct) {}
+/* }}} */
+
+/* {{{ proto integer ZMQ::clock()
+ A monotonic clock
+*/
+PHP_METHOD(zmq, clock)
+{
+ if (zend_parse_parameters_none() == FAILURE) {
+ return;
+ }
+ RETURN_LONG((long) php_zmq_clock (ZMQ_G (clock_ctx)));
+}
+/* }}} */
+
+/* {{{ proto ZMQContext ZMQContext::__construct(integer $io_threads[, boolean $is_persistent = true])
+ Build a new ZMQContext object
+*/
+PHP_METHOD(zmqcontext, __construct)
+{
+ php_zmq_context_object *intern;
+ long io_threads = 1;
+ zend_bool is_persistent = 1;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|lb", &io_threads, &is_persistent) == FAILURE) {
+ return;
+ }
+ intern = PHP_ZMQ_CONTEXT_OBJECT;
+ intern->context = php_zmq_context_get(io_threads, is_persistent TSRMLS_CC);
+
+ if (!intern->context) {
+ zend_throw_exception_ex(php_zmq_context_exception_sc_entry, errno TSRMLS_CC, "Error creating context: %s", zmq_strerror(errno));
+ return;
+ }
+ return;
+}
+/* }}} */
+
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+/* {{{ proto ZMQContext ZMQContext::setOpt(int option, int value)
+ Set a context option
+*/
+PHP_METHOD(zmqcontext, setOpt)
+{
+ php_zmq_context_object *intern;
+ long option, value;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ll", &option, &value) == FAILURE) {
+ return;
+ }
+ intern = PHP_ZMQ_CONTEXT_OBJECT;
+
+ switch (option) {
+ case ZMQ_MAX_SOCKETS:
+ {
+ if (zmq_ctx_set(intern->context->z_ctx, option, value) != 0) {
+ zend_throw_exception_ex(php_zmq_context_exception_sc_entry_get (), errno TSRMLS_CC, "Failed to set the option ZMQ::CTXOPT_MAX_SOCKETS value: %s", zmq_strerror(errno));
+ return;
+ }
+ }
+ break;
+
+ default:
+ {
+ zend_throw_exception(php_zmq_context_exception_sc_entry_get (), "Unknown option key", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+ }
+ return;
+}
+/* }}} */
+
+/* {{{ proto ZMQContext ZMQContext::getOpt(int option)
+ Set a context option
+*/
+PHP_METHOD(zmqcontext, getOpt)
+{
+ php_zmq_context_object *intern;
+ long option;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &option) == FAILURE) {
+ return;
+ }
+ intern = PHP_ZMQ_CONTEXT_OBJECT;
+
+ switch (option) {
+
+ case ZMQ_MAX_SOCKETS:
+ {
+ int value = zmq_ctx_get(intern->context->z_ctx, option);
+ RETURN_LONG(value);
+ }
+ break;
+
+ default:
+ {
+ zend_throw_exception(php_zmq_context_exception_sc_entry_get (), "Unknown option key", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+ }
+ return;
+}
+/* }}} */
+#endif
+
+
+/* {{{ static php_zmq_socket *php_zmq_socket_new(php_zmq_context *context, int type, zend_bool is_persistent TSRMLS_DC)
+ Create a new zmq socket
+*/
+static php_zmq_socket *php_zmq_socket_new(php_zmq_context *context, int type, zend_bool is_persistent TSRMLS_DC)
+{
+ php_zmq_socket *zmq_sock;
+
+ zmq_sock = pecalloc(1, sizeof(php_zmq_socket), is_persistent);
+ zmq_sock->z_socket = zmq_socket(context->z_ctx, type);
+ zmq_sock->pid = getpid();
+
+ if (!zmq_sock->z_socket) {
+ pefree(zmq_sock, is_persistent);
+ return NULL;
+ }
+
+ zmq_sock->is_persistent = is_persistent;
+
+ zend_hash_init(&(zmq_sock->connect), 0, NULL, NULL, is_persistent);
+ zend_hash_init(&(zmq_sock->bind), 0, NULL, NULL, is_persistent);
+ return zmq_sock;
+}
+/* }}} */
+
+static char *php_zmq_socket_plist_key(int type, const char *persistent_id, int *plist_key_len)
+{
+ char *plist_key = NULL;
+ *plist_key_len = spprintf(&plist_key, 0, "zmq_socket:[%d]-[%s]", type, persistent_id);
+ return plist_key;
+}
+
+static void php_zmq_socket_store(php_zmq_socket *zmq_sock_p, int type, const char *persistent_id TSRMLS_DC)
+{
+ zend_rsrc_list_entry le;
+
+ char *plist_key = NULL;
+ int plist_key_len = 0;
+
+ plist_key = php_zmq_socket_plist_key(type, persistent_id, &plist_key_len);
+
+ le.type = php_zmq_socket_list_entry();
+ le.ptr = zmq_sock_p;
+
+ if (zend_hash_update(&EG(persistent_list), plist_key, plist_key_len + 1, (void *)&le, sizeof(le), NULL) == FAILURE) {
+ php_error_docref(NULL TSRMLS_CC, E_ERROR, "Could not register persistent entry for the socket");
+ }
+ efree(plist_key);
+}
+
+/* {{{ static php_zmq_socket *php_zmq_socket_get(php_zmq_context *context, int type, const char *persistent_id, zend_bool *is_new TSRMLS_DC)
+ Tries to get context from plist and allocates a new context if context does not exist
+*/
+static php_zmq_socket *php_zmq_socket_get(php_zmq_context *context, int type, const char *persistent_id, zend_bool *is_new TSRMLS_DC)
+{
+ php_zmq_socket *zmq_sock_p;
+ zend_bool is_persistent;
+
+ is_persistent = (context->is_persistent && persistent_id) ? 1 : 0;
+ *is_new = 0;
+
+ if (is_persistent) {
+ char *plist_key = NULL;
+ int plist_key_len = 0;
+
+ zend_rsrc_list_entry *le = NULL;
+
+ plist_key = php_zmq_socket_plist_key(type, persistent_id, &plist_key_len);
+
+ if (zend_hash_find(&EG(persistent_list), plist_key, plist_key_len + 1, (void *)&le) == SUCCESS) {
+ if (le->type == php_zmq_socket_list_entry()) {
+ efree(plist_key);
+ return (php_zmq_socket *) le->ptr;
+ }
+ }
+ efree(plist_key);
+ }
+
+ zmq_sock_p = php_zmq_socket_new(context, type, is_persistent TSRMLS_CC);
+
+ if (!zmq_sock_p) {
+ return NULL;
+ }
+
+ *is_new = 1;
+ return zmq_sock_p;
+}
+/* }}} */
+
+char *php_zmq_printable_func (zend_fcall_info *fci, zend_fcall_info_cache *fci_cache TSRMLS_DC)
+{
+ char *buffer = NULL;
+
+ if (fci->object_ptr) {
+ spprintf (&buffer, 0, "%s::%s", Z_OBJCE_P (fci->object_ptr)->name, fci_cache->function_handler->common.function_name);
+ } else {
+ if (Z_TYPE_P (fci->function_name) == IS_OBJECT) {
+ spprintf (&buffer, 0, "%s", Z_OBJCE_P (fci->function_name)->name);
+ }
+ else {
+ spprintf (&buffer, 0, "%s", Z_STRVAL_P (fci->function_name));
+ }
+ }
+ return buffer;
+}
+
+static zend_bool php_zmq_connect_callback(zval *socket, zend_fcall_info *fci, zend_fcall_info_cache *fci_cache, const char *persistent_id TSRMLS_DC)
+{
+ zval *retval_ptr, *pid_z;
+ zval **params[2];
+ zend_bool retval = 1;
+
+ ALLOC_INIT_ZVAL(pid_z);
+
+ if (persistent_id) {
+ ZVAL_STRING(pid_z, persistent_id, 1);
+ } else {
+ ZVAL_NULL(pid_z);
+ }
+
+ /* Call the cb */
+ params[0] = &socket;
+ params[1] = &pid_z;
+
+ fci->params = params;
+ fci->param_count = 2;
+ fci->retval_ptr_ptr = &retval_ptr;
+ fci->no_separation = 1;
+
+ if (zend_call_function(fci, fci_cache TSRMLS_CC) == FAILURE) {
+ if (!EG(exception)) {
+ char *buf = php_zmq_printable_func (fci, fci_cache TSRMLS_CC);
+
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, 0 TSRMLS_CC, "Failed to invoke 'on_new_socket' callback %s()", buf);
+ efree (buf);
+ }
+ retval = 0;
+ }
+ zval_ptr_dtor(&pid_z);
+
+ if (retval_ptr) {
+ zval_ptr_dtor(&retval_ptr);
+ }
+
+ if (EG(exception)) {
+ retval = 0;
+ }
+
+ return retval;
+}
+
+/* {{{ proto ZMQContext ZMQContext::getSocket(integer $type[, string $persistent_id = null[, callback $on_new_socket = null]])
+ Build a new ZMQContext object
+*/
+PHP_METHOD(zmqcontext, getsocket)
+{
+ php_zmq_socket *socket;
+ php_zmq_socket_object *interns;
+ php_zmq_context_object *intern;
+ long type;
+ char *persistent_id = NULL;
+ int rc, persistent_id_len;
+ zend_bool is_new;
+
+ zend_fcall_info fci;
+ zend_fcall_info_cache fci_cache;
+
+ PHP_ZMQ_ERROR_HANDLING_INIT()
+ PHP_ZMQ_ERROR_HANDLING_THROW()
+
+ fci.size = 0;
+ rc = zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l|s!f!", &type, &persistent_id, &persistent_id_len, &fci, &fci_cache);
+
+ PHP_ZMQ_ERROR_HANDLING_RESTORE()
+
+ if (rc == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_CONTEXT_OBJECT;
+ socket = php_zmq_socket_get(intern->context, type, persistent_id, &is_new TSRMLS_CC);
+
+ if (!socket) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Error creating socket: %s", zmq_strerror(errno));
+ return;
+ }
+
+ object_init_ex(return_value, php_zmq_socket_sc_entry);
+ interns = (php_zmq_socket_object *)zend_object_store_get_object(return_value TSRMLS_CC);
+ interns->socket = socket;
+
+ /* Need to add refcount if context is not persistent */
+ if (!intern->context->is_persistent) {
+ zend_objects_store_add_ref(getThis() TSRMLS_CC);
+ interns->context_obj = getThis();
+ Z_ADDREF_P(interns->context_obj);
+ }
+
+ if (is_new) {
+ if(fci.size) {
+ if (!php_zmq_connect_callback(return_value, &fci, &fci_cache, persistent_id TSRMLS_CC)) {
+ php_zmq_socket_destroy(socket);
+ interns->socket = NULL;
+ zval_dtor(return_value);
+ return;
+ }
+ }
+ if (socket->is_persistent) {
+ php_zmq_socket_store(socket, type, persistent_id TSRMLS_CC);
+ }
+ }
+ if (socket->is_persistent) {
+ interns->persistent_id = estrdup(persistent_id);
+ }
+ return;
+}
+/* }}} */
+
+/* {{{ proto ZMQContext ZMQContext::isPersistent()
+ Whether the context is persistent
+*/
+PHP_METHOD(zmqcontext, ispersistent)
+{
+ php_zmq_context_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_CONTEXT_OBJECT;
+ RETURN_BOOL(intern->context->is_persistent);
+}
+/* }}} */
+
+/* {{{ proto ZMQContext ZMQContext::__clone()
+ Clones the instance of the ZMQContext class
+*/
+PHP_METHOD(zmqcontext, __clone) { }
+/* }}} */
+
+/* --- END ZMQContext --- */
+
+/* --- START ZMQSocket --- */
+
+/* {{{ proto ZMQSocket ZMQSocket::__construct(ZMQContext $context, integer $type[, string $persistent_id = null[, callback $on_new_socket = null]])
+ Build a new ZMQSocket object
+*/
+PHP_METHOD(zmqsocket, __construct)
+{
+ php_zmq_socket *socket;
+ php_zmq_socket_object *intern;
+ php_zmq_context_object *internc;
+ long type;
+ char *persistent_id = NULL;
+ int rc, persistent_id_len;
+ zval *obj;
+ zend_bool is_new;
+
+ zend_fcall_info fci;
+ zend_fcall_info_cache fci_cache;
+
+ PHP_ZMQ_ERROR_HANDLING_INIT()
+ PHP_ZMQ_ERROR_HANDLING_THROW()
+
+ fci.size = 0;
+ rc = zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "Ol|s!f!", &obj, php_zmq_context_sc_entry, &type, &persistent_id, &persistent_id_len, &fci, &fci_cache);
+
+ PHP_ZMQ_ERROR_HANDLING_RESTORE()
+
+ if (rc == FAILURE) {
+ return;
+ }
+
+ internc = (php_zmq_context_object *) zend_object_store_get_object(obj TSRMLS_CC);
+ socket = php_zmq_socket_get(internc->context, type, persistent_id, &is_new TSRMLS_CC);
+
+ if (!socket) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Error creating socket: %s", zmq_strerror(errno));
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ intern->socket = socket;
+
+ /* Need to add refcount if context is not persistent */
+ if (!internc->context->is_persistent) {
+ intern->context_obj = obj;
+ zend_objects_store_add_ref(intern->context_obj TSRMLS_CC);
+ Z_ADDREF_P(intern->context_obj);
+ }
+
+ if (is_new) {
+ if (fci.size) {
+ if (!php_zmq_connect_callback(getThis(), &fci, &fci_cache, persistent_id TSRMLS_CC)) {
+ php_zmq_socket_destroy(socket);
+ intern->socket = NULL;
+ return;
+ }
+ }
+ if (socket->is_persistent) {
+ php_zmq_socket_store(socket, type, persistent_id TSRMLS_CC);
+ }
+ }
+ if (socket->is_persistent) {
+ intern->persistent_id = estrdup(persistent_id);
+ }
+
+ return;
+}
+/* }}} */
+
+/* {{{ static zend_bool php_zmq_send(php_zmq_socket_object *intern, char *message_param, int message_param_len, long flags TSRMLS_DC)
+*/
+static zend_bool php_zmq_send(php_zmq_socket_object *intern, char *message_param, int message_param_len, long flags TSRMLS_DC)
+{
+ int rc, errno_;
+ zmq_msg_t message;
+
+ if (zmq_msg_init_size(&message, message_param_len) != 0) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to initialize message structure: %s", zmq_strerror(errno));
+ return 0;
+ }
+ memcpy(zmq_msg_data(&message), message_param, message_param_len);
+
+ rc = zmq_sendmsg(intern->socket->z_socket, &message, flags);
+ errno_ = errno;
+
+ zmq_msg_close(&message);
+
+ if (rc == -1) {
+ if (errno_ == EAGAIN) {
+ return 0;
+ }
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno_ TSRMLS_CC, "Failed to send message: %s", zmq_strerror(errno_));
+ return 0;
+ }
+
+ return 1;
+}
+/* }}} */
+
+static void php_zmq_sendmsg_impl(INTERNAL_FUNCTION_PARAMETERS)
+{
+ php_zmq_socket_object *intern;
+ char *message_param;
+ int message_param_len;
+ long flags = 0;
+ zend_bool ret;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|l", &message_param, &message_param_len, &flags) == FAILURE) {
+ return;
+ }
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ ret = php_zmq_send(intern, message_param, message_param_len, flags TSRMLS_CC);
+
+ if (ret) {
+ ZMQ_RETURN_THIS;
+ } else {
+ RETURN_FALSE;
+ }
+}
+
+/* {{{ proto ZMQSocket ZMQSocket::send(string $message[, integer $flags = 0])
+ Send a message. Return true if message was sent and false on EAGAIN
+*/
+PHP_METHOD(zmqsocket, send)
+{
+ php_zmq_sendmsg_impl(INTERNAL_FUNCTION_PARAM_PASSTHRU);
+}
+/* }}} */
+
+#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
+static int php_zmq_send_cb(zval **ppzval, int num_args, va_list args, zend_hash_key *hash_key)
+{
+ TSRMLS_FETCH();
+#else
+static int php_zmq_send_cb(zval **ppzval TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
+{
+#endif
+ zval tmpcopy;
+ php_zmq_socket_object *intern;
+ int flags, *rc, *to_send;
+
+ intern = va_arg(args, php_zmq_socket_object *);
+ flags = va_arg(args, int);
+ to_send = va_arg(args, int *);
+ rc = va_arg(args, int *);
+
+ if (--(*to_send)) {
+ flags = flags | ZMQ_SNDMORE;
+ } else {
+ flags = flags & ~ZMQ_SNDMORE;
+ }
+
+ tmpcopy = **ppzval;
+ zval_copy_ctor(&tmpcopy);
+ INIT_PZVAL(&tmpcopy);
+
+ if (Z_TYPE(tmpcopy) != IS_STRING) {
+ convert_to_string(&tmpcopy);
+ }
+
+ *rc = php_zmq_send(intern, Z_STRVAL(tmpcopy), Z_STRLEN(tmpcopy), flags TSRMLS_CC);
+
+ zval_dtor(&tmpcopy);
+
+ if (!*rc) {
+ return ZEND_HASH_APPLY_STOP;
+ }
+ return ZEND_HASH_APPLY_KEEP;
+}
+
+/* {{{ proto ZMQSocket ZMQSocket::sendmulti(arrays $messages[, integer $flags = 0])
+ Send a multipart message. Return true if message was sent and false on EAGAIN
+*/
+PHP_METHOD(zmqsocket, sendmulti)
+{
+ zval *messages;
+ php_zmq_socket_object *intern;
+ int to_send, ret = 0;
+ long flags = 0;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a|l", &messages, &flags) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ to_send = zend_hash_num_elements(Z_ARRVAL_P(messages));
+
+#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
+ zend_hash_apply_with_arguments(Z_ARRVAL_P(messages), (apply_func_args_t) php_zmq_send_cb, 4, intern, flags, &to_send, &ret);
+#else
+ zend_hash_apply_with_arguments(Z_ARRVAL_P(messages) TSRMLS_CC, (apply_func_args_t) php_zmq_send_cb, 4, intern, flags, &to_send, &ret);
+#endif
+
+ if (ret) {
+ ZMQ_RETURN_THIS;
+ } else {
+ RETURN_FALSE;
+ }
+}
+
+/* {{{ static zend_bool php_zmq_recv(php_zmq_socket_object *intern, long flags, zval *return_value TSRMLS_DC)
+*/
+static zend_bool php_zmq_recv(php_zmq_socket_object *intern, long flags, zval *return_value TSRMLS_DC)
+{
+ int rc, errno_;
+ zmq_msg_t message;
+
+ if (zmq_msg_init(&message) != 0) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to initialize message structure: %s", zmq_strerror(errno));
+ return 0;
+ }
+
+ rc = zmq_recvmsg(intern->socket->z_socket, &message, flags);
+ errno_ = errno;
+
+ if (rc == -1) {
+ zmq_msg_close(&message);
+ if (errno == EAGAIN) {
+ return 0;
+ }
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno_ TSRMLS_CC, "Failed to receive message: %s", zmq_strerror(errno_));
+ return 0;
+ }
+
+ ZVAL_STRINGL(return_value, zmq_msg_data(&message), zmq_msg_size(&message), 1);
+ zmq_msg_close(&message);
+ return 1;
+}
+/* }}} */
+
+static void php_zmq_recvmsg_impl(INTERNAL_FUNCTION_PARAMETERS)
+{
+ php_zmq_socket_object *intern;
+ zend_bool retval;
+ long flags = 0;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|l", &flags) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ retval = php_zmq_recv(intern, flags, return_value TSRMLS_CC);
+
+ if (retval == 0) {
+ RETURN_FALSE;
+ }
+ return;
+}
+
+/* {{{ proto string ZMQ::recv([integer $flags = 0])
+ Receive a message
+*/
+PHP_METHOD(zmqsocket, recv)
+{
+ php_zmq_recvmsg_impl(INTERNAL_FUNCTION_PARAM_PASSTHRU);
+}
+/* }}} */
+
+/* {{{ proto array ZMQ::recvmulti([integer $flags = 0])
+ Receive an array of message parts
+*/
+PHP_METHOD(zmqsocket, recvmulti)
+{
+ php_zmq_socket_object *intern;
+ size_t value_len;
+ long flags = 0;
+ zend_bool retval;
+ zval *msg;
+#if ZMQ_VERSION_MAJOR < 3
+ int64_t value;
+#else
+ int value;
+#endif
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|l", &flags) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ array_init(return_value);
+ value_len = sizeof (value);
+
+ do {
+ MAKE_STD_ZVAL(msg);
+ retval = php_zmq_recv(intern, flags, msg TSRMLS_CC);
+ if (retval == 0) {
+ FREE_ZVAL(msg);
+ zval_dtor(return_value);
+ RETURN_FALSE;
+ }
+ add_next_index_zval(return_value, msg);
+ zmq_getsockopt(intern->socket->z_socket, ZMQ_RCVMORE, &value, &value_len);
+ } while (value > 0);
+
+ return;
+}
+/* }}} */
+
+/** {{{ string ZMQ::getPersistentId()
+ Returns the persistent id of the object
+*/
+PHP_METHOD(zmqsocket, getpersistentid)
+{
+ php_zmq_socket_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+
+ if (intern->socket->is_persistent && intern->persistent_id) {
+ RETURN_STRING(intern->persistent_id, 1);
+ }
+ RETURN_NULL();
+}
+/* }}} */
+
+/* {{{ proto ZMQSocket ZMQSocket::bind(string $dsn[, boolean $force = false])
+ Bind the socket to an endpoint
+*/
+PHP_METHOD(zmqsocket, bind)
+{
+ php_zmq_socket_object *intern;
+ char *dsn;
+ int dsn_len;
+ zend_bool force = 0;
+ void *dummy = (void *)1;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &dsn, &dsn_len, &force) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+
+ /* already connected ? */
+ if (!force && zend_hash_exists(&(intern->socket->bind), dsn, dsn_len + 1)) {
+ ZMQ_RETURN_THIS;
+ }
+
+ if (zmq_bind(intern->socket->z_socket, dsn) != 0) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to bind the ZMQ: %s", zmq_strerror(errno));
+ return;
+ }
+
+ zend_hash_add(&(intern->socket->bind), dsn, dsn_len + 1, (void *)&dummy, sizeof(void *), NULL);
+ ZMQ_RETURN_THIS;
+}
+/* }}} */
+
+/* {{{ proto ZMQSocket ZMQSocket::connect(string $dsn[, boolean $force = false])
+ Connect the socket to an endpoint
+*/
+PHP_METHOD(zmqsocket, connect)
+{
+ php_zmq_socket_object *intern;
+ char *dsn;
+ int dsn_len;
+ zend_bool force = 0;
+ void *dummy = (void *)1;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &dsn, &dsn_len, &force) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+
+ /* already connected ? */
+ if (!force && zend_hash_exists(&(intern->socket->connect), dsn, dsn_len + 1)) {
+ ZMQ_RETURN_THIS;
+ }
+
+ if (zmq_connect(intern->socket->z_socket, dsn) != 0) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to connect the ZMQ: %s", zmq_strerror(errno));
+ return;
+ }
+
+ (void) zend_hash_add(&(intern->socket->connect), dsn, dsn_len + 1, (void *)&dummy, sizeof(void *), NULL);
+ ZMQ_RETURN_THIS;
+}
+/* }}} */
+
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+/* {{{ proto ZMQSocket ZMQSocket::unbind(string $dsn)
+ Unbind the socket from an endpoint
+*/
+PHP_METHOD(zmqsocket, unbind)
+{
+ php_zmq_socket_object *intern;
+ char *dsn;
+ int dsn_len;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &dsn, &dsn_len) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+
+ if (zmq_unbind(intern->socket->z_socket, dsn) != 0) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to unbind the ZMQ socket: %s", zmq_strerror(errno));
+ return;
+ }
+
+ zend_hash_del(&(intern->socket->bind), dsn, dsn_len + 1);
+ ZMQ_RETURN_THIS;
+}
+/* }}} */
+
+/* {{{ proto ZMQSocket ZMQSocket::disconnect(string $dsn)
+ Disconnect the socket from an endpoint
+*/
+PHP_METHOD(zmqsocket, disconnect)
+{
+ php_zmq_socket_object *intern;
+ char *dsn;
+ int dsn_len;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &dsn, &dsn_len) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+
+ if (zmq_disconnect(intern->socket->z_socket, dsn) != 0) {
+ zend_throw_exception_ex(php_zmq_socket_exception_sc_entry, errno TSRMLS_CC, "Failed to disconnect the ZMQ socket: %s", zmq_strerror(errno));
+ return;
+ }
+
+ zend_hash_del(&(intern->socket->connect), dsn, dsn_len + 1);
+ ZMQ_RETURN_THIS;
+}
+/* }}} */
+#endif
+
+#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
+static int php_zmq_get_keys(zval **ppzval, int num_args, va_list args, zend_hash_key *hash_key)
+{
+ TSRMLS_FETCH();
+#else
+static int php_zmq_get_keys(zval **ppzval TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
+{
+#endif
+ zval *retval;
+
+ if (num_args != 1) {
+ /* Incorrect args ? */
+ return ZEND_HASH_APPLY_KEEP;
+ }
+
+ retval = va_arg(args, zval *);
+
+ if (hash_key->nKeyLength == 0) {
+ /* Should not happen */
+ return ZEND_HASH_APPLY_REMOVE;
+ }
+
+ add_next_index_stringl(retval, hash_key->arKey, hash_key->nKeyLength - 1, 1);
+ return ZEND_HASH_APPLY_KEEP;
+}
+/* }}} */
+
+/* {{{ proto array ZMQ::getEndpoints()
+ Returns endpoints where this socket is connected/bound to. Contains two keys ('bind', 'connect')
+*/
+PHP_METHOD(zmqsocket, getendpoints)
+{
+ php_zmq_socket_object *intern;
+ zval *connect, *bind;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ array_init(return_value);
+
+ MAKE_STD_ZVAL(connect);
+ MAKE_STD_ZVAL(bind);
+
+ array_init(connect);
+ array_init(bind);
+
+#if (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION < 3)
+ zend_hash_apply_with_arguments(&(intern->socket->connect), (apply_func_args_t) php_zmq_get_keys, 1, connect);
+ zend_hash_apply_with_arguments(&(intern->socket->bind), (apply_func_args_t) php_zmq_get_keys, 1, bind);
+#else
+ zend_hash_apply_with_arguments(&(intern->socket->connect) TSRMLS_CC, (apply_func_args_t) php_zmq_get_keys, 1, connect);
+ zend_hash_apply_with_arguments(&(intern->socket->bind) TSRMLS_CC, (apply_func_args_t) php_zmq_get_keys, 1, bind);
+#endif
+
+ add_assoc_zval(return_value, "connect", connect);
+ add_assoc_zval(return_value, "bind", bind);
+ return;
+}
+/* }}} */
+
+/* {{{ proto integer ZMQSocket::getSocketType()
+ Returns the socket type
+*/
+PHP_METHOD(zmqsocket, getsockettype)
+{
+ int type;
+ size_t type_siz;
+ php_zmq_socket_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ type_siz = sizeof (int);
+
+ if (zmq_getsockopt(intern->socket->z_socket, ZMQ_TYPE, &type, &type_siz) != -1) {
+ RETURN_LONG(type);
+ }
+ RETURN_LONG(-1);
+}
+/* }}} */
+
+/* {{{ proto boolean ZMQSocket::isPersistent()
+ Whether the socket is persistent
+*/
+PHP_METHOD(zmqsocket, ispersistent)
+{
+ php_zmq_socket_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_SOCKET_OBJECT;
+ RETURN_BOOL(intern->socket->is_persistent);
+}
+/* }}} */
+
+/* {{{ proto ZMQSocket ZMQSocket::__clone()
+ Clones the instance of the ZMQSocket class
+*/
+PHP_METHOD(zmqsocket, __clone) { }
+/* }}} */
+
+/* -- END ZMQSocket--- */
+
+/* -- START ZMQPoll --- */
+
+/* {{{ proto integer ZMQPoll::add(ZMQSocket $object, integer $events)
+ Add a ZMQSocket object into the pollset
+*/
+PHP_METHOD(zmqpoll, add)
+{
+ php_zmq_poll_object *intern;
+ zval *object;
+ long events;
+ int pos, key_len = 35;
+ char key[35];
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "zl", &object, &events) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_POLL_OBJECT;
+
+ switch (Z_TYPE_P(object)) {
+ case IS_OBJECT:
+ if (!instanceof_function(Z_OBJCE_P(object), php_zmq_socket_sc_entry TSRMLS_CC)) {
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, "The first argument must be an instance of ZMQSocket or a resource", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+ break;
+
+ case IS_RESOURCE:
+ /* noop */
+ break;
+
+ default:
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, "The first argument must be an instance of ZMQSocket or a resource", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ break;
+ }
+
+ pos = php_zmq_pollset_add(&(intern->set), object, events TSRMLS_CC);
+
+ if (pos < 0) {
+ const char *message = NULL;
+
+ switch (pos) {
+ case PHP_ZMQ_POLLSET_ERR_NO_STREAM:
+ message = "The supplied resource is not a valid stream resource";
+ break;
+
+ case PHP_ZMQ_POLLSET_ERR_CANNOT_CAST:
+ message = "The supplied resource is not castable";
+ break;
+
+ case PHP_ZMQ_POLLSET_ERR_CAST_FAILED:
+ message = "Failed to cast the supplied stream resource";
+ break;
+
+ case PHP_ZMQ_POLLSET_ERR_NO_INIT:
+ message = "The ZMQSocket object has not been initialized properly";
+ break;
+
+ case PHP_ZMQ_POLLSET_ERR_NO_POLL:
+ message = "The ZMQSocket object has not been initialized with polling";
+ break;
+
+ default:
+ message = "Unknown error";
+ break;
+ }
+
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, message, PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+
+ if (!php_zmq_pollset_get_key(&(intern->set), pos, key, &key_len TSRMLS_CC)) {
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, "Failed to get the item key", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+
+ RETURN_STRINGL(key, key_len, 1);
+}
+/* }}} */
+
+/* {{{ proto boolean ZMQPoll::remove(mixed $item)
+ Remove item from poll set
+*/
+PHP_METHOD(zmqpoll, remove)
+{
+ php_zmq_poll_object *intern;
+ zval *item;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &item) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_POLL_OBJECT;
+
+ if (intern->set.num_items == 0) {
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, "No sockets assigned to the ZMQPoll", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+
+ switch (Z_TYPE_P(item)) {
+
+ case IS_OBJECT:
+ if (!instanceof_function(Z_OBJCE_P(item), php_zmq_socket_sc_entry TSRMLS_CC)) {
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, "The object must be an instanceof ZMQSocket", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+ /* break intentionally missing */
+ case IS_RESOURCE:
+ RETVAL_BOOL(php_zmq_pollset_delete(&(intern->set), item TSRMLS_CC));
+ break;
+
+ default:
+ convert_to_string(item);
+ RETVAL_BOOL(php_zmq_pollset_delete_by_key(&(intern->set), Z_STRVAL_P(item), Z_STRLEN_P(item) TSRMLS_CC));
+ break;
+ }
+
+ return;
+}
+/* }}} */
+
+/* {{{ proto integer ZMQPoll::poll(array &$readable, array &$writable[, integer $timeout = -1])
+ Poll the sockets
+*/
+PHP_METHOD(zmqpoll, poll)
+{
+ php_zmq_poll_object *intern;
+ zval *r_array, *w_array;
+
+ long timeout = -1;
+ int rc;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a!a!|l", &r_array, &w_array, &timeout) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_POLL_OBJECT;
+
+ if (intern->set.num_items == 0) {
+ zend_throw_exception(php_zmq_poll_exception_sc_entry, "No sockets assigned to the ZMQPoll", PHP_ZMQ_INTERNAL_ERROR TSRMLS_CC);
+ return;
+ }
+
+ rc = php_zmq_pollset_poll(&(intern->set), timeout * PHP_ZMQ_TIMEOUT, r_array, w_array, intern->set.errors);
+
+ if (rc == -1) {
+ zend_throw_exception_ex(php_zmq_poll_exception_sc_entry, errno TSRMLS_CC, "Poll failed: %s", zmq_strerror(errno));
+ return;
+ }
+ RETURN_LONG(rc);
+}
+/* }}} */
+
+/* {{{ proto integer ZMQPoll::count()
+ Returns the number of items in the set
+*/
+PHP_METHOD(zmqpoll, count)
+{
+ php_zmq_poll_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_POLL_OBJECT;
+ RETURN_LONG(intern->set.num_items);
+}
+/* }}} */
+
+/* {{{ proto ZMQPoll ZMQPoll::clear()
+ Clear the pollset
+*/
+PHP_METHOD(zmqpoll, clear)
+{
+ php_zmq_poll_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_POLL_OBJECT;
+
+ php_zmq_pollset_delete_all(&(intern->set) TSRMLS_CC);
+ ZMQ_RETURN_THIS;
+}
+/* }}} */
+
+/* {{{ proto array ZMQPoll::getLastErrors()
+ Returns last errors
+*/
+PHP_METHOD(zmqpoll, getlasterrors)
+{
+ php_zmq_poll_object *intern;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_POLL_OBJECT;
+
+ Z_ADDREF_P(intern->set.errors);
+ RETVAL_ZVAL(intern->set.errors, 1, 0);
+ return;
+}
+/* }}} */
+
+/* {{{ proto ZMQPoll ZMQPoll::__clone()
+ Clones the instance of the ZMQPoll class
+*/
+PHP_METHOD(zmqpoll, __clone) { }
+/* }}} */
+
+/* -- END ZMQPoll */
+
+/* {{{ proto void ZMQDevice::__construct(ZMQSocket frontend, ZMQSocket backend)
+ Construct a device
+*/
+PHP_METHOD(zmqdevice, __construct)
+{
+ php_zmq_device_object *intern;
+ zval *f, *b, *c = NULL;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "OO|O!", &f, php_zmq_socket_sc_entry, &b, php_zmq_socket_sc_entry, &c, php_zmq_socket_sc_entry) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+
+ intern->front = f;
+ intern->back = b;
+ if (c) {
+ intern->capture = c;
+ zend_objects_store_add_ref(c TSRMLS_CC);
+ Z_ADDREF_P(c);
+ } else
+ intern->capture = NULL;
+
+ zend_objects_store_add_ref(f TSRMLS_CC);
+ Z_ADDREF_P(f);
+
+ zend_objects_store_add_ref(b TSRMLS_CC);
+ Z_ADDREF_P(b);
+}
+/* }}} */
+
+/* {{{ proto void ZMQDevice::run()
+ Start a device
+*/
+PHP_METHOD(zmqdevice, run)
+{
+ php_zmq_device_object *intern;
+ zend_bool rc;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "") == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+ rc = php_zmq_device (intern TSRMLS_CC);
+
+ if (!rc && !EG (exception)) {
+ zend_throw_exception_ex(php_zmq_device_exception_sc_entry, errno TSRMLS_CC, "Failed to start the device: %s", zmq_strerror (errno));
+ return;
+ }
+ return;
+}
+/* }}} */
+
+static
+void s_clear_device_callback (php_zmq_device_cb_t *cb)
+{
+ if (cb->initialized) {
+ zval_ptr_dtor(&cb->fci.function_name);
+
+ if (cb->user_data) {
+ zval_ptr_dtor(&cb->user_data);
+ }
+ if (cb->fci.object_ptr != NULL) {
+ zval_ptr_dtor(&cb->fci.object_ptr);
+ }
+
+ memset (cb, 0, sizeof (php_zmq_device_cb_t));
+ cb->initialized = 0;
+ }
+}
+
+/* {{{ proto void ZMQDevice::setIdleTimeout (int $milliseconds)
+ Set the idle timeout value
+*/
+PHP_METHOD(zmqdevice, setidletimeout)
+{
+ php_zmq_device_object *intern;
+ long timeout;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &timeout) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+ intern->idle_cb.timeout = timeout;
+ ZMQ_RETURN_THIS;
+
+}
+/* }}} */
+
+PHP_METHOD(zmqdevice, getidletimeout)
+{
+ php_zmq_device_object *intern;
+
+ if (zend_parse_parameters_none() == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+ RETURN_LONG(intern->idle_cb.timeout);
+}
+
+
+PHP_METHOD(zmqdevice, settimertimeout)
+{
+ php_zmq_device_object *intern;
+ long timeout;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &timeout) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+ intern->timer_cb.timeout = timeout;
+ ZMQ_RETURN_THIS;
+}
+
+PHP_METHOD(zmqdevice, gettimertimeout)
+{
+ php_zmq_device_object *intern;
+
+ if (zend_parse_parameters_none() == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+ RETURN_LONG(intern->timer_cb.timeout);
+}
+
+
+static
+void s_init_device_callback (php_zmq_device_cb_t *cb, zend_fcall_info *fci, zend_fcall_info_cache *fci_cache, long timeout, zval *user_data TSRMLS_DC)
+{
+ if (user_data) {
+ cb->user_data = user_data;
+ Z_ADDREF_P(user_data);
+ } else {
+ MAKE_STD_ZVAL (user_data);
+ ZVAL_NULL(user_data);
+ Z_ADDREF_P(user_data);
+
+ cb->user_data = user_data;
+ }
+ memcpy (&cb->fci, fci, sizeof (*fci));
+ memcpy (&cb->fci_cache, fci_cache, sizeof (*fci_cache));
+
+ Z_ADDREF_P (fci->function_name);
+ if (fci->object_ptr) {
+ Z_ADDREF_P (fci->object_ptr);
+ }
+ cb->initialized = 1;
+ cb->scheduled_at = php_zmq_clock (ZMQ_G (clock_ctx)) + timeout;
+ cb->timeout = timeout;
+}
+
+/* {{{ proto void ZMQDevice::setIdleCallback (callable $function, integer timeout [, mixed $userdata])
+ Set the idle timeout value
+*/
+PHP_METHOD(zmqdevice, setidlecallback)
+{
+ php_zmq_device_object *intern;
+ zval *user_data = NULL;
+ zend_fcall_info fci;
+ zend_fcall_info_cache fci_cache;
+ long timeout = 0;
+
+ if (ZEND_NUM_ARGS() == 2) {
+ php_error_docref(NULL TSRMLS_CC, E_DEPRECATED, "The signature for setIdleCallback has changed, please update your code");
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "f|z!", &fci, &fci_cache, &user_data) == FAILURE) {
+ return;
+ }
+ }
+ else {
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "fl|z!", &fci, &fci_cache, &timeout, &user_data) == FAILURE) {
+ return;
+ }
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+
+ /* Hack for backwards compatible behaviour */
+ if (!timeout) {
+ if (intern->idle_cb.timeout) {
+ timeout = intern->idle_cb.timeout;
+ }
+ }
+
+ s_clear_device_callback (&intern->idle_cb);
+
+ if (fci.size > 0) {
+ s_init_device_callback (&intern->idle_cb, &fci, &fci_cache, timeout, user_data TSRMLS_CC);
+ }
+ ZMQ_RETURN_THIS;
+
+}
+/* }}} */
+
+/* {{{ proto void ZMQDevice::setTimerCallback (callable $function, integer timeout [, mixed $userdata])
+ Set the timer function
+*/
+PHP_METHOD(zmqdevice, settimercallback)
+{
+ php_zmq_device_object *intern;
+ zval *user_data = NULL;
+ zend_fcall_info fci;
+ zend_fcall_info_cache fci_cache;
+ long timeout;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "fl|z!", &fci, &fci_cache, &timeout, &user_data) == FAILURE) {
+ return;
+ }
+
+ intern = PHP_ZMQ_DEVICE_OBJECT;
+
+ s_clear_device_callback (&intern->timer_cb);
+ if (fci.size > 0) {
+ s_init_device_callback (&intern->timer_cb, &fci, &fci_cache, timeout, user_data TSRMLS_CC);
+ }
+ ZMQ_RETURN_THIS;
+}
+/* }}} */
+
+/* {{{ proto ZMQDevice ZMQDevice::__clone()
+ Clones the instance of the ZMQDevice class
+*/
+PHP_METHOD(zmqdevice, __clone) { }
+/* }}} */
+
+/* -- END ZMQPoll */
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_construct_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_clock_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+static zend_function_entry php_zmq_class_methods[] = {
+ PHP_ME(zmq, __construct, zmq_construct_args, ZEND_ACC_PRIVATE|ZEND_ACC_CTOR)
+ PHP_ME(zmq, clock, zmq_clock_args, ZEND_ACC_PUBLIC|ZEND_ACC_STATIC)
+ {NULL, NULL, NULL}
+};
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_context_construct_args, 0, 0, 0)
+ ZEND_ARG_INFO(0, io_threads)
+ ZEND_ARG_INFO(0, persistent)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_context_getsocket_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, type)
+ ZEND_ARG_INFO(0, dsn)
+ ZEND_ARG_INFO(0, on_new_socket)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_context_ispersistent_args, 0, 0, 2)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_context_clone_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+ZEND_BEGIN_ARG_INFO_EX(zmq_context_setopt_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, option)
+ ZEND_ARG_INFO(0, value)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_context_getopt_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, option)
+ZEND_END_ARG_INFO()
+#endif
+
+static zend_function_entry php_zmq_context_class_methods[] = {
+ PHP_ME(zmqcontext, __construct, zmq_context_construct_args, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR|ZEND_ACC_FINAL)
+ PHP_ME(zmqcontext, getsocket, zmq_context_getsocket_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqcontext, ispersistent, zmq_context_ispersistent_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqcontext, __clone, zmq_context_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+ PHP_ME(zmqcontext, setOpt, zmq_context_setopt_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqcontext, getOpt, zmq_context_getopt_args, ZEND_ACC_PUBLIC)
+#endif
+ {NULL, NULL, NULL}
+};
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_construct_args, 0, 0, 2)
+ ZEND_ARG_OBJ_INFO(0, ZMQContext, ZMQContext, 0)
+ ZEND_ARG_INFO(0, type)
+ ZEND_ARG_INFO(0, persistent_id)
+ ZEND_ARG_INFO(0, on_new_socket)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_bind_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, dsn)
+ ZEND_ARG_INFO(0, force)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_connect_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, dsn)
+ ZEND_ARG_INFO(0, force)
+ZEND_END_ARG_INFO()
+
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_unbind_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, dsn)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_disconnect_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, dsn)
+ZEND_END_ARG_INFO()
+#endif
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_setsockopt_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, key)
+ ZEND_ARG_INFO(0, value)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getendpoints_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getsockettype_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_send_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, message)
+ ZEND_ARG_INFO(0, mode)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_recv_args, 0, 0, 0)
+ ZEND_ARG_INFO(0, mode)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getpersistentid_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_getsockopt_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, key)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_ispersistent_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_socket_clone_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+static zend_function_entry php_zmq_socket_class_methods[] = {
+ PHP_ME(zmqsocket, __construct, zmq_socket_construct_args, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR|ZEND_ACC_FINAL)
+ PHP_ME(zmqsocket, send, zmq_socket_send_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, recv, zmq_socket_recv_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, sendmulti, zmq_socket_send_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, recvmulti, zmq_socket_recv_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, bind, zmq_socket_bind_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, connect, zmq_socket_connect_args, ZEND_ACC_PUBLIC)
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+ PHP_ME(zmqsocket, unbind, zmq_socket_unbind_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, disconnect, zmq_socket_disconnect_args, ZEND_ACC_PUBLIC)
+#endif
+ PHP_ME(zmqsocket, setsockopt, zmq_socket_setsockopt_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, getendpoints, zmq_socket_getendpoints_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, getsockettype, zmq_socket_getsockettype_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, ispersistent, zmq_socket_ispersistent_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, getpersistentid, zmq_socket_getpersistentid_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, getsockopt, zmq_socket_getsockopt_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqsocket, __clone, zmq_socket_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
+ PHP_MALIAS(zmqsocket, sendmsg, send, zmq_socket_send_args, ZEND_ACC_PUBLIC)
+ PHP_MALIAS(zmqsocket, recvmsg, recv, zmq_socket_recv_args, ZEND_ACC_PUBLIC)
+ {NULL, NULL, NULL}
+};
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_add_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, entry)
+ ZEND_ARG_INFO(0, type)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_poll_args, 0, 0, 2)
+ ZEND_ARG_INFO(1, readable)
+ ZEND_ARG_INFO(1, writable)
+ ZEND_ARG_INFO(0, timeout)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_getlasterrors_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_remove_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, remove)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_count_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_clear_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_poll_clone_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+static zend_function_entry php_zmq_poll_class_methods[] = {
+ PHP_ME(zmqpoll, add, zmq_poll_add_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqpoll, poll, zmq_poll_poll_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqpoll, getlasterrors, zmq_poll_getlasterrors_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqpoll, remove, zmq_poll_remove_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqpoll, count, zmq_poll_count_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqpoll, clear, zmq_poll_clear_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqpoll, __clone, zmq_poll_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
+ {NULL, NULL, NULL}
+};
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_construct_args, 0, 0, 2)
+ ZEND_ARG_OBJ_INFO(0, frontend, ZMQSocket, 0)
+ ZEND_ARG_OBJ_INFO(0, backend, ZMQSocket, 0)
+ ZEND_ARG_OBJ_INFO(0, capture, ZMQSocket, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_run_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_setidlecallback_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, idle_callback)
+ ZEND_ARG_INFO(0, timeout)
+ ZEND_ARG_INFO(0, user_data)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_settimercallback_args, 0, 0, 2)
+ ZEND_ARG_INFO(0, idle_callback)
+ ZEND_ARG_INFO(0, timeout)
+ ZEND_ARG_INFO(0, user_data)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_setidletimeout_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, timeout)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_settimertimeout_args, 0, 0, 1)
+ ZEND_ARG_INFO(0, timeout)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_getidletimeout_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_gettimertimeout_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+ZEND_BEGIN_ARG_INFO_EX(zmq_device_clone_args, 0, 0, 0)
+ZEND_END_ARG_INFO()
+
+static zend_function_entry php_zmq_device_class_methods[] = {
+ PHP_ME(zmqdevice, __construct, zmq_device_construct_args, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR|ZEND_ACC_FINAL)
+ PHP_ME(zmqdevice, run, zmq_device_run_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, setidlecallback, zmq_device_setidlecallback_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, setidletimeout, zmq_device_setidletimeout_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, getidletimeout, zmq_device_getidletimeout_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, settimercallback, zmq_device_settimercallback_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, settimertimeout, zmq_device_settimertimeout_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, gettimertimeout, zmq_device_gettimertimeout_args, ZEND_ACC_PUBLIC)
+ PHP_ME(zmqdevice, __clone, zmq_device_clone_args, ZEND_ACC_PRIVATE|ZEND_ACC_FINAL)
+ {NULL, NULL, NULL}
+};
+
+zend_function_entry zmq_functions[] = {
+ {NULL, NULL, NULL}
+};
+
+static void php_zmq_context_object_free_storage(void *object TSRMLS_DC)
+{
+ php_zmq_context_object *intern = (php_zmq_context_object *)object;
+
+ if (!intern) {
+ return;
+ }
+
+ if (intern->context) {
+ if (!intern->context->is_persistent) {
+ php_zmq_context_destroy(intern->context);
+ }
+ }
+
+ zend_object_std_dtor(&intern->zo TSRMLS_CC);
+ efree(intern);
+}
+
+static void php_zmq_socket_object_free_storage(void *object TSRMLS_DC)
+{
+ php_zmq_socket_object *intern = (php_zmq_socket_object *)object;
+
+ if (!intern) {
+ return;
+ }
+
+ if (intern->socket) {
+ if (intern->socket->is_persistent && intern->persistent_id) {
+ efree(intern->persistent_id);
+ }
+
+ if (!intern->socket->is_persistent) {
+ php_zmq_socket_destroy(intern->socket);
+ }
+ }
+
+ if (intern->context_obj) {
+ zend_objects_store_del_ref(intern->context_obj TSRMLS_CC);
+ Z_DELREF_P(intern->context_obj);
+ }
+
+ zend_object_std_dtor(&intern->zo TSRMLS_CC);
+ efree(intern);
+}
+
+static void php_zmq_poll_object_free_storage(void *object TSRMLS_DC)
+{
+ php_zmq_poll_object *intern = (php_zmq_poll_object *)object;
+
+ if (!intern) {
+ return;
+ }
+
+ php_zmq_pollset_deinit(&(intern->set) TSRMLS_CC);
+ zend_object_std_dtor(&intern->zo TSRMLS_CC);
+ efree(intern);
+}
+
+static void php_zmq_device_object_free_storage(void *object TSRMLS_DC)
+{
+ php_zmq_device_object *intern = (php_zmq_device_object *)object;
+
+ if (!intern) {
+ return;
+ }
+
+ s_clear_device_callback (&intern->idle_cb);
+ s_clear_device_callback (&intern->timer_cb);
+
+ if (intern->front) {
+ zend_objects_store_del_ref(intern->front TSRMLS_CC);
+ zval_ptr_dtor (&intern->front);
+ }
+
+ if (intern->back) {
+ zend_objects_store_del_ref(intern->back TSRMLS_CC);
+ zval_ptr_dtor (&intern->back);
+ }
+
+ if (intern->capture) {
+ zend_objects_store_del_ref(intern->capture TSRMLS_CC);
+ zval_ptr_dtor (&intern->capture);
+ }
+
+ zend_object_std_dtor(&intern->zo TSRMLS_CC);
+ efree(intern);
+}
+
+/* PHP 5.4 */
+#if PHP_VERSION_ID < 50399
+# define object_properties_init(zo, class_type) { \
+ zval *tmp; \
+ zend_hash_copy((*zo).properties, \
+ &class_type->default_properties, \
+ (copy_ctor_func_t) zval_add_ref, \
+ (void *) &tmp, \
+ sizeof(zval *)); \
+ }
+#endif
+
+static zend_object_value php_zmq_context_object_new_ex(zend_class_entry *class_type, php_zmq_context_object **ptr TSRMLS_DC)
+{
+ zend_object_value retval;
+ php_zmq_context_object *intern;
+
+ /* Allocate memory for it */
+ intern = (php_zmq_context_object *) emalloc(sizeof(php_zmq_context_object));
+ memset(&intern->zo, 0, sizeof(zend_object));
+
+ /* Context is initialized in the constructor */
+ intern->context = NULL;
+
+ if (ptr) {
+ *ptr = intern;
+ }
+
+ zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
+ object_properties_init(&intern->zo, class_type);
+
+ retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_context_object_free_storage, NULL TSRMLS_CC);
+ retval.handlers = (zend_object_handlers *) &zmq_context_object_handlers;
+ return retval;
+}
+
+static zend_object_value php_zmq_socket_object_new_ex(zend_class_entry *class_type, php_zmq_socket_object **ptr TSRMLS_DC)
+{
+ zend_object_value retval;
+ php_zmq_socket_object *intern;
+
+ /* Allocate memory for it */
+ intern = (php_zmq_socket_object *) emalloc(sizeof(php_zmq_socket_object));
+ memset(&intern->zo, 0, sizeof(zend_object));
+
+ intern->socket = NULL;
+ intern->persistent_id = NULL;
+ intern->context_obj = NULL;
+
+ if (ptr) {
+ *ptr = intern;
+ }
+
+ zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
+ object_properties_init(&intern->zo, class_type);
+
+ retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_socket_object_free_storage, NULL TSRMLS_CC);
+ retval.handlers = (zend_object_handlers *) &zmq_socket_object_handlers;
+ return retval;
+}
+
+static zend_object_value php_zmq_poll_object_new_ex(zend_class_entry *class_type, php_zmq_poll_object **ptr TSRMLS_DC)
+{
+ zend_object_value retval;
+ php_zmq_poll_object *intern;
+
+ /* Allocate memory for it */
+ intern = (php_zmq_poll_object *) emalloc(sizeof(php_zmq_poll_object));
+ memset(&intern->zo, 0, sizeof(zend_object));
+
+ php_zmq_pollset_init(&(intern->set));
+
+ if (ptr) {
+ *ptr = intern;
+ }
+
+ zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
+ object_properties_init(&intern->zo, class_type);
+
+ retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_poll_object_free_storage, NULL TSRMLS_CC);
+ retval.handlers = (zend_object_handlers *) &zmq_poll_object_handlers;
+ return retval;
+}
+
+static zend_object_value php_zmq_device_object_new_ex(zend_class_entry *class_type, php_zmq_device_object **ptr TSRMLS_DC)
+{
+ zend_object_value retval;
+ php_zmq_device_object *intern;
+
+ /* Allocate memory for it */
+ intern = (php_zmq_device_object *) emalloc(sizeof(php_zmq_device_object));
+ memset(&intern->zo, 0, sizeof(zend_object));
+
+ memset (&intern->idle_cb, 0, sizeof (php_zmq_device_cb_t));
+ memset (&intern->timer_cb, 0, sizeof (php_zmq_device_cb_t));
+
+ intern->front = NULL;
+ intern->back = NULL;
+ intern->capture = NULL;
+
+ if (ptr) {
+ *ptr = intern;
+ }
+
+ zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
+ object_properties_init(&intern->zo, class_type);
+
+ retval.handle = zend_objects_store_put(intern, NULL, (zend_objects_free_object_storage_t) php_zmq_device_object_free_storage, NULL TSRMLS_CC);
+ retval.handlers = (zend_object_handlers *) &zmq_device_object_handlers;
+ return retval;
+}
+
+static zend_object_value php_zmq_context_object_new(zend_class_entry *class_type TSRMLS_DC)
+{
+ return php_zmq_context_object_new_ex(class_type, NULL TSRMLS_CC);
+}
+
+static zend_object_value php_zmq_socket_object_new(zend_class_entry *class_type TSRMLS_DC)
+{
+ return php_zmq_socket_object_new_ex(class_type, NULL TSRMLS_CC);
+}
+
+static zend_object_value php_zmq_poll_object_new(zend_class_entry *class_type TSRMLS_DC)
+{
+ return php_zmq_poll_object_new_ex(class_type, NULL TSRMLS_CC);
+}
+
+static zend_object_value php_zmq_device_object_new(zend_class_entry *class_type TSRMLS_DC)
+{
+ return php_zmq_device_object_new_ex(class_type, NULL TSRMLS_CC);
+}
+
+ZEND_RSRC_DTOR_FUNC(php_zmq_context_dtor)
+{
+ if (rsrc->ptr) {
+ php_zmq_context *ctx = (php_zmq_context *)rsrc->ptr;
+ php_zmq_context_destroy(ctx);
+ rsrc->ptr = NULL;
+ }
+}
+
+ZEND_RSRC_DTOR_FUNC(php_zmq_socket_dtor)
+{
+ if (rsrc->ptr) {
+ php_zmq_socket *zms = (php_zmq_socket *)rsrc->ptr;
+ php_zmq_socket_destroy(zms);
+ rsrc->ptr = NULL;
+ }
+}
+
+static
+void php_zmq_init_globals (zend_php_zmq_globals *zmq_globals)
+{
+ zmq_globals->clock_ctx = NULL;
+}
+
+PHP_MINIT_FUNCTION(zmq)
+{
+ char version[PHP_ZMQ_VERSION_LEN];
+ zend_class_entry ce, ce_context, ce_socket, ce_poll, ce_device;
+ zend_class_entry ce_exception, ce_context_exception, ce_socket_exception, ce_poll_exception, ce_device_exception;
+
+ le_zmq_context = zend_register_list_destructors_ex(NULL, php_zmq_context_dtor, "ZMQ persistent context", module_number);
+ le_zmq_socket = zend_register_list_destructors_ex(NULL, php_zmq_socket_dtor, "ZMQ persistent socket", module_number);
+
+ memcpy(&zmq_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
+ memcpy(&zmq_context_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
+ memcpy(&zmq_socket_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
+ memcpy(&zmq_poll_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
+ memcpy(&zmq_device_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
+
+ INIT_CLASS_ENTRY(ce, "ZMQ", php_zmq_class_methods);
+ ce.create_object = NULL;
+ zmq_object_handlers.clone_obj = NULL;
+ php_zmq_sc_entry = zend_register_internal_class(&ce TSRMLS_CC);
+
+ INIT_CLASS_ENTRY(ce_context, "ZMQContext", php_zmq_context_class_methods);
+ ce_context.create_object = php_zmq_context_object_new;
+ zmq_context_object_handlers.clone_obj = NULL;
+ php_zmq_context_sc_entry = zend_register_internal_class(&ce_context TSRMLS_CC);
+
+ INIT_CLASS_ENTRY(ce_socket, "ZMQSocket", php_zmq_socket_class_methods);
+ ce_socket.create_object = php_zmq_socket_object_new;
+ zmq_socket_object_handlers.clone_obj = NULL;
+ php_zmq_socket_sc_entry = zend_register_internal_class(&ce_socket TSRMLS_CC);
+
+ INIT_CLASS_ENTRY(ce_poll, "ZMQPoll", php_zmq_poll_class_methods);
+ ce_poll.create_object = php_zmq_poll_object_new;
+ zmq_poll_object_handlers.clone_obj = NULL;
+ php_zmq_poll_sc_entry = zend_register_internal_class(&ce_poll TSRMLS_CC);
+
+ INIT_CLASS_ENTRY(ce_device, "ZMQDevice", php_zmq_device_class_methods);
+ ce_device.create_object = php_zmq_device_object_new;
+ zmq_device_object_handlers.clone_obj = NULL;
+ php_zmq_device_sc_entry = zend_register_internal_class(&ce_device TSRMLS_CC);
+
+ INIT_CLASS_ENTRY(ce_exception, "ZMQException", NULL);
+ php_zmq_exception_sc_entry = zend_register_internal_class_ex(&ce_exception, zend_exception_get_default(TSRMLS_C), NULL TSRMLS_CC);
+ php_zmq_exception_sc_entry->ce_flags &= ~ZEND_ACC_FINAL_CLASS;
+
+ INIT_CLASS_ENTRY(ce_context_exception, "ZMQContextException", NULL);
+ php_zmq_context_exception_sc_entry = zend_register_internal_class_ex(&ce_context_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
+ php_zmq_context_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
+
+ INIT_CLASS_ENTRY(ce_socket_exception, "ZMQSocketException", NULL);
+ php_zmq_socket_exception_sc_entry = zend_register_internal_class_ex(&ce_socket_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
+ php_zmq_socket_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
+
+ INIT_CLASS_ENTRY(ce_poll_exception, "ZMQPollException", NULL);
+ php_zmq_poll_exception_sc_entry = zend_register_internal_class_ex(&ce_poll_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
+ php_zmq_poll_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
+
+ INIT_CLASS_ENTRY(ce_device_exception, "ZMQDeviceException", NULL);
+ php_zmq_device_exception_sc_entry = zend_register_internal_class_ex(&ce_device_exception, php_zmq_exception_sc_entry, "ZMQException" TSRMLS_CC);
+ php_zmq_device_exception_sc_entry->ce_flags |= ZEND_ACC_FINAL_CLASS;
+
+ ZEND_INIT_MODULE_GLOBALS(php_zmq, php_zmq_init_globals, NULL);
+
+ ZMQ_G(clock_ctx) = php_zmq_clock_init ();
+
+ if (!ZMQ_G(clock_ctx)) {
+ php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed to initialise clock");
+ return FAILURE;
+ }
+
+#define PHP_ZMQ_REGISTER_CONST_LONG(const_name, value) \
+ zend_declare_class_constant_long(php_zmq_sc_entry, const_name, sizeof(const_name)-1, (long)value TSRMLS_CC);
+#define PHP_ZMQ_REGISTER_CONST_STRING(const_name, value) \
+ zend_declare_class_constant_string (php_zmq_sc_entry, const_name, sizeof(const_name)-1, value TSRMLS_CC);
+
+ /* Socket constants */
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PAIR", ZMQ_PAIR);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PUB", ZMQ_PUB);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_SUB", ZMQ_SUB);
+#if ZMQ_VERSION_MAJOR >= 3
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XSUB", ZMQ_XSUB);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XPUB", ZMQ_XPUB);
+#endif
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_REQ", ZMQ_REQ);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_REP", ZMQ_REP);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XREQ", ZMQ_XREQ);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_XREP", ZMQ_XREP);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PUSH", ZMQ_PUSH);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_PULL", ZMQ_PULL);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_DEALER", ZMQ_DEALER);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_ROUTER", ZMQ_ROUTER);
+#if ZMQ_MAJOR_VERSION >= 4
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_STREAM", ZMQ_STREAM);
+#endif
+
+ /* 2.0? */
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_UPSTREAM", ZMQ_PULL);
+ PHP_ZMQ_REGISTER_CONST_LONG("SOCKET_DOWNSTREAM", ZMQ_PUSH);
+
+#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
+ PHP_ZMQ_REGISTER_CONST_LONG("MODE_SNDLABEL", ZMQ_SNDLABEL);
+#endif
+
+ PHP_ZMQ_REGISTER_CONST_LONG("POLL_IN", ZMQ_POLLIN);
+ PHP_ZMQ_REGISTER_CONST_LONG("POLL_OUT", ZMQ_POLLOUT);
+
+ PHP_ZMQ_REGISTER_CONST_LONG("MODE_SNDMORE", ZMQ_SNDMORE);
+ PHP_ZMQ_REGISTER_CONST_LONG("MODE_NOBLOCK", ZMQ_DONTWAIT);
+ PHP_ZMQ_REGISTER_CONST_LONG("MODE_DONTWAIT", ZMQ_DONTWAIT);
+
+ PHP_ZMQ_REGISTER_CONST_LONG("DEVICE_FORWARDER", ZMQ_FORWARDER);
+ PHP_ZMQ_REGISTER_CONST_LONG("DEVICE_QUEUE", ZMQ_QUEUE);
+ PHP_ZMQ_REGISTER_CONST_LONG("DEVICE_STREAMER", ZMQ_STREAMER);
+
+ PHP_ZMQ_REGISTER_CONST_LONG("ERR_INTERNAL", PHP_ZMQ_INTERNAL_ERROR);
+ PHP_ZMQ_REGISTER_CONST_LONG("ERR_EAGAIN", EAGAIN);
+ PHP_ZMQ_REGISTER_CONST_LONG("ERR_ENOTSUP", ENOTSUP);
+ PHP_ZMQ_REGISTER_CONST_LONG("ERR_EFSM", EFSM);
+ PHP_ZMQ_REGISTER_CONST_LONG("ERR_ETERM", ETERM);
+
+ php_zmq_get_lib_version(version);
+ PHP_ZMQ_REGISTER_CONST_STRING("LIBZMQ_VER", version);
+
+ php_zmq_register_sockopt_constants (php_zmq_sc_entry TSRMLS_CC);
+
+#if (ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR >= 2) || ZMQ_VERSION_MAJOR > 3
+ PHP_ZMQ_REGISTER_CONST_LONG("CTXOPT_MAX_SOCKETS", ZMQ_MAX_SOCKETS);
+#endif
+
+#undef PHP_ZMQ_REGISTER_CONST_LONG
+#undef PHP_ZMQ_REGISTER_CONST_STRING
+
+ return SUCCESS;
+}
+
+PHP_MSHUTDOWN_FUNCTION(zmq)
+{
+ php_zmq_clock_destroy (&ZMQ_G (clock_ctx));
+ return SUCCESS;
+}
+
+PHP_MINFO_FUNCTION(zmq)
+{
+ char version[PHP_ZMQ_VERSION_LEN];
+ php_zmq_get_lib_version(version);
+
+ php_info_print_table_start();
+
+ php_info_print_table_header(2, "ZMQ extension", "enabled");
+ php_info_print_table_row(2, "ZMQ extension version", PHP_ZMQ_VERSION);
+ php_info_print_table_row(2, "libzmq version", version);
+
+ php_info_print_table_end();
+ DISPLAY_INI_ENTRIES();
+}
+
+zend_module_entry zmq_module_entry =
+{
+ STANDARD_MODULE_HEADER,
+ PHP_ZMQ_EXTNAME,
+ zmq_functions, /* Functions */
+ PHP_MINIT(zmq), /* MINIT */
+ PHP_MSHUTDOWN(zmq), /* MSHUTDOWN */
+ NULL, /* RINIT */
+ NULL, /* RSHUTDOWN */
+ PHP_MINFO(zmq), /* MINFO */
+ PHP_ZMQ_VERSION, /* version */
+ STANDARD_MODULE_PROPERTIES
+};
+
+#ifdef COMPILE_DL_ZMQ
+ZEND_GET_MODULE(zmq)
+#endif /* COMPILE_DL_ZMQ */
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_clock.c
^
|
| (renamed from zmq-1.1.1/zmq_clock.c)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_clock.c
^
|
| (renamed from zmq-1.1.1/zmq_clock.c)
|
|
[-]
[+]
|
Added |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_device.c
^
|
| @@ -0,0 +1,343 @@
+/*
++-----------------------------------------------------------------------------------+
+| ZMQ extension for PHP |
+| Copyright (c) 2010-2013, Mikko Koppanen <mkoppanen@php.net> |
+| All rights reserved. |
++-----------------------------------------------------------------------------------+
+| Redistribution and use in source and binary forms, with or without |
+| modification, are permitted provided that the following conditions are met: |
+| * Redistributions of source code must retain the above copyright |
+| notice, this list of conditions and the following disclaimer. |
+| * Redistributions in binary form must reproduce the above copyright |
+| notice, this list of conditions and the following disclaimer in the |
+| documentation and/or other materials provided with the distribution. |
+| * Neither the name of the copyright holder nor the |
+| names of its contributors may be used to endorse or promote products |
+| derived from this software without specific prior written permission. |
++-----------------------------------------------------------------------------------+
+| THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
+| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
+| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
+| DISCLAIMED. IN NO EVENT SHALL MIKKO KOPPANEN BE LIABLE FOR ANY |
+| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
+| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
+| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
+| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
+| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
+| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
++-----------------------------------------------------------------------------------+
+*/
+
+/*
+ Based on zeromq 2.1.x devices, which is:
+ Copyright (c) 2007-2011 iMatix Corporation
+ Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file
+*/
+
+#include "php_zmq.h"
+#include "php_zmq_private.h"
+
+ZEND_EXTERN_MODULE_GLOBALS(php_zmq)
+
+static
+zend_bool s_invoke_device_cb (php_zmq_device_cb_t *cb, uint64_t current_ts TSRMLS_DC)
+{
+ zend_bool retval = 0;
+ zval **params[1];
+ zval *retval_ptr = NULL;
+
+ params [0] = &cb->user_data;
+ cb->fci.params = params;
+ cb->fci.param_count = 1;
+
+ /* Call the cb */
+ cb->fci.no_separation = 1;
+ cb->fci.retval_ptr_ptr = &retval_ptr;
+
+ if (zend_call_function(&(cb->fci), &(cb->fci_cache) TSRMLS_CC) == FAILURE) {
+ if (!EG(exception)) {
+ char *buf = php_zmq_printable_func (&(cb->fci), &(cb->fci_cache) TSRMLS_CC);
+
+ zend_throw_exception_ex(php_zmq_device_exception_sc_entry_get (), 0 TSRMLS_CC, "Failed to invoke callback %s()", buf);
+ efree (buf);
+ }
+ }
+ if (retval_ptr) {
+ convert_to_boolean(retval_ptr);
+ if (Z_BVAL_P(retval_ptr)) {
+ retval = 1;
+ }
+ zval_ptr_dtor(&retval_ptr);
+ }
+ cb->scheduled_at = current_ts + cb->timeout;
+ return retval;
+}
+
+static
+int s_capture_message (void *socket, zmq_msg_t *msg, int more)
+{
+ int rc;
+ zmq_msg_t msg_cp;
+ rc = zmq_msg_init (&msg_cp);
+ if (rc == -1)
+ return -1;
+
+ rc = zmq_msg_copy (&msg_cp, msg);
+ if (rc == -1) {
+ zmq_msg_close (&msg_cp);
+ return -1;
+ }
+
+ return
+ zmq_sendmsg (socket, &msg_cp, more ? ZMQ_SNDMORE : 0);
+}
+
+static
+int s_calculate_timeout (php_zmq_device_object *intern TSRMLS_DC)
+{
+ int timeout = -1;
+ uint64_t current = php_zmq_clock (ZMQ_G (clock_ctx));
+
+ /* Do we have timer? */
+ if (intern->timer_cb.initialized && intern->timer_cb.timeout) {
+ /* This is when we need to launch timer */
+ timeout = (int) (intern->timer_cb.scheduled_at - current);
+
+ /* If we are tiny bit late, make sure it's asap */
+ if (timeout <= 0) {
+ return 1 * PHP_ZMQ_TIMEOUT;
+ }
+ }
+
+ /* Do we have idle callback? */
+ if (intern->idle_cb.initialized && intern->idle_cb.timeout) {
+ /* Do we need to reduce next timing? */
+ int idle_timeout = (int) (intern->idle_cb.scheduled_at - current);
+
+ /* Might happen if we get scheduled tiny bit late */
+ if (idle_timeout <= 0) {
+ return 1 * PHP_ZMQ_TIMEOUT;
+ }
+
+ if (timeout == -1 || idle_timeout < timeout)
+ timeout = idle_timeout;
+ }
+
+ if (timeout > 0)
+ timeout *= PHP_ZMQ_TIMEOUT;
+
+ return timeout;
+}
+
+
+zend_bool php_zmq_device (php_zmq_device_object *intern TSRMLS_DC)
+{
+ int errno_;
+ uint64_t last_message_received;
+ void *capture_sock;
+ php_zmq_socket_object *front, *back;
+
+ zmq_msg_t msg;
+#if ZMQ_VERSION_MAJOR >= 3
+ int more;
+#else
+ int64_t more;
+#endif
+
+#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
+ int label;
+ size_t labelsz = sizeof(label);
+#endif
+
+ size_t moresz;
+ zmq_pollitem_t items [2];
+
+ int rc = zmq_msg_init (&msg);
+
+ if (rc != 0) {
+ return 0;
+ }
+
+ front = (php_zmq_socket_object *)zend_object_store_get_object(intern->front TSRMLS_CC);
+ back = (php_zmq_socket_object *)zend_object_store_get_object(intern->back TSRMLS_CC);
+
+ items [0].socket = front->socket->z_socket;
+ items [0].fd = 0;
+ items [0].events = ZMQ_POLLIN;
+ items [0].revents = 0;
+ items [1].socket = back->socket->z_socket;
+ items [1].fd = 0;
+ items [1].events = ZMQ_POLLIN;
+ items [1].revents = 0;
+
+ capture_sock = NULL;
+ if (intern->capture) {
+ php_zmq_socket_object *capture = (php_zmq_socket_object *)zend_object_store_get_object(intern->capture TSRMLS_CC);
+ capture_sock = capture->socket->z_socket;
+ }
+
+ last_message_received = php_zmq_clock (ZMQ_G (clock_ctx));
+
+ intern->timer_cb.scheduled_at = last_message_received + intern->timer_cb.timeout;
+ intern->idle_cb.scheduled_at = last_message_received + intern->idle_cb.timeout;
+
+ while (1) {
+ uint64_t current_ts = 0;
+
+ /* Calculate poll_timeout based on idle / timer cb */
+ int timeout = s_calculate_timeout (intern TSRMLS_CC);
+
+ rc = zmq_poll(&items [0], 2, timeout);
+ if (rc < 0) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ current_ts = php_zmq_clock (ZMQ_G (clock_ctx));
+
+ if (rc > 0)
+ last_message_received = current_ts;
+
+ /* Do we have a timer callback? */
+ if (intern->timer_cb.initialized && intern->timer_cb.timeout > 0) {
+ /* Is it timer to call the timer ? */
+ if (intern->timer_cb.scheduled_at <= current_ts) {
+ if (!s_invoke_device_cb (&intern->timer_cb, current_ts TSRMLS_CC)) {
+ zmq_msg_close (&msg);
+ return 1;
+ }
+ }
+ }
+
+ /* Do we have a idle callback? */
+ if (rc == 0 && intern->idle_cb.initialized && intern->idle_cb.timeout > 0) {
+ /* Is it timer to call the idle callback ? */
+ if ((current_ts - last_message_received) >= intern->idle_cb.timeout &&
+ intern->idle_cb.scheduled_at <= current_ts) {
+ if (!s_invoke_device_cb (&intern->idle_cb, current_ts TSRMLS_CC)) {
+ zmq_msg_close (&msg);
+ return 1;
+ }
+ }
+ continue;
+ }
+
+ if (items [0].revents & ZMQ_POLLIN) {
+ while (1) {
+
+ rc = zmq_recvmsg(items [0].socket, &msg, 0);
+ if (rc == -1) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ moresz = sizeof(more);
+ rc = zmq_getsockopt(items [0].socket, ZMQ_RCVMORE, &more, &moresz);
+ if (rc < 0) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
+ labelsz = sizeof(label);
+
+ rc = zmq_getsockopt(items [0].socket, ZMQ_RCVLABEL, &label, &labelsz);
+ if (rc < 0) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ rc = zmq_sendmsg (items [1].socket, &msg, label ? ZMQ_SNDLABEL : (more ? ZMQ_SNDMORE : 0));
+ more = more | label;
+#else
+ if (capture_sock) {
+ rc = s_capture_message (capture_sock, &msg, more);
+
+ if (rc == -1) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+ }
+ rc = zmq_sendmsg (items [1].socket, &msg, more ? ZMQ_SNDMORE : 0);
+#endif
+ if (rc == -1) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ if (!more)
+ break;
+ }
+ }
+
+ if (items [1].revents & ZMQ_POLLIN) {
+ while (1) {
+ rc = zmq_recvmsg(items [1].socket, &msg, 0);
+ if (rc == -1) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ moresz = sizeof (more);
+ rc = zmq_getsockopt(items [1].socket, ZMQ_RCVMORE, &more, &moresz);
+ if (rc < 0) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ return errno_;
+ }
+
+#if ZMQ_VERSION_MAJOR == 3 && ZMQ_VERSION_MINOR == 0
+ labelsz = sizeof(label);
+ rc = zmq_getsockopt(items [1].socket, ZMQ_RCVLABEL, &label, &labelsz);
+ if (rc < 0) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ rc = zmq_sendmsg (items [0].socket, &msg, label ? ZMQ_SNDLABEL : (more ? ZMQ_SNDMORE : 0));
+ more = more | label;
+#else
+ if (capture_sock) {
+ rc = s_capture_message (capture_sock, &msg, more);
+
+ if (rc == -1) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+ }
+ rc = zmq_sendmsg (items [0].socket, &msg, more ? ZMQ_SNDMORE : 0);
+#endif
+ if (rc == -1) {
+ errno_ = errno;
+ zmq_msg_close (&msg);
+ errno = errno_;
+ return 0;
+ }
+
+ if (!more)
+ break;
+ }
+ }
+ }
+ zmq_msg_close (&msg);
+ return 0;
+}
+
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_fd_stream.c
^
|
| (renamed from zmq-1.1.1/zmq_fd_stream.c)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_fd_stream.c
^
|
| (renamed from zmq-1.1.1/zmq_fd_stream.c)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_pollset.c
^
|
| (renamed from zmq-1.1.1/zmq_pollset.c)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_pollset.c
^
|
| (renamed from zmq-1.1.1/zmq_pollset.c)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_sockopt.c
^
|
| (renamed from zmq-1.1.1/zmq_sockopt.c)
|
|
[-]
[+]
|
Changed |
zmq-1.1.2.tgz/zmq-1.1.2/zmq_sockopt.c
^
|
| (renamed from zmq-1.1.1/zmq_sockopt.c)
|
