test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-02 03:47:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Optimize fiber event process.

Browse Source
This commit is contained in:
zhengshuxin 2024-10-26 13:53:44 +08:00
parent c8da96ebc2
commit 721b5f383b
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib_acl/src/init/acl_init.c
View File

@ -25,7 +25,7 @@
#include "init.h" #include "init.h"
static char *version = "3.6.1-6 20241025-17:42"; static char *version = "3.6.1-6 20241026-13:34";
const char *acl_version(void) const char *acl_version(void)
{ {

6
lib_fiber/c/src/fiber_io.c
View File

@ -586,9 +586,7 @@ int fiber_wait_read(FILE_EVENT *fe)
// If the IO reading timeout set in setsockopt. // If the IO reading timeout set in setsockopt.
// Clear FIBER_F_TIMER flag been set in wakeup_timers. // Clear FIBER_F_TIMER flag been set in wakeup_timers.
curr->flag &= ~FIBER_F_TIMER; curr->flag &= ~FIBER_F_TIMER;
// Delete the IO read event directly, don't buffer the delete event_del_read(__thread_fiber->event, fe, 0);
// status.
event_del_read(__thread_fiber->event, fe, 1);
acl_fiber_set_errno(curr, FIBER_EAGAIN); acl_fiber_set_errno(curr, FIBER_EAGAIN);
acl_fiber_set_error(FIBER_EAGAIN); acl_fiber_set_error(FIBER_EAGAIN);
@ -683,7 +681,7 @@ int fiber_wait_write(FILE_EVENT *fe)
#ifndef USE_POLL_WAIT #ifndef USE_POLL_WAIT
else if (curr->flag & FIBER_F_TIMER) { else if (curr->flag & FIBER_F_TIMER) {
curr->flag &= ~FIBER_F_TIMER; curr->flag &= ~FIBER_F_TIMER;
event_del_write(__thread_fiber->event, fe, 1); event_del_write(__thread_fiber->event, fe, 0);
acl_fiber_set_errno(curr, FIBER_EAGAIN); acl_fiber_set_errno(curr, FIBER_EAGAIN);
acl_fiber_set_error(FIBER_EAGAIN); acl_fiber_set_error(FIBER_EAGAIN);