/cygdrive/d/src/svn/vrut/trunk/modules/tracking/backup/receiver.cpp

Go to the documentation of this file.

/*
 * $Id: receiver.cpp $
 *
 * Description  : UDP packet listener
 * Author       : Radek Bien <mail: radek.bien@seznam.cz>  <ICQ: 201-963-660>
 *
 * Purpose      :
 *     UDP packet receiver implementation file
 */

#include "receiver.h"
#include "../../core/src/flexilog.h"
Receiver::Receiver(wxString remoteAddr, unsigned short remotePort, unsigned short localPort, unsigned bufferLength)
{
       packetBuffer = new char[bufferLength + 1];
       packetMaxLength = bufferLength;

       local.AnyAddress();
       local.Service(localPort);
       //remote.Hostname(remoteAddr);
       remote.AnyAddress();
       remote.Service(remotePort);

       recvSocket = new wxDatagramSocket(local,  wxSOCKET_NOWAIT);
       if (recvSocket->Error()) LOGERROR(wxT("<Tracking> Socket error while creating"));
//     this->recvSocket->SetEventHandler(*this, SocketHandlingID);
//     this->recvSocket->SetNotify(wxSOCKET_OUTPUT_FLAG | wxSOCKET_INPUT_FLAG | wxSOCKET_CONNECTION_FLAG| wxSOCKET_LOST_FLAG);
//     this->recvSocket->Notify(true);
//     this->Connect(wxEVT_SOCKET, wxSocketEventHandler(Receiver::ProcessEvtSocket), NULL, this);
}
Receiver::~Receiver()
{
       delete [] packetBuffer;
       recvSocket->Destroy();
}
void Receiver::UpdateSocket(wxString remoteAddr, unsigned short remotePort, unsigned short localPort)
{
  recvSocket->Destroy();
  local.AnyAddress();
  local.Service(localPort);
  //remote.Hostname(remoteAddr);
  remote.AnyAddress();
  remote.Service(remotePort);
  

       recvSocket = new wxDatagramSocket(local,  wxSOCKET_NOWAIT);
       if (recvSocket->Error()) LOGERROR(wxT("<Tracking> Socket error while updating"));
       LOGERROR(wxT("<Tracking> Socket recreated"));

}
bool Receiver::Receive()
{
  //  recvSocket->WaitForRead(0, 10);
  //  recvSocket->SetTimeout(1);

  recvSocket->RecvFrom(remote, packetBuffer, packetMaxLength);
       packetLength = recvSocket->LastCount();
       if (packetLength != 0)
       {
              if (packetLength > packetMaxLength){ LOGERROR(wxT("<Tracking> Too long datagram received!")); return false;};
              if (packetLength == packetMaxLength){ LOGWARNING(wxT("<Tracking> Maximum amount of data on receiver buffer. Consider larger")); return false;};
              packetBuffer[packetLength] = 0;
              return true;
       }
       // if (recvSocket->Error()){ LOGERROR(wxT("<Tracking> Socket Error - no data received.")); return false;}
       return false;
}
void Receiver::ResizeBuffer(unsigned short length)
{
       if (length != packetMaxLength)
       {
              packetMaxLength = length;
              delete [] packetBuffer;
              packetBuffer = new char[length  + 1];
       }
}

---