Skip to content

Commit 3805b3c

Browse files
committed
update
1 parent 4548d17 commit 3805b3c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

cgrpc/balancer.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ func (b *corelibBalancer) UpdateClientConnState(ss balancer.ClientConnState) err
127127
Addition: addition,
128128
},
129129
}
130-
go sc.Connect()
130+
sc.Connect()
131131
} else if len(dservers) == 0 {
132132
//this is not a new register and this register is offline
133133
server.dservers = nil
@@ -192,7 +192,7 @@ func (b *corelibBalancer) UpdateSubConnState(sc balancer.SubConn, s balancer.Sub
192192
delete(b.servers, sc)
193193
b.cc.RemoveSubConn(sc)
194194
} else {
195-
go sc.Connect()
195+
sc.Connect()
196196
}
197197
} else if s.ConnectivityState == connectivity.Ready {
198198
//online

0 commit comments

Comments
 (0)