OrbitObserver/AccelerationClient.cpp

Go to the documentation of this file.

#include "AccelerationClient.h"

using namespace std;

/*! \brief Default constructor. Object will be useless until <code>Connect()</code>
 *   is called.
 */
AccelerationMessage::AccelerationMessage( )
    : m_clientSocket( NULL )
{
        m_deltaV = 0;
}

/*! \brief Constructs the device and calls Connect().  This method has no return
 *  value so failures in the Connect() method may not be reported.  If
 * failures must be handled, you should use the default constructor and
 * call Connect() explicitly.
 *
 * @param serverName argument is the hostname or dotted decimal IP address at
 * which Sim Propagator is to be found.  The port number is presumed to be the
 * default port.
 * @param port
 */
AccelerationMessage::AccelerationMessage( const char *serverName, int port )
   : m_clientSocket( NULL )
{
        Connect( serverName, port );
        m_deltaV = 0;
}

/*! \brief Destroys the AccelerationMessage.
 */
AccelerationMessage::~AccelerationMessage( )
{
        delete m_clientSocket;
}

/*! \brief Attempts to connect the SimPropagator.
 *
 * @param serverName argument is the hostname or dotted decimal IP address at
 * which the Sim Propagator is to be found.
 * @param portNumber argument is the port to access on the server.
 * @return 0 on success or -1 on failure.
 */
int AccelerationMessage::Connect( const char *serverName, int portNumber )
{
        int returnValue = -1;

        try
        {

                if ( m_clientSocket != NULL)
                {
                        delete m_clientSocket;
                }

                m_clientSocket = new ClientSocket;

                m_clientSocket -> Connect( serverName, portNumber );
        }
        catch ( SocketException& error )
        {
                std::cout << "Exception was caught: " << error.description( ) << "\n";
                return( returnValue );
        }
        returnValue = 0;
        return( returnValue );
}

/*! \brief Send a message that is stored in m_message to the acceleration server
 *
 *  returns the length of the message or -1 for failure.
 */
int AccelerationMessage::SendMessage( )
{
        int returnValue = -1;

        try
        {
                *m_clientSocket << m_message;
        }
        catch ( SocketException& error )
        {
                std::cout << "Exception was caught: " << error.description( ) << "\n";
                return( returnValue );
        }

        returnValue = m_message.length( );
        return ( returnValue );
}


/*! \brief Receive a message from the acceleration server
 *
 *  returns the length of the message or -1 for failure.
 */
int AccelerationMessage::ReceiveMessage( )
{
        int returnValue = -1;

        try
        {
                *m_clientSocket >> m_response;
        }
        catch ( SocketException& error )
        {
                std::cout << "Exception was caught: " << error.description( ) << "\n";
                return( returnValue );
        }

        returnValue = m_response.length( );
        return ( returnValue );
}


/*! \brief Parses response from Acceleration Server.
 *
 *  $PASHR ACK
 *  $PASHR NACK
 *  $PASHR VEL deltaV
 */
void AccelerationMessage::CheckResponse( )
{
        stringstream _response( m_response );
        string command;
        string function;

        _response >> command;

        switch ( ConvertString( command ) )
        {
                case $PASHR:
                        _response >> function;
                        switch( ConvertString( function ) )
                        {
                                case VEL:
                                        _response >> m_deltaV;
                                        break;
                                case ACK:
                                        cout << "Command Successfully Sent." << endl;
                                        break;
                                case NACK:
                                        cout << "WARNING: Command NOT Successfully Sent. " << endl;
                                        break;
                                default:
                                        cout << "WARNING: BAD FUNCTION RESPONSE FROM ACCELERATION SERVER " << function << endl;
                                        break;
                        }
                        break;

                default:
                        cout << "WARNING: BAD RESPONSE FROM ACCELERATION SERVER " << m_response << endl; 
                        break;

        }
        
}

/*! \brief Convert string to int for switch case
 *
 *  @param data
 */
int AccelerationMessage::ConvertString( string data )
{
        if( data == "$PASHR" ) return( $PASHR );
        else if( data == "VEL" ) return( VEL );
        else if( data == "ACK" ) return( ACK );
        else if( data == "NACK" ) return( NACK );
        else return( -1 );
}

/*! \brief Send acceleration message to acceleration server
 * 
 */
void AccelerationMessage::SendAccelerationMessage( int _spaceVehicleNumber, double _startTime, double _duration, CAMdoubleVector _acceleration, double _mass )
{
        stringstream _message;
        _message.precision( 16 );
        _message << "$PASHS ACC " << _spaceVehicleNumber << " "
                 << _startTime << " "
                 << _duration << " "
                 << _acceleration(1) << " "
                 << _acceleration(2) << " "
                 << _acceleration(3) << " "
                 << _mass << endl;
        m_message = _message.str( );

        if( SendMessage( ) == -1 )
                cerr << "WARNING: MESSAGE FAILED TO SEND CORRECTLY TO ACCELERATION SERVER " << endl;

        if( ReceiveMessage( ) == -1 )
                cerr << "WARNING: MESSAGE FAILED TO RECEIVE CORRECTLY FROM ACCELERATION SERVER " << endl;

        CheckResponse( );
}


double AccelerationMessage::GetDeltaV( )
{
        stringstream _message;
        _message.precision( 18 );
        _message << "$PASHQ VEL" << endl;
        m_message = _message.str( );
        
        if( SendMessage( ) == -1 )
                cerr << "WARNING: MESSAGE FAILED TO SEND CORRECTLY TO ACCELERATION SERVER " << endl;

        if( ReceiveMessage( ) == -1 )
                cerr << "WARNING: MESSAGE FAILED TO RECEIVE CORRECTLY FROM ACCELERATION SERVER " << endl;

        CheckResponse( );
        
        return( m_deltaV );     
}


void AccelerationMessage::ResetValues( )
{
        stringstream _message;
        _message.precision( 18 );
        _message << "$PASHS RST" << endl;
        m_message = _message.str( );
        
        if( SendMessage( ) == -1 )
                cerr << "WARNING: MESSAGE FAILED TO SEND CORRECTLY TO ACCELERATION SERVER " << endl;

        if( ReceiveMessage( ) == -1 )
                cerr << "WARNING: MESSAGE FAILED TO RECEIVE CORRECTLY FROM ACCELERATION SERVER " << endl;

        CheckResponse( );
}

---