opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-01 15:07:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #9315 from wanyaoqi/bugfix/wyq/restart-session-check-lease-living

Browse Source 
fix(host): check lease living on restart etcd session
This commit is contained in:
Zexi Li
2020-12-09 20:33:08 +08:00
committed by GitHub
parent 516f5ab0d3 92e0ed3434
commit feb81db1b8
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/cloudcommon/etcd/etcd.go
+4
View File
@@ -143,6 +143,10 @@ func (cli *SEtcdClient) GetClient() *clientv3.Client {
return cli.client
}
func (cli *SEtcdClient) SessionLiving() bool {
return cli.leaseLiving
}
func (cli *SEtcdClient) startSession() error {
ctx := context.TODO()
pkg/hostman/host_health/etcd.go
+4 -1
View File
@@ -112,8 +112,11 @@ func (c *SEtcdClient) OnKeepaliveFailure() {
}
func (c *SEtcdClient) Reconnect() {
if c.cli.SessionLiving() {
return
}
for {
if err := c.cli.RestartSession(); err != nil {
if err := c.cli.RestartSession(); err != nil && !c.cli.SessionLiving() {
log.Errorf("restart session failed %s", err)
time.Sleep(1 * time.Second)
} else {