Merge pull request #40 from Tantalor93/usetimeout

use defined timeout, not always default
networkservicemesh · Oct 15, 2021 · f19ab01 · f19ab01
2 parents 519fee1 + 6271df0
commit f19ab01
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fanout.go b/fanout.go
@@ -75,7 +75,7 @@ func (f *Fanout) ServeDNS(ctx context.Context, w dns.ResponseWriter, m *dns.Msg)
 	if !f.match(&req) {
 		return plugin.NextOrFailure(f.Name(), f.Next, ctx, w, m)
 	}
-	timeoutContext, cancel := context.WithTimeout(ctx, defaultTimeout)
+	timeoutContext, cancel := context.WithTimeout(ctx, f.timeout)
 	defer cancel()
 	clientCount := len(f.clients)
 	workerChannel := make(chan Client, f.workerCount)