From 03c115d2d7094013e05b35b16323ca2c7a8e99db Mon Sep 17 00:00:00 2001 From: Anand Kumar Subramanian Date: Mon, 29 Jun 2020 14:44:32 -0700 Subject: [PATCH] Fixed the parameters for subscribe APIs --- sonic_data_client/transl_data_client.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/sonic_data_client/transl_data_client.go b/sonic_data_client/transl_data_client.go index 4799cd5dd..9e38ffd96 100644 --- a/sonic_data_client/transl_data_client.go +++ b/sonic_data_client/transl_data_client.go @@ -131,7 +131,8 @@ func (c *TranslClient) StreamRun(q *queue.PriorityQueue, stop chan struct{}, w * for i,sub := range subscribe.Subscription { stringPaths[i] = c.path2URI[sub.Path] } - subSupport,_ := translib.IsSubscribeSupported(stringPaths) + req := translib.IsSubscribeRequest{Paths:stringPaths} + subSupport,_ := translib.IsSubscribeSupported(req) var onChangeSubsString []string var onChangeSubsgNMI []*gnmipb.Path onChangeMap := make(map[string]*gnmipb.Path) @@ -303,7 +304,8 @@ func TranslSubscribe(gnmiPaths []*gnmipb.Path, stringPaths []string, pathMap map defer c.w.Done() q := queue.NewPriorityQueue(1, false) var sync_done bool - translib.Subscribe(stringPaths, q, c.channel) + req := translib.SubscribeRequest{Paths:stringPaths, Q:q, Stop:c.channel} + translib.Subscribe(req) for { items, err := q.Get(1) if err != nil {