|
|
@ -80,10 +80,10 @@ func (p *EtcdClient) List() []Server {
|
|
|
|
for {
|
|
|
|
for {
|
|
|
|
for i := 0; i < psDesired; i++ {
|
|
|
|
for i := 0; i < psDesired; i++ {
|
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), p.timeout)
|
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), p.timeout)
|
|
|
|
cancel()
|
|
|
|
|
|
|
|
psKey := pserver.PsPath + strconv.Itoa(i)
|
|
|
|
psKey := pserver.PsPath + strconv.Itoa(i)
|
|
|
|
log.Debugf("checking %s", psKey)
|
|
|
|
log.Debugf("checking %s", psKey)
|
|
|
|
resp, err := p.client.Get(ctx, psKey)
|
|
|
|
resp, err := p.client.Get(ctx, psKey)
|
|
|
|
|
|
|
|
cancel()
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
log.Infof("Get psKey= %s error, %v", psKey, err)
|
|
|
|
log.Infof("Get psKey= %s error, %v", psKey, err)
|
|
|
|
time.Sleep(p.timeout)
|
|
|
|
time.Sleep(p.timeout)
|
|
|
|