X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=php_http_client_curl.c;fp=php_http_client_curl.c;h=fbb950ac276eb4a059a4494746601dea236c3fa1;hb=87db9817d428282792c8146d9c2ae9748ebf6f1e;hp=0000000000000000000000000000000000000000;hpb=7a5c865f6faf8b1b6c91735e9d3b040449ea74ba;p=m6w6%2Fext-http

diff --git a/php_http_client_curl.c b/php_http_client_curl.c
new file mode 100644
index 0000000..fbb950a
--- /dev/null
+++ b/php_http_client_curl.c
@@ -0,0 +1,2006 @@
+/*
+    +--------------------------------------------------------------------+
+    | 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-2013, Michael Wallner <mike@php.net>            |
+    +--------------------------------------------------------------------+
+*/
+
+#include "php_http_api.h"
+#include "php_http_client.h"
+
+#if PHP_HTTP_HAVE_CURL
+
+#if PHP_HTTP_HAVE_EVENT
+#	include <event.h>
+#	if !PHP_HTTP_HAVE_EVENT2 && /* just be really sure */ !(LIBEVENT_VERSION_NUMBER >= 0x02000000)
+#		define event_base_new event_init
+#		define event_assign(e, b, s, a, cb, d) do {\
+			event_set(e, s, a, cb, d); \
+			event_base_set(b, e); \
+		} while(0)
+#	endif
+#	ifndef DBG_EVENTS
+#		define DBG_EVENTS 0
+#	endif
+#endif
+
+typedef struct php_http_client_curl {
+	CURLM *handle;
+
+	int unfinished;  /* int because of curl_multi_perform() */
+
+#if PHP_HTTP_HAVE_EVENT
+	struct event *timeout;
+	unsigned useevents:1;
+#endif
+} php_http_client_curl_t;
+
+typedef struct php_http_client_curl_handler {
+	CURL *handle;
+	php_resource_factory_t *rf;
+	php_http_client_t *client;
+	php_http_client_progress_state_t progress;
+
+	php_http_client_enqueue_t queue;
+
+	struct {
+		php_http_message_parser_t *parser;
+		php_http_message_t *message;
+		php_http_buffer_t *buffer;
+	} request;
+
+	struct {
+		php_http_message_parser_t *parser;
+		php_http_message_t *message;
+		php_http_buffer_t *buffer;
+	} response;
+
+	struct {
+		HashTable cache;
+
+		struct curl_slist *headers;
+		struct curl_slist *resolve;
+		php_http_buffer_t cookies;
+		php_http_buffer_t ranges;
+
+		long redirects;
+		unsigned range_request:1;
+		unsigned encode_cookies:1;
+
+		struct {
+			uint count;
+			double delay;
+		} retry;
+
+	} options;
+
+} php_http_client_curl_handler_t;
+
+typedef struct php_http_curle_storage {
+	char *url;
+	char *cookiestore;
+	char errorbuffer[0x100];
+} php_http_curle_storage_t;
+
+static inline php_http_curle_storage_t *php_http_curle_get_storage(CURL *ch) {
+	php_http_curle_storage_t *st = NULL;
+
+	curl_easy_getinfo(ch, CURLINFO_PRIVATE, &st);
+
+	if (!st) {
+		st = pecalloc(1, sizeof(*st), 1);
+		curl_easy_setopt(ch, CURLOPT_PRIVATE, st);
+		curl_easy_setopt(ch, CURLOPT_ERRORBUFFER, st->errorbuffer);
+	}
+
+	return st;
+}
+
+static void *php_http_curle_ctor(void *opaque, void *init_arg TSRMLS_DC)
+{
+	void *ch;
+
+	if ((ch = curl_easy_init())) {
+		php_http_curle_get_storage(ch);
+		return ch;
+	}
+	return NULL;
+}
+
+static void *php_http_curle_copy(void *opaque, void *handle TSRMLS_DC)
+{
+	void *ch;
+
+	if ((ch = curl_easy_duphandle(handle))) {
+		curl_easy_reset(ch);
+		php_http_curle_get_storage(ch);
+		return ch;
+	}
+	return NULL;
+}
+
+static void php_http_curle_dtor(void *opaque, void *handle TSRMLS_DC)
+{
+	php_http_curle_storage_t *st = php_http_curle_get_storage(handle);
+
+	curl_easy_cleanup(handle);
+
+	if (st) {
+		if (st->url) {
+			pefree(st->url, 1);
+		}
+		if (st->cookiestore) {
+			pefree(st->cookiestore, 1);
+		}
+		pefree(st, 1);
+	}
+}
+
+static php_resource_factory_ops_t php_http_curle_resource_factory_ops = {
+	php_http_curle_ctor,
+	php_http_curle_copy,
+	php_http_curle_dtor
+};
+
+static void *php_http_curlm_ctor(void *opaque, void *init_arg TSRMLS_DC)
+{
+	return curl_multi_init();
+}
+
+static void php_http_curlm_dtor(void *opaque, void *handle TSRMLS_DC)
+{
+	curl_multi_cleanup(handle);
+}
+
+static php_resource_factory_ops_t php_http_curlm_resource_factory_ops = {
+	php_http_curlm_ctor,
+	NULL,
+	php_http_curlm_dtor
+};
+
+/* curl callbacks */
+
+static size_t php_http_curle_read_callback(void *data, size_t len, size_t n, void *ctx)
+{
+	php_http_message_body_t *body = ctx;
+
+	if (body) {
+		TSRMLS_FETCH_FROM_CTX(body->ts);
+		return php_stream_read(php_http_message_body_stream(body), data, len * n);
+	}
+	return 0;
+}
+
+static int php_http_curle_progress_callback(void *ctx, double dltotal, double dlnow, double ultotal, double ulnow)
+{
+	php_http_client_curl_handler_t *h = ctx;
+	zend_bool update = 0;
+
+	if (h->progress.dl.total != dltotal
+	||	h->progress.dl.now != dlnow
+	||	h->progress.ul.total != ultotal
+	||	h->progress.ul.now != ulnow
+	) {
+		update = 1;
+
+		h->progress.dl.total = dltotal;
+		h->progress.dl.now = dlnow;
+		h->progress.ul.total = ultotal;
+		h->progress.ul.now = ulnow;
+	}
+
+	if (update && h->client->callback.progress.func) {
+		h->client->callback.progress.func(h->client->callback.progress.arg, h->client, &h->queue, &h->progress);
+	}
+
+	return 0;
+}
+
+static curlioerr php_http_curle_ioctl_callback(CURL *ch, curliocmd cmd, void *ctx)
+{
+	php_http_message_body_t *body = ctx;
+
+	if (cmd != CURLIOCMD_RESTARTREAD) {
+		return CURLIOE_UNKNOWNCMD;
+	}
+
+	if (body) {
+		TSRMLS_FETCH_FROM_CTX(body->ts);
+
+		if (SUCCESS == php_stream_rewind(php_http_message_body_stream(body))) {
+			return CURLIOE_OK;
+		}
+	}
+
+	return CURLIOE_FAILRESTART;
+}
+
+static int php_http_curle_raw_callback(CURL *ch, curl_infotype type, char *data, size_t length, void *ctx)
+{
+	php_http_client_curl_handler_t *h = ctx;
+	unsigned flags = 0;
+
+	/* catch progress */
+	switch (type) {
+		case CURLINFO_TEXT:
+			if (data[0] == '-') {
+			} else if (php_memnstr(data, ZEND_STRL("Adding handle:"), data + length)) {
+				h->progress.info = "setup";
+			} else if (php_memnstr(data, ZEND_STRL("addHandle"), data + length)) {
+				h->progress.info = "setup";
+			} else if (php_memnstr(data, ZEND_STRL("About to connect"), data + length)) {
+				h->progress.info = "resolve";
+			} else if (php_memnstr(data, ZEND_STRL("Trying"), data + length)) {
+				h->progress.info = "connect";
+			} else if (php_memnstr(data, ZEND_STRL("Found bundle for host"), data + length)) {
+				h->progress.info = "connect";
+			} else if (php_memnstr(data, ZEND_STRL("Connected"), data + length)) {
+				h->progress.info = "connected";
+			} else if (php_memnstr(data, ZEND_STRL("Re-using existing connection!"), data + length)) {
+				h->progress.info = "connected";
+			} else if (php_memnstr(data, ZEND_STRL("blacklisted"), data + length)) {
+				h->progress.info = "blacklist check";
+			} else if (php_memnstr(data, ZEND_STRL("SSL"), data + length)) {
+				h->progress.info = "ssl negotiation";
+			} else if (php_memnstr(data, ZEND_STRL("left intact"), data + length)) {
+				h->progress.info = "not disconnected";
+			} else if (php_memnstr(data, ZEND_STRL("closed"), data + length)) {
+				h->progress.info = "disconnected";
+			} else if (php_memnstr(data, ZEND_STRL("Issue another request"), data + length)) {
+				h->progress.info = "redirect";
+			} else if (php_memnstr(data, ZEND_STRL("Operation timed out"), data + length)) {
+				h->progress.info = "timeout";
+			} else {
+#if PHP_DEBUG
+				h->progress.info = data;
+#endif
+			}
+			if (h->client->callback.progress.func) {
+				h->client->callback.progress.func(h->client->callback.progress.arg, h->client, &h->queue, &h->progress);
+			}
+			break;
+		case CURLINFO_HEADER_OUT:
+		case CURLINFO_DATA_OUT:
+		case CURLINFO_SSL_DATA_OUT:
+			h->progress.info = "send";
+			break;
+		case CURLINFO_HEADER_IN:
+		case CURLINFO_DATA_IN:
+		case CURLINFO_SSL_DATA_IN:
+			h->progress.info = "receive";
+			break;
+		default:
+			break;
+	}
+	/* process data */
+	switch (type) {
+		case CURLINFO_HEADER_IN:
+		case CURLINFO_DATA_IN:
+			php_http_buffer_append(h->response.buffer, data, length);
+
+			if (h->options.redirects) {
+				flags |= PHP_HTTP_MESSAGE_PARSER_EMPTY_REDIRECTS;
+			}
+
+			if (PHP_HTTP_MESSAGE_PARSER_STATE_FAILURE == php_http_message_parser_parse(h->response.parser, h->response.buffer, flags, &h->response.message)) {
+				return -1;
+			}
+			break;
+
+		case CURLINFO_HEADER_OUT:
+		case CURLINFO_DATA_OUT:
+			php_http_buffer_append(h->request.buffer, data, length);
+
+			if (PHP_HTTP_MESSAGE_PARSER_STATE_FAILURE == php_http_message_parser_parse(h->request.parser, h->request.buffer, flags, &h->request.message)) {
+				return -1;
+			}
+			break;
+		default:
+			break;
+	}
+
+#if 0
+	/* debug */
+	_dpf(type, data, length);
+#endif
+
+	return 0;
+}
+
+static int php_http_curle_dummy_callback(char *data, size_t n, size_t l, void *s)
+{
+	return n*l;
+}
+
+static STATUS php_http_curle_get_info(CURL *ch, HashTable *info)
+{
+	char *c;
+	long l;
+	double d;
+	struct curl_slist *s, *p;
+	zval *subarray, array;
+	INIT_PZVAL_ARRAY(&array, info);
+
+	/* BEGIN::CURLINFO */
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_EFFECTIVE_URL, &c)) {
+		add_assoc_string_ex(&array, "effective_url", sizeof("effective_url"), c ? c : "", 1);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_RESPONSE_CODE, &l)) {
+		add_assoc_long_ex(&array, "response_code", sizeof("response_code"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_TOTAL_TIME, &d)) {
+		add_assoc_double_ex(&array, "total_time", sizeof("total_time"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_NAMELOOKUP_TIME, &d)) {
+		add_assoc_double_ex(&array, "namelookup_time", sizeof("namelookup_time"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONNECT_TIME, &d)) {
+		add_assoc_double_ex(&array, "connect_time", sizeof("connect_time"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PRETRANSFER_TIME, &d)) {
+		add_assoc_double_ex(&array, "pretransfer_time", sizeof("pretransfer_time"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SIZE_UPLOAD, &d)) {
+		add_assoc_double_ex(&array, "size_upload", sizeof("size_upload"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SIZE_DOWNLOAD, &d)) {
+		add_assoc_double_ex(&array, "size_download", sizeof("size_download"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SPEED_DOWNLOAD, &d)) {
+		add_assoc_double_ex(&array, "speed_download", sizeof("speed_download"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SPEED_UPLOAD, &d)) {
+		add_assoc_double_ex(&array, "speed_upload", sizeof("speed_upload"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_HEADER_SIZE, &l)) {
+		add_assoc_long_ex(&array, "header_size", sizeof("header_size"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REQUEST_SIZE, &l)) {
+		add_assoc_long_ex(&array, "request_size", sizeof("request_size"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SSL_VERIFYRESULT, &l)) {
+		add_assoc_long_ex(&array, "ssl_verifyresult", sizeof("ssl_verifyresult"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_FILETIME, &l)) {
+		add_assoc_long_ex(&array, "filetime", sizeof("filetime"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONTENT_LENGTH_DOWNLOAD, &d)) {
+		add_assoc_double_ex(&array, "content_length_download", sizeof("content_length_download"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONTENT_LENGTH_UPLOAD, &d)) {
+		add_assoc_double_ex(&array, "content_length_upload", sizeof("content_length_upload"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_STARTTRANSFER_TIME, &d)) {
+		add_assoc_double_ex(&array, "starttransfer_time", sizeof("starttransfer_time"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONTENT_TYPE, &c)) {
+		add_assoc_string_ex(&array, "content_type", sizeof("content_type"), c ? c : "", 1);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REDIRECT_TIME, &d)) {
+		add_assoc_double_ex(&array, "redirect_time", sizeof("redirect_time"), d);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REDIRECT_COUNT, &l)) {
+		add_assoc_long_ex(&array, "redirect_count", sizeof("redirect_count"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_HTTP_CONNECTCODE, &l)) {
+		add_assoc_long_ex(&array, "connect_code", sizeof("connect_code"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_HTTPAUTH_AVAIL, &l)) {
+		add_assoc_long_ex(&array, "httpauth_avail", sizeof("httpauth_avail"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PROXYAUTH_AVAIL, &l)) {
+		add_assoc_long_ex(&array, "proxyauth_avail", sizeof("proxyauth_avail"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_OS_ERRNO, &l)) {
+		add_assoc_long_ex(&array, "os_errno", sizeof("os_errno"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_NUM_CONNECTS, &l)) {
+		add_assoc_long_ex(&array, "num_connects", sizeof("num_connects"), l);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SSL_ENGINES, &s)) {
+		MAKE_STD_ZVAL(subarray);
+		array_init(subarray);
+		for (p = s; p; p = p->next) {
+			if (p->data) {
+				add_next_index_string(subarray, p->data, 1);
+			}
+		}
+		add_assoc_zval_ex(&array, "ssl_engines", sizeof("ssl_engines"), subarray);
+		curl_slist_free_all(s);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_COOKIELIST, &s)) {
+		MAKE_STD_ZVAL(subarray);
+		array_init(subarray);
+		for (p = s; p; p = p->next) {
+			if (p->data) {
+				add_next_index_string(subarray, p->data, 1);
+			}
+		}
+		add_assoc_zval_ex(&array, "cookies", sizeof("cookies"), subarray);
+		curl_slist_free_all(s);
+	}
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REDIRECT_URL, &c)) {
+		add_assoc_string_ex(&array, "redirect_url", sizeof("redirect_url"), c ? c : "", 1);
+	}
+#if PHP_HTTP_CURL_VERSION(7,19,0)
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PRIMARY_IP, &c)) {
+		add_assoc_string_ex(&array, "primary_ip", sizeof("primary_ip"), c ? c : "", 1);
+	}
+#endif
+#if PHP_HTTP_CURL_VERSION(7,19,0)
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_APPCONNECT_TIME, &d)) {
+		add_assoc_double_ex(&array, "appconnect_time", sizeof("appconnect_time"), d);
+	}
+#endif
+#if PHP_HTTP_CURL_VERSION(7,19,4)
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONDITION_UNMET, &l)) {
+		add_assoc_long_ex(&array, "condition_unmet", sizeof("condition_unmet"), l);
+	}
+#endif
+#if PHP_HTTP_CURL_VERSION(7,21,0)
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PRIMARY_PORT, &l)) {
+		add_assoc_long_ex(&array, "primary_port", sizeof("primary_port"), l);
+	}
+#endif
+#if PHP_HTTP_CURL_VERSION(7,21,0)
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_LOCAL_IP, &c)) {
+		add_assoc_string_ex(&array, "local_ip", sizeof("local_ip"), c ? c : "", 1);
+	}
+#endif
+#if PHP_HTTP_CURL_VERSION(7,21,0)
+	if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_LOCAL_PORT, &l)) {
+		add_assoc_long_ex(&array, "local_port", sizeof("local_port"), l);
+	}
+#endif
+
+	/* END::CURLINFO */
+
+#if PHP_HTTP_CURL_VERSION(7,19,1) && defined(PHP_HTTP_HAVE_OPENSSL)
+	{
+		int i;
+		zval *ci_array;
+		struct curl_certinfo *ci;
+		char *colon, *keyname;
+
+		if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CERTINFO, &ci)) {
+			MAKE_STD_ZVAL(ci_array);
+			array_init(ci_array);
+
+			for (i = 0; i < ci->num_of_certs; ++i) {
+				s = ci->certinfo[i];
+
+				MAKE_STD_ZVAL(subarray);
+				array_init(subarray);
+				for (p = s; p; p = p->next) {
+					if (p->data) {
+						if ((colon = strchr(p->data, ':'))) {
+							keyname = estrndup(p->data, colon - p->data);
+							add_assoc_string_ex(subarray, keyname, colon - p->data + 1, colon + 1, 1);
+							efree(keyname);
+						} else {
+							add_next_index_string(subarray, p->data, 1);
+						}
+					}
+				}
+				add_next_index_zval(ci_array, subarray);
+			}
+			add_assoc_zval_ex(&array, "certinfo", sizeof("certinfo"), ci_array);
+		}
+	}
+#endif
+	add_assoc_string_ex(&array, "error", sizeof("error"), php_http_curle_get_storage(ch)->errorbuffer, 1);
+
+	return SUCCESS;
+}
+
+static int compare_queue(php_http_client_enqueue_t *e, void *handle)
+{
+	return handle == ((php_http_client_curl_handler_t *) e->opaque)->handle;
+}
+
+static void php_http_curlm_responsehandler(php_http_client_t *context)
+{
+	int remaining = 0;
+	php_http_client_enqueue_t *enqueue;
+	php_http_client_curl_t *curl = context->ctx;
+	TSRMLS_FETCH_FROM_CTX(context->ts);
+
+	do {
+		CURLMsg *msg = curl_multi_info_read(curl->handle, &remaining);
+
+		if (msg && CURLMSG_DONE == msg->msg) {
+			if (CURLE_OK != msg->data.result) {
+				php_http_curle_storage_t *st = php_http_curle_get_storage(msg->easy_handle);
+				php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s; %s (%s)", curl_easy_strerror(msg->data.result), STR_PTR(st->errorbuffer), STR_PTR(st->url));
+			}
+
+			if ((enqueue = php_http_client_enqueued(context, msg->easy_handle, compare_queue))) {
+				php_http_client_curl_handler_t *handler = enqueue->opaque;
+
+				context->callback.response.func(context->callback.response.arg, context, &handler->queue, &handler->request.message, &handler->response.message);
+			}
+		}
+	} while (remaining);
+}
+
+#if PHP_HTTP_HAVE_EVENT
+
+typedef struct php_http_curlm_event {
+	struct event evnt;
+	php_http_client_t *context;
+} php_http_curlm_event_t;
+
+static inline int etoca(short action) {
+	switch (action & (EV_READ|EV_WRITE)) {
+		case EV_READ:
+			return CURL_CSELECT_IN;
+			break;
+		case EV_WRITE:
+			return CURL_CSELECT_OUT;
+			break;
+		case EV_READ|EV_WRITE:
+			return CURL_CSELECT_IN|CURL_CSELECT_OUT;
+			break;
+		default:
+			return 0;
+	}
+}
+
+static void php_http_curlm_timeout_callback(int socket, short action, void *event_data)
+{
+	php_http_client_t *context = event_data;
+	php_http_client_curl_t *curl = context->ctx;
+
+#if DBG_EVENTS
+	fprintf(stderr, "T");
+#endif
+	if (curl->useevents) {
+		CURLMcode rc;
+		TSRMLS_FETCH_FROM_CTX(context->ts);
+
+		/* ignore and use -1,0 on timeout */
+		(void) socket;
+		(void) action;
+
+		while (CURLM_CALL_MULTI_PERFORM == (rc = curl_multi_socket_action(curl->handle, CURL_SOCKET_TIMEOUT, 0, &curl->unfinished)));
+
+		if (CURLM_OK != rc) {
+			php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s",  curl_multi_strerror(rc));
+		}
+
+		php_http_curlm_responsehandler(context);
+	}
+}
+
+static void php_http_curlm_event_callback(int socket, short action, void *event_data)
+{
+	php_http_client_t *context = event_data;
+	php_http_client_curl_t *curl = context->ctx;
+
+#if DBG_EVENTS
+	fprintf(stderr, "E");
+#endif
+	if (curl->useevents) {
+		CURLMcode rc = CURLM_OK;
+		TSRMLS_FETCH_FROM_CTX(context->ts);
+
+		while (CURLM_CALL_MULTI_PERFORM == (rc = curl_multi_socket_action(curl->handle, socket, etoca(action), &curl->unfinished)));
+
+		if (CURLM_OK != rc) {
+			php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", curl_multi_strerror(rc));
+		}
+
+		php_http_curlm_responsehandler(context);
+
+		/* remove timeout if there are no transfers left */
+		if (!curl->unfinished && event_initialized(curl->timeout) && event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
+			event_del(curl->timeout);
+		}
+	}
+}
+
+static int php_http_curlm_socket_callback(CURL *easy, curl_socket_t sock, int action, void *socket_data, void *assign_data)
+{
+	php_http_client_t *context = socket_data;
+	php_http_client_curl_t *curl = context->ctx;
+
+#if DBG_EVENTS
+	fprintf(stderr, "S");
+#endif
+	if (curl->useevents) {
+		int events = EV_PERSIST;
+		php_http_curlm_event_t *ev = assign_data;
+		TSRMLS_FETCH_FROM_CTX(context->ts);
+
+		if (!ev) {
+			ev = ecalloc(1, sizeof(php_http_curlm_event_t));
+			ev->context = context;
+			curl_multi_assign(curl->handle, sock, ev);
+		} else {
+			event_del(&ev->evnt);
+		}
+
+		switch (action) {
+			case CURL_POLL_IN:
+				events |= EV_READ;
+				break;
+			case CURL_POLL_OUT:
+				events |= EV_WRITE;
+				break;
+			case CURL_POLL_INOUT:
+				events |= EV_READ|EV_WRITE;
+				break;
+
+			case CURL_POLL_REMOVE:
+				efree(ev);
+				/* no break */
+			case CURL_POLL_NONE:
+				return 0;
+
+			default:
+				php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unknown socket action %d", action);
+				return -1;
+		}
+
+		event_assign(&ev->evnt, PHP_HTTP_G->curl.event_base, sock, events, php_http_curlm_event_callback, context);
+		event_add(&ev->evnt, NULL);
+	}
+
+	return 0;
+}
+
+static void php_http_curlm_timer_callback(CURLM *multi, long timeout_ms, void *timer_data)
+{
+	php_http_client_t *context = timer_data;
+	php_http_client_curl_t *curl = context->ctx;
+
+#if DBG_EVENTS
+	fprintf(stderr, "\ntimer <- timeout_ms: %ld\n", timeout_ms);
+#endif
+	if (curl->useevents) {
+
+		if (timeout_ms < 0) {
+			php_http_curlm_timeout_callback(CURL_SOCKET_TIMEOUT, /*EV_READ|EV_WRITE*/0, context);
+		} else if (timeout_ms > 0 || !event_initialized(curl->timeout) || !event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
+			struct timeval timeout;
+			TSRMLS_FETCH_FROM_CTX(context->ts);
+
+			if (!event_initialized(curl->timeout)) {
+				event_assign(curl->timeout, PHP_HTTP_G->curl.event_base, CURL_SOCKET_TIMEOUT, 0, php_http_curlm_timeout_callback, context);
+			} else if (event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
+				event_del(curl->timeout);
+			}
+
+			timeout.tv_sec = timeout_ms / 1000;
+			timeout.tv_usec = (timeout_ms % 1000) * 1000;
+
+			event_add(curl->timeout, &timeout);
+		}
+	}
+}
+
+#endif /* HAVE_EVENT */
+
+/* curl options */
+
+static php_http_options_t php_http_curle_options;
+
+#define PHP_HTTP_CURLE_OPTION_CHECK_STRLEN	0x0001
+#define PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR	0x0002
+#define PHP_HTTP_CURLE_OPTION_TRANSFORM_MS	0x0004
+
+static STATUS php_http_curle_option_set_ssl_verifyhost(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+
+	if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_SSL_VERIFYHOST, Z_BVAL_P(val) ? 2 : 0)) {
+		return FAILURE;
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_cookiestore(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+
+	if (val) {
+		php_http_curle_storage_t *storage = php_http_curle_get_storage(curl->handle);
+
+		if (storage->cookiestore) {
+			pefree(storage->cookiestore, 1);
+		}
+		storage->cookiestore = pestrndup(Z_STRVAL_P(val), Z_STRLEN_P(val), 1);
+		if (	CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIEFILE, storage->cookiestore)
+			||	CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIEJAR, storage->cookiestore)
+		) {
+			return FAILURE;
+		}
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_cookies(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	if (val && Z_TYPE_P(val) != IS_NULL) {
+		if (curl->options.encode_cookies) {
+			if (SUCCESS == php_http_url_encode_hash_ex(HASH_OF(val), &curl->options.cookies, ZEND_STRL(";"), ZEND_STRL("="), NULL, 0 TSRMLS_CC)) {
+				php_http_buffer_fix(&curl->options.cookies);
+				if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIE, curl->options.cookies.data)) {
+					return FAILURE;
+				}
+			} else {
+				return FAILURE;
+			}
+		} else {
+			HashPosition pos;
+			php_http_array_hashkey_t cookie_key = php_http_array_hashkey_init(0);
+			zval **cookie_val;
+
+			FOREACH_KEYVAL(pos, val, cookie_key, cookie_val) {
+				zval *zv = php_http_ztyp(IS_STRING, *cookie_val);
+
+				php_http_array_hashkey_stringify(&cookie_key);
+				php_http_buffer_appendf(&curl->options.cookies, "%s=%s; ", cookie_key.str, Z_STRVAL_P(zv));
+				php_http_array_hashkey_stringfree(&cookie_key);
+
+				zval_ptr_dtor(&zv);
+			}
+
+			php_http_buffer_fix(&curl->options.cookies);
+			if (curl->options.cookies.used) {
+				if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIE, curl->options.cookies.data)) {
+					return FAILURE;
+				}
+			}
+		}
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_encodecookies(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+
+	curl->options.encode_cookies = Z_BVAL_P(val);
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_lastmodified(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	if (Z_LVAL_P(val)) {
+		if (Z_LVAL_P(val) > 0) {
+			if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMEVALUE, Z_LVAL_P(val))) {
+				return FAILURE;
+			}
+		} else {
+			if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMEVALUE, (long) PHP_HTTP_G->env.request.time + Z_LVAL_P(val))) {
+				return FAILURE;
+			}
+		}
+		if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMECONDITION, (long) (curl->options.range_request ? CURL_TIMECOND_IFUNMODSINCE : CURL_TIMECOND_IFMODSINCE))) {
+			return FAILURE;
+		}
+	} else {
+		if (	CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMEVALUE, 0)
+			||	CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMECONDITION, 0)
+		) {
+			return FAILURE;
+		}
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_compress(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+
+	if (Z_BVAL_P(val)) {
+		curl->options.headers = curl_slist_append(curl->options.headers, "Accept-Encoding: gzip;q=1.0,deflate;q=0.5");
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_etag(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	php_http_buffer_t header;
+	zend_bool is_quoted = !((Z_STRVAL_P(val)[0] != '"') || (Z_STRVAL_P(val)[Z_STRLEN_P(val)-1] != '"'));
+
+	php_http_buffer_init(&header);
+	php_http_buffer_appendf(&header, is_quoted?"%s: %s":"%s: \"%s\"", curl->options.range_request?"If-Match":"If-None-Match", Z_STRVAL_P(val));
+	php_http_buffer_fix(&header);
+	curl->options.headers = curl_slist_append(curl->options.headers, header.data);
+	php_http_buffer_dtor(&header);
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_range(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	php_http_buffer_reset(&curl->options.ranges);
+
+	if (val && Z_TYPE_P(val) != IS_NULL) {
+		HashPosition pos;
+		zval **rr, **rb, **re;
+
+		FOREACH_VAL(pos, val, rr) {
+			if (Z_TYPE_PP(rr) == IS_ARRAY) {
+				if (2 == php_http_array_list(Z_ARRVAL_PP(rr) TSRMLS_CC, 2, &rb, &re)) {
+					if (	((Z_TYPE_PP(rb) == IS_LONG) || ((Z_TYPE_PP(rb) == IS_STRING) && is_numeric_string(Z_STRVAL_PP(rb), Z_STRLEN_PP(rb), NULL, NULL, 1))) &&
+							((Z_TYPE_PP(re) == IS_LONG) || ((Z_TYPE_PP(re) == IS_STRING) && is_numeric_string(Z_STRVAL_PP(re), Z_STRLEN_PP(re), NULL, NULL, 1)))) {
+						zval *rbl = php_http_ztyp(IS_LONG, *rb);
+						zval *rel = php_http_ztyp(IS_LONG, *re);
+
+						if ((Z_LVAL_P(rbl) >= 0) && (Z_LVAL_P(rel) >= 0)) {
+							php_http_buffer_appendf(&curl->options.ranges, "%ld-%ld,", Z_LVAL_P(rbl), Z_LVAL_P(rel));
+						}
+						zval_ptr_dtor(&rbl);
+						zval_ptr_dtor(&rel);
+					}
+
+				}
+			}
+		}
+
+		if (curl->options.ranges.used) {
+			curl->options.range_request = 1;
+			/* ditch last comma */
+			curl->options.ranges.data[curl->options.ranges.used - 1] = '\0';
+		}
+	}
+
+	if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RANGE, curl->options.ranges.data)) {
+		return FAILURE;
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_resume(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+
+	if (Z_LVAL_P(val) > 0) {
+		curl->options.range_request = 1;
+	}
+	if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RESUME_FROM, Z_LVAL_P(val))) {
+		return FAILURE;
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_retrydelay(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+
+	curl->options.retry.delay = Z_DVAL_P(val);
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_retrycount(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+
+	curl->options.retry.count = Z_LVAL_P(val);
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_redirect(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+
+	if (	CURLE_OK != curl_easy_setopt(ch, CURLOPT_FOLLOWLOCATION, Z_LVAL_P(val) ? 1L : 0L)
+		||	CURLE_OK != curl_easy_setopt(ch, CURLOPT_MAXREDIRS, curl->options.redirects = Z_LVAL_P(val))
+	) {
+		return FAILURE;
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_curle_option_set_portrange(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+	long localport = 0, localportrange = 0;
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	if (val && Z_TYPE_P(val) != IS_NULL) {
+		zval **z_port_start, *zps_copy = NULL, **z_port_end, *zpe_copy = NULL;
+
+		switch (php_http_array_list(Z_ARRVAL_P(val) TSRMLS_CC, 2, &z_port_start, &z_port_end)) {
+		case 2:
+			zps_copy = php_http_ztyp(IS_LONG, *z_port_start);
+			zpe_copy = php_http_ztyp(IS_LONG, *z_port_end);
+			localportrange = labs(Z_LVAL_P(zps_copy)-Z_LVAL_P(zpe_copy))+1L;
+			/* no break */
+		case 1:
+			if (!zps_copy) {
+				zps_copy = php_http_ztyp(IS_LONG, *z_port_start);
+			}
+			localport = (zpe_copy && Z_LVAL_P(zpe_copy) > 0) ? MIN(Z_LVAL_P(zps_copy), Z_LVAL_P(zpe_copy)) : Z_LVAL_P(zps_copy);
+			zval_ptr_dtor(&zps_copy);
+			if (zpe_copy) {
+				zval_ptr_dtor(&zpe_copy);
+			}
+			break;
+		default:
+			break;
+		}
+	}
+	if (	CURLE_OK != curl_easy_setopt(ch, CURLOPT_LOCALPORT, localport)
+		||	CURLE_OK != curl_easy_setopt(ch, CURLOPT_LOCALPORTRANGE, localportrange)
+	) {
+		return FAILURE;
+	}
+	return SUCCESS;
+}
+
+#if PHP_HTTP_CURL_VERSION(7,21,3)
+static STATUS php_http_curle_option_set_resolve(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	if (val && Z_TYPE_P(val) != IS_NULL) {
+		php_http_array_hashkey_t key = php_http_array_hashkey_init(0);
+		HashPosition pos;
+		zval **data;
+
+		FOREACH_KEYVAL(pos, val, key, data) {
+			zval *cpy = php_http_ztyp(IS_STRING, *data);
+			curl->options.resolve = curl_slist_append(curl->options.resolve, Z_STRVAL_P(cpy));
+			zval_ptr_dtor(&cpy);
+		}
+
+		if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RESOLVE, curl->options.resolve)) {
+			return FAILURE;
+		}
+	} else {
+		if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RESOLVE, NULL)) {
+			return FAILURE;
+		}
+	}
+	return SUCCESS;
+}
+#endif
+
+static void php_http_curle_options_init(php_http_options_t *registry TSRMLS_DC)
+{
+	php_http_option_t *opt;
+
+	/* proxy */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("proxyhost"), CURLOPT_PROXY, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+	}
+	php_http_option_register(registry, ZEND_STRL("proxytype"), CURLOPT_PROXYTYPE, IS_LONG);
+	php_http_option_register(registry, ZEND_STRL("proxyport"), CURLOPT_PROXYPORT, IS_LONG);
+	if ((opt = php_http_option_register(registry, ZEND_STRL("proxyauth"), CURLOPT_PROXYUSERPWD, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("proxyauthtype"), CURLOPT_PROXYAUTH, IS_LONG))) {
+		Z_LVAL(opt->defval) = CURLAUTH_ANYSAFE;
+	}
+	php_http_option_register(registry, ZEND_STRL("proxytunnel"), CURLOPT_HTTPPROXYTUNNEL, IS_BOOL);
+#if PHP_HTTP_CURL_VERSION(7,19,4)
+	php_http_option_register(registry, ZEND_STRL("noproxy"), CURLOPT_NOPROXY, IS_STRING);
+#endif
+
+	/* dns */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("dns_cache_timeout"), CURLOPT_DNS_CACHE_TIMEOUT, IS_LONG))) {
+		Z_LVAL(opt->defval) = 60;
+	}
+	php_http_option_register(registry, ZEND_STRL("ipresolve"), CURLOPT_IPRESOLVE, IS_LONG);
+#if PHP_HTTP_CURL_VERSION(7,21,3)
+	if ((opt = php_http_option_register(registry, ZEND_STRL("resolve"), CURLOPT_RESOLVE, IS_ARRAY))) {
+		opt->setter = php_http_curle_option_set_resolve;
+	}
+#endif
+#if PHP_HTTP_CURL_VERSION(7,24,0)
+	if ((opt = php_http_option_register(registry, ZEND_STRL("dns_servers"), CURLOPT_DNS_SERVERS, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+	}
+#endif
+
+	/* limits */
+	php_http_option_register(registry, ZEND_STRL("low_speed_limit"), CURLOPT_LOW_SPEED_LIMIT, IS_LONG);
+	php_http_option_register(registry, ZEND_STRL("low_speed_time"), CURLOPT_LOW_SPEED_TIME, IS_LONG);
+
+	/* LSF weirdance
+	php_http_option_register(registry, ZEND_STRL("max_send_speed"), CURLOPT_MAX_SEND_SPEED_LARGE, IS_LONG);
+	php_http_option_register(registry, ZEND_STRL("max_recv_speed"), CURLOPT_MAX_RECV_SPEED_LARGE, IS_LONG);
+	*/
+
+	/* connection handling */
+	/* crashes
+	if ((opt = php_http_option_register(registry, ZEND_STRL("maxconnects"), CURLOPT_MAXCONNECTS, IS_LONG))) {
+		Z_LVAL(opt->defval) = 5;
+	}
+	*/
+	php_http_option_register(registry, ZEND_STRL("fresh_connect"), CURLOPT_FRESH_CONNECT, IS_BOOL);
+	php_http_option_register(registry, ZEND_STRL("forbid_reuse"), CURLOPT_FORBID_REUSE, IS_BOOL);
+
+	/* outgoing interface */
+	php_http_option_register(registry, ZEND_STRL("interface"), CURLOPT_INTERFACE, IS_STRING);
+	if ((opt = php_http_option_register(registry, ZEND_STRL("portrange"), CURLOPT_LOCALPORT, IS_ARRAY))) {
+		opt->setter = php_http_curle_option_set_portrange;
+	}
+
+	/* another endpoint port */
+	php_http_option_register(registry, ZEND_STRL("port"), CURLOPT_PORT, IS_LONG);
+
+	/* RFC4007 zone_id */
+#if PHP_HTTP_CURL_VERSION(7,19,0)
+	php_http_option_register(registry, ZEND_STRL("address_scope"), CURLOPT_ADDRESS_SCOPE, IS_LONG);
+#endif
+
+	/* auth */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("httpauth"), CURLOPT_USERPWD, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("httpauthtype"), CURLOPT_HTTPAUTH, IS_LONG))) {
+		Z_LVAL(opt->defval) = CURLAUTH_ANYSAFE;
+	}
+
+	/* redirects */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("redirect"), CURLOPT_FOLLOWLOCATION, IS_LONG))) {
+		opt->setter = php_http_curle_option_set_redirect;
+	}
+	php_http_option_register(registry, ZEND_STRL("unrestricted_auth"), CURLOPT_UNRESTRICTED_AUTH, IS_BOOL);
+#if PHP_HTTP_CURL_VERSION(7,19,1)
+	php_http_option_register(registry, ZEND_STRL("postredir"), CURLOPT_POSTREDIR, IS_LONG);
+#endif
+
+	/* retries */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("retrycount"), 0, IS_LONG))) {
+		opt->setter = php_http_curle_option_set_retrycount;
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("retrydelay"), 0, IS_DOUBLE))) {
+		opt->setter = php_http_curle_option_set_retrydelay;
+	}
+
+	/* referer */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("referer"), CURLOPT_REFERER, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("autoreferer"), CURLOPT_AUTOREFERER, IS_BOOL))) {
+		ZVAL_BOOL(&opt->defval, 1);
+	}
+
+	/* useragent */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("useragent"), CURLOPT_USERAGENT, IS_STRING))) {
+		/* don't check strlen, to allow sending no useragent at all */
+		ZVAL_STRING(&opt->defval, "PECL::HTTP/" PHP_HTTP_EXT_VERSION " (PHP/" PHP_VERSION ")", 0);
+	}
+
+	/* resume */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("resume"), CURLOPT_RESUME_FROM, IS_LONG))) {
+		opt->setter = php_http_curle_option_set_resume;
+	}
+	/* ranges */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("range"), CURLOPT_RANGE, IS_ARRAY))) {
+		opt->setter = php_http_curle_option_set_range;
+	}
+
+	/* etag */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("etag"), 0, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+		opt->setter = php_http_curle_option_set_etag;
+	}
+
+	/* compression */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("compress"), 0, IS_BOOL))) {
+		opt->setter = php_http_curle_option_set_compress;
+	}
+
+	/* lastmodified */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("lastmodified"), 0, IS_LONG))) {
+		opt->setter = php_http_curle_option_set_lastmodified;
+	}
+
+	/* cookies */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("encodecookies"), 0, IS_BOOL))) {
+		opt->setter = php_http_curle_option_set_encodecookies;
+		ZVAL_BOOL(&opt->defval, 1);
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("cookies"), 0, IS_ARRAY))) {
+		opt->setter = php_http_curle_option_set_cookies;
+	}
+
+	/* cookiesession, don't load session cookies from cookiestore */
+	php_http_option_register(registry, ZEND_STRL("cookiesession"), CURLOPT_COOKIESESSION, IS_BOOL);
+	/* cookiestore, read initial cookies from that file and store cookies back into that file */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("cookiestore"), 0, IS_STRING))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+		opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		opt->setter = php_http_curle_option_set_cookiestore;
+	}
+
+	/* maxfilesize */
+	php_http_option_register(registry, ZEND_STRL("maxfilesize"), CURLOPT_MAXFILESIZE, IS_LONG);
+
+	/* http protocol version */
+	php_http_option_register(registry, ZEND_STRL("protocol"), CURLOPT_HTTP_VERSION, IS_LONG);
+
+	/* timeouts */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("timeout"), CURLOPT_TIMEOUT_MS, IS_DOUBLE))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_TRANSFORM_MS;
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("connecttimeout"), CURLOPT_CONNECTTIMEOUT_MS, IS_DOUBLE))) {
+		opt->flags |= PHP_HTTP_CURLE_OPTION_TRANSFORM_MS;
+		Z_DVAL(opt->defval) = 3;
+	}
+
+	/* tcp */
+#if PHP_HTTP_CURL_VERSION(7,25,0)
+	php_http_option_register(registry, ZEND_STRL("tcp_keepalive"), CURLOPT_TCP_KEEPALIVE, IS_BOOL);
+	if ((opt = php_http_option_register(registry, ZEND_STRL("tcp_keepidle"), CURLOPT_TCP_KEEPIDLE, IS_LONG))) {
+		Z_LVAL(opt->defval) = 60;
+	}
+	if ((opt = php_http_option_register(registry, ZEND_STRL("tcp_keepintvl"), CURLOPT_TCP_KEEPINTVL, IS_LONG))) {
+		Z_LVAL(opt->defval) = 60;
+	}
+#endif
+
+	/* ssl */
+	if ((opt = php_http_option_register(registry, ZEND_STRL("ssl"), 0, IS_ARRAY))) {
+		registry = &opt->suboptions;
+
+		if ((opt = php_http_option_register(registry, ZEND_STRL("cert"), CURLOPT_SSLCERT, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+		php_http_option_register(registry, ZEND_STRL("certtype"), CURLOPT_SSLCERTTYPE, IS_STRING);
+
+		if ((opt = php_http_option_register(registry, ZEND_STRL("key"), CURLOPT_SSLKEY, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+		php_http_option_register(registry, ZEND_STRL("keytype"), CURLOPT_SSLKEYTYPE, IS_STRING);
+		php_http_option_register(registry, ZEND_STRL("keypasswd"), CURLOPT_SSLKEYPASSWD, IS_STRING);
+		php_http_option_register(registry, ZEND_STRL("engine"), CURLOPT_SSLENGINE, IS_STRING);
+		php_http_option_register(registry, ZEND_STRL("version"), CURLOPT_SSLVERSION, IS_LONG);
+		if ((opt = php_http_option_register(registry, ZEND_STRL("verifypeer"), CURLOPT_SSL_VERIFYPEER, IS_BOOL))) {
+			ZVAL_BOOL(&opt->defval, 1);
+		}
+		if ((opt = php_http_option_register(registry, ZEND_STRL("verifyhost"), CURLOPT_SSL_VERIFYHOST, IS_BOOL))) {
+			ZVAL_BOOL(&opt->defval, 1);
+			opt->setter = php_http_curle_option_set_ssl_verifyhost;
+		}
+		php_http_option_register(registry, ZEND_STRL("cipher_list"), CURLOPT_SSL_CIPHER_LIST, IS_STRING);
+		if ((opt = php_http_option_register(registry, ZEND_STRL("cainfo"), CURLOPT_CAINFO, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+#ifdef PHP_HTTP_CURL_CAINFO
+			ZVAL_STRING(&opt->defval, PHP_HTTP_CURL_CAINFO, 0);
+#endif
+		}
+		if ((opt = php_http_option_register(registry, ZEND_STRL("capath"), CURLOPT_CAPATH, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+		if ((opt = php_http_option_register(registry, ZEND_STRL("random_file"), CURLOPT_RANDOM_FILE, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+		if ((opt = php_http_option_register(registry, ZEND_STRL("egdsocket"), CURLOPT_EGDSOCKET, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+#if PHP_HTTP_CURL_VERSION(7,19,0)
+		if ((opt = php_http_option_register(registry, ZEND_STRL("issuercert"), CURLOPT_ISSUERCERT, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+#	ifdef PHP_HTTP_HAVE_OPENSSL
+		if ((opt = php_http_option_register(registry, ZEND_STRL("crlfile"), CURLOPT_CRLFILE, IS_STRING))) {
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
+			opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
+		}
+#	endif
+#endif
+#if PHP_HTTP_CURL_VERSION(7,19,1) && defined(PHP_HTTP_HAVE_OPENSSL)
+		php_http_option_register(registry, ZEND_STRL("certinfo"), CURLOPT_CERTINFO, IS_BOOL);
+#endif
+	}
+}
+
+static zval *php_http_curle_get_option(php_http_option_t *opt, HashTable *options, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	zval *option;
+
+	if ((option = php_http_option_get(opt, options, NULL))) {
+		option = php_http_ztyp(opt->type, option);
+		zend_hash_quick_update(&curl->options.cache, opt->name.s, opt->name.l, opt->name.h, &option, sizeof(zval *), NULL);
+	}
+	return option;
+}
+
+static STATUS php_http_curle_set_option(php_http_option_t *opt, zval *val, void *userdata)
+{
+	php_http_client_curl_handler_t *curl = userdata;
+	CURL *ch = curl->handle;
+	zval tmp;
+	STATUS rv = SUCCESS;
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	if (!val) {
+		val = &opt->defval;
+	}
+
+	switch (opt->type) {
+	case IS_BOOL:
+		if (opt->setter) {
+			rv = opt->setter(opt, val, curl);
+		} else if (CURLE_OK != curl_easy_setopt(ch, opt->option, (long) Z_BVAL_P(val))) {
+			rv = FAILURE;
+		}
+		break;
+
+	case IS_LONG:
+		if (opt->setter) {
+			rv = opt->setter(opt, val, curl);
+		} else if (CURLE_OK != curl_easy_setopt(ch, opt->option, Z_LVAL_P(val))) {
+			rv = FAILURE;
+		}
+		break;
+
+	case IS_STRING:
+		if (!(opt->flags & PHP_HTTP_CURLE_OPTION_CHECK_STRLEN) || Z_STRLEN_P(val)) {
+			if (!(opt->flags & PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR) || !Z_STRVAL_P(val) || SUCCESS == php_check_open_basedir(Z_STRVAL_P(val) TSRMLS_CC)) {
+				if (opt->setter) {
+					rv = opt->setter(opt, val, curl);
+				} else if (CURLE_OK != curl_easy_setopt(ch, opt->option, Z_STRVAL_P(val))) {
+					rv = FAILURE;
+				}
+			}
+		}
+		break;
+
+	case IS_DOUBLE:
+		if (opt->flags & PHP_HTTP_CURLE_OPTION_TRANSFORM_MS) {
+			tmp = *val;
+			Z_DVAL(tmp) *= 1000;
+			val = &tmp;
+		}
+		if (opt->setter) {
+			rv = opt->setter(opt, val, curl);
+		} else if (CURLE_OK != curl_easy_setopt(ch, opt->option, (long) Z_DVAL_P(val))) {
+			rv = FAILURE;
+		}
+		break;
+
+	case IS_ARRAY:
+		if (opt->setter) {
+			rv = opt->setter(opt, val, curl);
+		} else if (Z_TYPE_P(val) != IS_NULL) {
+			rv = php_http_options_apply(&opt->suboptions, Z_ARRVAL_P(val), curl);
+		}
+		break;
+
+	default:
+		if (opt->setter) {
+			rv = opt->setter(opt, val, curl);
+		} else {
+			rv = FAILURE;
+		}
+		break;
+	}
+	if (rv != SUCCESS) {
+		php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Could not set option %s", opt->name.s);
+	}
+	return rv;
+}
+
+
+/* client ops */
+
+static STATUS php_http_client_curl_handler_reset(php_http_client_curl_handler_t *curl)
+{
+	CURL *ch = curl->handle;
+	php_http_curle_storage_t *st;
+
+	if ((st = php_http_curle_get_storage(ch))) {
+		if (st->url) {
+			pefree(st->url, 1);
+			st->url = NULL;
+		}
+		if (st->cookiestore) {
+			pefree(st->cookiestore, 1);
+			st->cookiestore = NULL;
+		}
+		st->errorbuffer[0] = '\0';
+	}
+
+	curl_easy_setopt(ch, CURLOPT_URL, NULL);
+	/* libcurl < 7.19.6 does not clear auth info with USERPWD set to NULL */
+#if PHP_HTTP_CURL_VERSION(7,19,1)
+	curl_easy_setopt(ch, CURLOPT_PROXYUSERNAME, NULL);
+	curl_easy_setopt(ch, CURLOPT_PROXYPASSWORD, NULL);
+	curl_easy_setopt(ch, CURLOPT_USERNAME, NULL);
+	curl_easy_setopt(ch, CURLOPT_PASSWORD, NULL);
+#endif
+
+#if PHP_HTTP_CURL_VERSION(7,21,3)
+	if (curl->options.resolve) {
+		curl_slist_free_all(curl->options.resolve);
+		curl->options.resolve = NULL;
+	}
+#endif
+	curl->options.retry.count = 0;
+	curl->options.retry.delay = 0;
+	curl->options.redirects = 0;
+	curl->options.encode_cookies = 1;
+
+	if (curl->options.headers) {
+		curl_slist_free_all(curl->options.headers);
+		curl->options.headers = NULL;
+	}
+
+	php_http_buffer_reset(&curl->options.cookies);
+	php_http_buffer_reset(&curl->options.ranges);
+
+	return SUCCESS;
+}
+
+static php_http_client_curl_handler_t *php_http_client_curl_handler_init(php_http_client_t *h, php_resource_factory_t *rf)
+{
+	void *handle;
+	php_http_client_curl_handler_t *handler;
+	TSRMLS_FETCH_FROM_CTX(h->ts);
+
+	if (!(handle = php_resource_factory_handle_ctor(rf, NULL TSRMLS_CC))) {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed to initialize curl handle");
+		return NULL;
+	}
+
+	handler = ecalloc(1, sizeof(*handler));
+	handler->rf = rf;
+	handler->client = h;
+	handler->handle = handle;
+	handler->request.buffer = php_http_buffer_init(NULL);
+	handler->request.parser = php_http_message_parser_init(NULL TSRMLS_CC);
+	handler->request.message = php_http_message_init(NULL, 0, NULL TSRMLS_CC);
+	handler->response.buffer = php_http_buffer_init(NULL);
+	handler->response.parser = php_http_message_parser_init(NULL TSRMLS_CC);
+	handler->response.message = php_http_message_init(NULL, 0, NULL TSRMLS_CC);
+	php_http_buffer_init(&handler->options.cookies);
+	php_http_buffer_init(&handler->options.ranges);
+	zend_hash_init(&handler->options.cache, 0, NULL, ZVAL_PTR_DTOR, 0);
+
+#if defined(ZTS)
+	curl_easy_setopt(handle, CURLOPT_NOSIGNAL, 1L);
+#endif
+	curl_easy_setopt(handle, CURLOPT_HEADER, 0L);
+	curl_easy_setopt(handle, CURLOPT_FILETIME, 1L);
+	curl_easy_setopt(handle, CURLOPT_AUTOREFERER, 1L);
+	curl_easy_setopt(handle, CURLOPT_VERBOSE, 1L);
+	curl_easy_setopt(handle, CURLOPT_NOPROGRESS, 0L);
+	curl_easy_setopt(handle, CURLOPT_HEADERFUNCTION, NULL);
+	curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, php_http_curle_dummy_callback);
+	curl_easy_setopt(handle, CURLOPT_DEBUGFUNCTION, php_http_curle_raw_callback);
+	curl_easy_setopt(handle, CURLOPT_READFUNCTION, php_http_curle_read_callback);
+	curl_easy_setopt(handle, CURLOPT_IOCTLFUNCTION, php_http_curle_ioctl_callback);
+	curl_easy_setopt(handle, CURLOPT_PROGRESSFUNCTION, php_http_curle_progress_callback);
+	curl_easy_setopt(handle, CURLOPT_DEBUGDATA, handler);
+	curl_easy_setopt(handle, CURLOPT_PROGRESSDATA, handler);
+
+	php_http_client_curl_handler_reset(handler);
+
+	return handler;
+}
+
+
+static STATUS php_http_client_curl_handler_prepare(php_http_client_curl_handler_t *curl, php_http_client_enqueue_t *enqueue)
+{
+	size_t body_size;
+	php_http_message_t *msg = enqueue->request;
+	php_http_curle_storage_t *storage = php_http_curle_get_storage(curl->handle);
+	TSRMLS_FETCH_FROM_CTX(curl->client->ts);
+
+	/* request url */
+	if (!PHP_HTTP_INFO(msg).request.url) {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot request empty URL");
+		return FAILURE;
+	}
+	storage->errorbuffer[0] = '\0';
+	if (storage->url) {
+		pefree(storage->url, 1);
+	}
+	storage->url = pestrdup(PHP_HTTP_INFO(msg).request.url, 1);
+	curl_easy_setopt(curl->handle, CURLOPT_URL, storage->url);
+
+	/* request method */
+	switch (php_http_select_str(PHP_HTTP_INFO(msg).request.method, 4, "GET", "HEAD", "POST", "PUT")) {
+		case 0:
+			curl_easy_setopt(curl->handle, CURLOPT_HTTPGET, 1L);
+			break;
+
+		case 1:
+			curl_easy_setopt(curl->handle, CURLOPT_NOBODY, 1L);
+			break;
+
+		case 2:
+			curl_easy_setopt(curl->handle, CURLOPT_POST, 1L);
+			break;
+
+		case 3:
+			curl_easy_setopt(curl->handle, CURLOPT_UPLOAD, 1L);
+			break;
+
+		default: {
+			if (PHP_HTTP_INFO(msg).request.method) {
+				curl_easy_setopt(curl->handle, CURLOPT_CUSTOMREQUEST, PHP_HTTP_INFO(msg).request.method);
+			} else {
+				php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot use empty request method");
+				return FAILURE;
+			}
+			break;
+		}
+	}
+
+	/* request headers */
+	php_http_message_update_headers(msg);
+	if (zend_hash_num_elements(&msg->hdrs)) {
+		php_http_array_hashkey_t header_key = php_http_array_hashkey_init(0);
+		zval **header_val;
+		HashPosition pos;
+		php_http_buffer_t header;
+
+		php_http_buffer_init(&header);
+		FOREACH_HASH_KEYVAL(pos, &msg->hdrs, header_key, header_val) {
+			if (header_key.type == HASH_KEY_IS_STRING) {
+				zval *header_cpy = php_http_ztyp(IS_STRING, *header_val);
+
+				php_http_buffer_appendf(&header, "%s: %s", header_key.str, Z_STRVAL_P(header_cpy));
+				php_http_buffer_fix(&header);
+				curl->options.headers = curl_slist_append(curl->options.headers, header.data);
+				php_http_buffer_reset(&header);
+
+				zval_ptr_dtor(&header_cpy);
+			}
+		}
+		php_http_buffer_dtor(&header);
+		curl_easy_setopt(curl->handle, CURLOPT_HTTPHEADER, curl->options.headers);
+	}
+
+	/* attach request body */
+	if ((body_size = php_http_message_body_size(msg->body))) {
+		/* RFC2616, section 4.3 (para. 4) states that »a message-body MUST NOT be included in a request if the
+		 * specification of the request method (section 5.1.1) does not allow sending an entity-body in request.«
+		 * Following the clause in section 5.1.1 (para. 2) that request methods »MUST be implemented with the
+		 * same semantics as those specified in section 9« reveal that not any single defined HTTP/1.1 method
+		 * does not allow a request body.
+		 */
+		php_stream_rewind(php_http_message_body_stream(msg->body));
+		curl_easy_setopt(curl->handle, CURLOPT_IOCTLDATA, msg->body);
+		curl_easy_setopt(curl->handle, CURLOPT_READDATA, msg->body);
+		curl_easy_setopt(curl->handle, CURLOPT_INFILESIZE, body_size);
+		curl_easy_setopt(curl->handle, CURLOPT_POSTFIELDSIZE, body_size);
+	}
+
+	php_http_options_apply(&php_http_curle_options, enqueue->options, curl);
+
+	return SUCCESS;
+}
+
+static void php_http_client_curl_handler_dtor(php_http_client_curl_handler_t *handler)
+{
+	TSRMLS_FETCH_FROM_CTX(handler->client->ts);
+
+	curl_easy_setopt(handler->handle, CURLOPT_NOPROGRESS, 1L);
+	curl_easy_setopt(handler->handle, CURLOPT_PROGRESSFUNCTION, NULL);
+	curl_easy_setopt(handler->handle, CURLOPT_VERBOSE, 0L);
+	curl_easy_setopt(handler->handle, CURLOPT_DEBUGFUNCTION, NULL);
+
+	php_resource_factory_handle_dtor(handler->rf, handler->handle TSRMLS_CC);
+	php_resource_factory_free(&handler->rf);
+
+	php_http_message_parser_free(&handler->request.parser);
+	php_http_message_free(&handler->request.message);
+	php_http_buffer_free(&handler->request.buffer);
+	php_http_message_parser_free(&handler->response.parser);
+	php_http_message_free(&handler->response.message);
+	php_http_buffer_free(&handler->response.buffer);
+	php_http_buffer_dtor(&handler->options.ranges);
+	php_http_buffer_dtor(&handler->options.cookies);
+	zend_hash_destroy(&handler->options.cache);
+
+	if (handler->options.headers) {
+		curl_slist_free_all(handler->options.headers);
+		handler->options.headers = NULL;
+	}
+
+	efree(handler);
+}
+
+static php_http_client_t *php_http_client_curl_init(php_http_client_t *h, void *handle)
+{
+	php_http_client_curl_t *curl;
+	TSRMLS_FETCH_FROM_CTX(h->ts);
+
+	if (!handle && !(handle = php_resource_factory_handle_ctor(h->rf, NULL TSRMLS_CC))) {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed to initialize curl handle");
+		return NULL;
+	}
+
+	curl = ecalloc(1, sizeof(*curl));
+	curl->handle = handle;
+	curl->unfinished = 0;
+	h->ctx = curl;
+
+	return h;
+}
+
+static void php_http_client_curl_dtor(php_http_client_t *h)
+{
+	php_http_client_curl_t *curl = h->ctx;
+	TSRMLS_FETCH_FROM_CTX(h->ts);
+
+#if PHP_HTTP_HAVE_EVENT
+	if (curl->timeout) {
+		efree(curl->timeout);
+		curl->timeout = NULL;
+	}
+#endif
+	curl->unfinished = 0;
+
+	php_resource_factory_handle_dtor(h->rf, curl->handle TSRMLS_CC);
+
+	efree(curl);
+	h->ctx = NULL;
+}
+
+static void queue_dtor(php_http_client_enqueue_t *e)
+{
+	php_http_client_curl_handler_t *handler = e->opaque;
+
+	if (handler->queue.dtor) {
+		e->opaque = handler->queue.opaque;
+		handler->queue.dtor(e);
+	}
+	php_http_client_curl_handler_dtor(handler);
+}
+
+static php_resource_factory_t *create_rf(const char *url TSRMLS_DC)
+{
+	php_url *purl;
+	php_resource_factory_t *rf = NULL;
+
+	if (!url || !*url) {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot request empty URL");
+		return NULL;
+	}
+
+	purl = php_url_parse(url);
+
+	if (!purl) {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not parse URL '%s'", url);
+		return NULL;
+	} else {
+		char *id_str = NULL;
+		size_t id_len = spprintf(&id_str, 0, "%s:%d", STR_PTR(purl->host), purl->port ? purl->port : 80);
+		php_persistent_handle_factory_t *pf = php_persistent_handle_concede(NULL, ZEND_STRL("http\\Client\\Curl\\Request"), id_str, id_len, NULL, NULL TSRMLS_CC);
+
+		if (pf) {
+			rf = php_resource_factory_init(NULL, php_persistent_handle_get_resource_factory_ops(), pf, (void (*)(void*)) php_persistent_handle_abandon);
+		}
+
+		php_url_free(purl);
+		efree(id_str);
+	}
+
+	if (!rf) {
+		rf = php_resource_factory_init(NULL, &php_http_curle_resource_factory_ops, NULL, NULL);
+	}
+
+	return rf;
+}
+
+static STATUS php_http_client_curl_enqueue(php_http_client_t *h, php_http_client_enqueue_t *enqueue)
+{
+	CURLMcode rs;
+	php_http_client_curl_t *curl = h->ctx;
+	php_http_client_curl_handler_t *handler;
+	php_http_client_progress_state_t *progress;
+	php_resource_factory_t *rf;
+	TSRMLS_FETCH_FROM_CTX(h->ts);
+
+	rf = create_rf(enqueue->request->http.info.request.url TSRMLS_CC);
+	if (!rf) {
+		return FAILURE;
+	}
+
+	handler = php_http_client_curl_handler_init(h, rf);
+	if (!handler) {
+		return FAILURE;
+	}
+
+	if (SUCCESS != php_http_client_curl_handler_prepare(handler, enqueue)) {
+		php_http_client_curl_handler_dtor(handler);
+		return FAILURE;
+	}
+
+	handler->queue = *enqueue;
+	enqueue->opaque = handler;
+	enqueue->dtor = queue_dtor;
+
+	if (CURLM_OK == (rs = curl_multi_add_handle(curl->handle, handler->handle))) {
+		zend_llist_add_element(&h->requests, enqueue);
+		++curl->unfinished;
+
+		if (h->callback.progress.func && SUCCESS == php_http_client_getopt(h, PHP_HTTP_CLIENT_OPT_PROGRESS_INFO, enqueue->request, &progress)) {
+			progress->info = "start";
+			h->callback.progress.func(h->callback.progress.arg, h, &handler->queue, progress);
+			progress->started = 1;
+		}
+
+		return SUCCESS;
+	} else {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not enqueue request: %s", curl_multi_strerror(rs));
+		return FAILURE;
+	}
+}
+
+static STATUS php_http_client_curl_dequeue(php_http_client_t *h, php_http_client_enqueue_t *enqueue)
+{
+	CURLMcode rs;
+	php_http_client_curl_t *curl = h->ctx;
+	php_http_client_curl_handler_t *handler = enqueue->opaque;
+	TSRMLS_FETCH_FROM_CTX(h->ts);
+
+	if (CURLM_OK == (rs = curl_multi_remove_handle(curl->handle, handler->handle))) {
+		zend_llist_del_element(&h->requests, handler->handle, (int (*)(void *, void *)) compare_queue);
+		return SUCCESS;
+	} else {
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not dequeue request: %s", curl_multi_strerror(rs));
+	}
+
+	return FAILURE;
+}
+
+static void php_http_client_curl_reset(php_http_client_t *h)
+{
+	zend_llist_element *next_el, *this_el;
+
+	for (this_el = h->requests.head; this_el; this_el = next_el) {
+		next_el = this_el->next;
+		php_http_client_curl_dequeue(h, (void *) this_el->data);
+	}
+}
+
+#ifdef PHP_WIN32
+#	define SELECT_ERROR SOCKET_ERROR
+#else
+#	define SELECT_ERROR -1
+#endif
+
+static STATUS php_http_client_curl_wait(php_http_client_t *h, struct timeval *custom_timeout)
+{
+	int MAX;
+	fd_set R, W, E;
+	struct timeval timeout;
+	php_http_client_curl_t *curl = h->ctx;
+
+#if PHP_HTTP_HAVE_EVENT
+	if (curl->useevents) {
+		TSRMLS_FETCH_FROM_CTX(h->ts);
+
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "not implemented");
+		return FAILURE;
+	}
+#endif
+
+	FD_ZERO(&R);
+	FD_ZERO(&W);
+	FD_ZERO(&E);
+
+	if (CURLM_OK == curl_multi_fdset(curl->handle, &R, &W, &E, &MAX)) {
+		if (custom_timeout && timerisset(custom_timeout)) {
+			timeout = *custom_timeout;
+		} else {
+			long max_tout = 1000;
+
+			if ((CURLM_OK == curl_multi_timeout(curl->handle, &max_tout)) && (max_tout > 0)) {
+				timeout.tv_sec = max_tout / 1000;
+				timeout.tv_usec = (max_tout % 1000) * 1000;
+			} else {
+				timeout.tv_sec = 0;
+				timeout.tv_usec = 1000;
+			}
+		}
+
+		if (MAX == -1) {
+			php_http_sleep((double) timeout.tv_sec + (double) (timeout.tv_usec / PHP_HTTP_MCROSEC));
+			return SUCCESS;
+		} else if (SELECT_ERROR != select(MAX + 1, &R, &W, &E, &timeout)) {
+			return SUCCESS;
+		}
+	}
+	return FAILURE;
+}
+
+static int php_http_client_curl_once(php_http_client_t *h)
+{
+	php_http_client_curl_t *curl = h->ctx;
+
+#if PHP_HTTP_HAVE_EVENT
+	if (curl->useevents) {
+		TSRMLS_FETCH_FROM_CTX(h->ts);
+		php_error_docref(NULL TSRMLS_CC, E_WARNING, "not implemented");
+		return FAILURE;
+	}
+#endif
+
+	while (CURLM_CALL_MULTI_PERFORM == curl_multi_perform(curl->handle, &curl->unfinished));
+
+	php_http_curlm_responsehandler(h);
+
+	return curl->unfinished;
+
+}
+
+static STATUS php_http_client_curl_exec(php_http_client_t *h)
+{
+	TSRMLS_FETCH_FROM_CTX(h->ts);
+
+#if PHP_HTTP_HAVE_EVENT
+	php_http_client_curl_t *curl = h->ctx;
+
+	if (curl->useevents) {
+		php_http_curlm_timeout_callback(CURL_SOCKET_TIMEOUT, /*EV_READ|EV_WRITE*/0, h);
+		do {
+			int ev_rc = event_base_dispatch(PHP_HTTP_G->curl.event_base);
+
+#if DBG_EVENTS
+			fprintf(stderr, "%c", "X.0"[ev_rc+1]);
+#endif
+
+			if (ev_rc < 0) {
+				php_error_docref(NULL TSRMLS_CC, E_ERROR, "Error in event_base_dispatch()");
+				return FAILURE;
+			}
+		} while (curl->unfinished);
+	} else
+#endif
+	{
+		while (php_http_client_curl_once(h)) {
+			if (SUCCESS != php_http_client_curl_wait(h, NULL)) {
+#ifdef PHP_WIN32
+				/* see http://msdn.microsoft.com/library/en-us/winsock/winsock/windows_sockets_error_codes_2.asp */
+				php_error_docref(NULL TSRMLS_CC, E_WARNING, "WinSock error: %d", WSAGetLastError());
+#else
+				php_error_docref(NULL TSRMLS_CC, E_WARNING, strerror(errno));
+#endif
+				return FAILURE;
+			}
+		}
+	}
+
+	return SUCCESS;
+}
+
+static STATUS php_http_client_curl_setopt(php_http_client_t *h, php_http_client_setopt_opt_t opt, void *arg)
+{
+	php_http_client_curl_t *curl = h->ctx;
+
+	switch (opt) {
+		case PHP_HTTP_CLIENT_OPT_ENABLE_PIPELINING:
+			if (CURLM_OK != curl_multi_setopt(curl->handle, CURLMOPT_PIPELINING, (long) *((zend_bool *) arg))) {
+				return FAILURE;
+			}
+			break;
+
+		case PHP_HTTP_CLIENT_OPT_USE_EVENTS:
+#if PHP_HTTP_HAVE_EVENT
+			if ((curl->useevents = *((zend_bool *) arg))) {
+				if (!curl->timeout) {
+					curl->timeout = ecalloc(1, sizeof(struct event));
+				}
+				curl_multi_setopt(curl->handle, CURLMOPT_SOCKETDATA, h);
+				curl_multi_setopt(curl->handle, CURLMOPT_SOCKETFUNCTION, php_http_curlm_socket_callback);
+				curl_multi_setopt(curl->handle, CURLMOPT_TIMERDATA, h);
+				curl_multi_setopt(curl->handle, CURLMOPT_TIMERFUNCTION, php_http_curlm_timer_callback);
+			} else {
+				curl_multi_setopt(curl->handle, CURLMOPT_SOCKETDATA, NULL);
+				curl_multi_setopt(curl->handle, CURLMOPT_SOCKETFUNCTION, NULL);
+				curl_multi_setopt(curl->handle, CURLMOPT_TIMERDATA, NULL);
+				curl_multi_setopt(curl->handle, CURLMOPT_TIMERFUNCTION, NULL);
+			}
+			break;
+#endif
+
+		default:
+			return FAILURE;
+	}
+	return SUCCESS;
+}
+
+static STATUS php_http_client_curl_getopt(php_http_client_t *h, php_http_client_getopt_opt_t opt, void *arg, void **res)
+{
+	php_http_client_enqueue_t *enqueue;
+
+	switch (opt) {
+	case PHP_HTTP_CLIENT_OPT_PROGRESS_INFO:
+		if ((enqueue = php_http_client_enqueued(h, arg, NULL))) {
+			php_http_client_curl_handler_t *handler = enqueue->opaque;
+
+			*((php_http_client_progress_state_t **) res) = &handler->progress;
+			return SUCCESS;
+		}
+		break;
+
+	case PHP_HTTP_CLIENT_OPT_TRANSFER_INFO:
+		if ((enqueue = php_http_client_enqueued(h, arg, NULL))) {
+			php_http_client_curl_handler_t *handler = enqueue->opaque;
+
+			php_http_curle_get_info(handler->handle, *(HashTable **) res);
+			return SUCCESS;
+		}
+		break;
+
+	default:
+		break;
+	}
+
+	return FAILURE;
+}
+
+static php_http_client_ops_t php_http_client_curl_ops = {
+	&php_http_curlm_resource_factory_ops,
+	php_http_client_curl_init,
+	NULL /* copy */,
+	php_http_client_curl_dtor,
+	php_http_client_curl_reset,
+	php_http_client_curl_exec,
+	php_http_client_curl_wait,
+	php_http_client_curl_once,
+	php_http_client_curl_enqueue,
+	php_http_client_curl_dequeue,
+	php_http_client_curl_setopt,
+	php_http_client_curl_getopt
+};
+
+php_http_client_ops_t *php_http_client_curl_get_ops(void)
+{
+	return &php_http_client_curl_ops;
+}
+
+PHP_MINIT_FUNCTION(http_client_curl)
+{
+	php_http_options_t *options;
+	php_http_client_driver_t driver = {
+		ZEND_STRL("curl"),
+		&php_http_client_curl_ops
+	};
+
+	if (SUCCESS != php_http_client_driver_add(&driver)) {
+			return FAILURE;
+		}
+
+	if (SUCCESS != php_persistent_handle_provide(ZEND_STRL("http\\Client\\Curl"), &php_http_curlm_resource_factory_ops, NULL, NULL TSRMLS_CC)) {
+		return FAILURE;
+	}
+	if (SUCCESS != php_persistent_handle_provide(ZEND_STRL("http\\Client\\Curl\\Request"), &php_http_curle_resource_factory_ops, NULL, NULL TSRMLS_CC)) {
+		return FAILURE;
+	}
+
+	if ((options = php_http_options_init(&php_http_curle_options, 1))) {
+		options->getter = php_http_curle_get_option;
+		options->setter = php_http_curle_set_option;
+
+		php_http_curle_options_init(options TSRMLS_CC);
+	}
+
+	/*
+	* HTTP Protocol Version Constants
+	*/
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_1_0", CURL_HTTP_VERSION_1_0, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_1_1", CURL_HTTP_VERSION_1_1, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_ANY", CURL_HTTP_VERSION_NONE, CONST_CS|CONST_PERSISTENT);
+
+	/*
+	* SSL Version Constants
+	*/
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_TLSv1", CURL_SSLVERSION_TLSv1, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_SSLv2", CURL_SSLVERSION_SSLv2, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_SSLv3", CURL_SSLVERSION_SSLv3, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_ANY", CURL_SSLVERSION_DEFAULT, CONST_CS|CONST_PERSISTENT);
+
+	/*
+	* DNS IPvX resolving
+	*/
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "IPRESOLVE_V4", CURL_IPRESOLVE_V4, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "IPRESOLVE_V6", CURL_IPRESOLVE_V6, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "IPRESOLVE_ANY", CURL_IPRESOLVE_WHATEVER, CONST_CS|CONST_PERSISTENT);
+
+	/*
+	* Auth Constants
+	*/
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_BASIC", CURLAUTH_BASIC, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_DIGEST", CURLAUTH_DIGEST, CONST_CS|CONST_PERSISTENT);
+#if PHP_HTTP_CURL_VERSION(7,19,3)
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_DIGEST_IE", CURLAUTH_DIGEST_IE, CONST_CS|CONST_PERSISTENT);
+#endif
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_NTLM", CURLAUTH_NTLM, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_GSSNEG", CURLAUTH_GSSNEGOTIATE, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_ANY", CURLAUTH_ANY, CONST_CS|CONST_PERSISTENT);
+
+	/*
+	* Proxy Type Constants
+	*/
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS4", CURLPROXY_SOCKS4, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS4A", CURLPROXY_SOCKS5, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS5_HOSTNAME", CURLPROXY_SOCKS5, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS5", CURLPROXY_SOCKS5, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_HTTP", CURLPROXY_HTTP, CONST_CS|CONST_PERSISTENT);
+#	if PHP_HTTP_CURL_VERSION(7,19,4)
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_HTTP_1_0", CURLPROXY_HTTP_1_0, CONST_CS|CONST_PERSISTENT);
+#	endif
+
+	/*
+	* Post Redirection Constants
+	*/
+#if PHP_HTTP_CURL_VERSION(7,19,1)
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_301", CURL_REDIR_POST_301, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_302", CURL_REDIR_POST_302, CONST_CS|CONST_PERSISTENT);
+	REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_ALL", CURL_REDIR_POST_ALL, CONST_CS|CONST_PERSISTENT);
+#endif
+
+	return SUCCESS;
+}
+
+PHP_MSHUTDOWN_FUNCTION(http_client_curl)
+{
+	php_http_options_dtor(&php_http_curle_options);
+	return SUCCESS;
+}
+
+#if PHP_HTTP_HAVE_EVENT
+PHP_RINIT_FUNCTION(http_client_curl)
+{
+	if (!PHP_HTTP_G->curl.event_base && !(PHP_HTTP_G->curl.event_base = event_base_new())) {
+		return FAILURE;
+	}
+	return SUCCESS;
+}
+PHP_RSHUTDOWN_FUNCTION(http_client_curl)
+{
+	if (PHP_HTTP_G->curl.event_base) {
+		event_base_free(PHP_HTTP_G->curl.event_base);
+		PHP_HTTP_G->curl.event_base = NULL;
+	}
+	return SUCCESS;
+}
+#endif /* PHP_HTTP_HAVE_EVENT */
+
+#endif /* PHP_HTTP_HAVE_CURL */
+
+/*
+ * Local variables:
+ * tab-width: 4
+ * c-basic-offset: 4
+ * End:
+ * vim600: noet sw=4 ts=4 fdm=marker
+ * vim<600: noet sw=4 ts=4
+ */