conncache: Fix concurrent map access.
Change-Id: I5375ce97ab1fdbaecbea52a7128a46bbd304acb8
diff --git a/runtime/internal/flow/manager/conncache.go b/runtime/internal/flow/manager/conncache.go
index 09de210..ed7326a 100644
--- a/runtime/internal/flow/manager/conncache.go
+++ b/runtime/internal/flow/manager/conncache.go
@@ -17,7 +17,6 @@
"v.io/v23/naming"
"v.io/v23/security"
"v.io/x/ref/lib/stats"
- iflow "v.io/x/ref/runtime/internal/flow"
"v.io/x/ref/runtime/internal/flow/conn"
)
@@ -344,8 +343,9 @@
auth flow.PeerAuthorizer, p flow.Protocol) (cachedConn, []string, []security.RejectedBlessing, error) {
network, addresses, err := resolve(ctx, p, network, address)
if err != nil {
- delete(c.started, key(network, address))
- return nil, nil, nil, iflow.MaybeWrapError(flow.ErrResolveFailed, ctx, err)
+ // TODO(suharshs): Add a unittest for failed resolution.
+ ctx.Errorf("Failed to resolve (%v, %v): %v", network, address, err)
+ return nil, nil, nil, nil
}
for _, address := range addresses {