ippSpyClient.cpp

Go to the documentation of this file.

#include "stdafx.h"

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


ippSpyClient::ippSpyClient()
: _state(disconnected) 
, _parent(0)
{ 

}
ippSpyClient::~ippSpyClient()
{

}

void ippSpyClient::setParent(ippClientServerSpy* parent)
{
  _parent=parent;
}

void ippSpyClient::Connect(
  const char* hostname,
  int port
)
{
  IPP_ASSERT(_state== disconnected);
  
  if(_state != disconnected) {
    return;
  }
  
  
//  while(!_pending_commands.empty()) {
//    _pending_commands.pop();
//  }

  bool bSuccess = _socket.Create();
  IPP_ASSERT(bSuccess);
 

  ippSocket::SERROR nRet =  _socket.Connect(hostname,port);
  if (nRet == ippSocket::SOCKET_WOULD_BLOCK) {
    //
    _state = trying_to_connect;
  } else  if (nRet == ippSocket::SOCKET_IS_CONNECTED) { 
    _state = connected;
//    _in_error_state = false;
//    _ready_to_send = true;
  } else {
    _state = disconnected;
    _socket.Close();
  }
}

void ippSpyClient::ProcessLine(const char* inputline)
{
  _parent->SendResponseLine(inputline,/* wellformed = */true);
}
void ippSpyClient::ProcessMisformedLine(const char* inputline)
{
  _parent->SendResponseLine(inputline,/* wellformed = */false);
}
void ippSpyClient::HeartBeat()
{
  ippSleep(1); // allow context switch
  switch(_state){
  case trying_to_connect:
    {
      switch(_socket.CanSendData()){ 
        case ippSocket::SOCKET_OK: 
          //xx _ready_to_send = true;
          //xx _in_error_state = false;
          _state = connected; 
        break;
        case ippSocket::SOCKET_WOULD_BLOCK:
          // this mean that the server is probably busy
          Disconnect();
          break;
        default:
          _state = disconnected;
          _socket.Close();
        }
      } break;
  case connected:
    {
      PerformRead();
    }
  }
}

void ippSpyClient::SendCommand(const char* command)
{
  //xx IPP_ASSERT(_ready_to_send);
  LogMessage("     send :",command);
  
  int _pending_tag=0;
  if(command[0]=='E') {
    sscanf(command+1,"%4d",&_pending_tag);
  } else {
    sscanf(command,"%5d",&_pending_tag);
  }
 
  _socket.Write(command);
  
  // see if we need to send the line termination
  int l = strlen(command);
  if (l > 2 && command[l-1] != '\n' && command[l-2]!='\r') { 
     _socket.Write("\r\n");
  }

 //xx _ready_to_send = false;
  // read the acknowledge tag
}

void ippSpyClient::Disconnect()
{
   ProbeConnection();
  _state = disconnected;
  _socket.Close();
//xx  _ready_to_send = false;
//xx  _in_error_state = false;
  LogMessage(" disconnected","");

 //xx _parent->Stop();
}

---