@@ -181,7 +181,7 @@ func TestMemoryLeakScenarios(t *testing.T) {
181181 writeDone := make (chan error , 1 )
182182 go func () {
183183 err := db .Set ([]byte ("key2" ), []byte ("value2" ))
184- require .NoError (t , err )
184+ assert .NoError (t , err )
185185 writeDone <- nil
186186 }()
187187
@@ -371,7 +371,8 @@ func TestBulkDeletionMemoryRecovery(t *testing.T) {
371371 runtime .ReadMemStats (& mBefore )
372372
373373 for _ , key := range keys {
374- db .Delete (key )
374+ err := db .Delete (key )
375+ assert .NoError (t , err )
375376 }
376377 runtime .GC ()
377378 var mAfter runtime.MemStats
@@ -474,7 +475,7 @@ func TestConcurrentAccess(t *testing.T) {
474475 for j := 0 ; j < opsPerGoroutine ; j ++ {
475476 key := []byte (fmt .Sprintf ("concurrent_key_%d_%d" , id , j ))
476477 err := db .Set (key , []byte ("concurrent_value" ))
477- require .NoError (t , err )
478+ assert .NoError (t , err )
478479 }
479480 }(i )
480481 }
@@ -486,7 +487,7 @@ func TestConcurrentAccess(t *testing.T) {
486487 defer wg .Done ()
487488 for j := 0 ; j < opsPerGoroutine ; j ++ {
488489 iter , err := db .Iterator (nil , nil )
489- require .NoError (t , err )
490+ assert .NoError (t , err )
490491 for iter .Valid () {
491492 _ = iter .Key ()
492493 iter .Next ()
@@ -524,7 +525,7 @@ func TestLockingAndRelease(t *testing.T) {
524525 release := make (chan struct {})
525526 go func () {
526527 iter , err := db .Iterator ([]byte ("conflict_key" ), []byte ("zzzz" ))
527- require .NoError (t , err )
528+ assert .NoError (t , err )
528529 assert .NoError (t , iter .Error (), "Iterator creation error" )
529530 close (ready ) // signal iterator is active
530531 <- release // hold the iterator a bit
@@ -535,7 +536,7 @@ func TestLockingAndRelease(t *testing.T) {
535536 done := make (chan struct {})
536537 go func () {
537538 err := db .Set ([]byte ("conflict_key" ), []byte ("updated" ))
538- require .NoError (t , err )
539+ assert .NoError (t , err )
539540 close (done )
540541 }()
541542
@@ -572,7 +573,8 @@ func TestLongRunningWorkload(t *testing.T) {
572573 err := db .Set (key , []byte ("workload_value" ))
573574 require .NoError (t , err )
574575 if i % 2 == 0 {
575- db .Delete (key )
576+ err = db .Delete (key )
577+ assert .NoError (t , err )
576578 }
577579 if i % reportInterval == 0 {
578580 runtime .GC ()
@@ -642,11 +644,12 @@ func TestRandomMemoryAccessPatterns(t *testing.T) {
642644 if j % 2 == 0 {
643645 key := []byte (fmt .Sprintf ("rand_key_%d_%d" , seed , j ))
644646 err := db .Set (key , []byte ("rand_value" ))
645- require .NoError (t , err )
647+ assert .NoError (t , err )
646648 } else {
647649 // Randomly delete some keys.
648650 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 )
650653 }
651654 }
652655 }(i )
0 commit comments