ippSpyServer.cpp

Go to the documentation of this file.

#include "stdafx.h"

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



ippSpyServer::ippSpyServer()
: _state(uninitialized)
, _parent(0)
{

}

ippSpyServer::~ippSpyServer()
{

}

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


void ippSpyServer::HeartBeat()
{
  ippSleep(1); // allow context switch
  switch(_state)
  {
  case uninitialized:
    return;
  case listening:
    PerformListening();
    return;
  case connected:
    PerformRead();
    ProbeConnection();
    return;
  }
}

void ippSpyServer::PerformListening()
{
  IPP_ASSERT(_state == listening);
  IPP_ASSERT(!_socket.IsValid());
  IPP_ASSERT(_listenSocket.IsValid());
 
  ippSocket::SERROR nRet = _listenSocket.Accept(_socket);
  
  switch(nRet) {
  case ippSocket::SOCKET_WOULD_BLOCK:
                // xx PRINTSTATUS("Waiting for connection ...");
    break;
  case ippSocket::SOCKET_OK:
    // we don't want to accept new connection 
    _listenSocket.Close();
    _state = connected;
    OnClientConnected();
    break;
  default:
    // a major problem has occur ...
    _listenSocket.Close();
    _state = uninitialized;
    break;
  }
}

void ippSpyServer::OnClientConnected()
{
  LogMessage("ippSpyServer::OnClientConnected");

}
void ippSpyServer::OnClientDisconnected()
{
  LogMessage("ippSpyServer::OnClientDisconnected");
}

bool ippSpyServer::PowerOff()
{
  _listenSocket.Close();
  _socket.Close();
  _state = uninitialized;
  return true;
}

bool ippSpyServer::PowerOn(int portNumber)
{

  _portNumber = portNumber;
  if (_state!=uninitialized ) {
    return false;
  }
  // Create a TCP/IP stream socket to "listen" 
  // incoming client connection
  if (!_listenSocket.Listen(_portNumber)) { 
          return false;
  }
  _state = listening;
  return true;
}
#include "ippdme/Parser/ippCommandParser.h"
void ippSpyServer::ProcessLine(const char* inputline)
{
  // verify that line received by the server from the external client
  // is syntacticly correct
  ippCommandParser parser;
  parser.setInput(inputline);
  ippCommandPtr ptr = parser.parseCommand();

  _parent->SendCommandLine(inputline,true);

}
void ippSpyServer::ProcessMisformedLine(const char* inputline)
{
  _parent->SendCommandLine(inputline,true);
}

void ippSpyServer::WriteToSocket(const char* line)
{
  int nRet = _socket.Write(line);
  if (nRet)  {
    OnConnectionLost();
  }
}

void ippSpyServer::OnConnectionLost()
{
  ippEngine::OnConnectionLost();
  OnClientDisconnected();

  // when a connection is lost the server goes
  // back to listen mode.
  // Create a TCP/IP stream socket to "listen" with
  if (!_listenSocket.Listen(_portNumber)) { 
    _state=uninitialized;
  } else {
    _state=listening;
  }
}

---