RTToolsetObserver.h

/*
 * Licensed Materials - Property of HCL and/or IBM
 * Copyright HCL Technologies Ltd. 2016, 2021. All Rights Reserved.
 * Copyright IBM Corporation 1999, 2016. All Rights Reserved.
 *
 * U.S. Government Users Restricted Rights -  Use, duplication or 
 * disclosure restricted by GSA ADP Schedule.
 */
 
#ifndef __RTToolsetObserver_h__
#define __RTToolsetObserver_h__ included
 
#ifdef PRAGMA
#pragma interface
#endif
 
#ifndef __RTObserver_h__
#include <RTObserver.h>
#endif
 
#ifndef __endeBoth_h__
#include <endeBoth.h>
#endif
 
#ifndef __endeTarg_h__
#include <endeTarg.h>
#endif
 
class RTToolsetObserver : public RTObserver
{
private:
    TO_bufferInfo rxBuffer;
    TO_bufferInfo txBuffer;
    TO_bufferInfo txTempBuffer;
    TO_structInfo structInfo;
 
public:
          RTToolsetObserver( RTDebugger  * theDebugger,
                     RTTcpSocket * theSocket,
                     int           theObsId,
                     const char  * initBuf = nullptr,
                     int           initLen = 0 );
    virtual       ~RTToolsetObserver( void );
 
    virtual int   evtChain(        int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
    virtual int   evtState(        int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtPresence(     int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtReference(    int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtMessageIn(    int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtMessageOut(   int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtMessageOutIn( int                  daemonId,
                   const RTDaemonInfo & sndDaemonInfo,
                   const RTDaemonInfo & recDaemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtRtsStatus(    int                  daemonId,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtVariable(     int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtChildren(     int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;                   
 
    virtual int   evtHistory(      int                  daemonId,
                   const RTDaemonInfo & daemonInfo,
                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   evtMessageQueue( int daemonId,
                                   const RTDaemonInfo & daemonInfo,
                                   const RTEventInfo  & eventInfo ) override;
 
    virtual int   receiveData ( void ) override;
    virtual int   transmitData( void ) override;
 
private:
    void          encoDeco( char * buffer, int bufLen );
 
    void          handleDaemon( void );
    void          handleActor( void );
    void          handlePort( void );
    void          handleState( void );
    void          handleChain( void );
    void          handleVariable( void );
    void          accessVariable( void );
    void          handleInject( void );
    void          handleGetMessages( void );
    void          handleSendToApp(void);
    void          handleGetChildren(void);
    void          sendResultCode( int resultCode );
 
    void          sendTxBuffer( void );
 
    static char * buildString( const char * actor_path,
                   int          actor_index,
                   const char * component_name = nullptr );
 
    // The data in message events is limited to this many bytes.
    enum { msgDataBufSize = 1000 };
 
private:
    // unavailable methods
    RTToolsetObserver( const RTToolsetObserver & );
    RTToolsetObserver & operator=( const RTToolsetObserver & );
}; //lint !e1712
 
#endif // __RTToolsetObserver_h__