Skip to content
Snippets Groups Projects

Resolve "Add an option to send gNMI Subscribe requests via SBI"

1 file
+ 3
7
Compare changes
  • Side-by-side
  • Inline
@@ -9,9 +9,9 @@ import (
"code.fbi.h-da.de/danet/gosdn/controller/nucleus/errors"
"code.fbi.h-da.de/danet/gosdn/controller/nucleus/types"
"code.fbi.h-da.de/danet/gosdn/forks/goarista/gnmi"
"github.com/google/uuid"
gpb "github.com/openconfig/gnmi/proto/gnmi"
log "github.com/sirupsen/logrus"
"go.mongodb.org/mongo-driver/x/mongo/driver/uuid"
)
const (
@@ -67,11 +67,7 @@ func (d *DeviceWatcher) SubToDevices(paths [][]string, opts *gnmi.SubscribeOptio
func (d *DeviceWatcher) subscribeToPndDevices(pndID string, devices []device.Device, opts *gnmi.SubscribeOptions) {
for _, device := range devices {
subID, err := uuid.New()
if err != nil {
log.Error(err)
return
}
subID := uuid.New()
stopContext, cancel := context.WithCancel(context.Background())
d.addToDeviceSubscriptions(subID, &deviceSubscriptionHelper{
@@ -87,7 +83,7 @@ func (d *DeviceWatcher) callSubscribe(stopContext context.Context, pndID string,
gNMIOptionsCtx = context.WithValue(gNMIOptionsCtx, types.CtxKeyOpts, opts)
// SubscriptionInformation conatins pnd ID, device ID and name to be used in the internal subscribe to check
// from which device a response or a problem occurs in case of an error
// from which device a response was sent
if err := device.Transport().SubscribeInternal(gNMIOptionsCtx, handleSubscribeResponse, &transport.SubscriptionInformation{
PndID: pndID,
DeviceID: device.ID().String(),
Loading