X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fmessaging%2Fmessage.hpp;h=838d9eece2a746be5031fd7fc46373d08a2d459e;hb=5328c8da64ea724f8730b7a0bbd3214fde66fca1;hp=0db0927f6baa851031e9cd5efd29098247c35bfb;hpb=0b08d9dc1639e926c1df4535703b67903a86aad7;p=ric-plt%2Fxapp-frame-cpp.git diff --git a/src/messaging/message.hpp b/src/messaging/message.hpp index 0db0927..838d9ee 100644 --- a/src/messaging/message.hpp +++ b/src/messaging/message.hpp @@ -49,6 +49,8 @@ #endif +namespace xapp { + // ------------------------------------------------------------------------ class Message { @@ -59,6 +61,7 @@ class Message { public: static const int NO_CHANGE = -99; // indicates no change to a send/reply parameter + static const int NO_WHID = -1; // no wormhole id applies static const int INVALID_MTYPE = -1; static const int INVALID_STATUS = -1; static const int INVALID_SUBID = -2; @@ -66,6 +69,7 @@ class Message { static const int RESPONSE = 0; // send types static const int MESSAGE = 1; + static const int WORMHOLE_MSG = 2; Message( rmr_mbuf_t* mbuf, void* mrc ); // builders Message( void* mrc, int payload_len ); @@ -77,14 +81,14 @@ class Message { std::unique_ptr Copy_payload( ); // copy the payload; deletable smart pointer - std::unique_ptr Get_meid(); // returns a copy of the meid bytes - int Get_available_size(); - int Get_len(); - int Get_mtype(); - Msg_component Get_payload(); - std::unique_ptr Get_src(); - int Get_state( ); - int Get_subid(); + std::unique_ptr Get_meid() const; // returns a copy of the meid bytes + int Get_available_size() const; + int Get_len() const; + int Get_mtype() const; + Msg_component Get_payload() const; + std::unique_ptr Get_src() const; + int Get_state( ) const; + int Get_subid() const; void Set_meid( std::shared_ptr new_meid ); void Set_mtype( int new_type ); @@ -93,7 +97,7 @@ class Message { bool Reply( ); bool Send( ); - bool Send( int mtype, int subid, int payload_len, unsigned char* payload, int stype ); + bool Send( int mtype, int subid, int payload_len, unsigned char* payload, int stype, int whid ); bool Send_msg( int mtype, int subid, int payload_len, std::shared_ptr payload ); bool Send_msg( int mtype, int subid, int payload_len, unsigned char* payload ); @@ -104,7 +108,10 @@ class Message { bool Send_response( int mtype, int subid, int payload_len, unsigned char* response ); bool Send_response( int payload_len, std::shared_ptr response ); bool Send_response( int payload_len, unsigned char* response ); + + bool Wormhole_send( int whid, int mtype, int subid, int payload_len, std::shared_ptr payload ); }; +} // namespace #endif