aboutsummaryrefslogtreecommitdiff
path: root/queue.go
diff options
context:
space:
mode:
authorale <ale@incal.net>2017-12-19 08:35:21 +0000
committerale <ale@incal.net>2017-12-19 08:35:21 +0000
commit3ff5e7b88f3c2838e93aeb57824c82508e1e1d66 (patch)
treed3af5abc9f304ff13f5ba1a06757ed2efbb0e302 /queue.go
parent06f170e9ca181f145a57150c111a0982db32d023 (diff)
downloadcrawl-3ff5e7b88f3c2838e93aeb57824c82508e1e1d66.tar.gz
crawl-3ff5e7b88f3c2838e93aeb57824c82508e1e1d66.zip
Simplify redirectHandler.Handle
Diffstat (limited to 'queue.go')
-rw-r--r--queue.go2
1 files changed, 0 insertions, 2 deletions
diff --git a/queue.go b/queue.go
index 7621226..da4a7b8 100644
--- a/queue.go
+++ b/queue.go
@@ -65,10 +65,8 @@ func (q *queue) Add(wb *leveldb.Batch, urlStr string, depth int, when time.Time)
func (q *queue) acquire(qp queuePair) {
wb := new(leveldb.Batch)
-
q.db.PutObjBatch(wb, activeQueueKey(qp.key), qp)
wb.Delete(qp.key)
-
q.db.Write(wb, nil)
atomic.AddInt32(&q.numActive, 1)