X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=src%2Fphp_http_client_curl.h;fp=src%2Fphp_http_client_curl.h;h=abd8f993085b28f18920659e1e71e4e899da4415;hp=91286477d76514b4511ecd37d1fb9844a3aadf4a;hb=43a9a6f8cb56e25c3770d652ce77045f89f68ca6;hpb=18871cafc58e15054412aea57b2456ffc0d49713

diff --git a/src/php_http_client_curl.h b/src/php_http_client_curl.h
index 9128647..abd8f99 100644
--- a/src/php_http_client_curl.h
+++ b/src/php_http_client_curl.h
@@ -19,8 +19,46 @@ struct php_http_client_curl_globals {
 	php_http_client_driver_t driver;
 };
 
+typedef struct php_http_client_curl_handle {
+	CURLM *multi;
+	CURLSH *share;
+} php_http_client_curl_handle_t;
+
+typedef struct php_http_client_curl_ops {
+	void *(*init)();
+	void (*dtor)(void **ctx_ptr);
+	ZEND_RESULT_CODE (*once)(void *ctx);
+	ZEND_RESULT_CODE (*wait)(void *ctx, struct timeval *custom_timeout);
+	ZEND_RESULT_CODE (*exec)(void *ctx);
+} php_http_client_curl_ops_t;
+
+typedef struct php_http_client_curl {
+	php_http_client_curl_handle_t *handle;
+
+	int unfinished;  /* int because of curl_multi_perform() */
+
+	void *ev_ctx;
+	php_http_client_curl_ops_t *ev_ops;
+} php_http_client_curl_t;
+
+static inline void php_http_client_curl_get_timeout(php_http_client_curl_t *curl, long max_tout, struct timeval *timeout)
+{
+	if ((CURLM_OK == curl_multi_timeout(curl->handle->multi, &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;
+	}
+}
+
+PHP_HTTP_API void php_http_client_curl_responsehandler(php_http_client_t *client);
+PHP_HTTP_API void php_http_client_curl_loop(php_http_client_t *client, curl_socket_t s, int curl_action);
+PHP_HTTP_API php_http_client_ops_t *php_http_client_curl_get_ops(void);
+
 PHP_MINIT_FUNCTION(http_client_curl);
 PHP_MSHUTDOWN_FUNCTION(http_client_curl);
+
 #endif /* PHP_HTTP_HAVE_CURL */
 
 #endif /* PHP_HTTP_CLIENT_CURL_H */