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

client/v3/lease.go: Log unhandled errors

dependabot/go_modules/go.uber.org/atomic-1.10.0
Lili Cosic 2021-06-01 11:57:42 +02:00
parent c7cbc6befa
commit 65cdf43e48
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
client/v3/lease.go
View File

@ -439,6 +439,9 @@ func (l *lessor) recvKeepAliveLoop() (gerr error) {
for {
stream, err := l.resetRecv()
if err != nil {
l.lg.Warn("error occurred during lease keep alive loop",
zap.Error(err),
)
if canceledByCaller(l.stopCtx, err) {
return err
}
@ -571,7 +574,9 @@ func (l *lessor) sendKeepAliveLoop(stream pb.Lease_LeaseKeepAliveClient) {
for _, id := range tosend {
r := &pb.LeaseKeepAliveRequest{ID: int64(id)}
if err := stream.Send(r); err != nil {
// TODO do something with this error?
l.lg.Warn("error occurred during lease keep alive request sending",
zap.Error(err),
)
return
}
}