Browse Source

filer: fix where deletion can miss under high concurrency

Chris Lu 5 years ago
parent
commit
d3e4a31058
1 changed files with 1 additions and 1 deletions
  1. 1 1
      weed/util/queue_unbounded.go

+ 1 - 1
weed/util/queue_unbounded.go

@@ -18,7 +18,7 @@ func (q *UnboundedQueue) EnQueue(items ...string) {
 	q.inboundLock.Lock()
 	defer q.inboundLock.Unlock()
 
-	q.outbound = append(q.outbound, items...)
+	q.inbound = append(q.inbound, items...)
 
 }