X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fxapp-mgmt%2Fmsgs_proc.hpp;h=fb9164e3b9c419d4608bcfacf5c233ddf0976277;hb=0f5c234d5da8897f2f831e02ff03912e582ba6e9;hp=8637440375bf66c3e03fb0b0267ff0838d77c1a1;hpb=3baf0b7442b45212ad859904fb061c3de4daef69;p=ric-app%2Fhw.git

diff --git a/src/xapp-mgmt/msgs_proc.hpp b/src/xapp-mgmt/msgs_proc.hpp
index 8637440..fb9164e 100644
--- a/src/xapp-mgmt/msgs_proc.hpp
+++ b/src/xapp-mgmt/msgs_proc.hpp
@@ -1,6 +1,6 @@
-/*
+ 	 /*
 ==================================================================================
-        Copyright (c) 2018-2019 AT&T Intellectual Property.
+        Copyright (c) 2019-2020 AT&T Intellectual Property.
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
@@ -30,6 +30,7 @@
 #include <rmr/RIC_message_types.h>
 #include <mdclog/mdclog.h>
 
+#include "a1_helper.hpp"
 #include "e2ap_control.hpp"
 #include "e2ap_control_response.hpp"
 #include "e2ap_indication.hpp"
@@ -39,8 +40,8 @@
 #include "subscription_request.hpp"
 #include "subscription_request.hpp"
 #include "subscription_response.hpp"
-#include "e2sm.hpp"
-#include "format_helper.hpp"
+#include "e2sm_subscription.hpp"
+#include "subs_mgmt.hpp"
 
 #define MAX_RMR_RECV_SIZE 2<<15
 
@@ -48,21 +49,22 @@ class XappMsgHandler{
 
 private:
 	std::string xapp_id;
+	SubscriptionHandler *_ref_sub_handler;
 public:
 	//constructor for xapp_id.
-	 XappMsgHandler(std::string xid){xapp_id=xid;};
+	 XappMsgHandler(std::string xid){xapp_id=xid; _ref_sub_handler=NULL;};
+	 XappMsgHandler(std::string xid, SubscriptionHandler &subhandler){xapp_id=xid; _ref_sub_handler=&subhandler;};
+
 	 void operator() (rmr_mbuf_t *, bool*);
 
-	 bool encode_subscription_request(unsigned char*, size_t* );
+	 void register_handler();
 	 bool encode_subscription_delete_request(unsigned char*, size_t* );
 
 	 bool decode_subscription_response(unsigned char*, size_t );
-	 bool decode_subscription_delete_response(unsigned char*, size_t );
-	 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 &);
 
+	 void testfunction() {std::cout << "<<<<<<<<<<<<<<<<<<IN TEST FUNCTION<<<<<<<<<<<<<<<" << std::endl;}
 };