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
02c3d2c4
Commit
02c3d2c4
authored
Aug 16, 2017
by
Steven Allen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
extract update go-testutil
License: MIT Signed-off-by:
Steven Allen
<
steven@stebalien.com
>
parent
f62a67a1
Changes
12
Hide whitespace changes
Inline
Side-by-side
Showing
12 changed files
with
17 additions
and
17 deletions
+17
-17
mock/centralized_client.go
mock/centralized_client.go
+1
-1
mock/centralized_server.go
mock/centralized_server.go
+1
-1
mock/centralized_test.go
mock/centralized_test.go
+1
-1
mock/dht.go
mock/dht.go
+3
-3
mock/interface.go
mock/interface.go
+1
-1
none/none_client.go
none/none_client.go
+1
-1
offline/offline_test.go
offline/offline_test.go
+1
-1
supernode/client.go
supernode/client.go
+2
-2
supernode/proxy/loopback.go
supernode/proxy/loopback.go
+1
-1
supernode/proxy/standard.go
supernode/proxy/standard.go
+3
-3
supernode/server.go
supernode/server.go
+1
-1
supernode/server_test.go
supernode/server_test.go
+1
-1
No files found.
mock/centralized_client.go
View file @
02c3d2c4
...
...
@@ -6,7 +6,7 @@ import (
"time"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
"g
ithub.com/ipfs/go-ipfs/thirdparty/
testutil"
"g
x/ipfs/QmZJD56ZWLViJAVkvLc7xbbDerHzUMLr2X4fLRYfbxZWDN/go-
testutil"
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
routing
"gx/ipfs/QmPjTrrSfE6TzLv6ya6VWhGcCgPrUAdcgrDcQyRDX2VyW1/go-libp2p-routing"
...
...
mock/centralized_server.go
View file @
02c3d2c4
...
...
@@ -6,7 +6,7 @@ import (
"sync"
"time"
"g
ithub.com/ipfs/go-ipfs/thirdparty/
testutil"
"g
x/ipfs/QmZJD56ZWLViJAVkvLc7xbbDerHzUMLr2X4fLRYfbxZWDN/go-
testutil"
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
cid
"gx/ipfs/QmTprEaAA2A9bst5XH7exuyi5KzNMK3SEDNN8rBDnKWcUS/go-cid"
...
...
mock/centralized_test.go
View file @
02c3d2c4
...
...
@@ -6,7 +6,7 @@ import (
"time"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"g
ithub.com/ipfs/go-ipfs/thirdparty/
testutil"
"g
x/ipfs/QmZJD56ZWLViJAVkvLc7xbbDerHzUMLr2X4fLRYfbxZWDN/go-
testutil"
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
u
"gx/ipfs/QmSU6eubNdhXjFBJBSksTp8kv8YRub8mGAPv8tVJHmL2EU/go-ipfs-util"
...
...
mock/dht.go
View file @
02c3d2c4
...
...
@@ -2,11 +2,11 @@ package mockrouting
import
(
context
"context"
"github.com/ipfs/go-ipfs/thirdparty/testutil
"
dht
"gx/ipfs/QmSFNexSqAnJKGfDwKnGx2sGB1EtLwsNQ586u18UkVLjAy/go-libp2p-kad-dht
"
ds
"gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore"
sync
"gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore/sync"
mocknet
"gx/ipfs/Qm
ZPBrKq6S1fdYaRAzYZivJL12QkUqHwnNzF9wC8VXC4bo
/go-libp2p/p2p/net/mock"
dht
"gx/ipfs/Qm
cKxeQomXUjo54VwisTiXeic5FFBknwUPtT7yRWvmPD1D/go-libp2p-kad-dht
"
mocknet
"gx/ipfs/Qm
XZ6XetFwaDNmszPCux9DaKqMykEJGDtWHSqprn94UXzM
/go-libp2p/p2p/net/mock"
"gx/ipfs/Qm
ZJD56ZWLViJAVkvLc7xbbDerHzUMLr2X4fLRYfbxZWDN/go-testutil
"
)
type
mocknetserver
struct
{
...
...
mock/interface.go
View file @
02c3d2c4
...
...
@@ -8,7 +8,7 @@ import (
"context"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"g
ithub.com/ipfs/go-ipfs/thirdparty/
testutil"
"g
x/ipfs/QmZJD56ZWLViJAVkvLc7xbbDerHzUMLr2X4fLRYfbxZWDN/go-
testutil"
routing
"gx/ipfs/QmPjTrrSfE6TzLv6ya6VWhGcCgPrUAdcgrDcQyRDX2VyW1/go-libp2p-routing"
ds
"gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore"
...
...
none/none_client.go
View file @
02c3d2c4
...
...
@@ -8,8 +8,8 @@ import (
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
routing
"gx/ipfs/QmPjTrrSfE6TzLv6ya6VWhGcCgPrUAdcgrDcQyRDX2VyW1/go-libp2p-routing"
p2phost
"gx/ipfs/QmRNyPNJGNCaZyYonJj7owciWTsMd9gRfEKmZY3o6xwN3h/go-libp2p-host"
cid
"gx/ipfs/QmTprEaAA2A9bst5XH7exuyi5KzNMK3SEDNN8rBDnKWcUS/go-cid"
p2phost
"gx/ipfs/QmW8Rgju5JrSMHP7RDNdiwwXyenRqAbtSaPfdQKQC7ZdH6/go-libp2p-host"
peer
"gx/ipfs/QmXYjuNuxVzXKJCfWasQk1RqkhVLDM9jtUKhqc2WPQmFSB/go-libp2p-peer"
)
...
...
offline/offline_test.go
View file @
02c3d2c4
...
...
@@ -3,8 +3,8 @@ package offline
import
(
"bytes"
"context"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore"
"gx/ipfs/QmZJD56ZWLViJAVkvLc7xbbDerHzUMLr2X4fLRYfbxZWDN/go-testutil"
"testing"
)
...
...
supernode/client.go
View file @
02c3d2c4
...
...
@@ -10,14 +10,14 @@ import (
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
routing
"gx/ipfs/QmPjTrrSfE6TzLv6ya6VWhGcCgPrUAdcgrDcQyRDX2VyW1/go-libp2p-routing"
"gx/ipfs/Qm
RNyPNJGNCaZyYonJj7owciWTsMd9gRfEKmZY3o6xwN3h
/go-libp2p-
host
"
dhtpb
"gx/ipfs/Qm
SFNexSqAnJKGfDwKnGx2sGB1EtLwsNQ586u18UkVLjAy
/go-libp2p-
kad-dht/pb
"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
loggables
"gx/ipfs/QmT4PgCNdv73hnFAqzHqwW44q7M9PWpykSswHDxndquZbc/go-libp2p-loggables"
cid
"gx/ipfs/QmTprEaAA2A9bst5XH7exuyi5KzNMK3SEDNN8rBDnKWcUS/go-cid"
"gx/ipfs/QmW8Rgju5JrSMHP7RDNdiwwXyenRqAbtSaPfdQKQC7ZdH6/go-libp2p-host"
peer
"gx/ipfs/QmXYjuNuxVzXKJCfWasQk1RqkhVLDM9jtUKhqc2WPQmFSB/go-libp2p-peer"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
pb
"gx/ipfs/QmbxkgUceEcuSZ4ZdBA3x74VUDSSYjHYmmeEqkjxbtZ6Jg/go-libp2p-record/pb"
dhtpb
"gx/ipfs/QmcKxeQomXUjo54VwisTiXeic5FFBknwUPtT7yRWvmPD1D/go-libp2p-kad-dht/pb"
)
var
log
=
logging
.
Logger
(
"supernode"
)
...
...
supernode/proxy/loopback.go
View file @
02c3d2c4
...
...
@@ -2,10 +2,10 @@ package proxy
import
(
context
"context"
dhtpb
"gx/ipfs/QmSFNexSqAnJKGfDwKnGx2sGB1EtLwsNQ586u18UkVLjAy/go-libp2p-kad-dht/pb"
peer
"gx/ipfs/QmXYjuNuxVzXKJCfWasQk1RqkhVLDM9jtUKhqc2WPQmFSB/go-libp2p-peer"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
inet
"gx/ipfs/QmahYsGWry85Y7WUe2SX5G4JkH2zifEQAUtJVLZ24aC9DF/go-libp2p-net"
dhtpb
"gx/ipfs/QmcKxeQomXUjo54VwisTiXeic5FFBknwUPtT7yRWvmPD1D/go-libp2p-kad-dht/pb"
)
// RequestHandler handles routing requests locally
...
...
supernode/proxy/standard.go
View file @
02c3d2c4
...
...
@@ -5,14 +5,14 @@ import (
"errors"
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
host
"gx/ipfs/Qm
RNyPNJGNCaZyYonJj7owciWTsMd9gRfEKmZY3o6xwN3h
/go-libp2p-
host
"
dhtpb
"gx/ipfs/Qm
SFNexSqAnJKGfDwKnGx2sGB1EtLwsNQ586u18UkVLjAy
/go-libp2p-
kad-dht/pb
"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
loggables
"gx/ipfs/QmT4PgCNdv73hnFAqzHqwW44q7M9PWpykSswHDxndquZbc/go-libp2p-loggables"
kbucket
"gx/ipfs/QmVU26BGUSt3LkbWmoH7dP16mNz5VVRg4hDmWZBHAkq97w/go-libp2p-kbucket"
host
"gx/ipfs/QmW8Rgju5JrSMHP7RDNdiwwXyenRqAbtSaPfdQKQC7ZdH6/go-libp2p-host"
peer
"gx/ipfs/QmXYjuNuxVzXKJCfWasQk1RqkhVLDM9jtUKhqc2WPQmFSB/go-libp2p-peer"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
inet
"gx/ipfs/QmahYsGWry85Y7WUe2SX5G4JkH2zifEQAUtJVLZ24aC9DF/go-libp2p-net"
kbucket
"gx/ipfs/QmbiCMdwmmhif5axuGSHzYbPFGeKjLAuMY6JrGpVteHFsy/go-libp2p-kbucket"
dhtpb
"gx/ipfs/QmcKxeQomXUjo54VwisTiXeic5FFBknwUPtT7yRWvmPD1D/go-libp2p-kad-dht/pb"
)
const
ProtocolSNR
=
"/ipfs/supernoderouting"
...
...
supernode/server.go
View file @
02c3d2c4
...
...
@@ -9,11 +9,11 @@ import (
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
pstore
"gx/ipfs/QmPgDWmTmuzvP7QE5zwo1TmjbJme9pmZHNujB2453jkCTr/go-libp2p-peerstore"
dhtpb
"gx/ipfs/QmSFNexSqAnJKGfDwKnGx2sGB1EtLwsNQ586u18UkVLjAy/go-libp2p-kad-dht/pb"
datastore
"gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore"
peer
"gx/ipfs/QmXYjuNuxVzXKJCfWasQk1RqkhVLDM9jtUKhqc2WPQmFSB/go-libp2p-peer"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
pb
"gx/ipfs/QmbxkgUceEcuSZ4ZdBA3x74VUDSSYjHYmmeEqkjxbtZ6Jg/go-libp2p-record/pb"
dhtpb
"gx/ipfs/QmcKxeQomXUjo54VwisTiXeic5FFBknwUPtT7yRWvmPD1D/go-libp2p-kad-dht/pb"
)
// Server handles routing queries using a database backend
...
...
supernode/server_test.go
View file @
02c3d2c4
...
...
@@ -3,8 +3,8 @@ package supernode
import
(
"testing"
dhtpb
"gx/ipfs/QmSFNexSqAnJKGfDwKnGx2sGB1EtLwsNQ586u18UkVLjAy/go-libp2p-kad-dht/pb"
datastore
"gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore"
dhtpb
"gx/ipfs/QmcKxeQomXUjo54VwisTiXeic5FFBknwUPtT7yRWvmPD1D/go-libp2p-kad-dht/pb"
)
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