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
8a1163ab
Commit
8a1163ab
authored
Sep 09, 2016
by
George Antoniadis
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Extract key and datastore
License: MIT Signed-off-by:
George Antoniadis
<
george@noodles.gr
>
parent
233550e1
Changes
28
Hide whitespace changes
Inline
Side-by-side
Showing
28 changed files
with
53 additions
and
53 deletions
+53
-53
dht/dht.go
dht/dht.go
+4
-4
dht/dht_bootstrap.go
dht/dht_bootstrap.go
+2
-2
dht/dht_test.go
dht/dht_test.go
+3
-3
dht/ext_test.go
dht/ext_test.go
+3
-3
dht/handlers.go
dht/handlers.go
+2
-2
dht/lookup.go
dht/lookup.go
+1
-1
dht/pb/message.go
dht/pb/message.go
+1
-1
dht/providers/providers.go
dht/providers/providers.go
+6
-6
dht/providers/providers_test.go
dht/providers/providers_test.go
+2
-2
dht/query.go
dht/query.go
+3
-3
dht/routing.go
dht/routing.go
+1
-1
kbucket/util.go
kbucket/util.go
+1
-1
mock/centralized_client.go
mock/centralized_client.go
+2
-2
mock/centralized_server.go
mock/centralized_server.go
+3
-3
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
+1
-1
offline/offline.go
offline/offline.go
+2
-2
record/record.go
record/record.go
+1
-1
record/selection.go
record/selection.go
+1
-1
record/validation.go
record/validation.go
+1
-1
record/validation_test.go
record/validation_test.go
+1
-1
routing.go
routing.go
+1
-1
supernode/client.go
supernode/client.go
+1
-1
supernode/proxy/standard.go
supernode/proxy/standard.go
+1
-1
supernode/server.go
supernode/server.go
+2
-2
supernode/server_test.go
supernode/server_test.go
+2
-2
No files found.
dht/dht.go
View file @
8a1163ab
...
...
@@ -9,22 +9,22 @@ import (
"sync"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
providers
"github.com/ipfs/go-ipfs/routing/dht/providers"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
record
"github.com/ipfs/go-ipfs/routing/record"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
goprocessctx
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/context"
goprocess
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
goprocessctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
ci
"gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
host
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/host"
protocol
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/protocol"
)
...
...
dht/dht_bootstrap.go
View file @
8a1163ab
...
...
@@ -12,8 +12,8 @@ import (
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
goprocess
"gx/ipfs/Qm
QopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn
/goprocess"
periodicproc
"gx/ipfs/Qm
QopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn
/goprocess/periodic"
goprocess
"gx/ipfs/Qm
SF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP
/goprocess"
periodicproc
"gx/ipfs/Qm
SF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP
/goprocess/periodic"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
...
...
dht/dht_test.go
View file @
8a1163ab
...
...
@@ -9,13 +9,13 @@ import (
"testing"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
record
"github.com/ipfs/go-ipfs/routing/record"
ci
"github.com/ipfs/go-ipfs/thirdparty/testutil/ci"
travisci
"github.com/ipfs/go-ipfs/thirdparty/testutil/ci/travis"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
dssync
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore/sync"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
dssync
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/sync"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
...
...
dht/ext_test.go
View file @
8a1163ab
...
...
@@ -6,12 +6,12 @@ import (
"testing"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
dssync
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore/sync"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
dssync
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/sync"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
...
...
dht/handlers.go
View file @
8a1163ab
...
...
@@ -5,10 +5,10 @@ import (
"fmt"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
lgbl
"github.com/ipfs/go-ipfs/thirdparty/loggables"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
...
...
dht/lookup.go
View file @
8a1163ab
package
dht
import
(
key
"github.com/ipfs/go-ipfs/blocks/key"
notif
"github.com/ipfs/go-ipfs/notifications"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
pset
"github.com/ipfs/go-ipfs/thirdparty/peerset"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
...
...
dht/pb/message.go
View file @
8a1163ab
...
...
@@ -3,10 +3,10 @@ package dht_pb
import
(
ma
"gx/ipfs/QmYzDkkgAEmrcNzFCiYo6L1dTX4EAG1gZkbtdbd9trL4vd/go-multiaddr"
key
"github.com/ipfs/go-ipfs/blocks/key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
inet
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/net"
)
...
...
dht/providers/providers.go
View file @
8a1163ab
...
...
@@ -6,18 +6,18 @@ import (
"strings"
"time"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
dsq
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore/query"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
goprocessctx
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/context"
goprocess
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
goprocessctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
autobatch
"gx/ipfs/QmSp3diFRRv4zR25nHU4MWNCdhT4R6cxrTPLx12MCi1TZb/autobatch"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
lru
"gx/ipfs/QmVYxfoJQiZijTgPNHCHgHELvQpbsJNTg6Crmc3dQkj3yy/golang-lru"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
base32
"gx/ipfs/Qmb1DA2A9LS2wR4FFweB4uEDomFsdmnw1VLawLE1yQzudj/base32"
autobatch
"gx/ipfs/QmcRHLm2aqDabkpcto1NzLad7YQhH99MGDHSWWvwMxKiZw/autobatch"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
dsq
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/query"
key
"github.com/ipfs/go-ipfs/blocks/key"
flags
"github.com/ipfs/go-ipfs/flags"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
...
...
dht/providers/providers_test.go
View file @
8a1163ab
...
...
@@ -5,9 +5,9 @@ import (
"testing"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)
...
...
dht/query.go
View file @
8a1163ab
...
...
@@ -3,14 +3,14 @@ package dht
import
(
"sync"
key
"github.com/ipfs/go-ipfs/blocks/key"
notif
"github.com/ipfs/go-ipfs/notifications"
"github.com/ipfs/go-ipfs/routing"
pset
"github.com/ipfs/go-ipfs/thirdparty/peerset"
todoctr
"github.com/ipfs/go-ipfs/thirdparty/todocounter"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
process
"gx/ipfs/Qm
QopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn
/goprocess"
ctxproc
"gx/ipfs/Qm
QopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn
/goprocess/context"
process
"gx/ipfs/Qm
SF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP
/goprocess"
ctxproc
"gx/ipfs/Qm
SF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP
/goprocess/context"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
queue
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore/queue"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
...
...
dht/routing.go
View file @
8a1163ab
...
...
@@ -7,13 +7,13 @@ import (
"sync"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
notif
"github.com/ipfs/go-ipfs/notifications"
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
kb
"github.com/ipfs/go-ipfs/routing/kbucket"
record
"github.com/ipfs/go-ipfs/routing/record"
pset
"github.com/ipfs/go-ipfs/thirdparty/peerset"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
...
...
kbucket/util.go
View file @
8a1163ab
...
...
@@ -5,10 +5,10 @@ import (
"crypto/sha256"
"errors"
key
"github.com/ipfs/go-ipfs/blocks/key"
ks
"github.com/ipfs/go-ipfs/routing/keyspace"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
// Returned if a routing table query returns no results. This is NOT expected
...
...
mock/centralized_client.go
View file @
8a1163ab
...
...
@@ -4,11 +4,11 @@ import (
"errors"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
...
...
mock/centralized_server.go
View file @
8a1163ab
...
...
@@ -5,10 +5,10 @@ import (
"sync"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
dssync
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore/sync"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
dssync
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/sync"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
...
...
mock/centralized_test.go
View file @
8a1163ab
...
...
@@ -4,9 +4,9 @@ import (
"testing"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
...
...
mock/dht.go
View file @
8a1163ab
...
...
@@ -3,9 +3,9 @@ package mockrouting
import
(
dht
"github.com/ipfs/go-ipfs/routing/dht"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
sync
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore/sync"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
sync
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/sync"
mocknet
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/net/mock"
)
...
...
mock/interface.go
View file @
8a1163ab
...
...
@@ -5,14 +5,14 @@
package
mockrouting
import
(
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
// Server provides mockrouting Clients
...
...
none/none_client.go
View file @
8a1163ab
...
...
@@ -3,13 +3,13 @@ package nilrouting
import
(
"errors"
key
"github.com/ipfs/go-ipfs/blocks/key"
repo
"github.com/ipfs/go-ipfs/repo"
routing
"github.com/ipfs/go-ipfs/routing"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
p2phost
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/host"
)
...
...
offline/offline.go
View file @
8a1163ab
...
...
@@ -4,11 +4,11 @@ import (
"errors"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
ds
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
ds
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
...
...
record/record.go
View file @
8a1163ab
...
...
@@ -5,10 +5,10 @@ import (
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
key
"github.com/ipfs/go-ipfs/blocks/key"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
ci
"gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
var
log
=
logging
.
Logger
(
"routing/record"
)
...
...
record/selection.go
View file @
8a1163ab
...
...
@@ -3,8 +3,8 @@ package record
import
(
"errors"
key
"github.com/ipfs/go-ipfs/blocks/key"
path
"github.com/ipfs/go-ipfs/path"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
// A SelectorFunc selects the best value for the given key from
...
...
record/validation.go
View file @
8a1163ab
...
...
@@ -5,12 +5,12 @@ import (
"errors"
"fmt"
key
"github.com/ipfs/go-ipfs/blocks/key"
path
"github.com/ipfs/go-ipfs/path"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
ci
"gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto"
mh
"gx/ipfs/QmYf7ng2hG5XBtJA3tN34DQ2GUN5HNksEw1rLDkmr6vGku/go-multihash"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
// ValidatorFunc is a function that is called to validate a given
...
...
record/validation_test.go
View file @
8a1163ab
...
...
@@ -4,8 +4,8 @@ import (
"encoding/base64"
"testing"
key
"github.com/ipfs/go-ipfs/blocks/key"
ci
"gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
var
OffensiveKey
=
"CAASXjBcMA0GCSqGSIb3DQEBAQUAA0sAMEgCQQDjXAQQMal4SB2tSnX6NJIPmC69/BT8A8jc7/gDUZNkEhdhYHvc7k7S4vntV/c92nJGxNdop9fKJyevuNMuXhhHAgMBAAE="
...
...
routing.go
View file @
8a1163ab
...
...
@@ -4,11 +4,11 @@ package routing
import
(
"errors"
key
"github.com/ipfs/go-ipfs/blocks/key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
ci
"gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
// ErrNotFound is returned when a search fails to find anything
...
...
supernode/client.go
View file @
8a1163ab
...
...
@@ -5,11 +5,11 @@ import (
"errors"
"time"
key
"github.com/ipfs/go-ipfs/blocks/key"
routing
"github.com/ipfs/go-ipfs/routing"
pb
"github.com/ipfs/go-ipfs/routing/dht/pb"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
loggables
"github.com/ipfs/go-ipfs/thirdparty/loggables"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
...
...
supernode/proxy/standard.go
View file @
8a1163ab
...
...
@@ -12,10 +12,10 @@ import (
host
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/host"
inet
"gx/ipfs/Qmf4ETeAWXuThBfWwonVyFqGFSgTWepUDEr1txcctvpTXS/go-libp2p/p2p/net"
key
"github.com/ipfs/go-ipfs/blocks/key"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
kbucket
"github.com/ipfs/go-ipfs/routing/kbucket"
loggables
"github.com/ipfs/go-ipfs/thirdparty/loggables"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
const
ProtocolSNR
=
"/ipfs/supernoderouting"
...
...
supernode/server.go
View file @
8a1163ab
...
...
@@ -4,11 +4,11 @@ import (
"errors"
"fmt"
key
"github.com/ipfs/go-ipfs/blocks/key"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
record
"github.com/ipfs/go-ipfs/routing/record"
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
datastore
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
datastore
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
pstore
"gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
peer
"gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
...
...
supernode/server_test.go
View file @
8a1163ab
...
...
@@ -3,9 +3,9 @@ package supernode
import
(
"testing"
key
"github.com/ipfs/go-ipfs/blocks/key"
dhtpb
"github.com/ipfs/go-ipfs/routing/dht/pb"
datastore
"gx/ipfs/QmNgqJarToRiq2GBaPJhkmW4B5BxS5B74E1rkGvv2JoaTp/go-datastore"
datastore
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
key
"gx/ipfs/Qmce4Y4zg3sYr7xKM5UueS67vhNni6EeWgCRnb7MbLJMew/go-key"
)
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