}
h.logger.Debugf("#ResourceStatusFailureHandler.Handle - RAN name: %s - message: %s", request.RanName, pduAsString)
}
- response, err := h.converter.Convert(request.Payload)
- if err != nil {
- h.logger.Errorf("#ResourceStatusFailureHandler.Handle - RAN name: %s - unpack failed. Error: %v", request.RanName, err)
- return
- }
-
- /*The RSM creates one measurement per cell*/
-
- if response.MeasurementInitiationResults == nil {
- h.logger.Infof("#ResourceStatusFailureHandler.Handle - RAN name: %s - ENB1_Measurement_ID: %d, ENB2_Measurement_ID: %d",
- request.RanName,
- response.ENB1_Measurement_ID,
- response.ENB2_Measurement_ID)
- } else {
- h.logger.Infof("#ResourceStatusFailureHandler.Handle - RAN name: %s - ENB1_Measurement_ID: %d, ENB2_Measurement_ID: %d, CellId: %s, FailedReportCharacteristics: %x",
- request.RanName,
- response.ENB1_Measurement_ID,
- response.ENB2_Measurement_ID,
- response.MeasurementInitiationResults[0].CellId,
- response.MeasurementInitiationResults[0].MeasurementFailureCauses[0].MeasurementFailedReportCharacteristics)
- }
+ //response, err := h.converter.Convert(request.Payload)
+ //if err != nil {
+ // h.logger.Errorf("#ResourceStatusFailureHandler.Handle - RAN name: %s - unpack failed. Error: %v", request.RanName, err)
+ // return
+ //}
+ //
+ ///*The RSM creates one measurement per cell*/
+ //
+ //if response.MeasurementInitiationResults == nil {
+ // h.logger.Infof("#ResourceStatusFailureHandler.Handle - RAN name: %s - ENB1_Measurement_ID: %d, ENB2_Measurement_ID: %d",
+ // request.RanName,
+ // response.ENB1_Measurement_ID,
+ // response.ENB2_Measurement_ID)
+ //} else {
+ // h.logger.Infof("#ResourceStatusFailureHandler.Handle - RAN name: %s - ENB1_Measurement_ID: %d, ENB2_Measurement_ID: %d, CellId: %s, FailedReportCharacteristics: %x",
+ // request.RanName,
+ // response.ENB1_Measurement_ID,
+ // response.ENB2_Measurement_ID,
+ // response.MeasurementInitiationResults[0].CellId,
+ // response.MeasurementInitiationResults[0].MeasurementFailureCauses[0].MeasurementFailedReportCharacteristics)
+ //}
}
package rmrmsghandlers
-import (
- "fmt"
- "rsm/converters"
- "rsm/e2pdus"
- "rsm/logger"
- "rsm/mocks"
- "rsm/models"
- "testing"
- "time"
-)
-
// Verify UnpackX2apPduAsString() and Convert() are called
+/*
func TestResourceStatusFailureHandlerConvertFailure(t *testing.T) {
- logger, err := logger.InitLogger(logger.DebugLevel)
+ logger, err := logger.InitLogger(logger.InfoLevel)
if err != nil {
t.Errorf("#... - failed to initialize logger, error: %s", err)
}
payload := []byte("aaa")
req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
converterMock := mocks.ResourceStatusFailureConverterMock{}
- converterMock.On("UnpackX2apPduAsString", req.Payload, e2pdus.MaxAsn1CodecMessageBufferSize).Return(string(payload), nil)
+ //converterMock.On("UnpackX2apPduAsString", req.Payload, e2pdus.MaxAsn1CodecMessageBufferSize).Return(string(payload), nil)
converterMock.On("Convert", req.Payload).Return((*models.ResourceStatusResponse)(nil), fmt.Errorf("error"))
h := NewResourceStatusFailureHandler(logger, &converterMock)
h.Handle(&req)
- converterMock.AssertNumberOfCalls(t, "UnpackX2apPduAsString", 1)
+ //converterMock.AssertNumberOfCalls(t, "UnpackX2apPduAsString", 1)
converterMock.AssertNumberOfCalls(t, "Convert", 1)
}
+
func TestResourceStatusFailureHandlerUnpackFailure(t *testing.T) {
logger, err := logger.InitLogger(logger.DebugLevel)
if err != nil {
converterMock.AssertNumberOfCalls(t, "UnpackX2apPduAsString", 1)
converterMock.AssertNumberOfCalls(t, "Convert", 0)
}
+*/
+/*
func TestResourceStatusFailureHandler(t *testing.T) {
- logger, err := logger.InitLogger(logger.DebugLevel)
+ logger, err := logger.InitLogger(logger.InfoLevel)
if err != nil {
t.Errorf("#... - failed to initialize logger, error: %s", err)
}
unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
- converer := converters.NewResourceStatusFailureConverter(unpacker)
+ converter := converters.NewResourceStatusFailureConverter(unpacker)
var payload []byte
fmt.Sscanf("400900320000040027000300000e0028000300000c00054001620044401800004540130002f8290007ab500000434006000000000740", "%x", &payload)
req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
- h := NewResourceStatusFailureHandler(logger, converer)
+ h := NewResourceStatusFailureHandler(logger, converter)
h.Handle(&req)
}
func TestResourceStatusFailureHandlerMinimalPdu(t *testing.T) {
- logger, err := logger.InitLogger(logger.DebugLevel)
+ logger, err := logger.InitLogger(logger.InfoLevel)
if err != nil {
t.Errorf("#... - failed to initialize logger, error: %s", err)
}
unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
- converer := converters.NewResourceStatusFailureConverter(unpacker)
+ converter := converters.NewResourceStatusFailureConverter(unpacker)
var payload []byte
fmt.Sscanf("400900170000030027000300000000280003000049000540020a80", "%x", &payload)
req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
- h := NewResourceStatusFailureHandler(logger, converer)
+ h := NewResourceStatusFailureHandler(logger, converter)
h.Handle(&req)
}
+*/
\ No newline at end of file