X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=php_http_request_pool_api.h;h=ddcac8393f566b4287517a9db2c790b7345baee8;hp=3243de936e0ea672eaee399c1f2212335a96e17e;hb=ea76053f1595a10c79735e36a51f54478ff15acf;hpb=48981407809f0404e0427637f8474c9ccc2eafa4 diff --git a/php_http_request_pool_api.h b/php_http_request_pool_api.h index 3243de9..ddcac83 100644 --- a/php_http_request_pool_api.h +++ b/php_http_request_pool_api.h @@ -1,66 +1,75 @@ /* - +----------------------------------------------------------------------+ - | 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-2007, Michael Wallner | + +--------------------------------------------------------------------+ */ /* $Id$ */ #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 "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 } http_request_pool; -#define http_request_pool_responsehandler _http_request_pool_responsehandler -extern void _http_request_pool_responsehandler(zval **req TSRMLS_DC); +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_responsehandler(p, r, c) _http_request_pool_responsehandler((p), (r), (c)) +extern int _http_request_pool_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 _http_request_pool_perform +#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 /*