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
6a37a454
Commit
6a37a454
authored
Jan 28, 2016
by
Jeromy
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
go-keyspace dep from libp2p added
License: MIT Signed-off-by:
Jeromy
<
jeromyj@gmail.com
>
parent
cd393ab5
Changes
34
Hide whitespace changes
Inline
Side-by-side
Showing
34 changed files
with
66 additions
and
66 deletions
+66
-66
dht/dht.go
dht/dht.go
+4
-4
dht/dht_bootstrap.go
dht/dht_bootstrap.go
+1
-1
dht/dht_net.go
dht/dht_net.go
+3
-3
dht/dht_test.go
dht/dht_test.go
+3
-3
dht/diag.go
dht/diag.go
+1
-1
dht/ext_test.go
dht/ext_test.go
+3
-3
dht/handlers.go
dht/handlers.go
+2
-2
dht/lookup.go
dht/lookup.go
+2
-2
dht/notif.go
dht/notif.go
+1
-1
dht/pb/message.go
dht/pb/message.go
+2
-2
dht/providers.go
dht/providers.go
+1
-1
dht/providers_test.go
dht/providers_test.go
+1
-1
dht/query.go
dht/query.go
+2
-2
dht/records.go
dht/records.go
+3
-3
dht/routing.go
dht/routing.go
+3
-3
kbucket/bucket.go
kbucket/bucket.go
+1
-1
kbucket/sorting.go
kbucket/sorting.go
+1
-1
kbucket/table.go
kbucket/table.go
+1
-1
kbucket/table_test.go
kbucket/table_test.go
+1
-1
kbucket/util.go
kbucket/util.go
+1
-1
mock/centralized_client.go
mock/centralized_client.go
+3
-3
mock/centralized_server.go
mock/centralized_server.go
+2
-2
mock/centralized_test.go
mock/centralized_test.go
+2
-2
mock/dht.go
mock/dht.go
+2
-2
mock/interface.go
mock/interface.go
+2
-2
none/none_client.go
none/none_client.go
+3
-3
offline/offline.go
offline/offline.go
+3
-3
record/record.go
record/record.go
+1
-1
record/validation.go
record/validation.go
+1
-1
routing.go
routing.go
+2
-2
supernode/client.go
supernode/client.go
+2
-2
supernode/proxy/loopback.go
supernode/proxy/loopback.go
+2
-2
supernode/proxy/standard.go
supernode/proxy/standard.go
+3
-3
supernode/server.go
supernode/server.go
+1
-1
No files found.
dht/dht.go
View file @
6a37a454
...
@@ -14,11 +14,11 @@ import (
...
@@ -14,11 +14,11 @@ import (
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
ci
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/crypto"
host
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/host"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
protocol
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/protocol"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
ci
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/crypto"
host
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/host"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
protocol
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/protocol"
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
...
...
dht/dht_bootstrap.go
View file @
6a37a454
...
@@ -10,7 +10,7 @@ import (
...
@@ -10,7 +10,7 @@ import (
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
goprocess
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
goprocess
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
periodicproc
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess/periodic"
periodicproc
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess/periodic"
...
...
dht/dht_net.go
View file @
6a37a454
...
@@ -6,10 +6,10 @@ import (
...
@@ -6,10 +6,10 @@ import (
ggio
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/io"
ggio
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/io"
ctxio
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-context/io"
ctxio
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-context/io"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
inet
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/net"
inet
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/net"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// handleNewStream implements the inet.StreamHandler
// handleNewStream implements the inet.StreamHandler
...
...
dht/dht_test.go
View file @
6a37a454
...
@@ -11,15 +11,15 @@ import (
...
@@ -11,15 +11,15 @@ import (
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
dssync
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore/sync"
dssync
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore/sync"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
netutil
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/test/util"
netutil
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/test/util"
ci
"github.com/ipfs/go-ipfs/util/testutil/ci"
ci
"github.com/ipfs/go-ipfs/util/testutil/ci"
travisci
"github.com/ipfs/go-ipfs/util/testutil/ci/travis"
travisci
"github.com/ipfs/go-ipfs/util/testutil/ci/travis"
...
...
dht/diag.go
View file @
6a37a454
...
@@ -4,7 +4,7 @@ import (
...
@@ -4,7 +4,7 @@ import (
"encoding/json"
"encoding/json"
"time"
"time"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
type
connDiagInfo
struct
{
type
connDiagInfo
struct
{
...
...
dht/ext_test.go
View file @
6a37a454
...
@@ -17,9 +17,9 @@ import (
...
@@ -17,9 +17,9 @@ import (
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
inet
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/net"
inet
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/net"
mocknet
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/net/mock"
mocknet
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/net/mock"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
func
TestGetFailures
(
t
*
testing
.
T
)
{
func
TestGetFailures
(
t
*
testing
.
T
)
{
...
...
dht/handlers.go
View file @
6a37a454
...
@@ -7,12 +7,12 @@ import (
...
@@ -7,12 +7,12 @@ import (
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
lgbl
"github.com/ipfs/go-ipfs/util/eventlog/loggables"
lgbl
"github.com/ipfs/go-ipfs/util/eventlog/loggables"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// The number of closer peers to send on requests.
// The number of closer peers to send on requests.
...
...
dht/lookup.go
View file @
6a37a454
package
dht
package
dht
import
(
import
(
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
notif
"github.com/ipfs/go-ipfs/notifications"
notif
"github.com/ipfs/go-ipfs/notifications"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
pset
"github.com/ipfs/go-ipfs/util/peerset"
pset
"github.com/ipfs/go-ipfs/util/peerset"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// Required in order for proper JSON marshaling
// Required in order for proper JSON marshaling
...
...
dht/notif.go
View file @
6a37a454
...
@@ -3,7 +3,7 @@ package dht
...
@@ -3,7 +3,7 @@ package dht
import
(
import
(
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
inet
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/net"
inet
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/net"
)
)
// netNotifiee defines methods to be used with the IpfsDHT
// netNotifiee defines methods to be used with the IpfsDHT
...
...
dht/pb/message.go
View file @
6a37a454
...
@@ -4,9 +4,9 @@ import (
...
@@ -4,9 +4,9 @@ import (
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
inet
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/net"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
inet
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/net"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
)
)
var
log
=
logging
.
Logger
(
"dht.pb"
)
var
log
=
logging
.
Logger
(
"dht.pb"
)
...
...
dht/providers.go
View file @
6a37a454
...
@@ -6,7 +6,7 @@ import (
...
@@ -6,7 +6,7 @@ import (
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
goprocessctx
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess/context"
goprocessctx
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
...
...
dht/providers_test.go
View file @
6a37a454
...
@@ -4,7 +4,7 @@ import (
...
@@ -4,7 +4,7 @@ import (
"testing"
"testing"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
...
...
dht/query.go
View file @
6a37a454
...
@@ -9,9 +9,9 @@ import (
...
@@ -9,9 +9,9 @@ import (
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
pset
"github.com/ipfs/go-ipfs/util/peerset"
pset
"github.com/ipfs/go-ipfs/util/peerset"
todoctr
"github.com/ipfs/go-ipfs/util/todocounter"
todoctr
"github.com/ipfs/go-ipfs/util/todocounter"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
queue
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer/queue"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
queue
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer/queue"
process
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
process
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
ctxproc
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess/context"
ctxproc
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess/context"
...
...
dht/records.go
View file @
6a37a454
...
@@ -5,12 +5,12 @@ import (
...
@@ -5,12 +5,12 @@ import (
"time"
"time"
ctxfrac
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-context/frac"
ctxfrac
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-context/frac"
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
ci
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/crypto"
ci
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/crypto"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// MaxRecordAge specifies the maximum time that any node will hold onto a record
// MaxRecordAge specifies the maximum time that any node will hold onto a record
...
...
dht/routing.go
View file @
6a37a454
...
@@ -5,7 +5,6 @@ import (
...
@@ -5,7 +5,6 @@ import (
"sync"
"sync"
"time"
"time"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
notif
"github.com/ipfs/go-ipfs/notifications"
notif
"github.com/ipfs/go-ipfs/notifications"
"github.com/ipfs/go-ipfs/routing"
"github.com/ipfs/go-ipfs/routing"
...
@@ -13,8 +12,9 @@ import (
...
@@ -13,8 +12,9 @@ import (
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
pset
"github.com/ipfs/go-ipfs/util/peerset"
pset
"github.com/ipfs/go-ipfs/util/peerset"
inet
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/net"
inet
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/net"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// asyncQueryBuffer is the size of buffered channels in async queries. This
// asyncQueryBuffer is the size of buffered channels in async queries. This
...
...
kbucket/bucket.go
View file @
6a37a454
...
@@ -4,7 +4,7 @@ import (
...
@@ -4,7 +4,7 @@ import (
"container/list"
"container/list"
"sync"
"sync"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
// Bucket holds a list of peers.
// Bucket holds a list of peers.
...
...
kbucket/sorting.go
View file @
6a37a454
...
@@ -2,7 +2,7 @@ package kbucket
...
@@ -2,7 +2,7 @@ package kbucket
import
(
import
(
"container/list"
"container/list"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
"sort"
"sort"
)
)
...
...
kbucket/table.go
View file @
6a37a454
...
@@ -7,8 +7,8 @@ import (
...
@@ -7,8 +7,8 @@ import (
"sync"
"sync"
"time"
"time"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
)
)
var
log
=
logging
.
Logger
(
"table"
)
var
log
=
logging
.
Logger
(
"table"
)
...
...
kbucket/table_test.go
View file @
6a37a454
...
@@ -7,7 +7,7 @@ import (
...
@@ -7,7 +7,7 @@ import (
tu
"github.com/ipfs/go-ipfs/util/testutil"
tu
"github.com/ipfs/go-ipfs/util/testutil"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
// Test basic features of the bucket struct
// Test basic features of the bucket struct
...
...
kbucket/util.go
View file @
6a37a454
...
@@ -8,7 +8,7 @@ import (
...
@@ -8,7 +8,7 @@ import (
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
ks
"github.com/ipfs/go-ipfs/routing/keyspace"
ks
"github.com/ipfs/go-ipfs/routing/keyspace"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
// Returned if a routing table query returns no results. This is NOT expected
// Returned if a routing table query returns no results. This is NOT expected
...
...
mock/centralized_client.go
View file @
6a37a454
...
@@ -6,15 +6,15 @@ import (
...
@@ -6,15 +6,15 @@ import (
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
"github.com/ipfs/go-ipfs/util/testutil"
"github.com/ipfs/go-ipfs/util/testutil"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
ma
"gx/ipfs/QmR3JkmZBKYXgNMNsNZawm914455Qof3PEopwuVSeXG7aV/go-multiaddr"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
)
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
...
...
mock/centralized_server.go
View file @
6a37a454
...
@@ -6,10 +6,10 @@ import (
...
@@ -6,10 +6,10 @@ import (
"time"
"time"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
"github.com/ipfs/go-ipfs/util/testutil"
"github.com/ipfs/go-ipfs/util/testutil"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// 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 @
6a37a454
...
@@ -4,11 +4,11 @@ import (
...
@@ -4,11 +4,11 @@ import (
"testing"
"testing"
"time"
"time"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/util/testutil"
"github.com/ipfs/go-ipfs/util/testutil"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
func
TestKeyNotFound
(
t
*
testing
.
T
)
{
func
TestKeyNotFound
(
t
*
testing
.
T
)
{
...
...
mock/dht.go
View file @
6a37a454
...
@@ -3,10 +3,10 @@ package mockrouting
...
@@ -3,10 +3,10 @@ package mockrouting
import
(
import
(
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
sync
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore/sync"
sync
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore/sync"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
dht
"github.com/ipfs/go-ipfs/routing/dht"
dht
"github.com/ipfs/go-ipfs/routing/dht"
"github.com/ipfs/go-ipfs/util/testutil"
"github.com/ipfs/go-ipfs/util/testutil"
mocknet
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/net/mock"
mocknet
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/net/mock"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
type
mocknetserver
struct
{
type
mocknetserver
struct
{
...
...
mock/interface.go
View file @
6a37a454
...
@@ -6,12 +6,12 @@ package mockrouting
...
@@ -6,12 +6,12 @@ package mockrouting
import
(
import
(
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/util/testutil"
"github.com/ipfs/go-ipfs/util/testutil"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
// Server provides mockrouting Clients
// Server provides mockrouting Clients
...
...
none/none_client.go
View file @
6a37a454
...
@@ -3,13 +3,13 @@ package nilrouting
...
@@ -3,13 +3,13 @@ package nilrouting
import
(
import
(
"errors"
"errors"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
repo
"github.com/ipfs/go-ipfs/repo"
repo
"github.com/ipfs/go-ipfs/repo"
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
p2phost
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/host"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
p2phost
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/host"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
)
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
var
log
=
logging
.
Logger
(
"mockrouter"
)
...
...
offline/offline.go
View file @
6a37a454
...
@@ -6,14 +6,14 @@ import (
...
@@ -6,14 +6,14 @@ import (
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
proto
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/ipfs/go-datastore"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
ci
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/crypto"
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
ci
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/crypto"
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
)
)
var
log
=
logging
.
Logger
(
"offlinerouting"
)
var
log
=
logging
.
Logger
(
"offlinerouting"
)
...
...
record/record.go
View file @
6a37a454
...
@@ -7,8 +7,8 @@ import (
...
@@ -7,8 +7,8 @@ import (
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
ci
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/crypto"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
ci
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/crypto"
)
)
var
log
=
logging
.
Logger
(
"routing/record"
)
var
log
=
logging
.
Logger
(
"routing/record"
)
...
...
record/validation.go
View file @
6a37a454
...
@@ -8,7 +8,7 @@ import (
...
@@ -8,7 +8,7 @@ import (
path
"github.com/ipfs/go-ipfs/path"
path
"github.com/ipfs/go-ipfs/path"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
u
"github.com/ipfs/go-ipfs/util"
u
"github.com/ipfs/go-ipfs/util"
ci
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/crypto"
ci
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/crypto"
)
)
// ValidatorFunc is a function that is called to validate a given
// ValidatorFunc is a function that is called to validate a given
...
...
routing.go
View file @
6a37a454
...
@@ -5,8 +5,8 @@ import (
...
@@ -5,8 +5,8 @@ import (
"errors"
"errors"
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
ci
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/crypto"
ci
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/crypto"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
)
...
...
supernode/client.go
View file @
6a37a454
...
@@ -12,9 +12,9 @@ import (
...
@@ -12,9 +12,9 @@ import (
routing
"github.com/ipfs/go-ipfs/routing"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/host"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/host"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
)
)
var
log
=
logging
.
Logger
(
"supernode"
)
var
log
=
logging
.
Logger
(
"supernode"
)
...
...
supernode/proxy/loopback.go
View file @
6a37a454
...
@@ -5,8 +5,8 @@ import (
...
@@ -5,8 +5,8 @@ import (
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
inet
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/net"
inet
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/net"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
// RequestHandler handles routing requests locally
// RequestHandler handles routing requests locally
...
...
supernode/proxy/standard.go
View file @
6a37a454
...
@@ -9,10 +9,10 @@ import (
...
@@ -9,10 +9,10 @@ import (
key
"github.com/ipfs/go-ipfs/blocks/key"
key
"github.com/ipfs/go-ipfs/blocks/key"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
kbucket
"github.com/ipfs/go-ipfs/routing/kbucket"
kbucket
"github.com/ipfs/go-ipfs/routing/kbucket"
host
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/host"
inet
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/net"
peer
"gx/ipfs/QmZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq/go-libp2p/p2p/peer"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
logging
"gx/ipfs/QmaPaGNE2GqnfJjRRpQuQuFHuJn4FZvsrGxdik4kgxCkBi/go-log"
host
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/host"
inet
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/net"
peer
"gx/ipfs/QmY3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC/go-libp2p/p2p/peer"
)
)
const
ProtocolSNR
=
"/ipfs/supernoderouting"
const
ProtocolSNR
=
"/ipfs/supernoderouting"
...
...
supernode/server.go
View file @
6a37a454
...
@@ -12,7 +12,7 @@ import (
...
@@ -12,7 +12,7 @@ import (
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
record
"github.com/ipfs/go-ipfs/routing/record"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
peer
"gx/ipfs/Qm
Y3NAw959vbE1oJooP9HchcRdBsbxhgQsEZTRhKgvoSuC
/go-libp2p/p2p/peer"
peer
"gx/ipfs/Qm
ZxtCsPRgCnCXwVPUjcBiFckkG5NMYM4Pthwe6X4C8uQq
/go-libp2p/p2p/peer"
)
)
// Server handles routing queries using a database backend
// Server handles routing queries using a database backend
...
...
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