X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=php_http_request_pool_api.h;h=c5fe971fe06831da78bf90104757c0751a028af3;hp=ead52dda7d4e035e7f70048c3635cbb9e8d47a91;hb=ad5f896b03adaa073134a00108a9cdf00720673a;hpb=aa931f5b858c3d8513e883ae913f0704557ca540 diff --git a/php_http_request_pool_api.h b/php_http_request_pool_api.h index ead52dd..c5fe971 100644 --- a/php_http_request_pool_api.h +++ b/php_http_request_pool_api.h @@ -1,16 +1,13 @@ /* - +----------------------------------------------------------------------+ - | PECL :: http | - +----------------------------------------------------------------------+ - | This source file is subject to version 3.0 of the PHP license, that | - | is bundled with this package in the file LICENSE, and is available | - | through the world-wide-web at http://www.php.net/license/3_0.txt. | - | If you did not receive a copy of the PHP license and are unable to | - | obtain it through the world-wide-web, please send a note to | - | license@php.net so we can mail you a copy immediately. | - +----------------------------------------------------------------------+ - | Copyright (c) 2004-2005 Michael Wallner | - +----------------------------------------------------------------------+ + +--------------------------------------------------------------------+ + | PECL :: http | + +--------------------------------------------------------------------+ + | Redistribution and use in source and binary forms, with or without | + | modification, are permitted provided that the conditions mentioned | + | in the accompanying LICENSE file are met. | + +--------------------------------------------------------------------+ + | Copyright (c) 2004-2010, Michael Wallner | + +--------------------------------------------------------------------+ */ /* $Id$ */ @@ -18,54 +15,74 @@ #ifndef PHP_HTTP_REQUEST_POOL_API_H #define PHP_HTTP_REQUEST_POOL_API_H #ifdef HTTP_HAVE_CURL +#ifdef ZEND_ENGINE_2 -#include "php_http_std_defs.h" -#include "php_http_request_api.h" -#include "phpstr/phpstr.h" - -#ifdef PHP_WIN32 -# include -#endif - -#include - -typedef struct { +typedef struct _http_request_pool_t { CURLM *ch; zend_llist finished; zend_llist handles; - zend_llist bodies; int unfinished; +#ifdef ZTS + void ***tsrm_ls; +#endif +#ifdef HTTP_HAVE_EVENT + struct event *timeout; + unsigned useevents:1; + unsigned runsocket:1; +#endif } http_request_pool; +typedef int (*http_request_pool_apply_func)(http_request_pool *pool, zval *request); +typedef int (*http_request_pool_apply_with_arg_func)(http_request_pool *pool, zval *request, void *arg); + +PHP_MINIT_FUNCTION(http_request_pool); +#ifdef HTTP_HAVE_EVENT +PHP_RINIT_FUNCTION(http_request_pool); +#endif + +#define http_request_pool_timeout _http_request_pool_timeout +extern struct timeval *_http_request_pool_timeout(http_request_pool *pool, struct timeval *timeout); + #define http_request_pool_responsehandler _http_request_pool_responsehandler -extern void _http_request_pool_responsehandler(zval **req, CURL *ch TSRMLS_DC); -#define http_request_pool_requesthandler(r, b) _http_request_pool_requesthandler((r), (b) TSRMLS_CC) -extern STATUS _http_request_pool_requesthandler(zval *request, http_request_body *body TSRMLS_DC); +extern void _http_request_pool_responsehandler(http_request_pool *pool); + +#define http_request_pool_apply_responsehandler _http_request_pool_responsehandler +extern int _http_request_pool_apply_responsehandler(http_request_pool *pool, zval *req, void *ch); #define http_request_pool_init(p) _http_request_pool_init((p) TSRMLS_CC) PHP_HTTP_API http_request_pool *_http_request_pool_init(http_request_pool *pool TSRMLS_DC); -#define http_request_pool_attach(p, r) _http_request_pool_attach((p), (r) TSRMLS_CC) -PHP_HTTP_API STATUS _http_request_pool_attach(http_request_pool *pool, zval *request TSRMLS_DC); +#define http_request_pool_attach(p, r) _http_request_pool_attach((p), (r)) +PHP_HTTP_API STATUS _http_request_pool_attach(http_request_pool *pool, zval *request); + +#define http_request_pool_detach(p, r) _http_request_pool_detach((p), (r)) +PHP_HTTP_API STATUS _http_request_pool_detach(http_request_pool *pool, zval *request); -#define http_request_pool_detach(p, r) _http_request_pool_detach((p), (r) TSRMLS_CC) -PHP_HTTP_API STATUS _http_request_pool_detach(http_request_pool *pool, zval *request TSRMLS_DC); +#define http_request_pool_apply(p, f) _http_request_pool_apply((p), (f)) +PHP_HTTP_API void _http_request_pool_apply(http_request_pool *pool, http_request_pool_apply_func cb); -#define http_request_pool_detach_all(p) _http_request_pool_detach_all((p) TSRMLS_CC) -PHP_HTTP_API void _http_request_pool_detach_all(http_request_pool *pool TSRMLS_DC); +#define http_request_pool_apply_with_arg(p, f, a) _http_request_pool_apply_with_arg((p), (f), (a)) +PHP_HTTP_API void _http_request_pool_apply_with_arg(http_request_pool *pool, http_request_pool_apply_with_arg_func cb, void *arg); -#define http_request_pool_send(p) _http_request_pool_send((p) TSRMLS_CC) -PHP_HTTP_API STATUS _http_request_pool_send(http_request_pool *pool TSRMLS_DC); +#define http_request_pool_detach_all(p) _http_request_pool_detach_all((p)) +PHP_HTTP_API void _http_request_pool_detach_all(http_request_pool *pool); + +#define http_request_pool_send(p) _http_request_pool_send((p)) +PHP_HTTP_API STATUS _http_request_pool_send(http_request_pool *pool); #define http_request_pool_select _http_request_pool_select PHP_HTTP_API STATUS _http_request_pool_select(http_request_pool *pool); -#define http_request_pool_perform(p) _http_request_pool_perform((p) TSRMLS_CC) -PHP_HTTP_API int _http_request_pool_perform(http_request_pool *pool TSRMLS_DC); +#define http_request_pool_select_ex _http_request_pool_select_ex +PHP_HTTP_API STATUS _http_request_pool_select_ex(http_request_pool *pool, struct timeval *custom_timeout); + +#define http_request_pool_perform(p) _http_request_pool_perform((p)) +PHP_HTTP_API int _http_request_pool_perform(http_request_pool *pool); -#define http_request_pool_dtor(p) _http_request_pool_dtor((p) TSRMLS_CC) -PHP_HTTP_API void _http_request_pool_dtor(http_request_pool *pool TSRMLS_DC); +#define http_request_pool_dtor(p) _http_request_pool_dtor((p)) +PHP_HTTP_API void _http_request_pool_dtor(http_request_pool *pool); +#endif #endif #endif