---

paradigm.cpp

Go to the documentation of this file.

#include "sysconfig.h"
#include "server.h"
#include "event.h"
#include "eventqueue.h"
#include "user.h"

#ifdef __BORLANDC__
#if (__BORLANDC__ < 0x550)
#include <condefs.h>
USEUNIT("connection.cpp");
USEUNIT("server.cpp");
USEUNIT("socket.cpp");
USEUNIT("log.cpp");
USEUNIT("event.cpp");
USEUNIT("eventqueue.cpp");
USEUNIT("user.cpp");
//---------------------------------------------------------------------------
#endif
#endif

EventQueue* g_chat_to_server = 0;
EventQueue* g_server_to_chat = 0;
Log* g_log = 0;

#ifdef WIN32
void StartServer(void * parms);
#else
void* StartServer(void * parms);
#endif
void Chat();

//---------------------------------------------------------------------------
#pragma argsused
int main(int argc, char **argv)
{
  g_log = new Log("");

#ifdef WIN32
  WSADATA wsaData;  // This could be made global if we had a good reason.

  // Request Windows to start socket services.
  int err = WSAStartup(0x202,&wsaData);
  if (err) {
    cout << "ERROR-main(WSAStartup):" << err << endl;
    delete g_log;
    return -1;
  }
#endif

  g_chat_to_server = new EventQueue(0);
  g_server_to_chat = new EventQueue(0);
  if (!g_chat_to_server->IsOk() || !g_server_to_chat->IsOk()) {
    g_log->Write("ERROR-main(EventQueue): Unable to start event queues.");
    delete g_log;
    return -1;
  }
  Server* server = new Server(*g_chat_to_server, *g_server_to_chat, *g_log);
  if (!server->Boot(32000)) {
    g_log->Write("ERROR-main(Server): Unable to start server.");
    delete g_log;
    return -1;
  }
  g_log->Write("INFO-Main(): Server starting up");

  // Start up our Network server
  THREADHANDLE_T server_thread;
  StartThread(server_thread, StartServer, 8192, (void*)server);

  // Main thread will handle our Chat driver
  Chat();
  WaitForSingleObject(&server_thread, INFINITE);

#ifdef WIN32
  WSACleanup();  // Must always cleanup Windows sockets
#endif
  return 0;
}

#ifdef WIN32
void StartServer(void * parms) {
#else
void* StartServer(void * parms) {
#endif
  Server* server = (Server *)parms;
  if (server)
    server->Run(NULL);
  delete server;
#ifdef UNIX
  return NULL;
#endif
}

void Chat() {
  typedef list<User> UserList;

  UserList users;   
  UserList::iterator u;
  Event* e;
  bool shutdown = false;

  while (!shutdown) {
    e = g_server_to_chat->Pop();
    if (!e) {
#ifdef WIN32
      Sleep(1);
#else
      usleep(1);
#endif
    } else {
      switch (e->mEventType) {
        case CONNECT_E: {
          char msg[] = "Welcome!\r\n";
          User user(e->mClientId);
          users.push_back(user);
          g_chat_to_server->Push(new Event(MESSAGE_E, user.Id(),
            strlen(msg), msg));
        }
        break;
        case DISCONNECT_E: {
          // A connection is lost - kill the its user in this subsystem.
          u = find(users.begin(),users.end(),e->mClientId);
          users.erase(u);
        }
        break;
        case MESSAGE_E: {
          // check for shutdown message
          // :WARN: test for null message as it should be just a CRLF
          if (e->mpData && !strncmp(e->mpData, "@shutdown", e->mDataLen)) {
            char msg[] = "Shutting down..BYE.\r\n";
            for(u = users.begin(); u != users.end(); u++) {
              g_chat_to_server->Push(new Event(MESSAGE_E, (*u).Id(),
                strlen(msg), msg));
            }
            g_chat_to_server->Push(new Event(SHUTDOWN_E, 0, 0, 0));
          } else { // otherwise we have a general message to echo
            string msg;
            if (e->mpData && e->mDataLen) {
              msg.append(e->mpData, e->mDataLen);
            }
            msg.append("\r\n");
            // message will be echoed to all clients
            for(u = users.begin(); u != users.end(); u++) {
              g_chat_to_server->Push(new Event(MESSAGE_E, (*u).Id(),
                msg.length(), msg.c_str()));
            }
          }
        }
        break;
        case SHUTDOWN_E:
          shutdown = true;
        break;
        case NONE_E:
        break;
      }  // switch
      delete e;
    }  // else
  } // while
}

---