Skip to content

Commit 65d6901

Browse files
committed
fix: Addressed review comments
1 parent 41da858 commit 65d6901

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

interop/orcalb.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,10 @@ func (b *orcab) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOpt
131131
func (b *orcab) updateSubConnState(sc balancer.SubConn, state balancer.SubConnState) {
132132
b.mu.Lock()
133133
defer b.mu.Unlock()
134+
if b.stopOOBListeners == nil {
135+
// Already closed; drop the state update.
136+
return
137+
}
134138
if state.ConnectivityState == connectivity.Ready {
135139
// Register an OOB listener when the SubConn becomes READY.
136140
stop := orca.RegisterOOBListener(sc, b, orca.OOBListenerOptions{

0 commit comments

Comments
 (0)