git.m6w6.name Git - m6w6/ext-http/blob - http_request_pool_api.c

   1 /*
   2     +--------------------------------------------------------------------+
   3     | PECL :: http                                                       |
   4     +--------------------------------------------------------------------+
   5     | Redistribution and use in source and binary forms, with or without |
   6     | modification, are permitted provided that the conditions mentioned |
   7     | in the accompanying LICENSE file are met.                          |
   8     +--------------------------------------------------------------------+
   9     | Copyright (c) 2004-2005, Michael Wallner <mike@php.net>            |
  10     +--------------------------------------------------------------------+
  11 */
  12
  13 /* $Id$ */
  14
  15 #ifdef HAVE_CONFIG_H
  16 #       include "config.h"
  17 #endif
  18
  19 #define HTTP_WANT_CURL
  20 #include "php_http.h"
  21
  22 #if defined(ZEND_ENGINE_2) && defined(HTTP_HAVE_CURL)
  23
  24 #include "php_http_api.h"
  25 #include "php_http_exception_object.h"
  26 #include "php_http_request_api.h"
  27 #include "php_http_request_object.h"
  28 #include "php_http_request_pool_api.h"
  29 #include "php_http_requestpool_object.h"
  30
  31 #ifndef HTTP_DEBUG_REQPOOLS
  32 #       define HTTP_DEBUG_REQPOOLS 0
  33 #endif
  34
  35 ZEND_EXTERN_MODULE_GLOBALS(http);
  36
  37 #ifndef HAVE_CURL_MULTI_STRERROR
  38 #       define curl_multi_strerror(dummy) "unknown error"
  39 #endif
  40
  41 #define http_request_pool_wrap_exception(o, n) _http_request_pool_wrap_exception((o), (n) TSRMLS_CC)
  42 static inline void _http_request_pool_wrap_exception(zval *old_exception, zval *new_exception TSRMLS_DC);
  43 static void http_request_pool_freebody(http_request_callback_ctx **body);
  44 static int http_request_pool_compare_handles(void *h1, void *h2);
  45
  46 /* {{{ http_request_pool *http_request_pool_init(http_request_pool *) */
  47 PHP_HTTP_API http_request_pool *_http_request_pool_init(http_request_pool *pool TSRMLS_DC)
  48 {
  49         zend_bool free_pool;
  50
  51 #if HTTP_DEBUG_REQPOOLS
  52         fprintf(stderr, "Initializing request pool %p\n", pool);
  53 #endif
  54
  55         if ((free_pool = (!pool))) {
  56                 pool = emalloc(sizeof(http_request_pool));
  57                 pool->ch = NULL;
  58         }
  59
  60         HTTP_CHECK_CURL_INIT(pool->ch, curl_multi_init(), ;);
  61         if (!pool->ch) {
  62                 if (free_pool) {
  63                         efree(pool);
  64                 }
  65                 return NULL;
  66         }
  67
  68         pool->unfinished = 0;
  69         zend_llist_init(&pool->finished, sizeof(zval *), (llist_dtor_func_t) ZVAL_PTR_DTOR, 0);
  70         zend_llist_init(&pool->handles, sizeof(zval *), (llist_dtor_func_t) ZVAL_PTR_DTOR, 0);
  71         zend_llist_init(&pool->bodies, sizeof(http_request_callback_ctx *), (llist_dtor_func_t) http_request_pool_freebody, 0);
  72
  73 #if HTTP_DEBUG_REQPOOLS
  74         fprintf(stderr, "Initialized request pool %p\n", pool);
  75 #endif
  76
  77         return pool;
  78 }
  79 /* }}} */
  80
  81 /* {{{ STATUS http_request_pool_attach(http_request_pool *, zval *) */
  82 PHP_HTTP_API STATUS _http_request_pool_attach(http_request_pool *pool, zval *request TSRMLS_DC)
  83 {
  84         getObjectEx(http_request_object, req, request);
  85
  86 #if HTTP_DEBUG_REQPOOLS
  87         fprintf(stderr, "Attaching HttpRequest(#%d) %p to pool %p\n", Z_OBJ_HANDLE_P(request), req, pool);
  88 #endif
  89
  90         if (req->pool) {
  91                 http_error_ex(HE_WARNING, HTTP_E_INVALID_PARAM, "HttpRequest object(#%d) is already member of %s HttpRequestPool", Z_OBJ_HANDLE_P(request), req->pool == pool ? "this" : "another");
  92         } else {
  93                 http_request_callback_ctx *body = http_request_callback_data_ex(http_request_body_new(), 0);
  94
  95                 if (SUCCESS != http_request_pool_requesthandler(request, body->data)) {
  96                         http_error_ex(HE_WARNING, HTTP_E_REQUEST, "Could not initialize HttpRequest object for attaching to the HttpRequestPool");
  97                 } else {
  98                         CURLMcode code = curl_multi_add_handle(pool->ch, req->ch);
  99
 100                         if ((CURLM_OK != code) && (CURLM_CALL_MULTI_PERFORM != code)) {
 101                                 http_error_ex(HE_WARNING, HTTP_E_REQUEST_POOL, "Could not attach HttpRequest object to the HttpRequestPool: %s", curl_multi_strerror(code));
 102                         } else {
 103                                 req->pool = pool;
 104
 105                                 zend_llist_add_element(&pool->handles, &request);
 106                                 zend_llist_add_element(&pool->bodies, &body);
 107
 108                                 ZVAL_ADDREF(request);
 109
 110 #if HTTP_DEBUG_REQPOOLS
 111                                 fprintf(stderr, "> %d HttpRequests attached to pool %p\n", zend_llist_count(&pool->handles), pool);
 112 #endif
 113                                 return SUCCESS;
 114                         }
 115                 }
 116                 efree(body->data);
 117                 efree(body);
 118         }
 119         return FAILURE;
 120 }
 121 /* }}} */
 122
 123 /* {{{ STATUS http_request_pool_detach(http_request_pool *, zval *) */
 124 PHP_HTTP_API STATUS _http_request_pool_detach(http_request_pool *pool, zval *request TSRMLS_DC)
 125 {
 126         CURLMcode code;
 127         getObjectEx(http_request_object, req, request);
 128
 129 #if HTTP_DEBUG_REQPOOLS
 130         fprintf(stderr, "Detaching HttpRequest(#%d) %p from pool %p\n", Z_OBJ_HANDLE_P(request), req, pool);
 131 #endif
 132
 133         if (!req->pool) {
 134                 /* not attached to any pool */
 135 #if HTTP_DEBUG_REQPOOLS
 136                 fprintf(stderr, "HttpRequest object(#%d) %p is not attached to any HttpRequestPool\n", Z_OBJ_HANDLE_P(request), req);
 137 #endif
 138         } else if (req->pool != pool) {
 139                 http_error_ex(HE_WARNING, HTTP_E_INVALID_PARAM, "HttpRequest object(#%d) is not attached to this HttpRequestPool", Z_OBJ_HANDLE_P(request));
 140         } else if (CURLM_OK != (code = curl_multi_remove_handle(pool->ch, req->ch))) {
 141                 http_error_ex(HE_WARNING, HTTP_E_REQUEST_POOL, "Could not detach HttpRequest object from the HttpRequestPool: %s", curl_multi_strerror(code));
 142         } else {
 143                 req->pool = NULL;
 144                 zend_llist_del_element(&pool->finished, request, http_request_pool_compare_handles);
 145                 zend_llist_del_element(&pool->handles, request, http_request_pool_compare_handles);
 146
 147 #if HTTP_DEBUG_REQPOOLS
 148                 fprintf(stderr, "> %d HttpRequests remaining in pool %p\n", zend_llist_count(&pool->handles), pool);
 149 #endif
 150
 151                 return SUCCESS;
 152         }
 153         return FAILURE;
 154 }
 155 /* }}} */
 156
 157 /* {{{ void http_request_pool_detach_all(http_request_pool *) */
 158 PHP_HTTP_API void _http_request_pool_detach_all(http_request_pool *pool TSRMLS_DC)
 159 {
 160         int count = zend_llist_count(&pool->handles);
 161
 162 #if HTTP_DEBUG_REQPOOLS
 163         fprintf(stderr, "Detaching %d requests from pool %p\n", count, pool);
 164 #endif
 165
 166         /*
 167          * we cannot apply a function to the llist which actually detaches
 168          * the curl handle *and* removes the llist element --
 169          * so let's get our hands dirty
 170          */
 171         if (count) {
 172                 int i = 0;
 173                 zend_llist_position pos;
 174                 zval **handle, **handles = emalloc(count * sizeof(zval *));
 175
 176                 for (handle = zend_llist_get_first_ex(&pool->handles, &pos); handle; handle = zend_llist_get_next_ex(&pool->handles, &pos)) {
 177                         handles[i++] = *handle;
 178                 }
 179
 180                 /* should never happen */
 181                 if (i != count) {
 182                         zend_error(E_ERROR, "number of fetched request handles do not match overall count");
 183                         count = i;
 184                 }
 185
 186                 for (i = 0; i < count; ++i) {
 187                         http_request_pool_detach(pool, handles[i]);
 188                 }
 189                 efree(handles);
 190         }
 191
 192 #if HTTP_DEBUG_REQPOOLS
 193         fprintf(stderr, "Destroying %d request bodies of pool %p\n", zend_llist_count(&pool->bodies), pool);
 194 #endif
 195
 196         /* free created bodies too */
 197         zend_llist_clean(&pool->bodies);
 198 }
 199
 200 /* {{{ STATUS http_request_pool_send(http_request_pool *) */
 201 PHP_HTTP_API STATUS _http_request_pool_send(http_request_pool *pool TSRMLS_DC)
 202 {
 203 #if HTTP_DEBUG_REQPOOLS
 204         fprintf(stderr, "Attempt to send %d requests of pool %p\n", zend_llist_count(&pool->handles), pool);
 205 #endif
 206
 207         while (http_request_pool_perform(pool)) {
 208                 if (SUCCESS != http_request_pool_select(pool)) {
 209 #ifdef PHP_WIN32
 210                         http_error(HE_WARNING, HTTP_E_SOCKET, WSAGetLastError());
 211 #else
 212                         http_error(HE_WARNING, HTTP_E_SOCKET, strerror(errno));
 213 #endif
 214                         return FAILURE;
 215                 }
 216         }
 217
 218 #if HTTP_DEBUG_REQPOOLS
 219         fprintf(stderr, "Finished sending %d HttpRequests of pool %p (still unfinished: %d)\n", zend_llist_count(&pool->handles), pool, pool->unfinished);
 220 #endif
 221
 222         return SUCCESS;
 223 }
 224 /* }}} */
 225
 226 /* {{{ void http_request_pool_dtor(http_request_pool *) */
 227 PHP_HTTP_API void _http_request_pool_dtor(http_request_pool *pool TSRMLS_DC)
 228 {
 229 #if HTTP_DEBUG_REQPOOLS
 230         fprintf(stderr, "Destructing request pool %p\n", pool);
 231 #endif
 232
 233         pool->unfinished = 0;
 234         zend_llist_clean(&pool->finished);
 235         zend_llist_clean(&pool->handles);
 236         zend_llist_clean(&pool->bodies);
 237         curl_multi_cleanup(pool->ch);
 238 }
 239 /* }}} */
 240
 241 #ifdef PHP_WIN32
 242 #       define SELECT_ERROR SOCKET_ERROR
 243 #else
 244 #       define SELECT_ERROR -1
 245 #endif
 246
 247 /* {{{ STATUS http_request_pool_select(http_request_pool *) */
 248 PHP_HTTP_API STATUS _http_request_pool_select(http_request_pool *pool)
 249 {
 250         int MAX;
 251         fd_set R, W, E;
 252         struct timeval timeout = {1, 0};
 253
 254         FD_ZERO(&R);
 255         FD_ZERO(&W);
 256         FD_ZERO(&E);
 257
 258         if (CURLM_OK == curl_multi_fdset(pool->ch, &R, &W, &E, &MAX)) {
 259                 if (MAX == -1 || SELECT_ERROR != select(MAX + 1, &R, &W, &E, &timeout)) {
 260                         return SUCCESS;
 261                 }
 262         }
 263         return FAILURE;
 264 }
 265 /* }}} */
 266
 267 /* {{{ int http_request_pool_perform(http_request_pool *) */
 268 PHP_HTTP_API int _http_request_pool_perform(http_request_pool *pool TSRMLS_DC)
 269 {
 270         CURLMsg *msg;
 271         int remaining = 0;
 272
 273         while (CURLM_CALL_MULTI_PERFORM == curl_multi_perform(pool->ch, &pool->unfinished));
 274
 275         while ((msg = curl_multi_info_read(pool->ch, &remaining))) {
 276                 if (CURLMSG_DONE == msg->msg) {
 277                         if (CURLE_OK != msg->data.result) {
 278                                 zval *old_exception = EG(exception);
 279
 280                                 if (old_exception) {
 281                                         EG(exception) = NULL;
 282                                 }
 283                                 http_error(HE_WARNING, HTTP_E_REQUEST, curl_easy_strerror(msg->data.result));
 284                                 if (old_exception) {
 285                                         http_request_pool_wrap_exception(old_exception, EG(exception));
 286                                 }
 287                         }
 288                         zend_llist_apply_with_argument(&pool->handles, (llist_apply_with_arg_func_t) http_request_pool_responsehandler, msg->easy_handle TSRMLS_CC);
 289                 }
 290         }
 291         if (EG(exception)) {
 292                 zval *exception = EG(exception);
 293
 294                 EG(exception) = NULL;
 295                 zend_throw_exception_object(exception TSRMLS_CC);
 296         }
 297
 298         return pool->unfinished;
 299 }
 300 /* }}} */
 301
 302 /* {{{ STATUS http_request_pool_requesthandler(zval *, http_request_body *) */
 303 STATUS _http_request_pool_requesthandler(zval *request, http_request_body *body TSRMLS_DC)
 304 {
 305         getObjectEx(http_request_object, req, request);
 306         if (SUCCESS == http_request_object_requesthandler(req, request, body)) {
 307                 http_request_conv(req->ch, &req->response, &req->request);
 308                 return SUCCESS;
 309         }
 310         return FAILURE;
 311 }
 312 /* }}} */
 313
 314 /* {{{ void http_request_pool_responsehandler(zval **) */
 315 void _http_request_pool_responsehandler(zval **req, CURL *ch TSRMLS_DC)
 316 {
 317         getObjectEx(http_request_object, obj, *req);
 318
 319         if (obj->ch == ch) {
 320
 321 #if HTTP_DEBUG_REQPOOLS
 322                 fprintf(stderr, "Fetching data from HttpRequest(#%d) %p of pool %p\n", Z_OBJ_HANDLE_PP(req), obj, obj->pool);
 323 #endif
 324
 325                 ZVAL_ADDREF(*req);
 326                 zend_llist_add_element(&obj->pool->finished, req);
 327                 http_request_object_responsehandler(obj, *req);
 328         }
 329 }
 330 /* }}} */
 331
 332 /*#*/
 333
 334 /* {{{ static void http_request_pool_wrap_exception(zval *, zval *) */
 335 static inline void _http_request_pool_wrap_exception(zval *old_exception, zval *new_exception TSRMLS_DC)
 336 {
 337         zend_class_entry *ce = HTTP_EX_CE(request_pool);
 338
 339         /*      if old_exception is already an HttpRequestPoolException append the new one,
 340                 else create a new HttpRequestPoolException and append the old and new exceptions */
 341         if (Z_OBJCE_P(old_exception) == ce) {
 342                 zval *exprop;
 343
 344                 exprop = zend_read_property(ce, old_exception, "requestExceptions", sizeof("requestExceptions")-1, 0 TSRMLS_CC);
 345                 SEP_PROP(&exprop);
 346                 convert_to_array(exprop);
 347
 348                 add_next_index_zval(exprop, new_exception);
 349                 zend_update_property(ce, old_exception, "requestExceptions", sizeof("requestExceptions")-1, exprop TSRMLS_CC);
 350                 zval_ptr_dtor(&exprop);
 351
 352                 EG(exception) = old_exception;
 353         } else {
 354                 zval *exval, *exprop;
 355
 356                 MAKE_STD_ZVAL(exval);
 357                 object_init_ex(exval, ce);
 358                 MAKE_STD_ZVAL(exprop);
 359                 array_init(exprop);
 360
 361                 add_next_index_zval(exprop, old_exception);
 362                 add_next_index_zval(exprop, new_exception);
 363                 zend_update_property(ce, exval, "requestExceptions", sizeof("requestExceptions")-1, exprop TSRMLS_CC);
 364                 zval_ptr_dtor(&exprop);
 365
 366                 EG(exception) = exval;
 367         }
 368 }
 369 /* }}} */
 370
 371 /* {{{ static void http_request_pool_freebody(http_request_ctx **) */
 372 static void http_request_pool_freebody(http_request_callback_ctx **body)
 373 {
 374         HTTP_REQUEST_CALLBACK_DATA(*body, http_request_body *, b);
 375         http_request_body_free(b);
 376         efree(*body);
 377 }
 378 /* }}} */
 379
 380 /* {{{ static int http_request_pool_compare_handles(void *, void *) */
 381 static int http_request_pool_compare_handles(void *h1, void *h2)
 382 {
 383         return (Z_OBJ_HANDLE_PP((zval **) h1) == Z_OBJ_HANDLE_P((zval *) h2));
 384 }
 385 /* }}} */
 386
 387 #endif /* ZEND_ENGINE_2 && HTTP_HAVE_CURL */
 388
 389
 390 /*
 391  * Local variables:
 392  * tab-width: 4
 393  * c-basic-offset: 4
 394  * End:
 395  * vim600: noet sw=4 ts=4 fdm=marker
 396  * vim<600: noet sw=4 ts=4
 397  */
 398