- fix some gcc warnings
[m6w6/ext-http] / http_request_pool_api.c
1 /*
2 +----------------------------------------------------------------------+
3 | PECL :: http |
4 +----------------------------------------------------------------------+
5 | This source file is subject to version 3.0 of the PHP license, that |
6 | is bundled with this package in the file LICENSE, and is available |
7 | through the world-wide-web at http://www.php.net/license/3_0.txt. |
8 | If you did not receive a copy of the PHP license and are unable to |
9 | obtain it through the world-wide-web, please send a note to |
10 | license@php.net so we can mail you a copy immediately. |
11 +----------------------------------------------------------------------+
12 | Copyright (c) 2004-2005 Michael Wallner <mike@php.net> |
13 +----------------------------------------------------------------------+
14 */
15
16 /* $Id$ */
17
18 #ifdef HAVE_CONFIG_H
19 # include "config.h"
20 #endif
21 #include "php.h"
22
23 #if defined(ZEND_ENGINE_2) && defined(HTTP_HAVE_CURL)
24
25 #include "php_http.h"
26 #include "php_http_std_defs.h"
27 #include "php_http_api.h"
28 #include "php_http_request_api.h"
29 #include "php_http_request_pool_api.h"
30 #include "php_http_request_object.h"
31 #include "php_http_requestpool_object.h"
32
33 #ifndef HTTP_DEBUG_REQPOOLS
34 # define HTTP_DEBUG_REQPOOLS 0
35 #endif
36
37 static void http_request_pool_freebody(http_request_body **body);
38 static int http_request_pool_compare_handles(void *h1, void *h2);
39
40 /* {{{ http_request_pool *http_request_pool_init(http_request_pool *) */
41 PHP_HTTP_API http_request_pool *_http_request_pool_init(http_request_pool *pool TSRMLS_DC)
42 {
43 zend_bool free_pool;
44 #if HTTP_DEBUG_REQPOOLS
45 fprintf(stderr, "Initializing request pool %p\n", pool);
46 #endif
47 if ((free_pool = (!pool))) {
48 pool = emalloc(sizeof(http_request_pool));
49 pool->ch = NULL;
50 }
51
52 if (!pool->ch) {
53 if (!(pool->ch = curl_multi_init())) {
54 http_error(E_WARNING, HTTP_E_CURL, "Could not initialize curl");
55 if (free_pool) {
56 efree(pool);
57 }
58 return NULL;
59 }
60 }
61
62 pool->unfinished = 0;
63 zend_llist_init(&pool->handles, sizeof(zval *), (llist_dtor_func_t) ZVAL_PTR_DTOR, 0);
64 zend_llist_init(&pool->bodies, sizeof(http_request_body *), (llist_dtor_func_t) http_request_pool_freebody, 0);
65 #if HTTP_DEBUG_REQPOOLS
66 fprintf(stderr, "Initialized request pool %p\n", pool);
67 #endif
68 return pool;
69 }
70 /* }}} */
71
72 /* {{{ STATUS http_request_pool_attach(http_request_pool *, zval *) */
73 PHP_HTTP_API STATUS _http_request_pool_attach(http_request_pool *pool, zval *request TSRMLS_DC)
74 {
75 getObjectEx(http_request_object, req, request);
76 #if HTTP_DEBUG_REQPOOLS
77 fprintf(stderr, "Attaching HttpRequest(#%d) %p to pool %p\n", Z_OBJ_HANDLE_P(request), req, pool);
78 #endif
79 if (req->pool) {
80 http_error_ex(E_WARNING, HTTP_E_CURL, "HttpRequest object(#%d) is already member of %s HttpRequestPool", Z_OBJ_HANDLE_P(request), req->pool == pool ? "this" : "another");
81 } else {
82 http_request_body *body = http_request_body_new();
83
84 if (SUCCESS != http_request_object_requesthandler(req, request, body)) {
85 http_error_ex(E_WARNING, HTTP_E_CURL, "Could not initialize HttpRequest object for attaching to the HttpRequestPool");
86 } else {
87 CURLMcode code = curl_multi_add_handle(pool->ch, req->ch);
88
89 if ((CURLM_OK != code) && (CURLM_CALL_MULTI_PERFORM != code)) {
90 http_error_ex(E_WARNING, HTTP_E_CURL, "Could not attach HttpRequest object to the HttpRequestPool: %s", curl_multi_strerror(code));
91 } else {
92 req->pool = pool;
93
94 zend_llist_add_element(&pool->handles, &request);
95 zend_llist_add_element(&pool->bodies, &body);
96
97 zval_add_ref(&request);
98 zend_objects_store_add_ref(request TSRMLS_CC);
99
100 #if HTTP_DEBUG_REQPOOLS
101 fprintf(stderr, "> %d HttpRequests attached to pool %p\n", zend_llist_count(&pool->handles), pool);
102 #endif
103 return SUCCESS;
104 }
105 }
106 efree(body);
107 }
108 return FAILURE;
109 }
110 /* }}} */
111
112 /* {{{ STATUS http_request_pool_detach(http_request_pool *, zval *) */
113 PHP_HTTP_API STATUS _http_request_pool_detach(http_request_pool *pool, zval *request TSRMLS_DC)
114 {
115 getObjectEx(http_request_object, req, request);
116 #if HTTP_DEBUG_REQPOOLS
117 fprintf(stderr, "Detaching HttpRequest(#%d) %p from pool %p\n", Z_OBJ_HANDLE_P(request), req, pool);
118 #endif
119 if (!req->pool) {
120 /* not attached to any pool */
121 #if HTTP_DEBUG_REQPOOLS
122 fprintf(stderr, "HttpRequest object(#%d) %p is not attached to any HttpRequestPool\n", Z_OBJ_HANDLE_P(request), req);
123 #endif
124 } else if (req->pool != pool) {
125 http_error_ex(E_WARNING, HTTP_E_CURL, "HttpRequest object(#%d) is not attached to this HttpRequestPool", Z_OBJ_HANDLE_P(request));
126 } else {
127 CURLMcode code;
128
129 req->pool = NULL;
130 zend_llist_del_element(&pool->handles, request, http_request_pool_compare_handles);
131 #if HTTP_DEBUG_REQPOOLS
132 fprintf(stderr, "> %d HttpRequests remaining in pool %p\n", zend_llist_count(&pool->handles), pool);
133 #endif
134 if (CURLM_OK != (code = curl_multi_remove_handle(pool->ch, req->ch))) {
135 http_error_ex(E_WARNING, HTTP_E_CURL, "Could not detach HttpRequest object from the HttpRequestPool: %s", curl_multi_strerror(code));
136 } else {
137 return SUCCESS;
138 }
139 }
140 return FAILURE;
141 }
142 /* }}} */
143
144 /* {{{ void http_request_pool_detach_all(http_request_pool *) */
145 PHP_HTTP_API void _http_request_pool_detach_all(http_request_pool *pool TSRMLS_DC)
146 {
147 int count = zend_llist_count(&pool->handles);
148 #if HTTP_DEBUG_REQPOOLS
149 fprintf(stderr, "Detaching %d requests from pool %p\n", count, pool);
150 #endif
151 /*
152 * we cannot apply a function to the llist which actually detaches
153 * the curl handle *and* removes the llist element --
154 * so let's get our hands dirty
155 */
156 if (count) {
157 int i = 0;
158 zend_llist_position pos;
159 zval **handle, **handles = emalloc(count * sizeof(zval *));
160
161 for (handle = zend_llist_get_first_ex(&pool->handles, &pos); handle; handle = zend_llist_get_next_ex(&pool->handles, &pos)) {
162 handles[i++] = *handle;
163 }
164 for (i = 0; i < count; ++i) {
165 http_request_pool_detach(pool, handles[i]);
166 }
167 efree(handles);
168 }
169 }
170
171
172 /* {{{ STATUS http_request_pool_send(http_request_pool *) */
173 PHP_HTTP_API STATUS _http_request_pool_send(http_request_pool *pool TSRMLS_DC)
174 {
175 #if HTTP_DEBUG_REQPOOLS
176 fprintf(stderr, "Attempt to send %d requests of pool %p\n", zend_llist_count(&pool->handles), pool);
177 #endif
178 while (http_request_pool_perform(pool)) {
179 #if HTTP_DEBUG_REQPOOLS
180 fprintf(stderr, "> %d unfinished requests of pool %p remaining\n", pool->unfinished, pool);
181 #endif
182 if (SUCCESS != http_request_pool_select(pool)) {
183 http_error(E_WARNING, HTTP_E_CURL, "Socket error");
184 return FAILURE;
185 }
186 }
187 #if HTTP_DEBUG_REQPOOLS
188 fprintf(stderr, "Finished sending %d HttpRequests of pool %p (still unfinished: %d)\n", zend_llist_count(&pool->handles), pool, pool->unfinished);
189 #endif
190 zend_llist_apply(&pool->handles, (llist_apply_func_t) http_request_pool_responsehandler TSRMLS_CC);
191 return SUCCESS;
192 }
193 /* }}} */
194
195 /* {{{ void http_request_pool_dtor(http_request_pool *) */
196 PHP_HTTP_API void _http_request_pool_dtor(http_request_pool *pool TSRMLS_DC)
197 {
198 #if HTTP_DEBUG_REQPOOLS
199 fprintf(stderr, "Destructing request pool %p\n", pool);
200 #endif
201 pool->unfinished = 0;
202 zend_llist_clean(&pool->handles);
203 zend_llist_clean(&pool->bodies);
204 curl_multi_cleanup(pool->ch);
205 }
206 /* }}} */
207
208 /* {{{ STATUS http_request_pool_select(http_request_pool *) */
209 PHP_HTTP_API STATUS _http_request_pool_select(http_request_pool *pool)
210 {
211 int MAX;
212 fd_set R, W, E;
213 struct timeval timeout = {1, 0};
214
215 FD_ZERO(&R);
216 FD_ZERO(&W);
217 FD_ZERO(&E);
218
219 curl_multi_fdset(pool->ch, &R, &W, &E, &MAX);
220 return (-1 != select(MAX + 1, &R, &W, &E, &timeout)) ? SUCCESS : FAILURE;
221 }
222 /* }}} */
223
224 /* {{{ int http_request_pool_perform(http_request_pool *) */
225 PHP_HTTP_API int _http_request_pool_perform(http_request_pool *pool)
226 {
227 while (CURLM_CALL_MULTI_PERFORM == curl_multi_perform(pool->ch, &pool->unfinished));
228 return pool->unfinished;
229 }
230 /* }}} */
231
232 /* {{{ void http_request_pool_responsehandler(zval **) */
233 void _http_request_pool_responsehandler(zval **req TSRMLS_DC)
234 {
235 getObjectEx(http_request_object, obj, *req);
236 #if HTTP_DEBUG_REQPOOLS
237 fprintf(stderr, "Fetching data from HttpRequest(#%d) %p of pool %p\n", Z_OBJ_HANDLE_PP(req), obj, obj->pool);
238 #endif
239 http_request_object_responsehandler(obj, *req);
240 }
241 /* }}} */
242
243 /*#*/
244
245 /* {{{ static void http_request_pool_freebody(http_request_body **) */
246 static void http_request_pool_freebody(http_request_body **body)
247 {
248 TSRMLS_FETCH();
249 http_request_body_free(*body);
250 }
251 /* }}} */
252
253 /* {{{ static int http_request_pool_compare_handles(void *, void *) */
254 static int http_request_pool_compare_handles(void *h1, void *h2)
255 {
256 int match = (Z_OBJ_HANDLE_PP((zval **) h1) == Z_OBJ_HANDLE_P((zval *) h2));
257 #if HTTP_DEBUG_REQPOOLS
258 /* if(match) fprintf(stderr, "OK\n"); */
259 #endif
260 return match;
261 }
262 /* }}} */
263
264 #endif /* ZEND_ENGINE_2 && HTTP_HAVE_CURL */
265
266
267 /*
268 * Local variables:
269 * tab-width: 4
270 * c-basic-offset: 4
271 * End:
272 * vim600: noet sw=4 ts=4 fdm=marker
273 * vim<600: noet sw=4 ts=4
274 */
275