X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=mc-core%2Fmc%2Fqueries%2Freconfig_status.gsql;h=ec2250fd793cdafd7133a6b8238c12c4a03eb802;hb=refs%2Fchanges%2F60%2F4560%2F1;hp=efe7eb5987d7b8bb01c82c6cf72777007632da3a;hpb=6d6450ecce1ee0f937dd7f90f83451154abdf118;p=ric-app%2Fmc.git

diff --git a/mc-core/mc/queries/reconfig_status.gsql b/mc-core/mc/queries/reconfig_status.gsql
index efe7eb5..ec2250f 100644
--- a/mc-core/mc/queries/reconfig_status.gsql
+++ b/mc-core/mc/queries/reconfig_status.gsql
@@ -82,6 +82,34 @@ from reconfig_status_join
 group by gnb_id, gTP_TEID, TB
 ;
 
+DEFINE{query_name 'reconfig_status_join_pci';
+	max_lfta_disorder '1'; max_hfta_disorder '1';
+	comment 'Associate gtp_teid using eUE_ID';
+}
+PARAM{ window uint; }
+Select r.eUE_ID, M.physCellId, r.gnb_id, r.TB,
+	r.max_start_time, r.max_end_time
+INNER_JOIN from  reconfig_status_merge r, gnb_ueid_cellid_map M
+where r.eUE_ID=M.id_MeNB_UE_X2AP_ID and r.gnb_id=M.GNB_ID and r.TB=M.TB
+;
+
+DEFINE{query_name 'reconfig_status_success_rate_pci';
+	max_lfta_disorder '1'; max_hfta_disorder '1';
+	comment 'fraction of DC connect requests which are successful, on a per-user (gtp_teid) basis.';
+}
+PARAM{ window uint; }
+select gnb_id as GNB_ID, physCellId,
+	($window*(TB+1))/1000 as TS, 
+	     $window/1000.0 as measurementInterval,
+	count(*) as total_reconfiguration_requests,
+	sum( GEQ(max_end_time,1) ) as successful_reconfiguration_requests,
+	(1.0*sum( GEQ( max_end_time,1) ))/count(*) as success_rate,
+	1.0 - ( (1.0*sum( GEQ( max_end_time,1) ))/count(*) ) as failure_rate
+from reconfig_status_join_pci
+group by gnb_id, TB, physCellId
+;
+
+
 
 // ----------------------------------------------
 //	Merge in reconfig_reject causes and aggregate with this.
@@ -91,6 +119,8 @@ DEFINE{query_name 'reconfig_status_reject_cause';
 }
 PARAM{ window uint; }
 Select gnb_id as GNB_ID, TB,
+	non_temporal( ($window*(TB+1))/1000 ) as TS, 
+	     $window/1000.0 as measurementInterval,
 	count(*) as total_reconfig_reject,
 	sum( GEQ(cause_radio_network,0) ) as count_radio_network,
 	sum( GEQ(cause_transport,0) ) as count_transport,
@@ -100,6 +130,36 @@ from ADDREQREJECT.sgnb_add_req_reject
 group by gnb_id, timestamp_ms / $window as TB
 ;
 
+DEFINE{query_name 'sgnb_add_req_reject_pci_join';
+	max_lfta_disorder '1'; max_hfta_disorder '1';
+	comment 'Join sgnb_add_req_reject with gnb_ueid_cellid_map to create data stream for reconfig_status_reject_cause';
+}
+PARAM{ window uint; }
+select M.TB,  M.GNB_ID, M.physCellId, g.cause_radio_network,
+	g.cause_transport, g.cause_protocol, g.cause_misc
+INNER_JOIN from ADDREQREJECT.sgnb_add_req_reject g, gnb_ueid_cellid_map M
+Where g.gnb_id=M.GNB_ID and g.id_MeNB_UE_X2AP_ID=M.id_MeNB_UE_X2AP_ID
+	and g.timestamp_ms/$window=M.TB
+;
+
+DEFINE{query_name 'reconfig_status_reject_cause_pci';
+	max_lfta_disorder '1'; max_hfta_disorder '1';
+	comment 'distribution of causes for DC rejection';
+}
+PARAM{ window uint; }
+Select GNB_ID, TB, 
+	non_temporal( ($window*(TB+1))/1000 ) as TS, physCellId,
+	     $window/1000.0 as measurementInterval,
+	count(*) as total_reconfig_reject,
+	sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+	sum( GEQ(cause_transport,0) ) as count_transport,
+	sum( GEQ(cause_protocol,0) ) as count_protocol,
+	sum( GEQ(cause_misc,0) ) as count_misc
+from sgnb_add_req_reject_pci_join
+group by GNB_ID, TB, physCellId
+;
+
+
 DEFINE{query_name 'reconfig_status_reject_join';
 	max_lfta_disorder '1'; max_hfta_disorder '1';
 	comment 'Associate gtp_teid using eUE_ID';
@@ -119,6 +179,8 @@ DEFINE{query_name 'reconfig_status_reject_cause_gtp_teid';
 }
 PARAM{ window uint; }
 Select gnb_id as GNB_ID, gTP_TEID, TB,
+	non_temporal( ($window*(TB+1))/1000 ) as TS, 
+	     $window/1000.0 as measurementInterval,
 	count(*) as total_reconfig_reject,
 	sum( GEQ(cause_radio_network,0) ) as count_radio_network,
 	sum( GEQ(cause_transport,0) ) as count_transport,
@@ -198,6 +260,35 @@ from mod_status_refuse_cause_base
 group by GNB_ID, TB
 ;
 
+DEFINE{query_name 'mod_status_refuse_cause_pci_join';
+	max_lfta_disorder '1'; max_hfta_disorder '1';
+	comment 'Join mod_status_refuse_cause_base with gnb_ueid_cellid_map to create data stream for mod_status_refuse_cause_pci';
+}
+PARAM{ window uint; }
+select M.TB,  M.GNB_ID, M.physCellId,
+	g.total_reconfig_refuse, g.count_radio_network,
+	g.count_transport, g.count_protocol, g.count_misc
+INNER_JOIN from mod_status_refuse_cause_base g, gnb_ueid_cellid_map M
+Where g.GNB_ID=M.GNB_ID and g.id_MeNB_UE_X2AP_ID=M.id_MeNB_UE_X2AP_ID
+	and g.TB=M.TB
+;
+
+DEFINE{query_name 'mod_status_refuse_cause_pci';
+	max_lfta_disorder '1'; max_hfta_disorder '1';
+	comment 'distribution of causes for a sgnb modification refusal (base)';
+}
+PARAM{ window uint; }
+Select GNB_ID, ($window*(TB+1))/1000 as TS, physCellId,
+	     $window/1000.0 as measurementInterval,
+	sum(total_reconfig_refuse) as total_reconfig_refuse,
+	sum( count_radio_network ) as count_radio_network,
+	sum( count_transport ) as count_transport,
+	sum( count_protocol ) as count_protocol,
+	sum( count_misc ) as count_misc
+from mod_status_refuse_cause_pci_join
+group by GNB_ID, TB, physCellId
+;
+
 DEFINE{query_name 'mod_req_reject_cause_base';
 	max_lfta_disorder '1'; max_hfta_disorder '1';
 	comment 'distribution of causes for a sgnb modification request reject (base)';