NetServer.cpp

Go to the documentation of this file.

/*  Project nGenEx
    Destroyer Studios LLC
    Copyright © 1997-2004. All Rights Reserved.

    SUBSYSTEM:    NetEx.lib
    FILE:         NetServer.cpp
    AUTHOR:       John DiCamillo


    OVERVIEW
    ========
    Network Server Pump for HTTP Server
*/


#include "MemDebug.h"
#include "NetServer.h"
#include "NetHost.h"
#include "NetLayer.h"

#include <stdlib.h>
#include <stdio.h>
#include <mmsystem.h>

// +-------------------------------------------------------------------+

DWORD WINAPI NetServerListenerProc(LPVOID link);
DWORD WINAPI NetServerReaderProc(LPVOID link);

struct PoolItem { NetServer* server; int thread_index; };

// +-------------------------------------------------------------------+

NetServer::NetServer(WORD port, int nthreads)
   : sock(true), pool(0), conn(0), poolsize(nthreads), err(0),
     server_shutdown(false), hreader(0)
{
   NetHost host;
   addr = NetAddr(host.Address().IPAddr(), port);

   sock.bind(addr);
   sock.listen(3);

   if (poolsize < 1) poolsize = 1;

   pool = new(__FILE__,__LINE__) HANDLE[poolsize];
   conn = new(__FILE__,__LINE__) NetSock*[poolsize];
   clients = new(__FILE__,__LINE__) NetAddr[poolsize];

   if (pool && conn && clients) {
      ZeroMemory(pool, poolsize * sizeof(HANDLE));
      ZeroMemory(conn, poolsize * sizeof(NetSock*));

      DWORD thread_id = 0;

      for (int i = 0; i < poolsize; i++) {
         thread_id = 0;
         PoolItem* item = new PoolItem;
         item->server = this;
         item->thread_index = i;

         pool[i] = CreateThread(0, 4096, NetServerReaderProc, (LPVOID) item, 0, &thread_id);
      }

      thread_id = 0;
      hreader = CreateThread(0, 4096, NetServerListenerProc, (LPVOID) this, 0, &thread_id);
   }
}

NetServer::~NetServer()
{
   if (!server_shutdown) {
      server_shutdown = true;
      sock.close();
   }

   if (hreader) {
      WaitForSingleObject(hreader, 1000);
      CloseHandle(hreader);
   }

   if (pool && poolsize) {
      for (int i = 0; i < poolsize; i++) {
         WaitForSingleObject(pool[i], 1000);
         CloseHandle(pool[i]);
         delete conn[i];
         conn[i] = 0;
      }

      delete [] pool;
      delete [] conn;
      delete [] clients;
   }
}

// +--------------------------------------------------------------------+

void
NetServer::Shutdown()
{
   server_shutdown = true;
}

// +--------------------------------------------------------------------+

DWORD WINAPI NetServerListenerProc(LPVOID link)
{
   NetServer* net_server = (NetServer*) link;

   if (net_server)
      return net_server->Listener();

   return (DWORD) E_POINTER;
}

DWORD
NetServer::Listener()
{
   while (!server_shutdown) {
      NetSock* s = sock.accept(&client_addr);

      while (s) {
         sync.acquire();

         for (int i = 0; i < poolsize; i++) {
            if (conn[i] == 0) {
               conn[i] = s;
               clients[i] = client_addr;
               s = 0;
               break;
            }
         }

         sync.release();

         // wait for a thread to become not busy
         if (s)
            Sleep(10);
      }
   }

   return 0;
}

// +--------------------------------------------------------------------+

DWORD WINAPI NetServerReaderProc(LPVOID link)
{
   if (!link) return (DWORD) E_POINTER;

   PoolItem*  item       = (PoolItem*) link;
   NetServer* net_server = item->server;
   int        index      = item->thread_index;

   delete item;

   if (net_server)
      return net_server->Reader(index);

   return (DWORD) E_POINTER;
}

DWORD
NetServer::Reader(int index)
{
   // init random seed for this thread:
   srand(timeGetTime());

   while (!server_shutdown) {
      sync.acquire();
      NetSock* s = conn[index];
      sync.release();

      if (s) {
         const int MAX_REQUEST = 4096;
         Text request;

         /***
          *** NOT SURE WHY, BUT THIS DOESN'T WORK FOR SHIT
          ***
          *** Setting the socket timeout to 2 seconds caused it
          *** to wait for two seconds, read nothing, and give up
          *** with a WSAETIMEDOUT error.  Meanwhile, the client
          *** immediately registered a failure (during the 2 sec
          *** delay) and aborted the request.
          ***

         s->set_timeout(2000);
         Text msg = s->recv();

         while (msg.length() > 0 && request.length() < MAX_REQUEST) {
            request += msg;
            msg = s->recv();
         }

          ***/

         request = s->recv();

         if (request.length() > 0 && !s->is_closed()) {
            Text response = ProcessRequest(request, clients[index]);
            err = s->send(response);
            if (err < 0) {
               err = NetLayer::GetLastError();
            }
         }

         sync.acquire();
         delete conn[index];
         conn[index] = 0;
         sync.release();
      }
      else {
         Sleep(5);
      }
   }

   return 0;
}

// +--------------------------------------------------------------------+

Text
NetServer::ProcessRequest(Text msg, const NetAddr& addr)
{
   if (msg.indexOf("GET ") == 0)
      return DefaultResponse();
   
   return ErrorResponse();
}

Text
NetServer::DefaultResponse()
{
   Text response = 
      "HTTP/1.0 200 OK\nServer: Generic NetServer 1.0\nMIME-Version: 1.0\nContent-type: text/html\n\n";

   response += "<html><head><title>Generic NetServer 1.0</title></head>\n\n";
   response += "<body bgcolor=\"black\" text=\"white\">\n";
   response += "<h1>Generic NetServer 1.0</h1>\n";
   response += "<p>Didn't think I could do it, did ya?\n";
   response += "</body></html>\n\n";

   return response;
}

Text
NetServer::ErrorResponse()
{
   Text response = 
      "HTTP/1.0 501 Not Implemented\nServer: Generic NetServer 1.0\nMIME-Version: 1.0\nContent-type: text/html\n\n";

   response += "<html><head><title>Generic NetServer 1.0</title></head>\n\n";
   response += "<body bgcolor=\"black\" text=\"white\">\n";
   response += "<h1>Generic NetServer 1.0</h1>\n";
   response += "<p>Sorry charlie...  I'm not a magician.\n";
   response += "</body></html>\n\n";

   return response;
}