multi: update linter, fix new issues

This commit is contained in:
Oliver Gugger
2023-05-12 10:09:56 +02:00
parent e549096b88
commit 56dba2df03
31 changed files with 263 additions and 301 deletions

View File

@@ -323,7 +323,9 @@ func (q *DiskOverflowQueue[T]) drainInputList() {
// What we do with this new item depends on what the mode of the
// queue currently is.
for q.pushToActiveQueue(task) {
for q.pushToActiveQueue(task) { //nolint:revive
// We retry until the task is handled or the quit
// channel is closed.
}
// If the above returned false because the quit channel was

View File

@@ -101,13 +101,9 @@ func TestMigrateChannelIDIndex(t *testing.T) {
// If the migration fails, the details bucket
// should be untouched.
if test.shouldFail {
if err := migtest.VerifyDB(
return migtest.VerifyDB(
tx, cChanDetailsBkt, test.pre,
); err != nil {
return err
}
return nil
)
}
// Else, we expect an updated summary bucket

View File

@@ -281,13 +281,9 @@ func after(shouldFail bool, preMigDB,
// If the migration fails, the sessions bucket should be
// untouched.
if shouldFail {
if err := migtest.VerifyDB(
return migtest.VerifyDB(
tx, cSessionBkt, preMigDB,
); err != nil {
return err
}
return nil
)
}
return migtest.VerifyDB(tx, cSessionBkt, postMigDB)

View File

@@ -144,14 +144,10 @@ func TestMigrateChannelToSessionIndex(t *testing.T) {
// If the migration fails, the details bucket
// should be untouched.
if test.shouldFail {
if err := migtest.VerifyDB(
return migtest.VerifyDB(
tx, cChanDetailsBkt,
test.preDetails,
); err != nil {
return err
}
return nil
)
}
// Else, we expect an updated details bucket