X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=http_request_pool_api.c;h=04acb2e6f07047f14723823bc472f7f1b72bd959;hp=e5482b41da4778dc90661b82b11f59c01fd3f262;hb=ad5f896b03adaa073134a00108a9cdf00720673a;hpb=d8d4c50ac3637c4fafae5cec91501795b334c11e diff --git a/http_request_pool_api.c b/http_request_pool_api.c index e5482b4..04acb2e 100644 --- a/http_request_pool_api.c +++ b/http_request_pool_api.c @@ -6,7 +6,7 @@ | modification, are permitted provided that the conditions mentioned | | in the accompanying LICENSE file are met. | +--------------------------------------------------------------------+ - | Copyright (c) 2004-2007, Michael Wallner | + | Copyright (c) 2004-2010, Michael Wallner | +--------------------------------------------------------------------+ */ @@ -109,7 +109,9 @@ PHP_HTTP_API http_request_pool *_http_request_pool_init(http_request_pool *pool /* {{{ STATUS http_request_pool_attach(http_request_pool *, zval *) */ PHP_HTTP_API STATUS _http_request_pool_attach(http_request_pool *pool, zval *request) { +#ifdef ZTS TSRMLS_FETCH_FROM_CTX(pool->tsrm_ls); +#endif getObjectEx(http_request_object, req, request); #if HTTP_DEBUG_REQPOOLS @@ -146,7 +148,9 @@ PHP_HTTP_API STATUS _http_request_pool_attach(http_request_pool *pool, zval *req PHP_HTTP_API STATUS _http_request_pool_detach(http_request_pool *pool, zval *request) { CURLMcode code; +#ifdef ZTS TSRMLS_FETCH_FROM_CTX(pool->tsrm_ls); +#endif getObjectEx(http_request_object, req, request); #if HTTP_DEBUG_REQPOOLS @@ -261,7 +265,9 @@ PHP_HTTP_API STATUS _http_request_pool_send(http_request_pool *pool) #ifdef HTTP_HAVE_EVENT if (pool->useevents) { do { - while (CURLM_CALL_MULTI_PERFORM == curl_multi_socket_all(pool->ch, &pool->unfinished)); +#if HTTP_DEBUG_REQPOOLS + fprintf(stderr, "& Starting event dispatcher of pool %p\n", pool); +#endif event_base_dispatch(HTTP_G->request.pool.event.base); } while (pool->unfinished); } else @@ -301,6 +307,8 @@ PHP_HTTP_API void _http_request_pool_dtor(http_request_pool *pool) efree(pool->timeout); #endif + http_request_pool_detach_all(pool); + pool->unfinished = 0; zend_llist_clean(&pool->finished); zend_llist_clean(&pool->handles); @@ -316,6 +324,13 @@ PHP_HTTP_API void _http_request_pool_dtor(http_request_pool *pool) /* {{{ STATUS http_request_pool_select(http_request_pool *) */ PHP_HTTP_API STATUS _http_request_pool_select(http_request_pool *pool) +{ + return http_request_pool_select_ex(pool, NULL); +} +/* }}} */ + +/* {{{ STATUS http_request_pool_select_ex(http_request_pool *, struct timeval *) */ +PHP_HTTP_API STATUS _http_request_pool_select_ex(http_request_pool *pool, struct timeval *custom_timeout) { int MAX; fd_set R, W, E; @@ -329,7 +344,11 @@ PHP_HTTP_API STATUS _http_request_pool_select(http_request_pool *pool) } #endif - http_request_pool_timeout(pool, &timeout); + if (custom_timeout && timerisset(custom_timeout)) { + timeout = *custom_timeout; + } else { + http_request_pool_timeout(pool, &timeout); + } FD_ZERO(&R); FD_ZERO(&W); @@ -394,7 +413,9 @@ void _http_request_pool_responsehandler(http_request_pool *pool) /* {{{ int http_request_pool_apply_responsehandler(http_request_pool *, zval *, void *) */ int _http_request_pool_apply_responsehandler(http_request_pool *pool, zval *req, void *ch) { +#ifdef ZTS TSRMLS_FETCH_FROM_CTX(pool->tsrm_ls); +#endif getObjectEx(http_request_object, obj, req); if ((!ch) || obj->request->ch == (CURL *) ch) { @@ -418,13 +439,13 @@ struct timeval *_http_request_pool_timeout(http_request_pool *pool, struct timev #ifdef HAVE_CURL_MULTI_TIMEOUT long max_tout = 1000; - if ((CURLM_OK == curl_multi_timeout(pool->ch, &max_tout)) && (max_tout != -1)) { + if ((CURLM_OK == curl_multi_timeout(pool->ch, &max_tout)) && (max_tout > 0)) { timeout->tv_sec = max_tout / 1000; timeout->tv_usec = (max_tout % 1000) * 1000; } else { #endif - timeout->tv_sec = 1; - timeout->tv_usec = 0; + timeout->tv_sec = 0; + timeout->tv_usec = 1000; #ifdef HAVE_CURL_MULTI_TIMEOUT } #endif @@ -465,9 +486,8 @@ static void http_request_pool_timeout_callback(int socket, short action, void *e if (CURLM_OK != rc) { http_error(HE_WARNING, HTTP_E_SOCKET, curl_multi_strerror(rc)); } -#if 0 - http_request_pool_timer_callback(pool->ch, 1000, pool); -#endif + + http_request_pool_responsehandler(pool); } } /* }}} */ @@ -550,6 +570,7 @@ static int http_request_pool_socket_callback(CURL *easy, curl_socket_t sock, int ev = ecalloc(1, sizeof(http_request_pool_event)); ev->pool = pool; curl_multi_assign(pool->ch, sock, ev); + event_base_set(HTTP_G->request.pool.event.base, &ev->evnt); } else { event_del(&ev->evnt); } @@ -559,7 +580,7 @@ static int http_request_pool_socket_callback(CURL *easy, curl_socket_t sock, int static const char action_strings[][8] = {"NONE", "IN", "OUT", "INOUT", "REMOVE"}; http_request *r; curl_easy_getinfo(easy, CURLINFO_PRIVATE, &r); - fprintf(stderr, "Callback on socket %d (%s) event %p of pool %p (%s)\n", (int) sock, action_strings[action], ev, pool, r->url); + fprintf(stderr, "Callback on socket %2d (%8s) event %p of pool %p (%d)\n", (int) sock, action_strings[action], ev, pool, pool->unfinished); } #endif @@ -585,7 +606,6 @@ static int http_request_pool_socket_callback(CURL *easy, curl_socket_t sock, int } event_set(&ev->evnt, sock, events, http_request_pool_event_callback, ev); - event_base_set(HTTP_G->request.pool.event.base, &ev->evnt); event_add(&ev->evnt, NULL); } @@ -600,18 +620,26 @@ static void http_request_pool_timer_callback(CURLM *multi, long timeout_ms, void if (pool->useevents) { TSRMLS_FETCH_FROM_CTX(pool->tsrm_ls); - struct timeval timeout = {timeout_ms / 1000, (timeout_ms % 1000) * 1000}; - - if (event_initialized(pool->timeout) && event_pending(pool->timeout, EV_TIMEOUT, NULL)) { + struct timeval timeout; + + if (!event_initialized(pool->timeout)) { + event_set(pool->timeout, -1, 0, http_request_pool_timeout_callback, pool); + event_base_set(HTTP_G->request.pool.event.base, pool->timeout); + } else if (event_pending(pool->timeout, EV_TIMEOUT, NULL)) { event_del(pool->timeout); } - event_set(pool->timeout, -1, 0, http_request_pool_timeout_callback, pool); - event_base_set(HTTP_G->request.pool.event.base, pool->timeout); + if (timeout_ms > 0) { + timeout.tv_sec = timeout_ms / 1000; + timeout.tv_usec = (timeout_ms % 1000) * 1000; + } else { + http_request_pool_timeout(pool, &timeout); + } + event_add(pool->timeout, &timeout); - + #if HTTP_DEBUG_REQPOOLS - fprintf(stderr, "Updating timeout (%lu, %lu) of pool %p\n", (ulong) timeout.tv_sec, (ulong) timeout.tv_usec, pool); + fprintf(stderr, "Updating timeout %lu (%lu, %lu) of pool %p\n", (ulong) timeout_ms, (ulong) timeout.tv_sec, (ulong) timeout.tv_usec, pool); #endif } }