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=ec15933434fb9da348173a4f8c5238525b22c814;hpb=6df19a4dacb4fcb6edb35a32af9c8f5c07c95e37;p=ric-app%2Fhw.git

diff --git a/src/xapp-mgmt/msgs_proc.hpp b/src/xapp-mgmt/msgs_proc.hpp
index ec15933..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:
-	 rmr_mbuf_t * operator() (rmr_mbuf_t *);
+	//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;}
 };