disable queue cache for unknown issue

MixinNetwork · Mar 18, 2019 · 4814f1d · 4814f1d
1 parent 696e6c5
commit 4814f1d
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/storage/badger_queue.go b/storage/badger_queue.go
@@ -87,11 +87,6 @@ func (q *Queue) PutCache(ps *PeerSnapshot) error {
 	q.mutex.Lock()
 	defer q.mutex.Unlock()
 
-	if q.cacheSet[ps.key] {
-		return nil
-	}
-	q.cacheSet[ps.key] = true
-
 	for {
 		put, err := q.cacheRing.Offer(ps)
 		if err != nil || put {
@@ -110,7 +105,6 @@ func (q *Queue) PopCache() (*PeerSnapshot, error) {
 		return nil, err
 	}
 	ps := item.(*PeerSnapshot)
-	delete(q.cacheSet, ps.key)
 	return ps, nil
 }