From fc47a6bebccdda7c33023b3d7a2fb5a06e462973 Mon Sep 17 00:00:00 2001 From: zhengshuxin Date: Sat, 26 Oct 2024 22:18:10 +0800 Subject: [PATCH] Test fiber io performance. --- lib_fiber/samples-c/server2/main.c | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/lib_fiber/samples-c/server2/main.c b/lib_fiber/samples-c/server2/main.c index 2f18d5fa6..0792c3da7 100644 --- a/lib_fiber/samples-c/server2/main.c +++ b/lib_fiber/samples-c/server2/main.c @@ -100,35 +100,35 @@ static void echo_client(ACL_FIBER *fiber acl_unused, void *ctx) __socket_count++; //printf("client fiber-%d: fd: %d\r\n", acl_fiber_self(), fd); - if (__read_timeout > 0 && __use_sockopt) { + if (__read_timeout > 0 && __use_sockopt) { struct timeval tm; tm.tv_sec = __read_timeout; tm.tv_usec = 0; #if defined(__APPLE__) || defined(_WIN32) || defined(_WIN64) if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, - (char*) &__read_timeout, sizeof(__read_timeout)) < 0) { + (char*) &__read_timeout, sizeof(__read_timeout)) < 0) { #else if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, &tm, sizeof(tm)) < 0) { #endif printf("%s: setsockopt error: %s\r\n", __FUNCTION__, acl_last_serror()); } - } + } - if (__write_timeout > 0 && __use_sockopt) { + if (__write_timeout > 0 && __use_sockopt) { struct timeval tm; tm.tv_sec = __write_timeout; tm.tv_usec = 0; #if defined(__APPLE__) || defined(_WIN32) || defined(_WIN64) if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, - (char*) &__write_timeout, sizeof(__write_timeout)) < 0) { + (char*) &__write_timeout, sizeof(__write_timeout)) < 0) { #else if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, &tm, sizeof(tm)) < 0) { #endif printf("%s: setsockopt error: %s\r\n", __FUNCTION__, acl_last_serror()); } - } + } while (1) { if (__read_timeout > 0 && !__use_sockopt) { @@ -252,7 +252,7 @@ static void fiber_accept(ACL_FIBER *fiber acl_unused, void *ctx) break; } - pfd = malloc(sizeof(SOCKET)); + pfd = (SOCKET *) malloc(sizeof(SOCKET)); assert(pfd != NULL); *pfd = cfd;