#if PHP_HTTP_HAVE_EVENT
# include <event.h>
+# if !PHP_HTTP_HAVE_EVENT2 && /* just be really sure */ !(LIBEVENT_VERSION_NUMBER >= 0x02000000)
+# define event_base_new event_init
+# define event_assign(e, b, s, a, cb, d) do {\
+ event_set(e, s, a, cb, d); \
+ event_base_set(b, e); \
+ } while(0)
+# endif
#endif
typedef struct php_http_curl_client_pool {
#endif
} php_http_curl_client_pool_t;
-static void *php_http_curlm_ctor(void *opaque TSRMLS_DC)
+static void *php_http_curlm_ctor(void *opaque, void *init_arg TSRMLS_DC)
{
return curl_multi_init();
}
zval **request;
if (CURLE_OK != msg->data.result) {
- php_http_curl_client_storage_t *st = get_storage(msg->easy_handle);
+ php_http_curl_client_storage_t *st = php_http_curl_client_get_storage(msg->easy_handle);
php_http_error(HE_WARNING, PHP_HTTP_E_CLIENT, "%s; %s (%s)", curl_easy_strerror(msg->data.result), STR_PTR(st->errorbuffer), STR_PTR(st->url));
}
ev = ecalloc(1, sizeof(php_http_client_pool_event_t));
ev->pool = pool;
curl_multi_assign(curl->handle, sock, ev);
- event_base_set(PHP_HTTP_G->curl.event_base, &ev->evnt);
} else {
event_del(&ev->evnt);
}
return -1;
}
- event_set(&ev->evnt, sock, events, php_http_curl_client_pool_event_callback, pool);
+ event_assign(&ev->evnt, PHP_HTTP_G->curl.event_base, sock, events, php_http_curl_client_pool_event_callback, pool);
event_add(&ev->evnt, NULL);
}
php_http_curl_client_pool_t *curl = pool->ctx;
#if DBG_EVENTS
- fprintf(stderr, "%ld", timeout_ms);
+ fprintf(stderr, "\ntimer <- timeout_ms: %ld\n", timeout_ms);
#endif
if (curl->useevents) {
if (timeout_ms < 0) {
- php_http_curl_client_pool_timeout_callback(CURL_SOCKET_TIMEOUT, CURL_CSELECT_IN|CURL_CSELECT_OUT, pool);
+ php_http_curl_client_pool_timeout_callback(CURL_SOCKET_TIMEOUT, EV_READ|EV_WRITE, pool);
} else if (timeout_ms > 0 || !event_initialized(curl->timeout) || !event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
struct timeval timeout;
TSRMLS_FETCH_FROM_CTX(pool->ts);
if (!event_initialized(curl->timeout)) {
- event_set(curl->timeout, -1, 0, php_http_curl_client_pool_timeout_callback, pool);
- event_base_set(PHP_HTTP_G->curl.event_base, curl->timeout);
+ event_assign(curl->timeout, PHP_HTTP_G->curl.event_base, CURL_SOCKET_TIMEOUT, 0, php_http_curl_client_pool_timeout_callback, pool);
} else if (event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
event_del(curl->timeout);
}
php_http_curl_client_pool_t *curl;
TSRMLS_FETCH_FROM_CTX(h->ts);
- if (!handle && !(handle = php_http_resource_factory_handle_ctor(h->rf TSRMLS_CC))) {
+ if (!handle && !(handle = php_resource_factory_handle_ctor(h->rf, NULL TSRMLS_CC))) {
php_http_error(HE_WARNING, PHP_HTTP_E_CLIENT_POOL, "could not initialize curl pool handle");
return NULL;
}
curl->unfinished = 0;
php_http_client_pool_reset(h);
- php_http_resource_factory_handle_dtor(h->rf, curl->handle TSRMLS_CC);
+ php_resource_factory_handle_dtor(h->rf, curl->handle TSRMLS_CC);
efree(curl);
h->ctx = NULL;
return curl->unfinished;
}
-#if PHP_HTTP_HAVE_EVENT
-static void dolog(int i, const char *m) {
- fprintf(stderr, "%d: %s\n", i, m);
-}
-#endif
+
static STATUS php_http_curl_client_pool_exec(php_http_client_pool_t *h)
{
TSRMLS_FETCH_FROM_CTX(h->ts);
php_http_curl_client_pool_t *curl = h->ctx;
if (curl->useevents) {
- event_set_log_callback(dolog);
+ php_http_curl_client_pool_timeout_callback(CURL_SOCKET_TIMEOUT, EV_READ|EV_WRITE, h);
do {
+ int ev_rc = event_base_dispatch(PHP_HTTP_G->curl.event_base);
+
#if DBG_EVENTS
- fprintf(stderr, "X");
+ fprintf(stderr, "%c", "X.0"[ev_rc+1]);
#endif
- event_base_dispatch(PHP_HTTP_G->curl.event_base);
+
+ if (ev_rc < 0) {
+ php_http_error(HE_ERROR, PHP_HTTP_E_RUNTIME, "Error in event_base_dispatch()");
+ return FAILURE;
+ }
} while (curl->unfinished);
} else
#endif
return SUCCESS;
}
-static php_http_resource_factory_ops_t php_http_curlm_resource_factory_ops = {
+static php_resource_factory_ops_t php_http_curlm_resource_factory_ops = {
php_http_curlm_ctor,
NULL,
php_http_curlm_dtor
o = ecalloc(1, sizeof(php_http_client_pool_object_t));
zend_object_std_init((zend_object *) o, ce TSRMLS_CC);
-#if PHP_VERSION_ID < 50339
- zend_hash_copy(((zend_object *) o)->properties, &(ce->default_properties), (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval*));
-#else
object_properties_init((zend_object *) o, ce);
-#endif
if (!(o->pool = p)) {
o->pool = php_http_client_pool_init(NULL, &php_http_curl_client_pool_ops, NULL, NULL TSRMLS_CC);
PHP_MINIT_FUNCTION(http_curl_client_pool)
{
- if (SUCCESS != php_http_persistent_handle_provide(ZEND_STRL("http_client_pool.curl"), &php_http_curlm_resource_factory_ops, NULL, NULL)) {
+ if (SUCCESS != php_persistent_handle_provide(ZEND_STRL("http_client_pool.curl"), &php_http_curlm_resource_factory_ops, NULL, NULL TSRMLS_CC)) {
return FAILURE;
}
return SUCCESS;
}
+#if PHP_HTTP_HAVE_EVENT
PHP_RINIT_FUNCTION(http_curl_client_pool)
{
-#if PHP_HTTP_HAVE_EVENT
- if (!PHP_HTTP_G->curl.event_base && !(PHP_HTTP_G->curl.event_base = event_init())) {
+ if (!PHP_HTTP_G->curl.event_base && !(PHP_HTTP_G->curl.event_base = event_base_new())) {
return FAILURE;
}
+ return SUCCESS;
+}
#endif
+#if PHP_HTTP_HAVE_EVENT
+PHP_RSHUTDOWN_FUNCTION(http_curl_client_pool)
+{
+ if (PHP_HTTP_G->curl.event_base) {
+ event_base_free(PHP_HTTP_G->curl.event_base);
+ PHP_HTTP_G->curl.event_base = NULL;
+ }
return SUCCESS;
}
+#endif
#endif /* PHP_HTTP_HAVE_CURL */