From f32a160cbb9373f6d1e58fccbb0435a561143ba4 Mon Sep 17 00:00:00 2001
From: Fabian Seidl <fabian.seidl@h-da.de>
Date: Wed, 29 Nov 2023 14:33:12 +0000
Subject: [PATCH] Resolve "Add error handling in case the paths for gNMI
Subscription for an MNE is empty"
See merge request danet/gosdn!631
---
controller/northbound/server/networkElement.go | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/controller/northbound/server/networkElement.go b/controller/northbound/server/networkElement.go
index 9497fb24c..4510896c7 100644
--- a/controller/northbound/server/networkElement.go
+++ b/controller/northbound/server/networkElement.go
@@ -9,6 +9,7 @@ import (
mnepb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/networkelement"
ppb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/pnd"
tpb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/transport"
+ "code.fbi.h-da.de/danet/gosdn/controller/config"
"code.fbi.h-da.de/danet/gosdn/controller/conflict"
"code.fbi.h-da.de/danet/gosdn/controller/customerrs"
"code.fbi.h-da.de/danet/gosdn/controller/interfaces/change"
@@ -629,7 +630,9 @@ func (n *NetworkElementServer) addMne(ctx context.Context,
return uuid.Nil, err
}
- n.networkElementWatchter.SubscribeToNetworkElement(mne, nil)
+ if mne.GetGnmiSubscriptionPaths() != nil || config.GetGnmiSubscriptionPaths() != nil {
+ n.networkElementWatchter.SubscribeToNetworkElement(mne, nil)
+ }
} else {
err = fmt.Errorf("invalid transport data provided")
return uuid.Nil, err
--
GitLab