X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fregistry.go;h=ddb022654e6eb08de81f907d3b3bcffc95e6d69e;hb=5112239fe7bf1a53f43d8898d2862921594b1f80;hp=d7f801102036a1a79d9d3c19f09c9ce6c05023fc;hpb=afbf95f5756a7b781859beb1e68b41f7319ed208;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/registry.go b/pkg/control/registry.go index d7f8011..ddb0226 100644 --- a/pkg/control/registry.go +++ b/pkg/control/registry.go @@ -101,7 +101,7 @@ func (r *Registry) GetRESTSubscription(restSubId string) (*RESTSubscription, err r.restSubscriptions[restSubId] = restSubscription return restSubscription, nil } else { - return restSubscription, fmt.Errorf("Registry: REST delete request is still ongoing for the endpoint=%v, restSubId=%v, SubDelReqOngoing=%v, SubReqOngoing=%v", restSubscription, restSubId, restSubscription.SubDelReqOngoing, restSubscription.SubReqOngoing) + return restSubscription, fmt.Errorf("Registry: REST request is still ongoing for the endpoint=%v, restSubId=%v, SubDelReqOngoing=%v, SubReqOngoing=%v", restSubscription, restSubId, restSubscription.SubDelReqOngoing, restSubscription.SubReqOngoing) } return restSubscription, nil } @@ -336,6 +336,7 @@ func (r *Registry) RemoveFromSubscription(subs *Subscription, trans *Transaction go func() { if waitRouteClean > 0 { + xapp.Logger.Debug("Pending %v in order to wait route cleanup", waitRouteClean) time.Sleep(waitRouteClean) }