---

/home/gilberto/prog/tesi2.31/TelepatiTcp/TCPConnection.h

Go to the documentation of this file.

#ifndef TCPConnection_h_DEFINExD
#define TCPConnection_h_DEFINED

#include <ant.h>
#include <IPAddress.h>
#include <OPENR/OSyslog.h>

enum ConnectionState {
  
  CONNECTION_INVALID=0,    
  CONNECTION_CONNECTING=1, 
  CONNECTION_CONNECTED=2,  
  CONNECTION_WAITING=3,    
  CONNECTION_LISTENING=4,  
  CONNECTION_SENDING=5,    
  CONNECTION_RECEIVING=6,  
  CONNECTION_CLOSING=7,    
  CONNECTION_CLOSED=8      
};

class TCPConnection {
 public:
  TCPConnection() { state= CONNECTION_INVALID; }; 
  TCPConnection(antStackRef ipStack) {ipstackRef=ipStack; state = CONNECTION_CLOSED; };
  virtual ~TCPConnection() {};
  
  inline antModuleRef& getEndpoint() {return endpoint;};

  inline void setState(ConnectionState st) {state = st;};
  inline ConnectionState getState() { return state;};

  inline void setPort(Port prt) {port=prt;};
  inline Port getPort() {return port;};

  virtual OStatus initConnection() = 0;
  virtual OStatus stop() = 0;
  
 protected:
  antModuleRef endpoint;     
  antStackRef ipstackRef;    
  
  ConnectionState state;     
  Port port;  
};

class TCPRecvConnection : public TCPConnection { 
 public:
  TCPRecvConnection() {}; 
  TCPRecvConnection(antStackRef ipStack, int bs);

  ~TCPRecvConnection(); 

  OStatus initConnection();
  OStatus stop();
  
  inline byte* getRecvData() { return recvData;};
  inline int getRecvSize() { return recvSize;}
  inline void setRecvSize(int size) { recvSize=size;}

 private:
    
  /* Buffer di ricezione*/
  antSharedBuffer recvBuffer; 
  /* Puntatore ai dati contenunti nel buffer di ricezione*/
  byte* recvData;         
  /* Dimensione buffer di Ricezine*/
  int recvSize;           
  
  /* Inizializza il buffer. @return oSUCCESS in caso si successo;
     oFAIL altrimenti*/   
  OStatus initBuffer();       
  /* Crea l'Endpoint- @return oSUCCESS in caso si successo; oFAIL
     altrimenti*/                 
  OStatus initTcpEndpoint();  
  
};


class TCPSendConnection : public TCPConnection {
 public:
  TCPSendConnection() {};  
  TCPSendConnection(antStackRef ipStack, int bs);

  ~TCPSendConnection(); 

  OStatus initConnection();
  OStatus stop();

  inline byte* getSendData() {return sendData;};
  inline int getSendSize() { return sendSize;}
  inline void setSendSize(int size) { sendSize=size;}
 private:
  
  /* Buffer di spedizione*/
  antSharedBuffer sendBuffer; 
  /* Puntatore ai dati contenunti nel buffer di spedizione*/
  byte* sendData;          
  /* Dimensione del buffer*/
  int bufferSize;            

  /* Dimensione dei dati da spedire*/
  int sendSize;             

  /* Inizializza il buffer. @return oSUCCESS in caso si successo;
     oFAIL altrimenti*/ 
  OStatus initBuffer();       
  /* Crea l'Endpoint. @return oSUCCESS in caso si successo; oFAIL
     altrimenti*/               
  OStatus initTcpEndpoint();  
};

#endif // TCPConnection_h_DEFINED

---