minor edit

OpsMx · Dec 17, 2024 · 9db3548 · 9db3548
1 parent 0f9af98
commit 9db3548
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/serviceconfig/service_server.go b/internal/serviceconfig/service_server.go
@@ -248,6 +248,7 @@ func runAPIHandler(em EchoManager, routes Destinations, ep SearchSpec, w http.Re
 	if session == nil {
 		logger.Warnw("no such destination for service request", "destination", ep.Destination, "serviceName", ep.ServiceName, "serviceType", ep.ServiceType)
 		w.WriteHeader(http.StatusBadGateway)
+		cancel()
 		return
 	}
 
@@ -257,6 +258,7 @@ func runAPIHandler(em EchoManager, routes Destinations, ep SearchSpec, w http.Re
 		logger.Errorf("unable to read entire message body")
 		w.WriteHeader(http.StatusServiceUnavailable)
 		return
+		cancel()
 	}
 	r.Body.Close()