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
dms3
go-dms3-routing
Commits
7aaad820
Commit
7aaad820
authored
Mar 05, 2017
by
Jeromy
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update go-libp2p-kad-dht with getclosestpeers fix
License: MIT Signed-off-by:
Jeromy
<
jeromyj@gmail.com
>
parent
de646f0c
Changes
12
Hide whitespace changes
Inline
Side-by-side
Showing
12 changed files
with
46 additions
and
46 deletions
+46
-46
mock/centralized_client.go
mock/centralized_client.go
+4
-4
mock/centralized_server.go
mock/centralized_server.go
+2
-2
mock/centralized_test.go
mock/centralized_test.go
+1
-1
mock/dht.go
mock/dht.go
+2
-2
mock/interface.go
mock/interface.go
+2
-2
none/none_client.go
none/none_client.go
+4
-4
offline/offline.go
offline/offline.go
+6
-6
supernode/client.go
supernode/client.go
+9
-9
supernode/proxy/loopback.go
supernode/proxy/loopback.go
+3
-3
supernode/proxy/standard.go
supernode/proxy/standard.go
+7
-7
supernode/server.go
supernode/server.go
+5
-5
supernode/server_test.go
supernode/server_test.go
+1
-1
No files found.
mock/centralized_client.go
View file @
7aaad820
...
@@ -8,16 +8,16 @@ import (
...
@@ -8,16 +8,16 @@ import (
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
routing
"gx/ipfs/QmUc6twRJRE9MNrUGd8eo9WjHHxebGppdZfptGCASkR7fF/go-libp2p-routing"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
peer
"gx/ipfs/QmWUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE/go-libp2p-peer"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
peer
"gx/ipfs/QmZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr/go-libp2p-peer"
routing
"gx/ipfs/QmZghcVHwXQC3Zvnvn24LgTmSPkEn2o3PDyKb6nrtPRzRh/go-libp2p-routing"
dhtpb
"gx/ipfs/QmZp9q8DbrGLztoxpkTC62mnRayRwHcAzGJJ8AvYRwjanR/go-libp2p-record/pb"
u
"gx/ipfs/QmZuY8aV7zbNXVy6DyN9SmnuH3o9nG852F4aTiSBpts8d1/go-ipfs-util"
u
"gx/ipfs/QmZuY8aV7zbNXVy6DyN9SmnuH3o9nG852F4aTiSBpts8d1/go-ipfs-util"
dhtpb
"gx/ipfs/QmcTnycWsBgvNYFYgWdWi8SRDCeevG8HBUQHkvg4KLXUsW/go-libp2p-record/pb"
pstore
"gx/ipfs/Qme1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU/go-libp2p-peerstore"
)
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
...
...
mock/centralized_server.go
View file @
7aaad820
...
@@ -8,11 +8,11 @@ import (
...
@@ -8,11 +8,11 @@ import (
"github.com/ipfs/go-ipfs/thirdparty/testutil"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
dssync
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore/sync"
dssync
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore/sync"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
peer
"gx/ipfs/QmZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr/go-libp2p-peer"
peer
"gx/ipfs/QmWUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE/go-libp2p-peer"
pstore
"gx/ipfs/Qme1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU/go-libp2p-peerstore"
)
)
// server is the mockrouting.Client's private interface to the routing server
// server is the mockrouting.Client's private interface to the routing server
...
...
mock/centralized_test.go
View file @
7aaad820
...
@@ -8,9 +8,9 @@ import (
...
@@ -8,9 +8,9 @@ import (
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
u
"gx/ipfs/QmZuY8aV7zbNXVy6DyN9SmnuH3o9nG852F4aTiSBpts8d1/go-ipfs-util"
u
"gx/ipfs/QmZuY8aV7zbNXVy6DyN9SmnuH3o9nG852F4aTiSBpts8d1/go-ipfs-util"
pstore
"gx/ipfs/Qme1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU/go-libp2p-peerstore"
)
)
func
TestKeyNotFound
(
t
*
testing
.
T
)
{
func
TestKeyNotFound
(
t
*
testing
.
T
)
{
...
...
mock/dht.go
View file @
7aaad820
...
@@ -5,8 +5,8 @@ import (
...
@@ -5,8 +5,8 @@ import (
"github.com/ipfs/go-ipfs/thirdparty/testutil"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
sync
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore/sync"
sync
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore/sync"
mockne
t
"gx/ipfs/Qm
U3g3psEDiC4tQh1Qu2NYg5aYVQqxC3m74ZavLwPfJEtu/go-libp2p/p2p/net/mock
"
dh
t
"gx/ipfs/Qm
aoxFZcgwGyoB57pCYQobejLoNgqaA6trr3zxxrbm4UXe/go-libp2p-kad-dht
"
dh
t
"gx/ipfs/Qm
UpZqxzrUoyDsgWXDri9yYgi5r5EK7J5Tan1MbgnawYLx/go-libp2p-kad-dht
"
mockne
t
"gx/ipfs/Qm
eWJwi61vii5g8zQUB9UGegfUbmhTKHgeDFP9XuSp5jZ4/go-libp2p/p2p/net/mock
"
)
)
type
mocknetserver
struct
{
type
mocknetserver
struct
{
...
...
mock/interface.go
View file @
7aaad820
...
@@ -11,8 +11,8 @@ import (
...
@@ -11,8 +11,8 @@ import (
"github.com/ipfs/go-ipfs/thirdparty/testutil"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
peer
"gx/ipfs/Qm
ZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr
/go-libp2p-
peer
"
routing
"gx/ipfs/Qm
Uc6twRJRE9MNrUGd8eo9WjHHxebGppdZfptGCASkR7fF
/go-libp2p-
routing
"
routing
"gx/ipfs/Qm
ZghcVHwXQC3Zvnvn24LgTmSPkEn2o3PDyKb6nrtPRzRh
/go-libp2p-
routing
"
peer
"gx/ipfs/Qm
WUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE
/go-libp2p-
peer
"
)
)
// Server provides mockrouting Clients
// Server provides mockrouting Clients
...
...
none/none_client.go
View file @
7aaad820
...
@@ -6,12 +6,12 @@ import (
...
@@ -6,12 +6,12 @@ import (
repo
"github.com/ipfs/go-ipfs/repo"
repo
"github.com/ipfs/go-ipfs/repo"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
routing
"gx/ipfs/QmUc6twRJRE9MNrUGd8eo9WjHHxebGppdZfptGCASkR7fF/go-libp2p-routing"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
peer
"gx/ipfs/Qm
ZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr
/go-libp2p-peer"
peer
"gx/ipfs/Qm
WUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE
/go-libp2p-peer"
routing
"gx/ipfs/Qm
ZghcVHwXQC3Zvnvn24LgTmSPkEn2o3PDyKb6nrtPRzRh
/go-libp2p-
routing
"
p2phost
"gx/ipfs/Qm
XzeAcmKDTfNZQBiyF22hQKuTK7P5z6MBBQLTk9bbiSUc
/go-libp2p-
host
"
p
2phost
"gx/ipfs/Qm
bzbRyd22gcW92U1rA2yKagB3myMYhk45XBknJ49F9XWJ
/go-libp2p-
host
"
p
store
"gx/ipfs/Qm
e1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU
/go-libp2p-
peerstore
"
)
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
...
...
offline/offline.go
View file @
7aaad820
...
@@ -7,16 +7,16 @@ import (
...
@@ -7,16 +7,16 @@ import (
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
ci
"gx/ipfs/QmNiCwBNA8MWDADTFVq1BonUEJbS2SvjAoNkZZrhEwcuUi/go-libp2p-crypto"
ci
"gx/ipfs/QmPGxZ1DP2w45WcogpW1h43BvseXbfke9N91qotpoQcUeS/go-libp2p-crypto"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
routing
"gx/ipfs/QmUc6twRJRE9MNrUGd8eo9WjHHxebGppdZfptGCASkR7fF/go-libp2p-routing"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
"gx/ipfs/QmWUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE/go-libp2p-peer"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
"gx/ipfs/QmZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr/go-libp2p-peer"
record
"gx/ipfs/QmcTnycWsBgvNYFYgWdWi8SRDCeevG8HBUQHkvg4KLXUsW/go-libp2p-record"
routing
"gx/ipfs/QmZghcVHwXQC3Zvnvn24LgTmSPkEn2o3PDyKb6nrtPRzRh/go-libp2p-routing"
pb
"gx/ipfs/QmcTnycWsBgvNYFYgWdWi8SRDCeevG8HBUQHkvg4KLXUsW/go-libp2p-record/pb"
record
"gx/ipfs/QmZp9q8DbrGLztoxpkTC62mnRayRwHcAzGJJ8AvYRwjanR/go-libp2p-record"
pstore
"gx/ipfs/Qme1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU/go-libp2p-peerstore"
pb
"gx/ipfs/QmZp9q8DbrGLztoxpkTC62mnRayRwHcAzGJJ8AvYRwjanR/go-libp2p-record/pb"
)
)
var
log
=
logging
.
Logger
(
"offlinerouting"
)
var
log
=
logging
.
Logger
(
"offlinerouting"
)
...
...
supernode/client.go
View file @
7aaad820
...
@@ -8,16 +8,16 @@ import (
...
@@ -8,16 +8,16 @@ import (
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
loggables
"gx/ipfs/QmTcfnDHimxBJqx6utpnWqVHdvyquXgkwAvYt4zMaJMKS2/go-libp2p-loggables"
routing
"gx/ipfs/QmUc6twRJRE9MNrUGd8eo9WjHHxebGppdZfptGCASkR7fF/go-libp2p-routing"
dhtpb
"gx/ipfs/QmUpZqxzrUoyDsgWXDri9yYgi5r5EK7J5Tan1MbgnawYLx/go-libp2p-kad-dht/pb"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
cid
"gx/ipfs/QmV5gPoRsjN1Gid3LMdNZTyfCtP2DsvqEbMAmz82RmmiGk/go-cid"
peer
"gx/ipfs/QmWUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE/go-libp2p-peer"
loggables
"gx/ipfs/QmXs1igHHEaUmMxKtbP8Z9wTjitQ75sqxaKQP4QgnLN4nn/go-libp2p-loggables"
"gx/ipfs/QmXzeAcmKDTfNZQBiyF22hQKuTK7P5z6MBBQLTk9bbiSUc/go-libp2p-host"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
peer
"gx/ipfs/QmZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr/go-libp2p-peer"
dhtpb
"gx/ipfs/QmaoxFZcgwGyoB57pCYQobejLoNgqaA6trr3zxxrbm4UXe/go-libp2p-kad-dht/pb"
routing
"gx/ipfs/QmZghcVHwXQC3Zvnvn24LgTmSPkEn2o3PDyKb6nrtPRzRh/go-libp2p-routing"
pb
"gx/ipfs/QmcTnycWsBgvNYFYgWdWi8SRDCeevG8HBUQHkvg4KLXUsW/go-libp2p-record/pb"
pb
"gx/ipfs/QmZp9q8DbrGLztoxpkTC62mnRayRwHcAzGJJ8AvYRwjanR/go-libp2p-record/pb"
pstore
"gx/ipfs/Qme1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU/go-libp2p-peerstore"
"gx/ipfs/QmbzbRyd22gcW92U1rA2yKagB3myMYhk45XBknJ49F9XWJ/go-libp2p-host"
)
)
var
log
=
logging
.
Logger
(
"supernode"
)
var
log
=
logging
.
Logger
(
"supernode"
)
...
@@ -56,7 +56,7 @@ func (c *Client) FindProvidersAsync(ctx context.Context, k *cid.Cid, max int) <-
...
@@ -56,7 +56,7 @@ func (c *Client) FindProvidersAsync(ctx context.Context, k *cid.Cid, max int) <-
case
<-
ctx
.
Done
()
:
case
<-
ctx
.
Done
()
:
log
.
Debug
(
ctx
.
Err
())
log
.
Debug
(
ctx
.
Err
())
return
return
case
ch
<-
p
:
case
ch
<-
*
p
:
}
}
}
}
}()
}()
...
@@ -125,7 +125,7 @@ func (c *Client) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo, err
...
@@ -125,7 +125,7 @@ func (c *Client) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo, err
}
}
for
_
,
p
:=
range
dhtpb
.
PBPeersToPeerInfos
(
response
.
GetCloserPeers
())
{
for
_
,
p
:=
range
dhtpb
.
PBPeersToPeerInfos
(
response
.
GetCloserPeers
())
{
if
p
.
ID
==
id
{
if
p
.
ID
==
id
{
return
p
,
nil
return
*
p
,
nil
}
}
}
}
return
pstore
.
PeerInfo
{},
errors
.
New
(
"could not find peer"
)
return
pstore
.
PeerInfo
{},
errors
.
New
(
"could not find peer"
)
...
...
supernode/proxy/loopback.go
View file @
7aaad820
...
@@ -2,10 +2,10 @@ package proxy
...
@@ -2,10 +2,10 @@ package proxy
import
(
import
(
context
"context"
context
"context"
inet
"gx/ipfs/Qm
RuZnMorqodado1yeTQiv1i9rmtKj29CjPSsBKM7DFXV4
/go-libp2p-net"
inet
"gx/ipfs/Qm
VtMT3fD7DzQNW7hdm6Xe6KPstzcggrhNpeVZ4422UpKK
/go-libp2p-net"
dhtpb
"gx/ipfs/Qm
UpZqxzrUoyDsgWXDri9yYgi5r5EK7J5Tan1MbgnawYLx
/go-libp2p-
kad-dht/pb
"
peer
"gx/ipfs/Qm
WUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE
/go-libp2p-
peer
"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
peer
"gx/ipfs/Qm
ZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr
/go-libp2p-
peer
"
dhtpb
"gx/ipfs/Qm
aoxFZcgwGyoB57pCYQobejLoNgqaA6trr3zxxrbm4UXe
/go-libp2p-
kad-dht/pb
"
)
)
// RequestHandler handles routing requests locally
// RequestHandler handles routing requests locally
...
...
supernode/proxy/standard.go
View file @
7aaad820
...
@@ -4,15 +4,15 @@ import (
...
@@ -4,15 +4,15 @@ import (
"context"
"context"
"errors"
"errors"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
inet
"gx/ipfs/QmRuZnMorqodado1yeTQiv1i9rmtKj29CjPSsBKM7DFXV4/go-libp2p-net"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
loggables
"gx/ipfs/QmTcfnDHimxBJqx6utpnWqVHdvyquXgkwAvYt4zMaJMKS2/go-libp2p-loggables"
kbucket
"gx/ipfs/QmTxn7JEA8DiBvd9vVzErAzadHn6TwjCKTjjUfPyRH9wjZ/go-libp2p-kbucket"
dhtpb
"gx/ipfs/QmUpZqxzrUoyDsgWXDri9yYgi5r5EK7J5Tan1MbgnawYLx/go-libp2p-kad-dht/pb"
inet
"gx/ipfs/QmVtMT3fD7DzQNW7hdm6Xe6KPstzcggrhNpeVZ4422UpKK/go-libp2p-net"
kbucket
"gx/ipfs/QmUwZcbSVMsLZzovZssH96rCUM5FAkrjaqhHLhJnFYd5z3/go-libp2p-kbucket"
peer
"gx/ipfs/QmWUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE/go-libp2p-peer"
loggables
"gx/ipfs/QmXs1igHHEaUmMxKtbP8Z9wTjitQ75sqxaKQP4QgnLN4nn/go-libp2p-loggables"
host
"gx/ipfs/QmXzeAcmKDTfNZQBiyF22hQKuTK7P5z6MBBQLTk9bbiSUc/go-libp2p-host"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
peer
"gx/ipfs/Qm
ZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr
/go-libp2p-
peer
"
dhtpb
"gx/ipfs/Qm
aoxFZcgwGyoB57pCYQobejLoNgqaA6trr3zxxrbm4UXe
/go-libp2p-
kad-dht/pb
"
host
"gx/ipfs/Qm
bzbRyd22gcW92U1rA2yKagB3myMYhk45XBknJ49F9XWJ
/go-libp2p-
host
"
pstore
"gx/ipfs/Qm
e1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU
/go-libp2p-
peerstore
"
)
)
const
ProtocolSNR
=
"/ipfs/supernoderouting"
const
ProtocolSNR
=
"/ipfs/supernoderouting"
...
...
supernode/server.go
View file @
7aaad820
...
@@ -8,13 +8,13 @@ import (
...
@@ -8,13 +8,13 @@ import (
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
pstore
"gx/ipfs/QmQMQ2RUjnaEEX8ybmrhuFFGhAwPjyL1Eo6ZoJGD7aAccM/go-libp2p-peerstore"
datastore
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
datastore
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
dhtpb
"gx/ipfs/Qm
UpZqxzrUoyDsgWXDri9yYgi5r5EK7J5Tan1MbgnawYLx
/go-libp2p-
kad-dht/pb
"
peer
"gx/ipfs/Qm
WUswjn261LSyVxWAEpMVtPdy8zmKBJJfBpG3Qdpa8ZsE
/go-libp2p-
peer
"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
peer
"gx/ipfs/QmZcUPvPhD1Xvk6mwijYF8AfR3mG31S1YsEfHG4khrFPRr/go-libp2p-peer"
dhtpb
"gx/ipfs/QmaoxFZcgwGyoB57pCYQobejLoNgqaA6trr3zxxrbm4UXe/go-libp2p-kad-dht/pb"
record
"gx/ipfs/QmZp9q8DbrGLztoxpkTC62mnRayRwHcAzGJJ8AvYRwjanR/go-libp2p-record"
record
"gx/ipfs/QmcTnycWsBgvNYFYgWdWi8SRDCeevG8HBUQHkvg4KLXUsW/go-libp2p-record"
pb
"gx/ipfs/QmZp9q8DbrGLztoxpkTC62mnRayRwHcAzGJJ8AvYRwjanR/go-libp2p-record/pb"
pb
"gx/ipfs/QmcTnycWsBgvNYFYgWdWi8SRDCeevG8HBUQHkvg4KLXUsW/go-libp2p-record/pb"
pstore
"gx/ipfs/Qme1g4e3m2SmdiSGGU3vSWmUStwUjc5oECnEriaK9Xa1HU/go-libp2p-peerstore"
)
)
// Server handles routing queries using a database backend
// Server handles routing queries using a database backend
...
...
supernode/server_test.go
View file @
7aaad820
...
@@ -4,7 +4,7 @@ import (
...
@@ -4,7 +4,7 @@ import (
"testing"
"testing"
datastore
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
datastore
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
dhtpb
"gx/ipfs/Qm
UpZqxzrUoyDsgWXDri9yYgi5r5EK7J5Tan1MbgnawYLx
/go-libp2p-kad-dht/pb"
dhtpb
"gx/ipfs/Qm
aoxFZcgwGyoB57pCYQobejLoNgqaA6trr3zxxrbm4UXe
/go-libp2p-kad-dht/pb"
)
)
func
TestPutProviderDoesntResultInDuplicates
(
t
*
testing
.
T
)
{
func
TestPutProviderDoesntResultInDuplicates
(
t
*
testing
.
T
)
{
...
...
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