@@ -196,7 +196,8 @@ static void curl_async_event_start(zend_async_event_t *event)
196
196
}
197
197
198
198
curl_multi_add_handle (curl_multi_handle , curl_event -> curl );
199
- curl_multi_socket_action (curl_multi_handle , CURL_SOCKET_TIMEOUT , 0 , NULL );
199
+ int running_handles = 0 ;
200
+ curl_multi_socket_action (curl_multi_handle , CURL_SOCKET_TIMEOUT , 0 , & running_handles );
200
201
201
202
if (UNEXPECTED (EG (exception ) != NULL )) {
202
203
event -> stop (event );
@@ -278,7 +279,8 @@ static void curl_poll_callback(
278
279
action |= CURL_CSELECT_ERR ;
279
280
}
280
281
281
- curl_multi_socket_action (curl_multi_handle , poll_event -> socket , action , NULL );
282
+ int running_handles = 0 ;
283
+ curl_multi_socket_action (curl_multi_handle , poll_event -> socket , action , & running_handles );
282
284
process_curl_completed_handles ();
283
285
}
284
286
@@ -357,7 +359,8 @@ static void timer_callback(
357
359
zend_async_event_t * event , zend_async_event_callback_t * callback , void * result , zend_object * exception
358
360
)
359
361
{
360
- curl_multi_socket_action (curl_multi_handle , CURL_SOCKET_TIMEOUT , 0 , NULL );
362
+ int running_handles = 0 ;
363
+ curl_multi_socket_action (curl_multi_handle , CURL_SOCKET_TIMEOUT , 0 , & running_handles );
361
364
process_curl_completed_handles ();
362
365
}
363
366
@@ -608,7 +611,10 @@ static void multi_timer_callback(
608
611
)
609
612
{
610
613
curl_multi_event_callback_t * async_event_callback = (curl_multi_event_callback_t * ) callback ;
611
- curl_multi_socket_action (async_event_callback -> curl_m_event -> curl_m -> multi , CURL_SOCKET_TIMEOUT , 0 , NULL );
614
+ int running_handles = 0 ;
615
+ curl_multi_socket_action (
616
+ async_event_callback -> curl_m_event -> curl_m -> multi , CURL_SOCKET_TIMEOUT , 0 , & running_handles
617
+ );
612
618
}
613
619
614
620
static int multi_timer_cb (CURLM * multi , const long timeout_ms , void * user_p )
@@ -688,7 +694,10 @@ static void curl_multi_poll_callback(
688
694
action |= CURL_CSELECT_ERR ;
689
695
}
690
696
691
- curl_multi_socket_action (poll_callback -> curl_m_event -> curl_m -> multi , socket_event -> socket , action , NULL );
697
+ int running_handles = 0 ;
698
+ curl_multi_socket_action (
699
+ poll_callback -> curl_m_event -> curl_m -> multi , socket_event -> socket , action , & running_handles
700
+ );
692
701
}
693
702
694
703
static int multi_socket_cb (CURL * curl , const curl_socket_t socket_fd , const int what , void * user_p , void * data )
@@ -816,7 +825,8 @@ CURLMcode curl_async_multi_perform(php_curlm * curl_m, int *running_handles)
816
825
return CURLM_INTERNAL_ERROR ;
817
826
}
818
827
819
- curl_multi_socket_action (curl_m -> multi , CURL_SOCKET_TIMEOUT , 0 , NULL );
828
+ int running_handles_internal = 0 ;
829
+ curl_multi_socket_action (curl_m -> multi , CURL_SOCKET_TIMEOUT , 0 , & running_handles_internal );
820
830
821
831
const curl_async_multi_event_t * async_event = curl_m -> async_event ;
822
832
@@ -870,7 +880,8 @@ CURLMcode curl_async_select(php_curlm * curl_m, int timeout_ms, int* numfds)
870
880
}
871
881
872
882
// Initiate execution of the transfer
873
- curl_multi_socket_action (multi_handle , CURL_SOCKET_TIMEOUT , 0 , NULL );
883
+ int running_handles = 0 ;
884
+ curl_multi_socket_action (multi_handle , CURL_SOCKET_TIMEOUT , 0 , & running_handles );
874
885
875
886
// Suspend coroutine until events are ready
876
887
ZEND_ASYNC_SUSPEND ();
0 commit comments