[ViewVC] Diff of: cvs/deliantra/server/socket/init.C

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.20 by root, Fri Dec 15 19:59:20 2006 UTC vs.
Revision 1.27 by root, Thu Dec 21 06:12:37 2006 UTC

  *
  * Mainly deals with initialization and higher level socket
  * maintenance (checking for lost connections and if data has arrived.)
  * The reading of data is handled in ericserver.c
  */
 #include <global.h>
 #include <sproto.h>
 #include <sys/types.h>
 #include <sys/time.h>
 #include <sys/socket.h>
 #include <netinet/in.h>
+#include <netinet/tcp.h>
+#include <netinet/ip.h>
 #include <netdb.h>
 #include <unistd.h>
 #include <arpa/inet.h>
  * socket setup is handled elsewhere.  We do send a version to the
  * client.
  */
 client::client (int fd, const char *peername)
 : fd (fd), host (strdup (peername)),
-  socket_ev (this, &client::socket_cb)
+  socket_ev (this, &client::socket_cb),
+  cmd_ev    (this, &client::cmd_cb),
+  cc_inv (this), cc_other (this)
 {
   {
     struct linger linger_opt;
     linger_opt.l_onoff = 0;
     linger_opt.l_linger = 0;
     if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))
-      LOG (llevError, "Cannot setsockopt(SO_LINGER): %s\n", strerror (errno));
+      LOG (llevError, "SO_LINGER: %s\n", strerror (errno));
   }
+  {
+    int val = IPTOS_LOWDELAY;
+    if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))
+      LOG (llevError, "IP_TOS: %s\n", strerror (errno));
+  }
+  {
+    int val = 1;
+    if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))
+      LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));
+  }
+#ifdef __linux__
+  {
+     int val;
+     // set some very aggressive keepalive parameters
+     val = 10;
+     if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
+       LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
+     val = 5;
+     if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
+       LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
+     val = 1;
+     if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
+       LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
+  }
+#endif
   {
     int bufsize = 65535;          /*Supposed absolute upper limit */
     int oldbufsize;
     int buflen = sizeof (int);
     getsockopt (fd, SOL_SOCKET, SO_SNDBUF, (char *) &oldbufsize, (socklen_t *) & buflen);
   }
   mapmode = Map0Cmd;
   darkness = 1;
-  status = Ns_Add;
   mapx = 11;
   mapy = 11;
   itemcmd = 1;              /* Default is version item1 command */
-  faces_sent_len = nrofpixmaps;
+  faces_sent = salloc0<uint8> (nrofpixmaps);
-  faces_sent = (uint8 *)calloc (nrofpixmaps, sizeof (*faces_sent));
-  if (!faces_sent)
-    fatal (OUT_OF_MEMORY);
   /* Do this so we don't send a face command for the client for
    * this face.  Face 0 is sent to the client to say clear
    * face information.
    */
   faces_sent[0] = NS_FACESENT_FACE;
+  // socket I/O is low priority
+  // we prefer to have the server run instead of handling client requests
+  socket_ev.prio (PE_PRIO_NORMAL + 1);
   socket_ev.fd (fd);
+  socket_ev.poll (PE_R);
+  // command handling is even lower priority
+  // that way no client can monopolise the server
+  cmd_ev.prio (PE_PRIO_NORMAL + 2);
   // initialisation done, kick it!
-  {
-    packet sl;
-    sl.printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);
+  send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);
-    send_packet (sl);
-    flush ();
+  flush ();
-  }
 #if 0//TODO
   socket_info.nconns++;
   if (socket_info.nconns > cst_tot.max_conn) cst_tot.max_conn = socket_info.nconns;
   if (socket_info.nconns > cst_lst.max_conn) cst_lst.max_conn = socket_info.nconns;
 #endif
 }
 client::~client ()
 {
-  status = Ns_Dead;
+  if (pl)
+    pl->socket = 0;
+  if (fd >= 0)
+    close (fd);
+  sfree<uint8> (faces_sent, nrofpixmaps);
+  free (stats.range);
+  free (stats.title);
+  free (host);
+}
+void
+client::destroy ()
+{
+  destroyed = true;
+  socket_ev.suspend ();
+  cmd_ev.suspend ();
 }
 /** This sets up the socket and reads all the image information into memory. */
 void
 init_ericserver (void)
 {
-  struct sockaddr_in insock;
-  struct linger linger_opt;
-  memset (&cst_tot, 0, sizeof (CS_Stats));
-  memset (&cst_lst, 0, sizeof (CS_Stats));
   cst_tot.time_start = time (NULL);
   cst_lst.time_start = time (NULL);
   LOG (llevDebug, "Initialize new client/server data\n");
 {
   LOG (llevDebug, "Freeing all new client/server information.\n");
   free_socket_images ();
 }
-/**
- * Frees a socket.
- * Basically, all we need to do here is free all data structures that
- * might be associated with the socket.  It is up to the caller to
- * update the list
- */
-void
-free_newsocket (client *ns)
-{
-  if (ns->fd >= 0)
-    close (ns->fd);
-  if (ns->stats.range)
-    free (ns->stats.range);
-  if (ns->stats.title)
-    free (ns->stats.title);
-  free (ns->host);
-  ns->fd = -1;
-  ns->stats.range = 0;
-  ns->stats.title = 0;
-  ns->host = 0;
-}
 /** Sends the 'goodbye' command to the player, and closes connection. */
 void
 final_free_player (player *pl)
 {
-  pl->socket->send_packet ("goodbye");
-  free_newsocket (pl->socket);
   free_player (pl);
 }
-bool
+client *
-add_client (int fd, const char *peername)
+client::create (int fd, const char *peername)
 {
   if (checkbanned (NULL, peername))
     {
       LOG (llevInfo, "Banned host tried to connect: [%s]\n", peername);
-      return false;
+      return 0;
     }
   else
     {
       client *ns = new client (dup (fd), peername);
       clients.push_back (ns);
+      ns->instantiate (); // effectively a nop right now
+      INVOKE_CLIENT (CONNECT, ns);
-      return true;
+      return ns;
     }
 }

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing deliantra/server/socket/init.C (file contents): Revision 1.20 by root, Fri Dec 15 19:59:20 2006 UTC vs. Revision 1.27 by root, Thu Dec 21 06:12:37 2006 UTC

Diff Legend

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.20 by root, Fri Dec 15 19:59:20 2006 UTC vs.
Revision 1.27 by root, Thu Dec 21 06:12:37 2006 UTC