From cb1ef6e1e2e7ac690f8aa1ef74161b622ffa6a7b Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Thu, 18 Dec 2014 22:47:34 -0500 Subject: [PATCH] feat: add time to taskQueue License: MIT Signed-off-by: Brian Tiger Chow Conflicts: exchange/bitswap/decision/taskqueue.go --- exchange/bitswap/decision/taskqueue.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/exchange/bitswap/decision/taskqueue.go b/exchange/bitswap/decision/taskqueue.go index 659e287d0..e2087a472 100644 --- a/exchange/bitswap/decision/taskqueue.go +++ b/exchange/bitswap/decision/taskqueue.go @@ -3,6 +3,7 @@ package decision import ( "fmt" "sync" + "time" wantlist "github.com/jbenet/go-ipfs/exchange/bitswap/wantlist" peer "github.com/jbenet/go-ipfs/p2p/peer" @@ -28,7 +29,9 @@ func newTaskQueue() *taskQueue { type task struct { Entry wantlist.Entry Target peer.ID - Trash bool + Trash bool // TODO make private + + created time.Time } func (t *task) String() string { @@ -46,8 +49,9 @@ func (tl *taskQueue) Push(entry wantlist.Entry, to peer.ID) { return } task := &task{ - Entry: entry, - Target: to, + Entry: entry, + Target: to, + created: time.Now(), } tl.tasks = append(tl.tasks, task) tl.taskmap[taskKey(to, entry.Key)] = task