diff options
| author | FWoltermann@gmail.com <FWoltermann@gmail.com@076cb2c4-205e-83fd-5cf3-1be9aa105544> | 2011-12-08 14:53:40 +0000 |
|---|---|---|
| committer | FWoltermann@gmail.com <FWoltermann@gmail.com@076cb2c4-205e-83fd-5cf3-1be9aa105544> | 2011-12-08 14:53:40 +0000 |
| commit | e33e19d0587146859d48a134ec9fd94e7b7ba5cd (patch) | |
| tree | 69d048c8801858d2756ab3a487090a7a1b74bf14 /NetEx/NetServer.cpp | |
| download | starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.zip starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.tar.gz starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.tar.bz2 | |
Initial upload
Diffstat (limited to 'NetEx/NetServer.cpp')
| -rw-r--r-- | NetEx/NetServer.cpp | 260 |
1 files changed, 260 insertions, 0 deletions
diff --git a/NetEx/NetServer.cpp b/NetEx/NetServer.cpp new file mode 100644 index 0000000..6534202 --- /dev/null +++ b/NetEx/NetServer.cpp @@ -0,0 +1,260 @@ +/* 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;
+}
|