mirror of
https://github.com/libp2p/go-libp2p.git
synced 2025-10-21 15:19:38 +08:00
rewrote imports to p2p
This commit is contained in:
@@ -21,9 +21,9 @@ 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"
|
||||||
|
|
||||||
pb "github.com/ipfs/go-ipfs/p2p/crypto/pb"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
pb "github.com/ipfs/go-libp2p/p2p/crypto/pb"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("crypto")
|
var log = logging.Logger("crypto")
|
||||||
|
@@ -1,7 +1,7 @@
|
|||||||
package crypto_test
|
package crypto_test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
. "github.com/ipfs/go-ipfs/p2p/crypto"
|
. "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
|
||||||
"bytes"
|
"bytes"
|
||||||
tu "github.com/ipfs/go-ipfs/util/testutil"
|
tu "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
@@ -10,7 +10,7 @@ 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"
|
||||||
|
|
||||||
pb "github.com/ipfs/go-ipfs/p2p/crypto/pb"
|
pb "github.com/ipfs/go-libp2p/p2p/crypto/pb"
|
||||||
)
|
)
|
||||||
|
|
||||||
type RsaPrivateKey struct {
|
type RsaPrivateKey struct {
|
||||||
|
@@ -14,7 +14,7 @@ import (
|
|||||||
"hash"
|
"hash"
|
||||||
|
|
||||||
bfish "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/crypto/blowfish"
|
bfish "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/crypto/blowfish"
|
||||||
ci "github.com/ipfs/go-ipfs/p2p/crypto"
|
ci "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
)
|
)
|
||||||
|
|
||||||
// List of supported ECDH curves
|
// List of supported ECDH curves
|
||||||
|
@@ -4,11 +4,11 @@ package secio
|
|||||||
import (
|
import (
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
ci "github.com/ipfs/go-ipfs/p2p/crypto"
|
ci "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
|
||||||
msgio "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-msgio"
|
msgio "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-msgio"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// SessionGenerator constructs secure communication sessions for a peer.
|
// SessionGenerator constructs secure communication sessions for a peer.
|
||||||
|
@@ -11,11 +11,11 @@ import (
|
|||||||
|
|
||||||
msgio "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-msgio"
|
msgio "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-msgio"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
ci "github.com/ipfs/go-ipfs/p2p/crypto"
|
|
||||||
pb "github.com/ipfs/go-ipfs/p2p/crypto/secio/pb"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
ci "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
pb "github.com/ipfs/go-libp2p/p2p/crypto/secio/pb"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("secio")
|
var log = logging.Logger("secio")
|
||||||
|
@@ -13,9 +13,9 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
||||||
|
|
||||||
"github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
"github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
"github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
"github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("mdns")
|
var log = logging.Logger("mdns")
|
||||||
|
@@ -6,15 +6,15 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
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"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
mstream "github.com/ipfs/go-ipfs/metrics/stream"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
|
mstream "github.com/ipfs/go-libp2p/util/metrics/stream"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
identify "github.com/ipfs/go-ipfs/p2p/protocol/identify"
|
identify "github.com/ipfs/go-libp2p/p2p/protocol/identify"
|
||||||
relay "github.com/ipfs/go-ipfs/p2p/protocol/relay"
|
relay "github.com/ipfs/go-libp2p/p2p/protocol/relay"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("p2p/host/basic")
|
var log = logging.Logger("p2p/host/basic")
|
||||||
|
@@ -5,9 +5,9 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
testutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
testutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
)
|
)
|
||||||
|
@@ -7,9 +7,9 @@ import (
|
|||||||
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"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
|
||||||
inat "github.com/ipfs/go-ipfs/p2p/nat"
|
inat "github.com/ipfs/go-libp2p/p2p/nat"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
)
|
)
|
||||||
|
|
||||||
// natManager takes care of adding + removing port mappings to the nat.
|
// natManager takes care of adding + removing port mappings to the nat.
|
||||||
|
@@ -3,11 +3,11 @@ package host
|
|||||||
import (
|
import (
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("p2p/host")
|
var log = logging.Logger("p2p/host")
|
||||||
|
@@ -7,14 +7,14 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
|
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
routing "github.com/ipfs/go-ipfs/routing"
|
routing "github.com/ipfs/go-ipfs/routing"
|
||||||
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("p2p/host/routed")
|
var log = logging.Logger("p2p/host/routed")
|
||||||
|
@@ -11,11 +11,11 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("conn")
|
var log = logging.Logger("conn")
|
||||||
|
@@ -11,10 +11,10 @@ import (
|
|||||||
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
||||||
reuseport "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-reuseport"
|
reuseport "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-reuseport"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
|
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// String returns the string rep of d.
|
// String returns the string rep of d.
|
||||||
|
@@ -6,9 +6,9 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
key "github.com/ipfs/go-ipfs/blocks/key"
|
key "github.com/ipfs/go-ipfs/blocks/key"
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
filter "github.com/ipfs/go-ipfs/p2p/net/filter"
|
filter "github.com/ipfs/go-libp2p/p2p/net/filter"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
msgio "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-msgio"
|
msgio "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-msgio"
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
|
@@ -13,9 +13,9 @@ import (
|
|||||||
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"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
filter "github.com/ipfs/go-ipfs/p2p/net/filter"
|
filter "github.com/ipfs/go-libp2p/p2p/net/filter"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ConnWrapper is any function that wraps a raw multiaddr connection
|
// ConnWrapper is any function that wraps a raw multiaddr connection
|
||||||
|
@@ -8,9 +8,9 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
secio "github.com/ipfs/go-ipfs/p2p/crypto/secio"
|
secio "github.com/ipfs/go-libp2p/p2p/crypto/secio"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// secureConn wraps another Conn object with an encrypted channel.
|
// secureConn wraps another Conn object with an encrypted channel.
|
||||||
|
@@ -7,8 +7,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
|
||||||
travis "github.com/ipfs/go-ipfs/util/testutil/ci/travis"
|
travis "github.com/ipfs/go-ipfs/util/testutil/ci/travis"
|
||||||
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
)
|
)
|
||||||
|
@@ -3,8 +3,8 @@ package net
|
|||||||
import (
|
import (
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
conn "github.com/ipfs/go-ipfs/p2p/net/conn"
|
conn "github.com/ipfs/go-libp2p/p2p/net/conn"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
||||||
|
@@ -7,10 +7,10 @@
|
|||||||
package mocknet
|
package mocknet
|
||||||
|
|
||||||
import (
|
import (
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
"io"
|
"io"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
@@ -4,9 +4,9 @@ import (
|
|||||||
"container/list"
|
"container/list"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
)
|
)
|
||||||
|
@@ -6,8 +6,8 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// link implements mocknet.Link
|
// link implements mocknet.Link
|
||||||
|
@@ -5,13 +5,13 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
bhost "github.com/ipfs/go-ipfs/p2p/host/basic"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
p2putil "github.com/ipfs/go-ipfs/p2p/test/util"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
bhost "github.com/ipfs/go-libp2p/p2p/host/basic"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
p2putil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
||||||
|
@@ -6,8 +6,8 @@ import (
|
|||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestNotifications(t *testing.T) {
|
func TestNotifications(t *testing.T) {
|
||||||
|
@@ -5,8 +5,8 @@ import (
|
|||||||
"math/rand"
|
"math/rand"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
||||||
|
@@ -4,8 +4,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// separate object so our interfaces are separate :)
|
// separate object so our interfaces are separate :)
|
||||||
|
@@ -7,7 +7,7 @@ import (
|
|||||||
|
|
||||||
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"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
)
|
)
|
||||||
|
|
||||||
// stream implements inet.Stream
|
// stream implements inet.Stream
|
||||||
|
@@ -9,10 +9,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
|
||||||
detectrace "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-detect-race"
|
detectrace "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-detect-race"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -6,8 +6,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
ci "github.com/ipfs/go-ipfs/util/testutil/ci"
|
ci "github.com/ipfs/go-ipfs/util/testutil/ci"
|
||||||
|
@@ -3,7 +3,7 @@ package swarm
|
|||||||
import (
|
import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -5,8 +5,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
ci "github.com/ipfs/go-ipfs/util/testutil/ci"
|
ci "github.com/ipfs/go-ipfs/util/testutil/ci"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -7,12 +7,12 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
filter "github.com/ipfs/go-ipfs/p2p/net/filter"
|
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
filter "github.com/ipfs/go-libp2p/p2p/net/filter"
|
||||||
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
||||||
|
@@ -1,8 +1,8 @@
|
|||||||
package swarm
|
package swarm
|
||||||
|
|
||||||
import (
|
import (
|
||||||
conn "github.com/ipfs/go-ipfs/p2p/net/conn"
|
conn "github.com/ipfs/go-libp2p/p2p/net/conn"
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
)
|
)
|
||||||
|
@@ -3,10 +3,10 @@ package swarm
|
|||||||
import (
|
import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -3,10 +3,10 @@ package swarm
|
|||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
conn "github.com/ipfs/go-ipfs/p2p/net/conn"
|
conn "github.com/ipfs/go-libp2p/p2p/net/conn"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
||||||
|
@@ -8,11 +8,11 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
mconn "github.com/ipfs/go-ipfs/metrics/conn"
|
conn "github.com/ipfs/go-libp2p/p2p/net/conn"
|
||||||
conn "github.com/ipfs/go-ipfs/p2p/net/conn"
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
mconn "github.com/ipfs/go-libp2p/util/metrics/conn"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
||||||
|
@@ -3,11 +3,11 @@ package swarm
|
|||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
mconn "github.com/ipfs/go-ipfs/metrics/conn"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
conn "github.com/ipfs/go-libp2p/p2p/net/conn"
|
||||||
conn "github.com/ipfs/go-ipfs/p2p/net/conn"
|
addrutil "github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
|
||||||
addrutil "github.com/ipfs/go-ipfs/p2p/net/swarm/addr"
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
mconn "github.com/ipfs/go-libp2p/util/metrics/conn"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
manet "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr-net"
|
||||||
|
@@ -3,10 +3,10 @@ package swarm
|
|||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/goprocess"
|
||||||
|
@@ -6,8 +6,8 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
testutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
testutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TestConnectednessCorrect starts a few networks, connects a few
|
// TestConnectednessCorrect starts a few networks, connects a few
|
||||||
|
@@ -7,8 +7,8 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestNotifications(t *testing.T) {
|
func TestNotifications(t *testing.T) {
|
||||||
|
@@ -1,7 +1,7 @@
|
|||||||
package swarm
|
package swarm
|
||||||
|
|
||||||
import (
|
import (
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
|
||||||
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
||||||
)
|
)
|
||||||
|
@@ -9,10 +9,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -6,8 +6,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestLatencyEWMAFun(t *testing.T) {
|
func TestLatencyEWMAFun(t *testing.T) {
|
||||||
|
@@ -11,9 +11,9 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
mh "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multihash"
|
mh "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multihash"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("peer")
|
var log = logging.Logger("peer")
|
||||||
|
@@ -6,10 +6,10 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
|
||||||
. "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
tu "github.com/ipfs/go-ipfs/util/testutil"
|
tu "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
. "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
b58 "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-base58"
|
b58 "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-base58"
|
||||||
)
|
)
|
||||||
|
@@ -5,7 +5,7 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
|
|
||||||
ds "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-datastore"
|
ds "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-datastore"
|
||||||
dssync "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-datastore/sync"
|
dssync "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-datastore/sync"
|
||||||
|
@@ -6,8 +6,8 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
key "github.com/ipfs/go-ipfs/blocks/key"
|
key "github.com/ipfs/go-ipfs/blocks/key"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
ks "github.com/ipfs/go-ipfs/routing/keyspace"
|
ks "github.com/ipfs/go-ipfs/routing/keyspace"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
// peerMetric tracks a peer and its distance to something else.
|
// peerMetric tracks a peer and its distance to something else.
|
||||||
|
@@ -1,6 +1,6 @@
|
|||||||
package queue
|
package queue
|
||||||
|
|
||||||
import peer "github.com/ipfs/go-ipfs/p2p/peer"
|
import peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
// PeerQueue maintains a set of peers ordered according to a metric.
|
// PeerQueue maintains a set of peers ordered according to a metric.
|
||||||
// Implementations of PeerQueue could order peers based on distances along
|
// Implementations of PeerQueue could order peers based on distances along
|
||||||
|
@@ -7,8 +7,8 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
key "github.com/ipfs/go-ipfs/blocks/key"
|
key "github.com/ipfs/go-ipfs/blocks/key"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
)
|
)
|
||||||
|
@@ -2,8 +2,8 @@ package queue
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("peerqueue")
|
var log = logging.Logger("peerqueue")
|
||||||
|
@@ -9,15 +9,15 @@ import (
|
|||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
|
||||||
mstream "github.com/ipfs/go-ipfs/metrics/stream"
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
pb "github.com/ipfs/go-ipfs/p2p/protocol/identify/pb"
|
|
||||||
config "github.com/ipfs/go-ipfs/repo/config"
|
config "github.com/ipfs/go-ipfs/repo/config"
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
pb "github.com/ipfs/go-libp2p/p2p/protocol/identify/pb"
|
||||||
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
|
mstream "github.com/ipfs/go-libp2p/util/metrics/stream"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("net/identify")
|
var log = logging.Logger("net/identify")
|
||||||
|
@@ -4,10 +4,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
identify "github.com/ipfs/go-ipfs/p2p/protocol/identify"
|
identify "github.com/ipfs/go-libp2p/p2p/protocol/identify"
|
||||||
testutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
testutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -4,7 +4,7 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
)
|
)
|
||||||
|
@@ -6,9 +6,9 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
lgbl "github.com/ipfs/go-ipfs/util/eventlog/loggables"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
lgbl "github.com/ipfs/go-libp2p/util/eventlog/loggables"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("net/mux")
|
var log = logging.Logger("net/mux")
|
||||||
|
@@ -4,7 +4,7 @@ import (
|
|||||||
"bytes"
|
"bytes"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
)
|
)
|
||||||
|
|
||||||
var testCases = map[string]string{
|
var testCases = map[string]string{
|
||||||
|
@@ -8,11 +8,11 @@ import (
|
|||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("ping")
|
var log = logging.Logger("ping")
|
||||||
|
@@ -5,8 +5,8 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
netutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
netutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestPing(t *testing.T) {
|
func TestPing(t *testing.T) {
|
||||||
|
@@ -6,11 +6,11 @@ import (
|
|||||||
|
|
||||||
mh "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multihash"
|
mh "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multihash"
|
||||||
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
)
|
)
|
||||||
|
|
||||||
var log = logging.Logger("p2p/protocol/relay")
|
var log = logging.Logger("p2p/protocol/relay")
|
||||||
|
@@ -4,11 +4,11 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
relay "github.com/ipfs/go-ipfs/p2p/protocol/relay"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
relay "github.com/ipfs/go-libp2p/p2p/protocol/relay"
|
||||||
|
testutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
)
|
)
|
||||||
|
@@ -6,12 +6,12 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
testutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
|
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
|
@@ -7,13 +7,13 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
host "github.com/ipfs/go-ipfs/p2p/host"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
swarm "github.com/ipfs/go-ipfs/p2p/net/swarm"
|
|
||||||
protocol "github.com/ipfs/go-ipfs/p2p/protocol"
|
|
||||||
testutil "github.com/ipfs/go-ipfs/p2p/test/util"
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
host "github.com/ipfs/go-libp2p/p2p/host"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
swarm "github.com/ipfs/go-libp2p/p2p/net/swarm"
|
||||||
|
protocol "github.com/ipfs/go-libp2p/p2p/protocol"
|
||||||
|
testutil "github.com/ipfs/go-libp2p/p2p/test/util"
|
||||||
|
|
||||||
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
ps "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-peerstream"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
@@ -5,12 +5,12 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
|
||||||
u "github.com/ipfs/go-ipfs/util"
|
u "github.com/ipfs/go-ipfs/util"
|
||||||
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
testutil "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
logging "github.com/ipfs/go-ipfs/vendor/go-log-v1.0.0"
|
||||||
|
|
||||||
ic "github.com/ipfs/go-ipfs/p2p/crypto"
|
ic "github.com/ipfs/go-libp2p/p2p/crypto"
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
)
|
)
|
||||||
|
@@ -3,12 +3,12 @@ package testutil
|
|||||||
import (
|
import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
metrics "github.com/ipfs/go-ipfs/metrics"
|
|
||||||
bhost "github.com/ipfs/go-ipfs/p2p/host/basic"
|
|
||||||
inet "github.com/ipfs/go-ipfs/p2p/net"
|
|
||||||
swarm "github.com/ipfs/go-ipfs/p2p/net/swarm"
|
|
||||||
peer "github.com/ipfs/go-ipfs/p2p/peer"
|
|
||||||
tu "github.com/ipfs/go-ipfs/util/testutil"
|
tu "github.com/ipfs/go-ipfs/util/testutil"
|
||||||
|
bhost "github.com/ipfs/go-libp2p/p2p/host/basic"
|
||||||
|
inet "github.com/ipfs/go-libp2p/p2p/net"
|
||||||
|
swarm "github.com/ipfs/go-libp2p/p2p/net/swarm"
|
||||||
|
peer "github.com/ipfs/go-libp2p/p2p/peer"
|
||||||
|
metrics "github.com/ipfs/go-libp2p/util/metrics"
|
||||||
|
|
||||||
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
ma "github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multiaddr"
|
||||||
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
context "github.com/ipfs/go-ipfs/Godeps/_workspace/src/golang.org/x/net/context"
|
||||||
|
Reference in New Issue
Block a user