X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fxapp-mgmt%2Fmsgs_proc.hpp;h=fb9164e3b9c419d4608bcfacf5c233ddf0976277;hb=23dad813c70c0d79cd1bd16009e00895e6509fd2;hp=ed9941f8dd50189aa48aa818f1b682668d909b74;hpb=b85024cd183a527cd8d61353637850cb6d30cf36;p=ric-app%2Fhw.git

diff --git a/src/xapp-mgmt/msgs_proc.hpp b/src/xapp-mgmt/msgs_proc.hpp
index ed9941f..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,38 +30,41 @@
 #include <rmr/RIC_message_types.h>
 #include <mdclog/mdclog.h>
 
-
-#include <subscription_request.hpp>
-#include <subscription_response.hpp>
-#include <subscription_delete_request.hpp>
-#include <subscription_delete_response.hpp>
-#include "subscription_request.hpp"
+#include "a1_helper.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 "e2sm.hpp"
-#include <e2ap_indication.hpp>
-#include <e2ap_control.hpp>
-#include <e2ap_control_response.hpp>
+#include "subscription_request.hpp"
+#include "subscription_request.hpp"
+#include "subscription_response.hpp"
+#include "e2sm_subscription.hpp"
+#include "subs_mgmt.hpp"
 
 #define MAX_RMR_RECV_SIZE 2<<15
 
 class XappMsgHandler{
 
 private:
-	unsigned char* message_buffer;
-	size_t* message_length;
-
+	std::string xapp_id;
+	SubscriptionHandler *_ref_sub_handler;
 public:
+	//constructor for xapp_id.
+	 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;}
 };