Telepati.h

#ifndef Telepati_h_DEFINED
#define Telepati_h_DEFINED

#include <OPENR/OObject.h>
#include <OPENR/OSubject.h>
#include <OPENR/OObserver.h>

#include "UDPConnection.h"  //Strutture delle connessioni usate da Telepati
#include <ant.h>  //stack tcp/ip
#include <EndpointTypes.h>  //tipi di Endpoint
#include "./Packages/Packages.h" //package usati da Telepati i TelepatiPkges

#include <vector> 
#include <queue>
#include "def.h"

#include "EtherStat.h"

using namespace std; 
const char* const AIBONET="/MS/OPEN-R/MW/CONF/AIBONET.CFG";  
class Telepati : public OObject {
 public:
    
  Telepati();
  virtual ~Telepati();
  
  OSubject*    subject[numOfSubject]; 
  OObserver*   observer[numOfObserver];
  virtual OStatus DoInit   (const OSystemEvent& event); 
  virtual OStatus DoStart  (const OSystemEvent& event); 
  virtual OStatus DoStop   (const OSystemEvent& event); 
  virtual OStatus DoDestroy(const OSystemEvent& event); 
  
  void SendCont(ANTENVMSG msg);  
  void ReceiveCont(ANTENVMSG msg);  
  inline void TimerEnd(void* msg){
    OSYSDEBUG(("#"));
    if(ackWaitingMsg != 0) //se c'e' un messaggio in attesa di Ack
      sendViaCtrl(ackWaitingMsg);
    return;};
  void BoneTimerEnd(void* msg);  
  void EtherStat(void* msg);  
  
  void SendNotify(const ONotifyEvent& event); 

  static const Port TELEPATI_PORT= 3030;  
  static const int TELEPATI_BUFFER_SIZE= 1024;  
  static const longword TELEPATI_ACK_TIME= 500; 
  static const longword TELEPATI_BONE_TIME= 8; 
  enum {
    DATA_CONNECTION=0, 
    CTRL_CONNECTION=1  
  }; 

 private:

  unsigned int sendMessage;
  unsigned int totalRecvMessage;
  unsigned int dataRecvMessage;

  vector<IPAddress> aiboIp;         /* Vettore di indirizzi IP degli AIBO*/
  UDPRecvConnection recvConnection; /* Endpoint per la ricezione*/
  UDPSendConnection* sendConnection; /* Array di Endpoint per la spedizione (ctrl Endpoint e Data Endpoint*/
  aiboState* aiboIpActive;          /* Stato di attivita' degli aibo presenti. Array, in link con aiboIp, di aiboState*/
  unsigned short* expectedSerial;   /* Array dei seriali attesi da ogni Aibo*/
  int numaibo;                      /* Numero di aibo presenti nel campo meno 1 (escluso colui su cui gira Telepati)*/
  queue<TelepatiPkg*> sendQueue;    /* Coda di TelepatiPkg. Si occupa della memorizazione dei messaggi in attesa di essere spediti*/
  queue<TelepatiPkg*> sendCtrlQueue; /* Coda dei messaggi di controllo.*/
  TelepatiPkg* ackWaitingMsg;      /* Puntatore che memorizza il messaggio in attesa di un Ack  */
  
   
  antStackRef ipstackRef;           /* Riferimento allo stack IP (richiesto da OPENR)*/
  EventID ackEvent;                 /*Evento: timer ciclico di controllo degli Ack ricevuti*/

  static const size_t LINEBUFFERSIZE= 256;   /* Buffer per il parsing dei file*/
  
  struct ackIdentify{
    unsigned short serial;
    int aibo;
  };

  OStatus parseIpConfigFile();   /* Parser del file di configurazione. Imposta numaibo, aiboIp, aiboIpActive. Fa il parsing del file AIBONET*/
  OStatus initConnections();     /* Inizializza le connessioni*/
  OStatus initRecvBuffer();      /* Inizializza il buffer di ricezione*/
  OStatus initRecvUdpEndpoint(); /* Inizializza l'Endpoint UDP per la ricezione*/
  OStatus initRecvBind();        /* Fa il Bind dell'Endpoint di ricezione */

  OStatus initSendBuffer(int i);      /* Inizializza il buffer di spedizione*/
  OStatus initSendUdpEndpoint(int i); /* Inizializza l'Endpoint UDP per la spedizione*/
  OStatus initSendBind(int i);        /* Fa il Bind dell'Endpoint di spedizione*/
  
  void send(TelepatiPkg* msg);   /* Spedisce il messaggio. @param msg messaggio da spedire*/
  void sendViaCtrl(TelepatiPkg* msg); /*Spedisce il messaggio attraverso la connessione Ctrl. @param msg messaggio da spedire*/
  void sendViaData(TelepatiPkg* msg); /*Spedisce il messaggio attraverso la connessione Data. @param msg messaggio da spedire*/
  void receive();                /* Avvia la ricezione*/
  
  /* Manda un HiMsg (msg di saluto) all'i-esimo Aibo. @param i aibo a cui mandare l'hy message*/
  inline void sendHiMsg(int i){
    OSYSDEBUG(("Telepati::sendHiMsg(%d)\n",i));
    send(new HiPkg(i));
#ifdef TELEPATI_POLLING
    aiboIpActive[i]= (aiboIpActive[i] == ACTIVE ? WAITINGREPLY : aiboIpActive[i]);
#endif
  };

  /* Manda un HiReplyMsg (msg di risposta al saluto) all'i-esimo Aibo. @param i aibo a cui mandare l'HiReply message*/
  inline void sendHiReplyMsg(int i){
    OSYSDEBUG(("Telepati::sendHiReplyMsg(%d)\n",i));
    send(new HiReplyPkg(i));
  };
  /* Manda un ByeMsg (msg di arrivederci) all'i-esimo Aibo. @param i aibo a cui mandare il byte message*/
  inline void sendByeMsg(int i){
    OSYSDEBUG(("Telepati::sendByeMsg(%d)\n",i));
    send(new ByePkg(i));
  };

  void sendAiboInfoMsg();        /* Manda un AiboInfoMsg all'observer di Telepati*/
  
  int aiboFromIp(const IPAddress& ip) const; /* Converte l'IP passato come parametro nell'indice da usare nell'array aiboIp*/
  void checkQueue();             /* Controlla la presenza di messaggi in attesa di essere spediti e, se presenti, li spedisce.*/
  void checkCtrlQueue();          /* Controlla la presenza di messaggi di ACK in attesa di essere spediti e, se presenti, li spedisce.*/
  IPAddress* retrieveMyIp();     /* Recupera l'indirizzo IP dell'Aibo stesso*/
  bool setAiboIpActive(int aibo, aiboState newVal);  /* Imposta l'array aiboIpActive per i-esimo Aibo in base al valore passato e se cambia ne informa l'observer. @param aibo aibo di cui modificare lo stato di attivita'. @param newVal nuovo stato di attività. @return true: se ha cambiato stato; false: altrimenti.*/
  void eraseFromAckWaitingMsg(unsigned short serial, int aibo);  /* Cancella un msg dal vettore ackWaitingMsg @param serial seriale del messaggio da cancellare @param aibo aibo di destinazione */
};

#endif  //Telepati_h_DEFINED

---