- fixes after review

leveldb/leveldbSerial_test.go

@@ -416,3 +416,30 @@ func TestSerialDB_PutRemoveGet(t *testing.T) {
 
 	_ = ldb.Close()
 }
+
+func TestSerialDB_PutRemovePutHas(t *testing.T) {
+	ldb := createSerialLevelDb(t, 100000, 1000000, 10)
+
+	key := []byte("key")
+	value := []byte("value")
+
+	_ = ldb.Put(key, value)
+
+	// manually put the <key, value> pair in storage
+	ldb.PutBatch()
+	time.Sleep(time.Second)
+	assert.Nil(t, ldb.Has(key)) // key was found
+
+	// we now remove the key
+	_ = ldb.Remove(key)
+
+	// manually delete the key from the storage
+	ldb.PutBatch()
+	time.Sleep(time.Second)
+	assert.NotNil(t, ldb.Has(key)) // missing key
+
+	_ = ldb.Put(key, value)     // put the key again
+	assert.Nil(t, ldb.Has(key)) // key was found
+
+	_ = ldb.Close()
+}

rtcache/removalTrackingCache.go

@@ -71,8 +71,8 @@ func (cache *removalTrackingCache) GetRemovalStatus(key []byte) types.RemovalSta
 
 // Clear is used to completely clear both caches.
 func (cache *removalTrackingCache) Clear() {
-	cache.mutCriticalArea.RLock()
-	defer cache.mutCriticalArea.RUnlock()
+	cache.mutCriticalArea.Lock()
+	defer cache.mutCriticalArea.Unlock()
 
 	cache.removalCache.Clear()
 	cache.unexportedCacher.Clear()

storageUnit/storageunit_test.go

@@ -148,7 +148,7 @@ func TestUnit_GetWithExplicitlyRemovedKeyShouldNotCallThePersister(t *testing.T)
 			return nil
 		},
 		GetCalled: func(key []byte) ([]byte, error) {
-			assert.Fail(t, "should have not called Has")
+			assert.Fail(t, "should have not called Get")
 			return nil, nil
 		},
 	}
@@ -219,7 +219,7 @@ func TestUnit_HasWithExplicitlyRemovedKeyShouldNotCallThePersister(t *testing.T)
 			return nil
 		},
 		GetCalled: func(key []byte) ([]byte, error) {
-			assert.Fail(t, "should have not called Has")
+			assert.Fail(t, "should have not called Get")
 			return nil, nil
 		},
 	}

testscommon/cacherMock.go

@@ -67,10 +67,13 @@ func (mock *cacherMock) HasOrAdd(key []byte, value interface{}, _ int) (has, add
 	defer mock.mut.Unlock()
 
 	_, found := mock.data[string(key)]
+	if found {
+		return found, !found
+	}
 
 	mock.data[string(key)] = value
 
-	return !found, found
+	return found, !found
 }
 
 // Remove -

types/interface.go

@@ -14,7 +14,7 @@ const (
 	UnknownRemovalStatus RemovalStatus = "unknown"
 	// ExplicitlyRemovedStatus defines the explicitly removed status
 	ExplicitlyRemovedStatus RemovalStatus = "explicitly removed"
-	// NotRemovedStatus the key is not removed
+	// NotRemovedStatus defines the not removed status
 	NotRemovedStatus RemovalStatus = "not removed"
 )