#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 {
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);
}
CURLMcode rs;
TSRMLS_FETCH_FROM_CTX(h->ts);
+ if (r->ops != php_http_curl_client_get_ops()) {
+ php_http_error(HE_WARNING, PHP_HTTP_E_CLIENT_POOL, "Cannot attach a non-curl client to this pool");
+ return FAILURE;
+ }
+
if (SUCCESS != php_http_curl_client_prepare(r, m)) {
return FAILURE;
}
{
php_http_curl_client_pool_t *curl = h->ctx;
php_http_curl_client_t *recurl = r->ctx;
- CURLMcode rs = curl_multi_remove_handle(curl->handle, recurl->handle);
+ CURLMcode rs;
TSRMLS_FETCH_FROM_CTX(h->ts);
- if (CURLM_OK == rs) {
+ if (r->ops != php_http_curl_client_get_ops()) {
+ php_http_error(HE_WARNING, PHP_HTTP_E_CLIENT_POOL, "Cannot attach a non-curl client to this pool");
+ return FAILURE;
+ }
+
+ if (CURLM_OK == (rs = curl_multi_remove_handle(curl->handle, recurl->handle))) {
return SUCCESS;
} else {
php_http_error(HE_WARNING, PHP_HTTP_E_CLIENT_POOL, "Could not detach request from pool: %s", curl_multi_strerror(rs));
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;
}
+#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 */