X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=e2ap%2Fpkg%2Fe2ap_wrapper%2Fut_packer_e2ap.go;h=fd2439bf3cdfb83aaaa09e3ef753f0cf6bf7ab34;hb=bf583163d3f26548dbeafd5631f83a403313d52f;hp=3449a9144880fc38087a681bf39d30d5b1c70b5c;hpb=e5e672c043d80c7a531b9d6d640ca8879d9bf01b;p=ric-plt%2Fsubmgr.git diff --git a/e2ap/pkg/e2ap_wrapper/ut_packer_e2ap.go b/e2ap/pkg/e2ap_wrapper/ut_packer_e2ap.go index 3449a91..fd2439b 100644 --- a/e2ap/pkg/e2ap_wrapper/ut_packer_e2ap.go +++ b/e2ap/pkg/e2ap_wrapper/ut_packer_e2ap.go @@ -49,7 +49,6 @@ var allowAction = map[int]bool{ } func AllowE2apToProcess(mtype int, actionFail bool) { - fmt.Printf("INFO: AllowE2apToProcess setting %d : %t -> %t", mtype, allowAction[mtype], actionFail) allowAction[mtype] = actionFail } @@ -231,6 +230,32 @@ func (e2apMsg *utMsgPackerSubscriptionDeleteFailure) String() string { return "utMsgPackerSubscriptionDeleteFailure" } +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- +type utMsgPackerSubscriptionDeleteRequired struct { + e2apMsgPackerSubscriptionDeleteFailure +} + +func (e2apMsg *utMsgPackerSubscriptionDeleteRequired) init() { +} + +func (e2apMsg *utMsgPackerSubscriptionDeleteRequired) Pack(data *e2ap.SubscriptionDeleteRequiredList) (error, *e2ap.PackedData) { + if allowAction[SUB_DEL_FAILURE] { + e2sub := origPackerif.NewPackerSubscriptionDeleteRequired() + return e2sub.Pack(data) + } + return fmt.Errorf("Error: Set to be fail by UT"), nil +} + +func (e2apMsg *utMsgPackerSubscriptionDeleteRequired) UnPack(msg *e2ap.PackedData) (error, *e2ap.SubscriptionDeleteRequiredList) { + if allowAction[SUB_DEL_FAILURE] { + e2sub := origPackerif.NewPackerSubscriptionDeleteRequired() + return e2sub.UnPack(msg) + } + return fmt.Errorf("Error: Set to be fail by UT"), nil +} + //----------------------------------------------------------------------------- // Public E2AP packer creators //----------------------------------------------------------------------------- @@ -261,6 +286,10 @@ func (*utAsn1E2APPacker) NewPackerSubscriptionDeleteFailure() e2ap.E2APMsgPacker return &utMsgPackerSubscriptionDeleteFailure{} } +func (p *utAsn1E2APPacker) NewPackerSubscriptionDeleteRequired() e2ap.E2APMsgPackerSubscriptionDeleteRequiredIf { + return &utMsgPackerSubscriptionDeleteRequired{} +} + func NewUtAsn1E2APPacker() e2ap.E2APPackerIf { return &utAsn1E2APPacker{} }