grpc
/
grpc-go
mirror of https://github.com/grpc/grpc-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rename controller

This commit is contained in:
iamqizhao 2016-05-25 18:17:23 -07:00
parent 9a14ca798d
commit db887c9bcd
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
clientconn.go
View File

@ -246,7 +246,7 @@ func Dial(target string, opts ...DialOption) (*ClientConn, error) {
return nil, err
}
}
go cc.controller()
go cc.lbWatcher()
}
colonPos := strings.LastIndex(target, ":")
@ -302,7 +302,7 @@ type ClientConn struct {
conns map[Address]*addrConn
}
func (cc *ClientConn) controller() {
func (cc *ClientConn) lbWatcher() {
for {
addrs, ok := <-cc.balancer.Notify()
if !ok {
@ -333,9 +333,7 @@ func (cc *ClientConn) controller() {
}
cc.mu.Unlock()
for _, a := range addrs {
if err := cc.newAddrConn(a, true); err != nil {
}
cc.newAddrConn(a, true)
}
for _, c := range del {
c.tearDown(errConnDrain)