X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fxapp-mgmt%2Fmsgs_proc.hpp;h=8637440375bf66c3e03fb0b0267ff0838d77c1a1;hb=91d30a6530398a9c7e50a15ea1cf9a027953bd39;hp=ec15933434fb9da348173a4f8c5238525b22c814;hpb=433b7b2a72c174c75ce2c0c75b225fa0bb813d32;p=ric-app%2Fhw.git diff --git a/src/xapp-mgmt/msgs_proc.hpp b/src/xapp-mgmt/msgs_proc.hpp index ec15933..8637440 100644 --- a/src/xapp-mgmt/msgs_proc.hpp +++ b/src/xapp-mgmt/msgs_proc.hpp @@ -30,28 +30,28 @@ #include #include - -#include -#include -#include -#include -#include "subscription_request.hpp" +#include "e2ap_control.hpp" +#include "e2ap_control_response.hpp" +#include "e2ap_indication.hpp" +#include "subscription_delete_request.hpp" +#include "subscription_delete_response.hpp" #include "subscription_helper.hpp" +#include "subscription_request.hpp" +#include "subscription_request.hpp" +#include "subscription_response.hpp" #include "e2sm.hpp" -#include -#include -#include +#include "format_helper.hpp" #define MAX_RMR_RECV_SIZE 2<<15 class XappMsgHandler{ private: - unsigned char* message_buffer; - size_t* message_length; - + std::string xapp_id; public: - rmr_mbuf_t * operator() (rmr_mbuf_t *); + //constructor for xapp_id. + XappMsgHandler(std::string xid){xapp_id=xid;}; + void operator() (rmr_mbuf_t *, bool*); bool encode_subscription_request(unsigned char*, size_t* ); bool encode_subscription_delete_request(unsigned char*, size_t* ); @@ -61,6 +61,7 @@ public: bool decode_subscription_response_failure(unsigned char*, size_t ); bool decode_subscription_delete_response_failure(unsigned char*, size_t ); + bool a1_policy_handler(char *, int* , a1_policy_helper &); };