주소 잘못 보냄
This commit is contained in:
@ -104,7 +104,7 @@ func (sp *hostPool) regist(desc *protos.OperationQueryRequest) (string, chan *op
|
|||||||
address := net.JoinHostPort(prvip, "9100")
|
address := net.JoinHostPort(prvip, "9100")
|
||||||
if conn, _ := net.DialTimeout("tcp", address, 3*time.Second); conn != nil {
|
if conn, _ := net.DialTimeout("tcp", address, 3*time.Second); conn != nil {
|
||||||
conn.Close()
|
conn.Close()
|
||||||
sp.exportChan <- "+" + prvip
|
sp.exportChan <- "+" + address
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -113,7 +113,7 @@ func (sp *hostPool) regist(desc *protos.OperationQueryRequest) (string, chan *op
|
|||||||
address := net.JoinHostPort(pubip, "9100")
|
address := net.JoinHostPort(pubip, "9100")
|
||||||
if conn, _ := net.DialTimeout("tcp", address, 3*time.Second); conn != nil {
|
if conn, _ := net.DialTimeout("tcp", address, 3*time.Second); conn != nil {
|
||||||
conn.Close()
|
conn.Close()
|
||||||
sp.exportChan <- "+" + pubip
|
sp.exportChan <- "+" + address
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user