---

tmt.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/tmt.h#1 $
 */

#ifndef _T_MESSAGE_TYPE_HH_
#define _T_MESSAGE_TYPE_HH_

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


namespace SmartSockets {                     

  class T_IPCX_API TipcSrv;
  class T_IPCX_API TipcMsg;

  class T_IPCX_API TipcMtException : public TipcException {

  public:
    TipcMtException () {}

    virtual ~TipcMtException () throw() {}

  };


  class T_IPCX_API TipcMt;

  class T_IPCX_API TipcMtTraverser {
  public:
    typedef bool (TipcMtTraverser::* Handler) (const char* name, TipcMt& mt); 

    TipcMtTraverser();

    void setHandler(Handler cbMethod);

    Handler getHandler();

    virtual ~TipcMtTraverser() throw();

    virtual bool onTraverse (const char* name, TipcMt& mt)throw () ;

    static T_PTR T_ENTRY traverseFuncDelegator 
    (
    T_STR name,
    T_IPC_MT mt,
    T_PTR arg
    );

  private:

    Handler _cbMethod;


  };

  class T_IPCX_API TipcMtEncrypt {
  public:
    typedef void (TipcMtEncrypt::* Handler) (void*& data, int4& dataSize, 
                                             const void* key, int4 keySize); 

    TipcMtEncrypt();

    void setEncryptHandler(Handler encryptMethod) ;
    Handler getEncryptHandler();

    void setDecryptHandler(Handler decryptMethod);

    Handler getDecryptHandler();


    virtual ~TipcMtEncrypt() throw();

    virtual  void encrypt(void*& data, int4& dataSize, const void* key, int4 keySize) 
    throw (TipcException);

    virtual  void decrypt(void*& data, int4& dataSize, const void* key, int4 keySize) 
    throw (TipcException);



    static void T_ENTRY encryptFuncDelegator 
    (
    T_BUF buf ,
    T_PTR key,
    T_INT4 key_size,
    T_PTR arg
    );

    static void T_ENTRY decryptFuncDelegator 
    (
    T_BUF buf ,
    T_PTR key,
    T_INT4 key_size,
    T_PTR arg
    );

  private:

    Handler _encryptMethod;
    Handler _decryptMethod;


  };



  class T_IPCX_API TipcMt {



    friend class TipcConn;
    friend class TipcSrv;
  private:
    T_IPC_MT _mt;  


  public:


    TipcMt(T_IPC_MT mt) throw ();

    TipcMt(const char * name) throw (TipcException);

    TipcMt(int4 num) throw (TipcException);


    TipcMt(const TipcMt& mt) throw (TipcException);

    virtual ~TipcMt() throw();

    static TipcMt create(const char * name, int4 num, const char * grammar) throw (TipcException);

    static TipcMt lookup(const char * name) throw (TipcException); 

    static void traverse(TipcMtTraverser* travObj)
    throw (TipcException);



    static TipcMt lookup(int4 num) throw (TipcException);


    static void destroy(TipcMt& mt) throw (TipcException);


    operator T_IPC_MT() const  throw() { return _mt;}

    void print(T_OUT_FUNC func =(T_OUT_FUNC)::TutOut) const 
    throw (TipcException);



    const char *  getGrammar() const throw (TipcException);

    const char *  getName() const throw (TipcException);



    int4 getNum() const throw (TipcException);


    int2 getPriority() const throw (TipcException);
    void setPriority(int2 priority) throw (TipcException);
    void setPriorityUnknown()throw (TipcException);



    int4 getUserProp() const throw (TipcException);
    void setUserProp(int4 user_prop) throw (TipcException);




    bool getCompression() const throw (TipcException);
    void setCompression(bool compression) throw (TipcException);




    T_IPC_DELIVERY_MODE getDeliveryMode() const throw (TipcException);

    void setDeliveryMode(T_IPC_DELIVERY_MODE delivery_mode)
    throw (TipcException);




    T_IPC_LB_MODE getLbMode() const throw (TipcException);
    void setLbMode(T_IPC_LB_MODE lb_mode) throw (TipcException); 



    real8 getDeliveryTimeout() const throw (TipcException);

    void setDeliveryTimeout(real8 delivery_timeout) 
    throw (TipcException);




    bool getHeaderStrEncode() const throw (TipcException);

    // set the header encode mode
    void setHeaderStrEncode(bool header_encode) 
    throw (TipcException);



    void setKey(const void* keyValue, int4 size) throw (TipcException);

    void setEncryptObj(TipcMtEncrypt* encryptObj = NULL)
    throw (TipcException);    


    TipcMtEncrypt* getDecryptObj() const 
    throw (TipcException);

    void setDecryptObj(TipcMtEncrypt* decryptObj = NULL)
    throw (TipcException);      



    TipcMtEncrypt* getEncryptObj() const
    throw (TipcException);

  };

} // namespace SmartSockets

#endif //_T_MESSAGE_TYPE_HH_

---