watchtower: fix linter errors
This commit is contained in:
parent
c68f747b4f
commit
7f48ff6717
@ -316,8 +316,8 @@ func (q *sessionQueue) drainBackups() {
|
|||||||
// before attempting to dequeue any pending updates.
|
// before attempting to dequeue any pending updates.
|
||||||
stateUpdate, isPending, backupID, err := q.nextStateUpdate()
|
stateUpdate, isPending, backupID, err := q.nextStateUpdate()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorf("SessionQueue(%s) unable to get next state "+
|
log.Errorf("SessionQueue(%v) unable to get next state "+
|
||||||
"update: %v", err)
|
"update: %v", q.ID(), err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -557,7 +557,7 @@ func (q *sessionQueue) sendStateUpdate(conn wtserver.Peer,
|
|||||||
// TODO(conner): borked watchtower
|
// TODO(conner): borked watchtower
|
||||||
err = fmt.Errorf("unable to ack seqnum=%d: %v",
|
err = fmt.Errorf("unable to ack seqnum=%d: %v",
|
||||||
stateUpdate.SeqNum, err)
|
stateUpdate.SeqNum, err)
|
||||||
log.Errorf("SessionQueue(%s) failed to ack update: %v", err)
|
log.Errorf("SessionQueue(%v) failed to ack update: %v", q.ID(), err)
|
||||||
return err
|
return err
|
||||||
|
|
||||||
case err == wtdb.ErrLastAppliedReversion:
|
case err == wtdb.ErrLastAppliedReversion:
|
||||||
|
Loading…
Reference in New Issue
Block a user