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"

#ifdef OPENR_ETHERSTAT  // se e' attivata la stampa delle statistiche di rete
#include <ERA201D1.h>
#endif

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);  
  void TimerEnd(void* msg);  
  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= 512;  
  static const longword TELEPATI_ACK_TIME= 1200; 
  static const longword TELEPATI_BONE_TIME= 5; 
 private:
#ifdef OPENR_DEBUG
  unsigned int sendMessage;
  unsigned int recvMessage;
#endif
#ifdef OPENR_ETHERSTAT
  void PrintWLANStatistics(const EtherDriverGetWLANStatisticsMsg& msg);
  void PrintWLANSettings(const EtherDriverGetWLANSettingsMsg& msg);
  void PrintEtherStatistics(const EtherDriverGetStatisticsMsg& msg);
#endif
  vector<IPAddress> aiboIp;         /* Vettore di indirizzi IP degli AIBO*/
  UDPRecvConnection recvConnection; /* Endpoint per la ricezione*/
  UDPSendConnection sendConnection; /* Endpoint per la spedizione*/
  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*/
  vector<TelepatiPkg*> ackWaitingMsg; /* Vettore che memorizza i messaggi in attesa di un Ack  */
  
  antStackRef    ipstackRef;      /* Riferimento allo stack IP (richiesto da OPENR)*/
  
  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();      /* Inizializza il buffer di spedizione*/
  OStatus initSendUdpEndpoint(); /* Inizializza l'Endpoint UDP per la spedizione*/
  OStatus initSendBind();        /* Fa il Bind dell'Endpoint di spedizione*/
  
  void send(TelepatiPkg* msg);   /* Spedisce il messaggio. @param msg messaggio da spedire*/
  void receive();                /* Avvia la ricezione*/
  
  /* Manda un HyMsg (msg di saluto) all'i-esimo Aibo. @param i aibo a cui mandare l'hy message*/
  inline void sendHyMsg(int i){
    OSYSDEBUG(("Telepati::sendHyMsg(%d)\n",i));
    send(new HyPkg(i));
#ifdef TELEPATI_POLLING
    aiboIpActive[i]= (aiboIpActive[i] == ACTIVE ? WAITINGREPLY : aiboIpActive[i]);
#endif
  };

  /* Manda un HyReplyMsg (msg di risposta al saluto) all'i-esimo Aibo. @param i aibo a cui mandare l'HyReply message*/
  inline void sendHyReplyMsg(int i){
    OSYSDEBUG(("Telepati::sendHyReplyMsg(%d)\n",i));
    send(new HyReplyPkg(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.*/
  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. @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

---