Changeset 371ce29 in network-game for server

Timestamp:

Nov 28, 2012, 3:38:24 PM (12 years ago)

Author:

dportnoy <dmp1488@…>

Branches:

master

Children:

439f7bc

Parents:

59061f6

Message:

The server now uses nonblocking sockets and sleep to free up cpu usage

File:

• server/server.cpp (modified) (6 diffs)

server/server.cpp

@@ -2 +2 @@
 
 #include <cstdlib>
+#include <cstdio>
 #include <unistd.h>
 #include <string>
-#include <netdb.h>
-#include <cstdio>
 #include <iostream>
 #include <vector>
 #include <algorithm>
 
+#include <fcntl.h>
+#include <assert.h>
+
 #include <sys/socket.h>
+#include <netdb.h>
 #include <netinet/in.h>
 #include <arpa/inet.h>
@@ -77 +80 @@
 }
 
+void set_nonblock(int sock)
+{
+    int flags;
+    flags = fcntl(sock, F_GETFL,0);
+    assert(flags != -1);
+    fcntl(sock, F_SETFL, flags | O_NONBLOCK);
+}
+
 int main(int argc, char *argv[])
 {
@@ -86 +97 @@
 
    srand(time(NULL));
-   int num = (rand() % 1000) + 1;
+   int num = 500;
+   //int num = (rand() % 0) + 1;
 
    cout << "num: " << num << endl;
@@ -99 +111 @@
    }
 
+   /*
    DataAccess da;
 
@@ -116 +129 @@
    da.printPlayers();
    cout << endl;
+   */
    
-   sock=socket(AF_INET, SOCK_DGRAM, 0);
+   sock = socket(AF_INET, SOCK_DGRAM, 0);
    if (sock < 0) error("Opening socket");
    length = sizeof(server);
@@ -127 +141 @@
       error("binding");
 
+   set_nonblock(sock);
+
    while (true) {
-      // if n == 0, means the client disconnected. may want to check this
+
+      usleep(5000);
+
       n = receiveMessage(&clientMsg, sock, &from);
-      if (n < 0)
-         error("recieveMessage");
-
-      processMessage(clientMsg, from, vctPlayers, num, serverMsg);
-
-      cout << "msg: " << serverMsg.buffer << endl;
-
-      n = sendMessage(&serverMsg, sock, &from);
-      if (n  < 0)
-         error("sendMessage");
-   }
+
+      if (n >= 0) {
+         cout << "Got a message" << endl;
+
+         processMessage(clientMsg, from, vctPlayers, num, serverMsg);
+
+         cout << "msg: " << serverMsg.buffer << endl;
+
+         n = sendMessage(&serverMsg, sock, &from);
+         if (n  < 0)
+            error("sendMessage");
+      }
+
+   }
+
    return 0;
 }