Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
p2p
go-p2p-kad-dht
Commits
26beb1f3
Commit
26beb1f3
authored
May 17, 2016
by
Jeromy
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update go-libp2p 3.2.2, nil maddr fixes
License: MIT Signed-off-by:
Jeromy
<
why@ipfs.io
>
parent
fd6f4b61
Changes
15
Hide whitespace changes
Inline
Side-by-side
Showing
15 changed files
with
24 additions
and
24 deletions
+24
-24
dht.go
dht.go
+3
-3
dht_bootstrap.go
dht_bootstrap.go
+1
-1
dht_net.go
dht_net.go
+2
-2
dht_test.go
dht_test.go
+2
-2
diag.go
diag.go
+1
-1
ext_test.go
ext_test.go
+3
-3
handlers.go
handlers.go
+1
-1
lookup.go
lookup.go
+1
-1
notif.go
notif.go
+1
-1
pb/message.go
pb/message.go
+2
-2
providers.go
providers.go
+1
-1
providers_test.go
providers_test.go
+1
-1
query.go
query.go
+2
-2
records.go
records.go
+1
-1
routing.go
routing.go
+2
-2
No files found.
dht.go
View file @
26beb1f3
...
...
@@ -15,10 +15,10 @@ import (
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
record
"github.com/ipfs/go-ipfs/routing/record"
ci
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
host
"gx/ipfs/QmUHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5/go-libp2p/p2p/host"
protocol
"gx/ipfs/QmUHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5/go-libp2p/p2p/protocol"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
host
"gx/ipfs/QmVL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm/go-libp2p/p2p/host"
protocol
"gx/ipfs/QmVL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm/go-libp2p/p2p/protocol"
logging
"gx/ipfs/QmaDNZ4QMdBdku1YZWBysufYyoQt1negQGNav6PLYarbY8/go-log"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
...
...
dht_bootstrap.go
View file @
26beb1f3
...
...
@@ -10,7 +10,7 @@ import (
routing
"github.com/ipfs/go-ipfs/routing"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
peer
"gx/ipfs/Qm
ZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7
/go-libp2p-peer"
peer
"gx/ipfs/Qm
byvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4
/go-libp2p-peer"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
periodicproc
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/periodic"
...
...
dht_net.go
View file @
26beb1f3
...
...
@@ -6,10 +6,10 @@ import (
ctxio
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-context/io"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
inet
"gx/ipfs/Qm
UHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5
/go-libp2p/p2p/net"
inet
"gx/ipfs/Qm
VL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm
/go-libp2p/p2p/net"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
)
// handleNewStream implements the inet.StreamHandler
...
...
dht_test.go
View file @
26beb1f3
...
...
@@ -17,9 +17,9 @@ import (
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
record
"github.com/ipfs/go-ipfs/routing/record"
netutil
"gx/ipfs/Qm
UHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5
/go-libp2p/p2p/test/util"
netutil
"gx/ipfs/Qm
VL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm
/go-libp2p/p2p/test/util"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
peer
"gx/ipfs/Qm
ZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7
/go-libp2p-peer"
peer
"gx/ipfs/Qm
byvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4
/go-libp2p-peer"
ci
"github.com/ipfs/go-ipfs/thirdparty/testutil/ci"
travisci
"github.com/ipfs/go-ipfs/thirdparty/testutil/ci/travis"
...
...
diag.go
View file @
26beb1f3
...
...
@@ -4,7 +4,7 @@ import (
"encoding/json"
"time"
peer
"gx/ipfs/Qm
ZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7
/go-libp2p-peer"
peer
"gx/ipfs/Qm
byvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4
/go-libp2p-peer"
)
type
connDiagInfo
struct
{
...
...
ext_test.go
View file @
26beb1f3
...
...
@@ -16,10 +16,10 @@ import (
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
inet
"gx/ipfs/Qm
UHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5
/go-libp2p/p2p/net"
mocknet
"gx/ipfs/Qm
UHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5
/go-libp2p/p2p/net/mock"
inet
"gx/ipfs/Qm
VL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm
/go-libp2p/p2p/net"
mocknet
"gx/ipfs/Qm
VL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm
/go-libp2p/p2p/net/mock"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
peer
"gx/ipfs/Qm
ZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7
/go-libp2p-peer"
peer
"gx/ipfs/Qm
byvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4
/go-libp2p-peer"
)
func
TestGetFailures
(
t
*
testing
.
T
)
{
...
...
handlers.go
View file @
26beb1f3
...
...
@@ -11,8 +11,8 @@ import (
lgbl
"github.com/ipfs/go-ipfs/thirdparty/loggables"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
)
// The number of closer peers to send on requests.
...
...
lookup.go
View file @
26beb1f3
...
...
@@ -5,8 +5,8 @@ import (
notif
"github.com/ipfs/go-ipfs/notifications"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
pset
"github.com/ipfs/go-ipfs/thirdparty/peerset"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
)
// Required in order for proper JSON marshaling
...
...
notif.go
View file @
26beb1f3
...
...
@@ -3,7 +3,7 @@ package dht
import
(
ma
"gx/ipfs/QmYzDkkgAEmrcNzFCiYo6L1dTX4EAG1gZkbtdbd9trL4vd/go-multiaddr"
inet
"gx/ipfs/Qm
UHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5
/go-libp2p/p2p/net"
inet
"gx/ipfs/Qm
VL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm
/go-libp2p/p2p/net"
)
// netNotifiee defines methods to be used with the IpfsDHT
...
...
pb/message.go
View file @
26beb1f3
...
...
@@ -4,9 +4,9 @@ import (
ma
"gx/ipfs/QmYzDkkgAEmrcNzFCiYo6L1dTX4EAG1gZkbtdbd9trL4vd/go-multiaddr"
key
"github.com/ipfs/go-ipfs/blocks/key"
inet
"gx/ipfs/QmUHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5/go-libp2p/p2p/net"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
inet
"gx/ipfs/QmVL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm/go-libp2p/p2p/net"
logging
"gx/ipfs/QmaDNZ4QMdBdku1YZWBysufYyoQt1negQGNav6PLYarbY8/go-log"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
)
var
log
=
logging
.
Logger
(
"dht.pb"
)
...
...
providers.go
View file @
26beb1f3
...
...
@@ -6,7 +6,7 @@ import (
key
"github.com/ipfs/go-ipfs/blocks/key"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
goprocessctx
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/context"
peer
"gx/ipfs/Qm
ZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7
/go-libp2p-peer"
peer
"gx/ipfs/Qm
byvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4
/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
...
...
providers_test.go
View file @
26beb1f3
...
...
@@ -4,7 +4,7 @@ import (
"testing"
key
"github.com/ipfs/go-ipfs/blocks/key"
peer
"gx/ipfs/Qm
ZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7
/go-libp2p-peer"
peer
"gx/ipfs/Qm
byvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4
/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
...
...
query.go
View file @
26beb1f3
...
...
@@ -9,9 +9,9 @@ import (
pset
"github.com/ipfs/go-ipfs/thirdparty/peerset"
todoctr
"github.com/ipfs/go-ipfs/thirdparty/todocounter"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
queue
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer/queue"
logging
"gx/ipfs/QmaDNZ4QMdBdku1YZWBysufYyoQt1negQGNav6PLYarbY8/go-log"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
queue
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer/queue"
process
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
ctxproc
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/context"
...
...
records.go
View file @
26beb1f3
...
...
@@ -9,8 +9,8 @@ import (
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
ci
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
)
// MaxRecordAge specifies the maximum time that any node will hold onto a record
...
...
routing.go
View file @
26beb1f3
...
...
@@ -12,9 +12,9 @@ import (
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
record
"github.com/ipfs/go-ipfs/routing/record"
pset
"github.com/ipfs/go-ipfs/thirdparty/peerset"
inet
"gx/ipfs/QmUHrgorZ1F9yGkgF2His5fsQ9xtCzjdsPGjizmcEW94i5/go-libp2p/p2p/net"
peer
"gx/ipfs/QmZpD74pUj6vuxTp1o6LhA3JavC2Bvh9fsWPPVvHnD9sE7/go-libp2p-peer"
inet
"gx/ipfs/QmVL44QeoQDTYK8RVdpkyja7uYcK3WDNoBNHVLonf9YDtm/go-libp2p/p2p/net"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
peer
"gx/ipfs/QmbyvM8zRFDkbFdYyt1MnevUMJ62SiSGbfDFZ3Z8nkrzr4/go-libp2p-peer"
)
// asyncQueryBuffer is the size of buffered channels in async queries. This
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment