X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=src%2Fphp_http_client.c;h=0749825ba40b9b601500f299f835888e52576bb8;hp=cedc239b68c1f780c2df5ef7b46b5bf74f448992;hb=e61393c76eb220de660f2b95111f9bf9e072fe1d;hpb=3ee3d5f53712e1e91d4ffef34aa0c6e8f4f8840e

diff --git a/src/php_http_client.c b/src/php_http_client.c
index cedc239..0749825 100644
--- a/src/php_http_client.c
+++ b/src/php_http_client.c
@@ -689,7 +689,7 @@ static PHP_METHOD(HttpClient, enqueue)
 	zend_fcall_info_cache fcc = empty_fcall_info_cache;
 	php_http_client_object_t *obj;
 	php_http_message_object_t *msg_obj;
-	php_http_client_enqueue_t q;
+	php_http_client_enqueue_t q = {0};
 
 	php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS(), "O|f", &request, php_http_get_client_request_class_entry(), &fci, &fcc), invalid_arg, return);
 
@@ -701,6 +701,17 @@ static PHP_METHOD(HttpClient, enqueue)
 		return;
 	}
 
+	/* set early for progress callback */
+	q.opaque = msg_obj;
+
+	if (obj->client->callback.progress.func) {
+		php_http_client_progress_state_t progress = {0};
+
+		progress.info = "prepare";
+		obj->client->callback.progress.func(obj->client->callback.progress.arg, obj->client, &q, &progress);
+	}
+
+	Z_ADDREF_P(request);
 	q.request = msg_obj->message;
 	q.options = combined_options(getThis(), request);
 	q.dtor = msg_queue_dtor;
@@ -711,12 +722,10 @@ static PHP_METHOD(HttpClient, enqueue)
 	if (fci.size) {
 		Z_TRY_ADDREF(fci.function_name);
 		if (fci.object) {
-			++GC_REFCOUNT(fci.object);
+			GC_ADDREF(fci.object);
 		}
 	}
 
-	Z_ADDREF_P(request);
-
 	php_http_expect(SUCCESS == php_http_client_enqueue(obj->client, &q), runtime,
 			msg_queue_dtor(&q);
 			return;
@@ -781,7 +790,7 @@ static PHP_METHOD(HttpClient, requeue)
 	if (fci.size) {
 		Z_TRY_ADDREF(fci.function_name);
 		if (fci.object) {
-			++GC_REFCOUNT(fci.object);
+			GC_ADDREF(fci.object);
 		}
 	}