File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -296,7 +296,7 @@ void swoole::async::ThreadPool::create_thread(const bool is_core_worker)
296
296
{
297
297
if (errno == EAGAIN)
298
298
{
299
- swSocket_wait (SwooleTG. aio_pipe_write , 1000 , SW_EVENT_WRITE);
299
+ swSocket_wait (event-> pipe_fd , 1000 , SW_EVENT_WRITE);
300
300
continue ;
301
301
}
302
302
else if (errno == EINTR)
@@ -350,6 +350,7 @@ void swoole::async::ThreadPool::create_thread(const bool is_core_worker)
350
350
event->object = new thread::id (this_thread::get_id ());
351
351
event->callback = aio_thread_release;
352
352
event->pipe_fd = SwooleG.aio_default_pipe_fd ;
353
+ event->canceled = false ;
353
354
354
355
--n_waiting;
355
356
++n_closing;
@@ -488,7 +489,7 @@ int swAio_callback(swReactor *reactor, swEvent *event)
488
489
AsyncEvent *event = events[i];
489
490
if (!event->canceled )
490
491
{
491
- event->callback (events[i] );
492
+ event->callback (event );
492
493
}
493
494
SwooleTG.aio_task_num --;
494
495
delete event;
You can’t perform that action at this time.
0 commit comments