vitalif
/
etcd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

etcd-runner: update to use new lease interface

release-3.2
Anthony Romano 2017-04-17 15:13:04 -07:00
parent b5384ac1c0
commit 78afc853f4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tools/functional-tester/etcd-runner/command/lease_renewer_command.go
View File

@ -50,7 +50,6 @@ func runLeaseRenewerFunc(cmd *cobra.Command, args []string) {
for { for {
var ( var (
l *clientv3.LeaseGrantResponse l *clientv3.LeaseGrantResponse
lk *clientv3.LeaseKeepAliveResponse
err error err error
) )
for { for {
@ -62,13 +61,14 @@ func runLeaseRenewerFunc(cmd *cobra.Command, args []string) {
expire := time.Now().Add(time.Duration(l.TTL-1) * time.Second) expire := time.Now().Add(time.Duration(l.TTL-1) * time.Second)
for { for {
lk, err = c.Lease.KeepAliveOnce(ctx, l.ID) lk := c.Lease.KeepAliveOnce(ctx, l.ID)
err = lk.Err
if grpc.Code(err) == codes.NotFound { if grpc.Code(err) == codes.NotFound {
if time.Since(expire) < 0 { if time.Since(expire) < 0 {
log.Printf("bad renew! exceeded: %v", time.Since(expire)) log.Printf("bad renew! exceeded: %v", time.Since(expire))
for { for {
lk, err = c.Lease.KeepAliveOnce(ctx, l.ID) lk = c.Lease.KeepAliveOnce(ctx, l.ID)
fmt.Println(lk, err) fmt.Println(lk)
time.Sleep(time.Second) time.Sleep(time.Second)
} }
} }