Changeset 118 in Main for trunk/Server/server.c

Timestamp:

Sep 21, 2024, 6:03:27 PM (8 weeks ago)

Author:

Nishi

Message:

use poll for select by default

File:

• trunk/Server/server.c (modified) (5 diffs)

trunk/Server/server.c

@@ -39 +39 @@
 #include "strptime.h"
 #else
+#ifdef USE_POLL
+#include <poll.h>
+#else
 #include <sys/select.h>
+#endif
 #include <sys/socket.h>
 #include <arpa/inet.h>
@@ -54 +58 @@
 extern char tw_server[];
 
-fd_set fdset;
 int sockcount = 0;
 
@@ -802 +805 @@
 
 void tw_server_loop(void) {
-        struct timeval tv;
         int i;
 #if defined(__MINGW32__) || defined(__HAIKU__)
@@ -810 +812 @@
         }
 #endif
+#ifdef USE_POLL
+        struct pollfd pollfds[sockcount];
+        for(i = 0; i < sockcount; i++) {
+                pollfds[i].fd = sockets[i];
+                pollfds[i].events = POLLIN | POLLPRI;
+        }
+#else
+                fd_set fdset;
+                struct timeval tv;
+#endif
         while(1) {
-                FD_ZERO(&fdset);
-                for(i = 0; i < sockcount; i++) {
-                        FD_SET(sockets[i], &fdset);
-                }
-                tv.tv_sec = 1;
-                tv.tv_usec = 0;
+#ifdef USE_POLL
+                int ret = poll(pollfds, sockcount, 1000);
+#else
+                        FD_ZERO(&fdset);
+                        for(i = 0; i < sockcount; i++) {
+                                FD_SET(sockets[i], &fdset);
+                        }
+                        tv.tv_sec = 1;
+                        tv.tv_usec = 0;
 #ifdef __HAIKU__
-                int ret = select(32, &fdset, NULL, NULL, &tv);
+                        int ret = select(32, &fdset, NULL, NULL, &tv);
 #else
                         int ret = select(FD_SETSIZE, &fdset, NULL, NULL, &tv);
+#endif
 #endif
                 if(ret == -1) {
@@ -837 +853 @@
                         int i;
                         for(i = 0; i < sockcount; i++) {
-                                if(FD_ISSET(sockets[i], &fdset)) {
+                                bool cond;
+#ifdef USE_POLL
+                                cond = pollfds[i].revents & POLLIN;
+#else
+                                        cond = FD_ISSET(sockets[i], &fdset);
+#endif
+                                if(cond) {
                                         SOCKADDR claddr;
                                         int clen = sizeof(claddr);