1. 09 Jun, 2016 1 commit
  2. 01 Jun, 2016 1 commit
  3. 17 May, 2016 1 commit
  4. 10 May, 2016 1 commit
  5. 04 May, 2016 1 commit
  6. 17 Apr, 2016 2 commits
  7. 11 Apr, 2016 1 commit
  8. 07 Apr, 2016 1 commit
  9. 30 Mar, 2016 1 commit
  10. 09 Mar, 2016 1 commit
  11. 13 Feb, 2016 2 commits
  12. 31 Jan, 2016 2 commits
  13. 30 Jan, 2016 3 commits
  14. 10 Nov, 2015 1 commit
  15. 08 Nov, 2015 1 commit
  16. 05 Nov, 2015 1 commit
  17. 27 Oct, 2015 1 commit
  18. 03 Oct, 2015 1 commit
  19. 29 Sep, 2015 1 commit
    • Jeromy's avatar
      Fix dht queries · badc7388
      Jeromy authored
      Queries previously would sometimes only query three (alpha value) peers
      before halting the operation. This PR changes the number of peers
      grabbed from the routing table to start a query to K.
      
      Dht nodes would also not respond with enough peers, as per the kademlia
      paper, this has been changed to from 4 to 'K'.
      
      The query mechanism itself also was flawed in that it would pull all the
      peers it had yet to query out of the queue and 'start' the query for
      them. The concurrency rate limiting was done inside the 'queryPeer'
      method after the goroutine was spawned. This did not allow for peers
      receiver from query replies to be properly queried in order of distance.
      
      License: MIT
      Signed-off-by: default avatarJeromy <jeromyj@gmail.com>
      badc7388
  20. 15 Sep, 2015 1 commit
  21. 09 Sep, 2015 1 commit
  22. 05 Jul, 2015 1 commit
  23. 01 Jun, 2015 1 commit
  24. 31 Mar, 2015 1 commit
  25. 07 Mar, 2015 2 commits
  26. 25 Feb, 2015 1 commit
    • Henry's avatar
      rewrote import paths of go.net/context to use golang.org/x/context · 9bc5b3d5
      Henry authored
      - updated go-ctxgroup and goprocess
      ctxgroup: AddChildGroup was changed to AddChild. Used in two files:
      - p2p/net/mock/mock_net.go
      - routing/dht/dht.go
      
      - updated context from hg repo to git
      prev. commit in hg was ad01a6fcc8a19d3a4478c836895ffe883bd2ceab. (context: make parentCancelCtx iterative)
      represents commit 84f8955a887232b6308d79c68b8db44f64df455c in git repo
      
      - updated context to master (b6fdb7d8a4ccefede406f8fe0f017fb58265054c)
      
      Aaron Jacobs (2):
      net/context: Don't accept a context in the DoSomethingSlow example.
      context: Be clear that users must cancel the result of WithCancel.
      
      Andrew Gerrand (1):
      go.net: use golang.org/x/... import paths
      
      Bryan C. Mills (1):
      net/context: Don't leak goroutines in Done example.
      
      Damien Neil (1):
      context: fix removal of cancelled timer contexts from parent
      
      David Symonds (2):
      context: Fix WithValue example code.
      net: add import comments.
      
      Sameer Ajmani (1):
      context: fix TestAllocs to account for ints in interfaces
      9bc5b3d5
  27. 03 Feb, 2015 2 commits
  28. 30 Jan, 2015 1 commit
    • Brian Tiger Chow's avatar
      log(dht): remove lots of query debug logs · 4e858580
      Brian Tiger Chow authored
      the debug log is flooded with pages upon pages of...
      
      we've gotta be more judicious with our use of console logs. i'm sure
      there's interesting actionable information in here. let's use the
      console logging more like a sniper rifle and less like birdshot.
      
      feel free to revert if there are specific critical statements in this
      changeset
      
      03:05:24.096 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLp>) QUERY worker for: <peer.ID QmSoLp> - not
      found, and no closer peers. prefixlog.go:107
      03:05:24.096 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLp>) completed prefixlog.go:107
      03:05:24.096 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLp>) finished prefixlog.go:107
      03:05:24.096 DEBUG        dht: dht(<peer.ID QmWGN3>)
      FindProviders(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK)
      Query(<peer.ID QmSoLn>) 0 provider entries prefixlog.go:107
      03:05:24.096 DEBUG        dht: dht(<peer.ID QmWGN3>)
      FindProviders(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK)
      Query(<peer.ID QmSoLn>) 0 provider entries decoded prefixlog.go:107
      03:05:24.096 DEBUG        dht: dht(<peer.ID QmWGN3>)
      FindProviders(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK)
      Query(<peer.ID QmSoLn>) got closer peers: 0 [] prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID QmWGN3>)
      FindProviders(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK)
      Query(<peer.ID QmSoLn>) end prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLn>) query finished prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLn>) QUERY worker for: <peer.ID QmSoLn> - not
      found, and no closer peers. prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLn>) completed prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      queryPeer(<peer.ID QmSoLn>) finished prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      all peers ended prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      spawnWorkers end prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      failure: %s routing: not found prefixlog.go:107
      03:05:24.097 DEBUG        dht: dht(<peer.ID
      QmWGN3>).Query(QmXvrpUZXCYaCkf1jfaQTJASS91xd47Yih2rnVC5YbFAAK).Run(3)
      end prefixlog.go:107
      4e858580
  29. 24 Jan, 2015 3 commits
  30. 23 Jan, 2015 1 commit
    • Juan Batiz-Benet's avatar
      dht/query: err return NotFound case · 2322f6fe
      Juan Batiz-Benet authored
      When some queries finished, but we got no result, it should
      be a simple NotFoundError. Only when every single query ended
      in error do we externalize those to the client, in case
      something major is going wrong
      2322f6fe
  31. 18 Jan, 2015 1 commit