X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=http_request_pool_api.c;h=a9cd4ede33fbc357deadbefd837308274ac20dbc;hp=437530350af87b17d01aa332b11ba424209b726b;hb=48981407809f0404e0427637f8474c9ccc2eafa4;hpb=77b24e0e5f85b64a168a4ea4ce83db9339b1f31b diff --git a/http_request_pool_api.c b/http_request_pool_api.c index 4375303..a9cd4ed 100644 --- a/http_request_pool_api.c +++ b/http_request_pool_api.c @@ -59,7 +59,6 @@ PHP_HTTP_API http_request_pool *_http_request_pool_init(http_request_pool *pool } } - pool->sent = 0; pool->unfinished = 0; zend_llist_init(&pool->handles, sizeof(zval *), (llist_dtor_func_t) ZVAL_PTR_DTOR, 0); zend_llist_init(&pool->bodies, sizeof(http_request_body *), (llist_dtor_func_t) http_request_pool_freebody, 0); @@ -160,14 +159,8 @@ PHP_HTTP_API void _http_request_pool_detach_all(http_request_pool *pool TSRMLS_D PHP_HTTP_API STATUS _http_request_pool_send(http_request_pool *pool TSRMLS_DC) { #if HTTP_DEBUG_REQPOOLS - fprintf(stderr, "Attempt to send requests of pool %p\n", pool); + fprintf(stderr, "Attempt to send %d requests of pool %p\n", zend_llist_count(&pool->handles), pool); #endif - if (pool->sent) { - http_error(E_WARNING, HTTP_E_CURL, "HttpRequestPools can only be used once"); - return FAILURE; - } else { - pool->sent = 1; - } while (http_request_pool_perform(pool)) { #if HTTP_DEBUG_REQPOOLS fprintf(stderr, "%d unfinished requests of pool %p remaining\n", pool->unfinished, pool);