[qfix] Use a context with RequestTimeout for requests (#609)

Signed-off-by: NikitaSkrynnik <nikita.skrynnik@xored.com>
networkservicemesh · Mar 28, 2024 · 19c20ba · 19c20ba
1 parent a6e6b23
commit 19c20ba
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/main.go b/main.go
@@ -251,10 +251,13 @@ func main() {
 		}
 
 		for {
+			requestCtx, requestCancel := context.WithTimeout(ctx, c.RequestTimeout)
+			defer requestCancel()
+
 			// Construct a request
 			request := constructRequest(ctx, c, id, &c.NetworkServices[i], monitoredConnections)
 
-			resp, err := nsmClient.Request(ctx, request)
+			resp, err := nsmClient.Request(requestCtx, request)
 			if err != nil {
 				logger.Errorf("failed connect to NSMgr: %v", err.Error())
 				continue