test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-01 19:37:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Test and optimize.

Browse Source
This commit is contained in:
shuxin 　　zheng 2024-10-24 09:39:55 +08:00
parent 5d1f8f995e
commit 6b973b55a1
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -256,7 +256,6 @@ static void fiber_io_loop(ACL_FIBER *self fiber_unused, void *ctx)
left = -1;
} else {
now = event_get_stamp(__thread_fiber->event);
last = now;
if (now >= timer->expire) {
left = 0;
} else {
@ -303,6 +302,7 @@ static void fiber_io_loop(ACL_FIBER *self fiber_unused, void *ctx)
now = event_get_stamp(__thread_fiber->event);
if (now - last >= left) {
wakeup_timers(__thread_fiber->ev_timer, now);
last = now;
}
if (timer_cache_size(__thread_fiber->ev_timer) == 0) {
@ -595,7 +595,7 @@ int fiber_wait_read(FILE_EVENT *fe)
return -1;
}
#endif
// else: the IO read event should has been removed in read_callback.
// else: the IO read event should have been removed in read_callback.
return ret;
}

8
lib_fiber/samples-c++1x/server/main.cpp
View File

@ -6,6 +6,8 @@
static void client_echo(const acl::shared_stream& conn, bool readable) {
acl::string buf;
conn->set_rw_timeout(1, true);
while (true) {
if (readable) {
struct timeval begin{}, end{};
@ -31,7 +33,11 @@ static void client_echo(const acl::shared_stream& conn, bool readable) {
printf("client write error %s\r\n", acl::last_serror());
break;
}
//acl::fiber::delay(1000);
time_t begin = time(NULL);
acl::fiber::delay(4000);
time_t end = time(NULL);
printf(">>>>>>>>>wakeup now, tc=%ld seconds<<<<<<<<\n", end - begin);
}
}