@@ -181,7 +181,7 @@ func TestMemoryLeakScenarios(t *testing.T) {
181
181
writeDone := make (chan error , 1 )
182
182
go func () {
183
183
err := db .Set ([]byte ("key2" ), []byte ("value2" ))
184
- require .NoError (t , err )
184
+ assert .NoError (t , err )
185
185
writeDone <- nil
186
186
}()
187
187
@@ -371,7 +371,8 @@ func TestBulkDeletionMemoryRecovery(t *testing.T) {
371
371
runtime .ReadMemStats (& mBefore )
372
372
373
373
for _ , key := range keys {
374
- db .Delete (key )
374
+ err := db .Delete (key )
375
+ require .NoError (t , err )
375
376
}
376
377
runtime .GC ()
377
378
var mAfter runtime.MemStats
@@ -474,7 +475,7 @@ func TestConcurrentAccess(t *testing.T) {
474
475
for j := 0 ; j < opsPerGoroutine ; j ++ {
475
476
key := []byte (fmt .Sprintf ("concurrent_key_%d_%d" , id , j ))
476
477
err := db .Set (key , []byte ("concurrent_value" ))
477
- require .NoError (t , err )
478
+ assert .NoError (t , err )
478
479
}
479
480
}(i )
480
481
}
@@ -486,7 +487,7 @@ func TestConcurrentAccess(t *testing.T) {
486
487
defer wg .Done ()
487
488
for j := 0 ; j < opsPerGoroutine ; j ++ {
488
489
iter , err := db .Iterator (nil , nil )
489
- require .NoError (t , err )
490
+ assert .NoError (t , err )
490
491
for iter .Valid () {
491
492
_ = iter .Key ()
492
493
iter .Next ()
@@ -524,7 +525,7 @@ func TestLockingAndRelease(t *testing.T) {
524
525
release := make (chan struct {})
525
526
go func () {
526
527
iter , err := db .Iterator ([]byte ("conflict_key" ), []byte ("zzzz" ))
527
- require .NoError (t , err )
528
+ assert .NoError (t , err )
528
529
assert .NoError (t , iter .Error (), "Iterator creation error" )
529
530
close (ready ) // signal iterator is active
530
531
<- release // hold the iterator a bit
@@ -535,7 +536,7 @@ func TestLockingAndRelease(t *testing.T) {
535
536
done := make (chan struct {})
536
537
go func () {
537
538
err := db .Set ([]byte ("conflict_key" ), []byte ("updated" ))
538
- require .NoError (t , err )
539
+ assert .NoError (t , err )
539
540
close (done )
540
541
}()
541
542
@@ -572,7 +573,8 @@ func TestLongRunningWorkload(t *testing.T) {
572
573
err := db .Set (key , []byte ("workload_value" ))
573
574
require .NoError (t , err )
574
575
if i % 2 == 0 {
575
- db .Delete (key )
576
+ err = db .Delete (key )
577
+ require .NoError (t , err )
576
578
}
577
579
if i % reportInterval == 0 {
578
580
runtime .GC ()
@@ -642,11 +644,12 @@ func TestRandomMemoryAccessPatterns(t *testing.T) {
642
644
if j % 2 == 0 {
643
645
key := []byte (fmt .Sprintf ("rand_key_%d_%d" , seed , j ))
644
646
err := db .Set (key , []byte ("rand_value" ))
645
- require .NoError (t , err )
647
+ assert .NoError (t , err )
646
648
} else {
647
649
// Randomly delete some keys.
648
650
key := []byte (fmt .Sprintf ("rand_key_%d_%d" , seed , j - 1 ))
649
- db .Delete (key )
651
+ err := db .Delete (key )
652
+ assert .NoError (t , err )
650
653
}
651
654
}
652
655
}(i )
0 commit comments