RSDK-9714: Call WaitGroup.Done in too many in-flight requests error p…

…ath. (#401)
viamrobotics · Jan 10, 2025 · a4cfa8d · a4cfa8d
1 parent 95db6b6
commit a4cfa8d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rpc/wrtc_server_stream.go b/rpc/wrtc_server_stream.go
@@ -284,6 +284,7 @@ func (s *webrtcServerStream) processHeaders(headers *webrtcpb.RequestHeaders) {
 	select {
 	case s.ch.server.callTickets <- struct{}{}:
 	default:
+		s.ch.server.processHeadersWorkers.Done()
 		s.closeWithSendError(status.Error(codes.ResourceExhausted, "too many in-flight requests"))
 		return
 	}