---

/home/gilberto/prog/tesi2.31/TelepatiUdp/UDPConnection.h

Go to the documentation of this file.

#ifndef UDPConnection_h_DEFINED
#define UDPConnection_h_DEFINED

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

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

class UDPConnection {
 public:
  UDPConnection() {state = CONNECTION_INVALID;};
  UDPConnection(antStackRef ipStack) {ipstackRef=ipStack; state = CONNECTION_CLOSED;  };

  virtual ~UDPConnection() {};

  inline antModuleRef& getEndpoint() {return endpoint;};
  inline void setState(ConnectionState st) {state = st;};
  inline ConnectionState getState() {return state;};
  
  virtual OStatus initConnection() = 0;
  virtual OStatus stop() = 0;  
  
 protected:
  antModuleRef endpoint;      
  antStackRef ipstackRef;     
  ConnectionState state;      
};

class UDPRecvConnection : public UDPConnection { 
 public:
  UDPRecvConnection() {};  
  UDPRecvConnection(antStackRef ipStack, int bs, Port port); 

  ~UDPRecvConnection();
  
  OStatus initConnection(); 
  OStatus stop();

  inline byte* getRecvData() { return recvData;};
  inline int getRecvSize() { return recvSize;}
  
 private:

  antSharedBuffer recvBuffer; /* Buffer di ricezione*/
  byte* recvData;             /* Puntatore ai dati contenunti nel buffer di ricezione*/
  int recvSize;               /* Dimensione buffer di Ricezione*/

  Port recvPort;              /* Porta di ricezione*/

  OStatus initBuffer();       /* Inizializza il buffer*/          
  OStatus initUdpEndpoint();  /* Crea l'Endpoint*/                
  OStatus initBind();         /* Effettua il Bind dell'Endpoint*/
};


class UDPSendConnection : public UDPConnection {
 public:
  UDPSendConnection() {}; 
  UDPSendConnection(antStackRef ipStack, int bs);

  ~UDPSendConnection();

  OStatus initConnection();
  OStatus stop();
  
  byte* getSendData() {return sendData;};
  inline int getSendSize() { return sendSize;}
  inline void setSendSize(int size) { sendSize=size;}

 private:

  antSharedBuffer sendBuffer; /* Buffer di spedizione*/
  byte* sendData;             /* Puntatore ai dati contenunti nel buffer di spedizione*/
  int bufferSize;             /* Dimensione del buffer*/
  int sendSize;               /* Dimensione dei dati spediti*/

  OStatus initBuffer();       /*Inizializza il buffer*/   
  OStatus initUdpEndpoint();  /*Crea l'Endpoint*/                 
  OStatus initBind();         /*Effettua il Bind dell'Endpoint*/
};

#endif // UDPConnection_h_DEFINED

---