X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fcontrol.go;fp=pkg%2Fcontrol%2Fcontrol.go;h=227eb0c6fbd8c852fc2539958a13685201d45104;hb=7dbc4adf49cd8f07f45c2412c47eb2829b8161f9;hp=3dacc5916c8e76b2caa3898cb74d026bf7e3f373;hpb=fc67b036d8944c372715b7306f892d2ddfb4684f;p=ric-plt%2Fsubmgr.git

diff --git a/pkg/control/control.go b/pkg/control/control.go
index 3dacc59..227eb0c 100755
--- a/pkg/control/control.go
+++ b/pkg/control/control.go
@@ -450,8 +450,12 @@ func (c *Control) RESTSubscriptionHandler(params interface{}) (*models.Subscript
 		c.PrintRESTSubscriptionRequest(p)
 	}
 
-	if c.e2IfState.IsE2ConnectionUp(p.Meid) == false {
-		xapp.Logger.Error("No E2 connection for ranName %v", *p.Meid)
+	if c.e2IfState.IsE2ConnectionUp(p.Meid) == false || c.e2IfState.IsE2ConnectionUnderReset(p.Meid) == true {
+		if c.e2IfState.IsE2ConnectionUp(p.Meid) == false {
+			xapp.Logger.Error("No E2 connection for ranName %v", *p.Meid)
+		} else if c.e2IfState.IsE2ConnectionUnderReset(p.Meid) == true {
+			xapp.Logger.Error("E2 Node for ranName %v UNDER RESET", *p.Meid)
+		}
 		c.UpdateCounter(cRestReqRejDueE2Down)
 		return nil, common.SubscribeServiceUnavailableCode
 	}