X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fx2_reset_response_handler.go;h=ca1b1756fff96f5733fa80826612e2179e8f1836;hb=7000880c4031e607a2fe36046fd097f486476a84;hp=3d6bd23381c4e707d8374494377dd8fe047ca5c2;hpb=de19068aaa1f3d2b415cd960106121ceb167aaa9;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/handlers/rmrmsghandlers/x2_reset_response_handler.go b/E2Manager/handlers/rmrmsghandlers/x2_reset_response_handler.go index 3d6bd23..ca1b175 100644 --- a/E2Manager/handlers/rmrmsghandlers/x2_reset_response_handler.go +++ b/E2Manager/handlers/rmrmsghandlers/x2_reset_response_handler.go @@ -13,12 +13,15 @@ // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. -// + +// This source code is part of the near-RT RIC (RAN Intelligent Controller) +// platform project (RICP). + package rmrmsghandlers -// #cgo CFLAGS: -I../../asn1codec/inc/ -I../../asn1codec/e2ap_engine/ -// #cgo LDFLAGS: -L ../../asn1codec/lib/ -L../../asn1codec/e2ap_engine/ -le2ap_codec -lasncodec +// #cgo CFLAGS: -I../../3rdparty/asn1codec/inc/ -I../../3rdparty/asn1codec/e2ap_engine/ +// #cgo LDFLAGS: -L ../../3rdparty/asn1codec/lib/ -L../../3rdparty/asn1codec/e2ap_engine/ -le2ap_codec -lasncodec // #include import "C" import ( @@ -33,6 +36,8 @@ import ( "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities" ) +const ResetResponseLogInfoElapsedTime = "#X2ResetResponseHandler.Handle - Summary: elapsed time for receiving and handling reset request message from E2 terminator: %f ms" + type X2ResetResponseHandler struct { logger *logger.Logger rnibDataService services.RNibDataService @@ -53,7 +58,7 @@ func (h X2ResetResponseHandler) Handle(request *models.NotificationRequest) { ranName := request.RanName h.logger.Infof("#X2ResetResponseHandler.Handle - RAN name: %s - received reset response. Payload: %x", ranName, request.Payload) - nodebInfo, err := h.rnibDataService.GetNodeb(ranName); + nodebInfo, err := h.rnibDataService.GetNodeb(ranName) if err != nil { h.logger.Errorf("#x2ResetResponseHandler.Handle - RAN name: %s - failed to retrieve nodebInfo entity. Error: %s", ranName, err) return @@ -61,19 +66,19 @@ func (h X2ResetResponseHandler) Handle(request *models.NotificationRequest) { if nodebInfo.ConnectionStatus == entities.ConnectionStatus_SHUTTING_DOWN { h.logger.Warnf("#X2ResetResponseHandler.Handle - RAN name: %s, connection status: %s - nodeB entity in incorrect state", nodebInfo.RanName, nodebInfo.ConnectionStatus) - h.logger.Infof("#X2ResetResponseHandler.Handle - Summary: elapsed time for receiving and handling reset request message from E2 terminator: %f ms", utils.ElapsedTime(request.StartTime)) + h.logger.Infof(ResetResponseLogInfoElapsedTime, utils.ElapsedTime(request.StartTime)) return } if nodebInfo.ConnectionStatus != entities.ConnectionStatus_CONNECTED { h.logger.Errorf("#X2ResetResponseHandler.Handle - RAN name: %s, connection status: %s - nodeB entity in incorrect state", nodebInfo.RanName, nodebInfo.ConnectionStatus) - h.logger.Infof("#X2ResetResponseHandler.Handle - Summary: elapsed time for receiving and handling reset request message from E2 terminator: %f ms", utils.ElapsedTime(request.StartTime)) + h.logger.Infof(ResetResponseLogInfoElapsedTime, utils.ElapsedTime(request.StartTime)) return } isSuccessfulResetResponse, err := h.isSuccessfulResetResponse(ranName, request.Payload) - h.logger.Infof("#X2ResetResponseHandler.Handle - Summary: elapsed time for receiving and handling reset request message from E2 terminator: %f ms", utils.ElapsedTime(request.StartTime)) + h.logger.Infof(ResetResponseLogInfoElapsedTime, utils.ElapsedTime(request.StartTime)) if err != nil || !isSuccessfulResetResponse { return