Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
Menu
Open sidebar
adam.huang
go-libp2p
Commits
b0ad2072
Commit
b0ad2072
authored
Apr 27, 2016
by
Jeromy
Browse files
rewrite all package paths to dvcs
parent
0d7301a7
Changes
65
Hide whitespace changes
Inline
Side-by-side
p2p/discovery/mdns.go
View file @
b0ad2072
...
@@ -9,12 +9,12 @@ import (
...
@@ -9,12 +9,12 @@ import (
"sync"
"sync"
"time"
"time"
"github.com/cryptix/mdns"
"github.com/ipfs/go-libp2p-peer"
"github.com/ipfs/go-libp2p/p2p/host"
"github.com/ipfs/go-libp2p/p2p/host"
"gx/ipfs/QmSscYPCcE1H3UQr2tnsJ2a9dK9LsHTBGgP71VW6fz67e5/mdns"
logging
"github.com/ipfs/go-log"
manet
"gx/ipfs/QmTrxSBY8Wqd5aBB4MeizeSzS5xFbK8dQBrYaMsiGnCBhb/go-multiaddr-net"
ma
"github.com/jbenet/go-multiaddr"
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
manet
"github.com/jbenet/go-multiaddr-net"
logging
"gx/ipfs/Qmazh5oNUVsDZTs2g59rq8aYQqwpss8tcUWQzor5sCCEuH/go-log"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
var
log
=
logging
.
Logger
(
"mdns"
)
var
log
=
logging
.
Logger
(
"mdns"
)
...
...
p2p/host/basic/basic_host.go
View file @
b0ad2072
...
@@ -3,19 +3,19 @@ package basichost
...
@@ -3,19 +3,19 @@ package basichost
import
(
import
(
"io"
"io"
peer
"github.com/ipfs/go-libp2p-peer"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
mstream
"github.com/ipfs/go-libp2p/p2p/metrics/stream"
mstream
"github.com/ipfs/go-libp2p/p2p/metrics/stream"
inet
"github.com/ipfs/go-libp2p/p2p/net"
inet
"github.com/ipfs/go-libp2p/p2p/net"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
identify
"github.com/ipfs/go-libp2p/p2p/protocol/identify"
identify
"github.com/ipfs/go-libp2p/p2p/protocol/identify"
relay
"github.com/ipfs/go-libp2p/p2p/protocol/relay"
relay
"github.com/ipfs/go-libp2p/p2p/protocol/relay"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
logging
"github.com/ipfs/go-log"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
goprocess
"github.com/jbenet/goprocess"
logging
"gx/ipfs/Qmazh5oNUVsDZTs2g59rq8aYQqwpss8tcUWQzor5sCCEuH/go-log"
context
"golang.org/x/net/context"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
msmux
"g
x/ipfs/QmUeEcYJrzAEKdQXjzTxCgNZgc9sRuwharsvzzm5Gd2oGB
/go-multistream"
msmux
"g
ithub.com/whyrusleeping
/go-multistream"
)
)
var
log
=
logging
.
Logger
(
"github.com/ipfs/go-libp2p/p2p/host/basic"
)
var
log
=
logging
.
Logger
(
"github.com/ipfs/go-libp2p/p2p/host/basic"
)
...
...
p2p/host/basic/basic_host_test.go
View file @
b0ad2072
...
@@ -9,7 +9,7 @@ import (
...
@@ -9,7 +9,7 @@ import (
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
testutil
"github.com/ipfs/go-libp2p/p2p/test/util"
testutil
"github.com/ipfs/go-libp2p/p2p/test/util"
context
"g
x/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-
net/context"
context
"g
olang.org/x/
net/context"
)
)
func
TestHostSimple
(
t
*
testing
.
T
)
{
func
TestHostSimple
(
t
*
testing
.
T
)
{
...
...
p2p/host/basic/natmgr.go
View file @
b0ad2072
...
@@ -3,12 +3,12 @@ package basichost
...
@@ -3,12 +3,12 @@ package basichost
import
(
import
(
"sync"
"sync"
lgbl
"github.com/ipfs/go-libp2p-loggables"
inat
"github.com/ipfs/go-libp2p/p2p/nat"
inat
"github.com/ipfs/go-libp2p/p2p/nat"
inet
"github.com/ipfs/go-libp2p/p2p/net"
inet
"github.com/ipfs/go-libp2p/p2p/net"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
ma
"github.com/jbenet/go-multiaddr"
lgbl
"gx/ipfs/QmYqiDbGUGqatbPFie11Py8cnyduoJYqcgKtjfhu1SQLh1/go-libp2p-loggables"
goprocess
"github.com/jbenet/goprocess"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
context
"golang.org/x/net/context"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
// natManager takes care of adding + removing port mappings to the nat.
// natManager takes care of adding + removing port mappings to the nat.
...
...
p2p/host/host.go
View file @
b0ad2072
package
host
package
host
import
(
import
(
peer
"github.com/ipfs/go-libp2p-peer"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
inet
"github.com/ipfs/go-libp2p/p2p/net"
inet
"github.com/ipfs/go-libp2p/p2p/net"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
msmux
"gx/ipfs/QmUeEcYJrzAEKdQXjzTxCgNZgc9sRuwharsvzzm5Gd2oGB/go-multistream"
logging
"github.com/ipfs/go-log"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
msmux
"github.com/whyrusleeping/go-multistream"
logging
"gx/ipfs/Qmazh5oNUVsDZTs2g59rq8aYQqwpss8tcUWQzor5sCCEuH/go-log"
context
"golang.org/x/net/context"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
var
log
=
logging
.
Logger
(
"github.com/ipfs/go-libp2p/p2p/host"
)
var
log
=
logging
.
Logger
(
"github.com/ipfs/go-libp2p/p2p/host"
)
...
...
p2p/host/routed/routed.go
View file @
b0ad2072
...
@@ -4,17 +4,17 @@ import (
...
@@ -4,17 +4,17 @@ import (
"fmt"
"fmt"
"time"
"time"
lgbl
"github.com/ipfs/go-libp2p-loggables"
peer
"github.com/ipfs/go-libp2p-peer"
host
"github.com/ipfs/go-libp2p/p2p/host"
host
"github.com/ipfs/go-libp2p/p2p/host"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
inet
"github.com/ipfs/go-libp2p/p2p/net"
inet
"github.com/ipfs/go-libp2p/p2p/net"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
lgbl
"gx/ipfs/QmYqiDbGUGqatbPFie11Py8cnyduoJYqcgKtjfhu1SQLh1/go-libp2p-loggables"
logging
"github.com/ipfs/go-log"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
context
"golang.org/x/net/context"
logging
"gx/ipfs/Qmazh5oNUVsDZTs2g59rq8aYQqwpss8tcUWQzor5sCCEuH/go-log"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
msmux
"g
x/ipfs/QmUeEcYJrzAEKdQXjzTxCgNZgc9sRuwharsvzzm5Gd2oGB
/go-multistream"
msmux
"g
ithub.com/whyrusleeping
/go-multistream"
)
)
var
log
=
logging
.
Logger
(
"github.com/ipfs/go-libp2p/p2p/host/routed"
)
var
log
=
logging
.
Logger
(
"github.com/ipfs/go-libp2p/p2p/host/routed"
)
...
...
p2p/metrics/bw_stats.go
View file @
b0ad2072
package
metrics
package
metrics
import
(
import
(
gm
"g
x/ipfs/QmeYJHEk8UjVVZ4XCRTZe6dFQrb8pGWD81LYCgeLp8CvMB
/go-metrics"
gm
"g
ithub.com/whyrusleeping
/go-metrics"
"sync"
"sync"
peer
"github.com/ipfs/go-libp2p-peer"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
)
)
type
Stats
struct
{
type
Stats
struct
{
...
...
p2p/metrics/conn/conn.go
View file @
b0ad2072
package
meterconn
package
meterconn
import
(
import
(
transport
"github.com/ipfs/go-libp2p-transport"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
transport
"gx/ipfs/QmRHqYZs3Diy8YC3bW16zvs8VDDwS2ARKBuKwALxEMqibc/go-libp2p-transport"
)
)
type
MeteredConn
struct
{
type
MeteredConn
struct
{
...
...
p2p/metrics/interface.go
View file @
b0ad2072
package
metrics
package
metrics
import
(
import
(
peer
"github.com/ipfs/go-libp2p-peer"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
)
)
type
StreamMeterCallback
func
(
int64
,
protocol
.
ID
,
peer
.
ID
)
type
StreamMeterCallback
func
(
int64
,
protocol
.
ID
,
peer
.
ID
)
...
...
p2p/metrics/stream/metered.go
View file @
b0ad2072
package
meterstream
package
meterstream
import
(
import
(
peer
"github.com/ipfs/go-libp2p-peer"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
metrics
"github.com/ipfs/go-libp2p/p2p/metrics"
inet
"github.com/ipfs/go-libp2p/p2p/net"
inet
"github.com/ipfs/go-libp2p/p2p/net"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
)
)
type
meteredStream
struct
{
type
meteredStream
struct
{
...
...
p2p/metrics/stream/metered_test.go
View file @
b0ad2072
...
@@ -5,10 +5,10 @@ import (
...
@@ -5,10 +5,10 @@ import (
"io/ioutil"
"io/ioutil"
"testing"
"testing"
randbo
"github.com/dustin/randbo"
peer
"github.com/ipfs/go-libp2p-peer"
inet
"github.com/ipfs/go-libp2p/p2p/net"
inet
"github.com/ipfs/go-libp2p/p2p/net"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
protocol
"github.com/ipfs/go-libp2p/p2p/protocol"
randbo
"gx/ipfs/QmYvsG72GsfLgUeSojXArjnU6L4Wmwk7wuAxtNLuyXcc1T/randbo"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
)
)
type
FakeStream
struct
{
type
FakeStream
struct
{
...
...
p2p/nat/nat.go
View file @
b0ad2072
...
@@ -8,13 +8,13 @@ import (
...
@@ -8,13 +8,13 @@ import (
"sync"
"sync"
"time"
"time"
nat
"g
x/ipfs/QmNLvkCDV6ZjUJsEwGNporYBuZdhWT6q7TBVYQwwRv12HT
/go-nat"
nat
"g
ithub.com/fd
/go-nat"
goprocess
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess
"
logging
"github.com/ipfs/go-log
"
periodic
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/periodic
"
ma
"github.com/jbenet/go-multiaddr
"
manet
"g
x/ipfs/QmTrxSBY8Wqd5aBB4MeizeSzS5xFbK8dQBrYaMsiGnCBhb
/go-multiaddr-net"
manet
"g
ithub.com/jbenet
/go-multiaddr-net"
logging
"gx/ipfs/Qmazh5oNUVsDZTs2g59rq8aYQqwpss8tcUWQzor5sCCEuH/go-log
"
goprocess
"github.com/jbenet/goprocess
"
notifier
"gx/ipfs/QmbcS9XrwZkF1rZj8bBwwzoYhVuA2PCnPhFUL1pyWGgt2A/go-notifier
"
periodic
"github.com/jbenet/goprocess/periodic
"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiadd
r"
notifier
"github.com/whyrusleeping/go-notifie
r"
)
)
var
(
var
(
...
...
p2p/net/conn/conn.go
View file @
b0ad2072
...
@@ -6,15 +6,15 @@ import (
...
@@ -6,15 +6,15 @@ import (
"net"
"net"
"time"
"time"
mpool
"gx/ipfs/QmRQhVisS8dmPbjBUthVkenn81pBxrx1GxE281csJhm2vL/go-msgio/mpoo
l"
u
"github.com/ipfs/go-ipfs-uti
l"
manet
"gx/ipfs/QmTrxSBY8Wqd5aBB4MeizeSzS5xFbK8dQBrYaMsiGnCBhb/go-multiaddr-net
"
ic
"github.com/ipfs/go-libp2p-crypto
"
ic
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY
/go-libp2p-
crypto
"
lgbl
"github.com/ipfs
/go-libp2p-
loggables
"
lgbl
"gx/ipfs/QmYqiDbGUGqatbPFie11Py8cnyduoJYqcgKtjfhu1SQLh1
/go-libp2p-
loggables
"
peer
"github.com/ipfs
/go-libp2p-
peer
"
u
"gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util
"
logging
"github.com/ipfs/go-log
"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer
"
mpool
"github.com/jbenet/go-msgio/mpool
"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context
"
ma
"github.com/jbenet/go-multiaddr
"
logging
"gx/ipfs/Qmazh5oNUVsDZTs2g59rq8aYQqwpss8tcUWQzor5sCCEuH/go-log
"
manet
"github.com/jbenet/go-multiaddr-net
"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr
"
context
"golang.org/x/net/context
"
)
)
var
log
=
logging
.
Logger
(
"conn"
)
var
log
=
logging
.
Logger
(
"conn"
)
...
...
p2p/net/conn/conn_test.go
View file @
b0ad2072
...
@@ -9,8 +9,8 @@ import (
...
@@ -9,8 +9,8 @@ import (
"time"
"time"
travis
"github.com/ipfs/go-libp2p/testutil/ci/travis"
travis
"github.com/ipfs/go-libp2p/testutil/ci/travis"
msgio
"g
x/ipfs/QmRQhVisS8dmPbjBUthVkenn81pBxrx1GxE281csJhm2vL
/go-msgio"
msgio
"g
ithub.com/jbenet
/go-msgio"
context
"g
x/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-
net/context"
context
"g
olang.org/x/
net/context"
)
)
func
msgioWrap
(
c
Conn
)
msgio
.
ReadWriter
{
func
msgioWrap
(
c
Conn
)
msgio
.
ReadWriter
{
...
...
p2p/net/conn/dial.go
View file @
b0ad2072
...
@@ -5,15 +5,15 @@ import (
...
@@ -5,15 +5,15 @@ import (
"math/rand"
"math/rand"
"strings"
"strings"
ci
"github.com/ipfs/go-libp2p-crypto"
lgbl
"github.com/ipfs/go-libp2p-loggables"
peer
"github.com/ipfs/go-libp2p-peer"
transport
"github.com/ipfs/go-libp2p-transport"
addrutil
"github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
addrutil
"github.com/ipfs/go-libp2p/p2p/net/swarm/addr"
transport
"gx/ipfs/QmRHqYZs3Diy8YC3bW16zvs8VDDwS2ARKBuKwALxEMqibc/go-libp2p-transport"
ma
"github.com/jbenet/go-multiaddr"
manet
"gx/ipfs/QmTrxSBY8Wqd5aBB4MeizeSzS5xFbK8dQBrYaMsiGnCBhb/go-multiaddr-net"
manet
"github.com/jbenet/go-multiaddr-net"
ci
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
msmux
"github.com/whyrusleeping/go-multistream"
msmux
"gx/ipfs/QmUeEcYJrzAEKdQXjzTxCgNZgc9sRuwharsvzzm5Gd2oGB/go-multistream"
context
"golang.org/x/net/context"
lgbl
"gx/ipfs/QmYqiDbGUGqatbPFie11Py8cnyduoJYqcgKtjfhu1SQLh1/go-libp2p-loggables"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
type
WrapFunc
func
(
transport
.
Conn
)
transport
.
Conn
type
WrapFunc
func
(
transport
.
Conn
)
transport
.
Conn
...
...
p2p/net/conn/dial_test.go
View file @
b0ad2072
...
@@ -11,15 +11,15 @@ import (
...
@@ -11,15 +11,15 @@ import (
"testing"
"testing"
"time"
"time"
ic
"github.com/ipfs/go-libp2p-crypto"
peer
"github.com/ipfs/go-libp2p-peer"
transport
"github.com/ipfs/go-libp2p-transport"
tu
"github.com/ipfs/go-libp2p/testutil"
tu
"github.com/ipfs/go-libp2p/testutil"
transport
"gx/ipfs/QmRHqYZs3Diy8YC3bW16zvs8VDDwS2ARKBuKwALxEMqibc/go-libp2p-transport"
ic
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
ma
"github.com/jbenet/go-multiaddr"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
msmux
"github.com/whyrusleeping/go-multistream"
grc
"github.com/whyrusleeping/gorocheck"
grc
"gx/ipfs/QmTd4Jgb4nbJq5uR55KJgGLyHWmM3dovS21D1HcwRneSLu/gorocheck"
context
"golang.org/x/net/context"
msmux
"gx/ipfs/QmUeEcYJrzAEKdQXjzTxCgNZgc9sRuwharsvzzm5Gd2oGB/go-multistream"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
func
goroFilter
(
r
*
grc
.
Goroutine
)
bool
{
func
goroFilter
(
r
*
grc
.
Goroutine
)
bool
{
...
...
p2p/net/conn/interface.go
View file @
b0ad2072
...
@@ -5,11 +5,11 @@ import (
...
@@ -5,11 +5,11 @@ import (
"net"
"net"
"time"
"time"
ic
"github.com/ipfs/go-libp2p-crypto"
peer
"github.com/ipfs/go-libp2p-peer"
transport
"github.com/ipfs/go-libp2p-transport"
filter
"github.com/ipfs/go-libp2p/p2p/net/filter"
filter
"github.com/ipfs/go-libp2p/p2p/net/filter"
transport
"gx/ipfs/QmRHqYZs3Diy8YC3bW16zvs8VDDwS2ARKBuKwALxEMqibc/go-libp2p-transport"
ma
"github.com/jbenet/go-multiaddr"
ic
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
type
PeerConn
interface
{
type
PeerConn
interface
{
...
...
p2p/net/conn/listen.go
View file @
b0ad2072
...
@@ -7,16 +7,16 @@ import (
...
@@ -7,16 +7,16 @@ import (
"sync"
"sync"
"time"
"time"
ic
"github.com/ipfs/go-libp2p-crypto"
peer
"github.com/ipfs/go-libp2p-peer"
transport
"github.com/ipfs/go-libp2p-transport"
filter
"github.com/ipfs/go-libp2p/p2p/net/filter"
filter
"github.com/ipfs/go-libp2p/p2p/net/filter"
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess"
ma
"github.com/jbenet/go-multiaddr"
goprocessctx
"gx/ipfs/QmQopLATEYMNg7dVqZRNDfeE2S1yKy8zrRh5xnYiuqeZBn/goprocess/context"
tec
"github.com/jbenet/go-temp-err-catcher"
transport
"gx/ipfs/QmRHqYZs3Diy8YC3bW16zvs8VDDwS2ARKBuKwALxEMqibc/go-libp2p-transport"
"github.com/jbenet/goprocess"
ic
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
goprocessctx
"github.com/jbenet/goprocess/context"
msmux
"gx/ipfs/QmUeEcYJrzAEKdQXjzTxCgNZgc9sRuwharsvzzm5Gd2oGB/go-multistream"
msmux
"github.com/whyrusleeping/go-multistream"
tec
"gx/ipfs/QmWHgLqrghM9zw77nF6gdvT9ExQ2RB9pLxkd8sDHZf1rWb/go-temp-err-catcher"
context
"golang.org/x/net/context"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt/go-libp2p-peer"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr"
)
)
const
(
const
(
...
...
p2p/net/conn/secure_conn.go
View file @
b0ad2072
...
@@ -5,11 +5,11 @@ import (
...
@@ -5,11 +5,11 @@ import (
"net"
"net"
"time"
"time"
secio
"gx/ipfs/QmPKuU1ohMDaJRJHmatXewCqjZp5wKrD3CK6m9TnCK6XBe
/go-libp2p-
seci
o"
ic
"github.com/ipfs
/go-libp2p-
crypt
o"
ic
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY
/go-libp2p-
crypto
"
peer
"github.com/ipfs
/go-libp2p-
peer
"
peer
"gx/ipfs/QmZwZjMVGss5rqYsJVGy18gNbkTJffFyq2x1uJ4e4p3ZAt
/go-libp2p-
peer
"
secio
"github.com/ipfs
/go-libp2p-
secio
"
context
"gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context
"
ma
"github.com/jbenet/go-multiaddr
"
ma
"gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr
"
context
"golang.org/x/net/context
"
)
)
// secureConn wraps another Conn object with an encrypted channel.
// secureConn wraps another Conn object with an encrypted channel.
...
...
p2p/net/conn/secure_conn_test.go
View file @
b0ad2072
...
@@ -7,10 +7,10 @@ import (
...
@@ -7,10 +7,10 @@ import (
"testing"
"testing"
"time"
"time"
ic
"github.com/ipfs/go-libp2p-crypto"
travis
"github.com/ipfs/go-libp2p/testutil/ci/travis"
travis
"github.com/ipfs/go-libp2p/testutil/ci/travis"
ic
"gx/ipfs/QmUEUu1CM8bxBJxc3ZLojAi8evhTr4byQogWstABet79oY/go-libp2p-crypto"
context
"g
x/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-
net/context"
context
"g
olang.org/x/
net/context"
)
)
func
upgradeToSecureConn
(
t
*
testing
.
T
,
ctx
context
.
Context
,
sk
ic
.
PrivKey
,
c
Conn
)
(
Conn
,
error
)
{
func
upgradeToSecureConn
(
t
*
testing
.
T
,
ctx
context
.
Context
,
sk
ic
.
PrivKey
,
c
Conn
)
(
Conn
,
error
)
{
...
...
Prev
1
2
3
4
Next
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