ehsserver.h

/* $Id: ehsserver.h 81 2012-03-20 12:03:05Z felfert $
 *
 * EHS is a library for embedding HTTP(S) support into a C++ application
 *
 * Copyright (C) 2004 Zachary J. Hansen
 *
 * Code cleanup, new features and bugfixes: Copyright (C) 2010 Fritz Elfert
 *
 *    This library is free software; you can redistribute it and/or
 *    modify it under the terms of the GNU Lesser General Public
 *    License version 2.1 as published by the Free Software Foundation;
 *
 *    This library is distributed in the hope that it will be useful,
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 *    Lesser General Public License for more details.
 *
 *    You should have received a copy of the GNU Lesser General Public
 *    License along with this library; if not, write to the Free Software
 *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 *    This can be found in the 'COPYING' file.
 *
 */

#ifndef _EHSSERVER_H_
#define _EHSSERVER_H_

class EHSServer {

    private:

        EHSServer(const EHSServer &);

        EHSServer & operator=(const EHSServer &);

    public:

        EHSServer(EHS *ipoTopLevelEHS);

        virtual ~EHSServer();

        void EndServerThread();

        void HandleData(int timeout, ehs_threadid_t tid = 0); 

        enum ServerRunningStatus {
            SERVERRUNNING_INVALID = 0,
            SERVERRUNNING_NOTRUNNING,
            SERVERRUNNING_SINGLETHREADED,
            SERVERRUNNING_THREADPOOL,
            SERVERRUNNING_ONETHREADPERREQUEST,
            SERVERRUNNING_SHOULDTERMINATE
        };

        ServerRunningStatus RunningStatus() const { return m_nServerRunningStatus; }

        bool AcceptedNewConnection() const { return m_bAcceptedNewConnection; }

        int RequestsPending() const { return m_nRequestsPending; }

        static void *PthreadHandleData_ThreadedStub(void *ipData);

    private:

        HttpRequest *GetNextRequest();

        void IncrementRequestsPending() { m_nRequestsPending++; }

        void RemoveEHSConnection(EHSConnection *ipoEHSConnection);

        void HandleData_Threaded();

        void ClearIdleConnections();

        void CheckClientSockets();

        void CheckAcceptSocket();

        int CreateFdSet();

        void RemoveFinishedConnections();

        ServerRunningStatus m_nServerRunningStatus;

        EHS * m_poTopLevelEHS;

        bool m_bAcceptedNewConnection;

        pthread_mutex_t m_oMutex;

        pthread_cond_t m_oDoneAccepting;

        int m_nRequestsPending;

        bool m_bAccepting;

        std::string m_sServerName;

        fd_set m_oReadFds;

        EHSConnectionList m_oEHSConnectionList;

        NetworkAbstraction * m_poNetworkAbstraction;

        ehs_threadid_t m_nAcceptThreadId;

        int m_nIdleTimeout;

        int m_nThreads;

        CurrentRequestMap m_oCurrentRequest;

        pthread_attr_t m_oThreadAttr;

        friend class EHSConnection;
};

#endif // _EHSSERVER_H_