ippClientServerSpy.cpp

Go to the documentation of this file.

#include "stdafx.h"

#include "ippdme/Spy/ippClientServerSpy.h"
#include "ippdme/assert.h"
#include "ippdme/Server/ippLogger.h"

// state machine
//
//
//               
//   disconnected 
//        |
//        | start
//        |
//        |
//   Action:  server.listen
ippClientServerSpy::ippClientServerSpy()
  : _logger(0)
  , _oldClientState(ippSpyClient::trying_to_connect)
  , _oldServerState(ippSpyServer::connected)
  , _listening_port(1294)
  , _state(disconnected)
{
  _client.setParent(this);
  _server.setParent(this);

}

ippClientServerSpy::~ippClientServerSpy()
{
  Stop();
}


bool ippClientServerSpy::Start(
  int listening_port,
  const char* server_ip,
  int server_port
)
{
  _listening_port = listening_port;
  if (getStatus() != disconnected) {
    Stop();
  }
  IPP_ASSERT(getStatus() == disconnected);
  HeartBeat();

  _client.Connect(server_ip,server_port);
  _state = trying_to_connect_to_remote_server;

  HeartBeat();
  return true;
}



void ippClientServerSpy::HeartBeat()
{
  _server.HeartBeat();
  _client.HeartBeat();

  STATE oldState = _state;

  ippSpyClient::STATE newClientState = getClientStatus();
  if (_oldClientState == ippSpyClient::trying_to_connect && newClientState == ippSpyClient::connected )
  { 
    _server.PowerOn(_listening_port);
    if (_server.getStatus() == ippSpyServer::listening) { 
      _state = listening;
    }
  }
  ippSpyServer::STATE _newServerState = getServerStatus();

  if (_newServerState == ippSpyServer::connected) { 
    _state = connected;
  }

  if (_oldServerState != _newServerState ) {
    _oldServerState = _newServerState;
    //xx __raise ServerStatusChanged(_oldServerState);
  }

  if (oldState !=  _state) {
    OnStatusChanged(_state);
  }

}

void ippClientServerSpy::Stop()
{
  _server.PowerOff();
  _client.Disconnect();
  HeartBeat();
  IPP_ASSERT(getServerStatus() == ippSpyServer::uninitialized);
  IPP_ASSERT(getClientStatus() == ippSpyClient::disconnected);
  _state = disconnected;
}

ippClientServerSpy::STATE ippClientServerSpy::getStatus() const {
  return _state;
}
void ippClientServerSpy::SendCommandLine(const char* inputline,bool bwellFormed)
{
  _client.SendCommand(inputline);
  if(_logger) {
    _logger->WriteLineFormat("<<< %s",inputline);
  }
}

void ippClientServerSpy::SendResponseLine(const char* inputline,bool bwellFormed)
{
  _server.WriteToSocket(inputline);
  if(_logger) {
    _logger->WriteLineFormat(">>> %s",inputline);
  }
}

void ippClientServerSpy::setLogger(ippLogger* logger)
{
  _logger = logger;
}

ippLogger* ippClientServerSpy::GetLogger() const
{
  return _logger;
}

ippSpyClient::STATE ippClientServerSpy::getClientStatus() const
{
  return _client.getStatus();
}
ippSpyServer::STATE ippClientServerSpy::getServerStatus() const
{
  return _server.getStatus();
}

 

---