---

tmon.h

/*
 * Copyright (c) 1991-2006 TIBCO Software Inc.
 * All rights reserved.
 * For more information, please contact:
 * TIBCO Software Inc., Palo Alto, California, USA
 *
 * $Id: //dev/packages/tpsi/cpsi/dev/68/src/rtworks/tmon.h#1 $
 */

#ifndef _T_MONITOR_HH_
#define _T_MONITOR_HH_

#include <rtworks/ipc.h>
#include <rtworks/tex.h>
#include <rtworks/tsrv.h>
#include <rtworks/tmon.h>

namespace SmartSockets {

  class T_IPCX_API TipcMonException : public TipcException {

  public:
    TipcMonException() {}

    virtual ~TipcMonException () throw() {}

  };


  class T_IPCX_API TipcMon {

    T_IPC_SRV _srv;

  public:
    TipcMon(const TipcSrv &tsrv) throw (TipcException);

    virtual ~TipcMon() throw();

  public:
    const char *  getIdentStr() const throw (TipcException);

    void setIdentStr(const char * type_str) throw (TipcException);

    // Watch methods

    void printWatch(T_OUT_FUNC out_func = (T_OUT_FUNC) TutOut)
    throw (TipcException);

    bool projectNamesGetWatch() const throw (TipcException);

    void projectNamesSetWatch(bool watch_status) throw (TipcException);

    bool clientNamesGetWatch() const throw (TipcException);

    void clientNamesSetWatch(bool watch_status) throw (TipcException);

    bool serverNamesGetWatch() const throw (TipcException);

    void serverNamesSetWatch(bool watch_status) throw (TipcException);

    bool subjectNamesGetWatch() const throw (TipcException);

    void subjectNamesSetWatch(bool watch_status) throw (TipcException);

    bool subjectSubscribeGetWatch(const char * subject_name) const
    throw (TipcException);

    void subjectSubscribeSetWatch(const char * subject_name, bool watch_status)
    throw (TipcException);

    void projectNamesPoll() throw (TipcException);

    void subjectNamesPoll() throw (TipcException);

    void subjectSubscribePoll(const char * dg_name) throw (TipcException);

    void clientNamesPoll() throw (TipcException);

    void serverNamesPoll() throw (TipcException);

    bool serverConnGetWatch() const throw (TipcException);

    void serverConnSetWatch(bool watch_status) throw (TipcException);

    void serverConnPoll() throw (TipcException);

    void serverGeneralPoll(const char * serverName) throw (TipcException);

    void serverTimePoll(const char * serverName) throw (TipcException);

    void serverBufferPoll(const char * serverName,
                          const char * connected_process_name)
    throw (TipcException);

    void serverOptionPoll(const char * serverName, const char * option_name)
    throw (TipcException);

    void serverMsgTrafficPoll(const char * serverName,
                              const char * connected_process_name)
    throw (TipcException);

    // New in 6.7 (this poll only)
    void serverMsgTrafficExPoll(const char * serverName,
                                const char * connected_process_name)
    throw (TipcException);

    void serverRoutePoll(const char * serverName, const char * dest_server_name)
    throw (TipcException);


    bool clientSubscribeGetWatch(const char * clientName) const
    throw (TipcException);

    void clientSubscribeSetWatch(const char * clientName,
                                 bool watch_status) throw (TipcException);

    bool clientTimeGetWatch(const char * clientName)  const
    throw (TipcException);

    void clientTimeSetWatch(const char * clientName,
                            bool watch_status) throw (TipcException);

    bool clientBufferGetWatch(const char * clientName) const
    throw (TipcException);

    void clientBufferSetWatch(const char * clientName,
                              bool watch_status) throw (TipcException);

    bool clientMsgRecvGetWatch(const char * clientName,
                               const char * msg_type_name) const
    throw (TipcException);

    void clientMsgRecvSetWatch(const char * clientName,
                               const char * msg_type_name,bool watch_status)
    throw (TipcException);

    bool clientMsgSendGetWatch(const char * clientName,
                               const char * msg_type_name) const
    throw (TipcException);

    void clientMsgSendSetWatch(const char * clientName,
                               const char * msg_type_name,
                               bool watch_status) throw (TipcException);


    void clientSubscribePoll(const char * clientName)
    throw (TipcException);

    void clientGeneralPoll(const char * clientName)
    throw (TipcException);

    void clientTimePoll(const char * clientName)
    throw (TipcException);

    void clientBufferPoll(const char * clientName)
    throw (TipcException);

    void clientOptionPoll(const char * clientName,
                          const char * option_name)
    throw (TipcException);

    void clientMsgTypePoll(const char * clientName,
                           const char * msg_type_name)
    throw (TipcException);

    // New in 6.7 (this poll only)
    void clientMsgTypeExPoll(const char * clientName,
                             const char * msg_type_name)
    throw (TipcException);

    void clientCbPoll(const char * clientName) throw (TipcException);

    void clientMsgTrafficPoll(const char * clientName)
    throw (TipcException);

    void clientSubjectPoll(const char * clientName,
                           const char * subject_name) throw (TipcException);

    // New in 6.7 (this poll only)
    void clientSubjectExPoll(const char * clientName,
                             const char * subject_name) throw (TipcException);

    // new APIs implemented in SS 6.4

    void clientNamesNumPoll() throw (TipcException);

    void clientSubscribeNumPoll(const char * client_name)
    throw (TipcException);

    void clientCpuPoll(const char * client_name)
    throw (TipcException);

    void serverCpuPoll(const char * server_name)
    throw (TipcException);

    void clientInfoPoll(const char * client_name)
    throw (TipcException);


    void clientCongestionSetWatch(const char * client_name, int4 high_water,
                                  int4 low_water,  bool watch_status) throw (TipcException);


    void serverCongestionSetWatch(const char * server_name,
                                  const char * connected_process_name, int4 high_water,
                                  int4 low_water,  bool watch_status) throw (TipcException);

    void serverMaxClientLicensesSetWatch(const char * server_name,
                                         bool watch_status) throw (TipcException);


    bool clientCongestionGetWatch(const char * client_name)
    throw (TipcException);

    bool serverCongestionGetWatch(const char * server_name,
                                  const char * connected_process_name) throw (TipcException);

    bool serverMaxClientLicensesGetWatch(const char * server_name)
    throw (TipcException);

    void clientExtPoll(const char * client_name)
    throw (TipcException);

    // new APIs implemented in SS 6.7

    void serverStartTimePoll(const char * serverName)
    throw (TipcException);

    void serverVersionPoll(const char * server_name)
    throw (TipcException);

    void clientVersionPoll(const char * client_name)
    throw (TipcException);

  };

} //namespace SmartSockets

#endif // _T_MONITOR_HH_

---