src/serveri.h

/*****************************************************************************
* This file is provided under the Creative Commons Attribution 3.0 license.
*
* You are free to share, copy, distribute, transmit, or adapt this work
* PROVIDED THAT you attribute the work to the authors listed below.
* For more information, please see the following web page:
* http://creativecommons.org/licenses/by/3.0/
*
* This file is a component of the Sleipnir library for functional genomics,
* authored by:
* Curtis Huttenhower (chuttenh@princeton.edu)
* Mark Schroeder
* Maria D. Chikina
* Olga G. Troyanskaya (ogt@princeton.edu, primary contact)
*
* If you use this library, the included executable tools, or any related
* code in your work, please cite the following publication:
* Curtis Huttenhower, Mark Schroeder, Maria D. Chikina, and
* Olga G. Troyanskaya.
* "The Sleipnir library for computational functional genomics"
*****************************************************************************/
#ifndef SERVERI_H
#define SERVERI_H

namespace Sleipnir {

class CServer;
class IServerClient;

class CServerImpl {
protected:
    typedef std::map<IServerClient*, pthread_t> TMapThreads;
    typedef std::vector<IServerClient*>         TVecClients;

    static const char*  c_szPort;
    static const char*  c_szTimeout;
    static CServer*     s_pServer;

#ifndef _MSC_VER
    static void Alarm( int );
#endif // _MSC_VER

    void Listen( );

    int             m_iPort;
    int             m_iTimeout;
    SOCKET          m_iSocket;
    bool            m_fStop;
    IServerClient*  m_pClient;
};

class CServerClientImpl {
public:
    static void* StartRoutine( void* );

    CServerClientImpl( SOCKET, IServerClient* );

private:
    static const size_t c_iBuffer   = 131072;

    ~CServerClientImpl( );

    void StartRoutine( );
    void ReadMessage( );

    SOCKET                      m_iSocket;
    IServerClient*              m_pClient;
    std::vector<unsigned char>  m_vecbMessage;
};

}

#endif // SERVERI_H