updated comment

open-telemetry · Dec 6, 2023 · 6883e32 · 6883e32
1 parent 2d82613
commit 6883e32
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/connector/failoverconnector/traces.go b/connector/failoverconnector/traces.go
@@ -39,6 +39,8 @@ func (f *tracesFailover) ConsumeTraces(ctx context.Context, td ptrace.Traces) er
 	}
 	err := tc.ConsumeTraces(ctx, td)
 	if err == nil {
+		// trylock to make sure for concurrent calls multiple invocations don't try to update the failover
+		// state simultaneously and don't wait to acquire lock in pipeline selector
 		f.stableTryLock.Lock(f.failover.reportStable, idx)
 		return nil
 	}

diff --git a/go.mod b/go.mod
@@ -1155,7 +1155,6 @@ replace (
 	github.com/open-telemetry/opentelemetry-collector-contrib/connector/countconnector => ./connector/countconnector
 	github.com/open-telemetry/opentelemetry-collector-contrib/connector/datadogconnector => ./connector/datadogconnector
 	github.com/open-telemetry/opentelemetry-collector-contrib/connector/exceptionsconnector => ./connector/exceptionsconnector
-	github.com/open-telemetry/opentelemetry-collector-contrib/connector/failoverconnector => ./connector/failoverconnector
 	github.com/open-telemetry/opentelemetry-collector-contrib/connector/routingconnector => ./connector/routingconnector
 	github.com/open-telemetry/opentelemetry-collector-contrib/connector/servicegraphconnector => ./connector/servicegraphconnector
 	github.com/open-telemetry/opentelemetry-collector-contrib/connector/spanmetricsconnector => ./connector/spanmetricsconnector