---

asyncclientconnector.h

Go to the documentation of this file.

/********************************************************************
        Copyright (c) 2001, Lee Patterson & Ant Works Software
        http://ssobjects.sourceforge.net

        created  :  
        filename :  asyncclientconnector.h
        author   :  Lee Patterson (workerant@users.sourceforge.net)
        
        purpose  :  
*********************************************************************/

#ifndef ASYNCCLIENTCONNECTOR_H
#define ASYNCCLIENTCONNECTOR_H

#include "ssobjects.h"
#include "serversocket.h"
#include "packetmessageque.h"

namespace ssobjects
{

#define throwAsyncClientConnectorException(m) (throw AsyncClientConnectorException(m,__FILE__,__LINE__))

class AsyncClientConnectorException : public GeneralException
{
  public: // Constructor/destructor
    AsyncClientConnectorException(char* pchMessage,const char* pFname,const int iLine) 
                        : GeneralException(pchMessage,pFname,iLine){};
};

class AsyncClientConnector
{

  protected:  //attributes
    unsigned16      m_wPort;      
    CStr            m_strHost;    
    ServerSocket*   m_pSocket;    
    PacketMessageQue        m_que;        
#ifdef _WIN32
    WSADATA         m_wsd;        
#endif

  protected:
    void        cleanup();        
    void        setNonBlocking(SOCKET sockfd);  

  private:    //construction
    AsyncClientConnector();

  public:     //overridables
    void handleException(GeneralException& e);
    void sendPacket(PacketBuffer* pPkt);          
    void sendPacket(PacketBuffer& pPkt);          
    void operator << (PacketBuffer&);             
    void operator << (PacketBuffer*);             
    PacketMessage* getMsg();                          

//TODO: add setTimeout() method

  public:     //construction
    AsyncClientConnector(const char* pszHost,word wPort);    
    ~AsyncClientConnector();                                 

  public:     //methods
    const char* getServer()     {return m_strHost;}                   
    const word  getPort()       {return m_wPort;}                     
    bool        isConnected()   {return m_pSocket ? true:false;}      
    ServerSocket* getSocket();                                        

    void        reconnect();                                          
    void        connect(const char* pszHost,const unsigned16 wPort);  
    void        connect();                                            
    void        close();                                              
    bool        idle();                                               

  private:
    //unused overloads
    AsyncClientConnector(const AsyncClientConnector&);
    AsyncClientConnector& operator=(const AsyncClientConnector&);
};

};

#endif  //ASYNCCLIENTCONNECTOR_H

---