ZFX + Developia

Code: Alles auswählen

void CWebServer::work()
{
    IServerProcess::work();

    s32 s = conn.accept();

    if (s >= 0)
    {
        try
        {
            boost::function0<s32> f = boost::bind( &CWebServer::serverThread, this, s, conn.getClientAddress());
            boost::thread td(f);
        }
        catch (exception& e)
        {
            Logger->log(ELMT_Warning, "Failed creating thread caused by: ", false);
            Logger->write(e.what());
        }
    }
}

s32 CWebServer::serverThread(s32 socket, string address)
{
    try
    {
        //! CWebServer is also the handler
        //! Debugging is disabled by default
        CHttp http(this, address, false);

        http.parseRequest(socket);

        conn.close(socket);

        return 0;
    }
    catch (exception& e)
    {
        Logger->log(ELMT_Warning, "Failed processing Request caused by: ", false);
        Logger->write(e.what());

        return -1;
    }
}

Code: Alles auswählen

class CClientHandler {
  private:
    bool isRunningValue = false;

  public:
    CClientHandler(Socket s) {
    }

    void Start() {
      isRunningValue = true;

      while (isRunningValue) {
      }
    }

    bool IsRunning() {
    }
}

Code: Alles auswählen

void CWebServer::work()
{
    IServerNode::work();

    s32 s = conn.accept();

    //! If the filedescriptor is valid we start a new thread
    if (s >= 0)
    {
        Logger->log(ELMT_Info, "New Web Request. Forking...");

        DatabaseManager->deactivate();

        s32 res = fork();

        if(res == 0)
        {
            DatabaseManager->activate();

            //! TODO: keep connections. ATM we just process one request and close the thread
            Logger->setLogToFile(false);
            Logger->setName("WebFork");
            this->writeUpdatesToDatabase(false);

            CHttp http(this, conn.getClientAddress(), false);
            http.parseRequest(s);

            conn.close(s);

            exit(0);
        }
        else if(res < 0)
            Logger->log(ELMT_Warning, "Something went wrong forking");

        DatabaseManager->activate();
    }

    //! Update the sessions
    //! We disconnect them after a 30 minute timeout
    SessionManager->work();
}