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
10689ca6
Commit
10689ca6
authored
Oct 04, 2016
by
Jeromy Johnson
Committed by
GitHub
Oct 04, 2016
Browse files
Merge pull request #132 from libp2p/feat/update-deps-2
update deps
parents
7081c172
70872ff6
Changes
44
Show whitespace changes
Inline
Side-by-side
p2p/net/swarm/limiter.go
View file @
10689ca6
...
@@ -4,10 +4,10 @@ import (
...
@@ -4,10 +4,10 @@ import (
"context"
"context"
"sync"
"sync"
peer
"github.com/ipfs/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
addrutil
"github.com/libp2p/go-addr-util"
addrutil
"github.com/libp2p/go-addr-util"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
peer
"github.com/libp2p/go-libp2p-peer"
ma
"github.com/multiformats/go-multiaddr"
)
)
type
dialResult
struct
{
type
dialResult
struct
{
...
...
p2p/net/swarm/limiter_test.go
View file @
10689ca6
...
@@ -8,9 +8,9 @@ import (
...
@@ -8,9 +8,9 @@ import (
"testing"
"testing"
"time"
"time"
peer
"github.com/ipfs/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
peer
"github.com/libp2p/go-libp2p-peer"
ma
"github.com/multiformats/go-multiaddr"
mafmt
"github.com/whyrusleeping/mafmt"
mafmt
"github.com/whyrusleeping/mafmt"
)
)
...
...
p2p/net/swarm/peers_test.go
View file @
10689ca6
...
@@ -4,9 +4,9 @@ import (
...
@@ -4,9 +4,9 @@ import (
"testing"
"testing"
"context"
"context"
peer
"github.com/
ipfs
/go-libp2p-peer"
peer
"github.com/
libp2p
/go-libp2p-peer"
pstore
"github.com/
ipfs
/go-libp2p-peerstore"
pstore
"github.com/
libp2p
/go-libp2p-peerstore"
ma
"github.com/
jbenet
/go-multiaddr"
ma
"github.com/
multiformats
/go-multiaddr"
)
)
func
TestPeers
(
t
*
testing
.
T
)
{
func
TestPeers
(
t
*
testing
.
T
)
{
...
...
p2p/net/swarm/simul_test.go
View file @
10689ca6
...
@@ -7,10 +7,10 @@ import (
...
@@ -7,10 +7,10 @@ import (
"testing"
"testing"
"time"
"time"
peer
"github.com/ipfs/go-libp2p-peer"
peer
"github.com/libp2p/go-libp2p-peer"
pstore
"github.com/ipfs/go-libp2p-peerstore"
pstore
"github.com/libp2p/go-libp2p-peerstore"
ma
"github.com/jbenet/go-multiaddr"
ci
"github.com/libp2p/go-testutil/ci"
ci
"github.com/libp2p/go-testutil/ci"
ma
"github.com/multiformats/go-multiaddr"
)
)
func
TestSimultOpen
(
t
*
testing
.
T
)
{
func
TestSimultOpen
(
t
*
testing
.
T
)
{
...
...
p2p/net/swarm/swarm.go
View file @
10689ca6
...
@@ -11,23 +11,23 @@ import (
...
@@ -11,23 +11,23 @@ import (
"sync"
"sync"
"time"
"time"
ci
"github.com/ipfs/go-libp2p-crypto"
peer
"github.com/ipfs/go-libp2p-peer"
pstore
"github.com/ipfs/go-libp2p-peerstore"
logging
"github.com/ipfs/go-log"
logging
"github.com/ipfs/go-log"
ma
"github.com/jbenet/go-multiaddr"
ps
"github.com/jbenet/go-peerstream"
ps
"github.com/jbenet/go-peerstream"
pst
"github.com/jbenet/go-stream-muxer"
pst
"github.com/jbenet/go-stream-muxer"
"github.com/jbenet/goprocess"
"github.com/jbenet/goprocess"
goprocessctx
"github.com/jbenet/goprocess/context"
goprocessctx
"github.com/jbenet/goprocess/context"
addrutil
"github.com/libp2p/go-addr-util"
addrutil
"github.com/libp2p/go-addr-util"
conn
"github.com/libp2p/go-libp2p-conn"
conn
"github.com/libp2p/go-libp2p-conn"
ci
"github.com/libp2p/go-libp2p-crypto"
metrics
"github.com/libp2p/go-libp2p-metrics"
metrics
"github.com/libp2p/go-libp2p-metrics"
mconn
"github.com/libp2p/go-libp2p-metrics/conn"
mconn
"github.com/libp2p/go-libp2p-metrics/conn"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
pstore
"github.com/libp2p/go-libp2p-peerstore"
transport
"github.com/libp2p/go-libp2p-transport"
transport
"github.com/libp2p/go-libp2p-transport"
filter
"github.com/libp2p/go-maddr-filter"
filter
"github.com/libp2p/go-maddr-filter"
tcpt
"github.com/libp2p/go-tcp-transport"
tcpt
"github.com/libp2p/go-tcp-transport"
ma
"github.com/multiformats/go-multiaddr"
psmss
"github.com/whyrusleeping/go-smux-multistream"
psmss
"github.com/whyrusleeping/go-smux-multistream"
spdy
"github.com/whyrusleeping/go-smux-spdystream"
spdy
"github.com/whyrusleeping/go-smux-spdystream"
yamux
"github.com/whyrusleeping/go-smux-yamux"
yamux
"github.com/whyrusleeping/go-smux-yamux"
...
...
p2p/net/swarm/swarm_addr.go
View file @
10689ca6
package
swarm
package
swarm
import
(
import
(
ma
"github.com/jbenet/go-multiaddr"
addrutil
"github.com/libp2p/go-addr-util"
addrutil
"github.com/libp2p/go-addr-util"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
ma
"github.com/multiformats/go-multiaddr"
)
)
// ListenAddresses returns a list of addresses at which this swarm listens.
// ListenAddresses returns a list of addresses at which this swarm listens.
...
...
p2p/net/swarm/swarm_addr_test.go
View file @
10689ca6
...
@@ -4,11 +4,11 @@ import (
...
@@ -4,11 +4,11 @@ import (
"context"
"context"
"testing"
"testing"
pstore
"github.com/ipfs/go-libp2p-peerstore"
ma
"github.com/jbenet/go-multiaddr"
addrutil
"github.com/libp2p/go-addr-util"
addrutil
"github.com/libp2p/go-addr-util"
metrics
"github.com/libp2p/go-libp2p-metrics"
metrics
"github.com/libp2p/go-libp2p-metrics"
pstore
"github.com/libp2p/go-libp2p-peerstore"
testutil
"github.com/libp2p/go-testutil"
testutil
"github.com/libp2p/go-testutil"
ma
"github.com/multiformats/go-multiaddr"
)
)
func
TestFilterAddrs
(
t
*
testing
.
T
)
{
func
TestFilterAddrs
(
t
*
testing
.
T
)
{
...
...
p2p/net/swarm/swarm_conn.go
View file @
10689ca6
...
@@ -4,12 +4,12 @@ import (
...
@@ -4,12 +4,12 @@ import (
"context"
"context"
"fmt"
"fmt"
ic
"github.com/ipfs/go-libp2p-crypto"
peer
"github.com/ipfs/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
ps
"github.com/jbenet/go-peerstream"
ps
"github.com/jbenet/go-peerstream"
ic
"github.com/libp2p/go-libp2p-crypto"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
ma
"github.com/multiformats/go-multiaddr"
)
)
// Conn is a simple wrapper around a ps.Conn that also exposes
// Conn is a simple wrapper around a ps.Conn that also exposes
...
...
p2p/net/swarm/swarm_dial.go
View file @
10689ca6
...
@@ -7,11 +7,11 @@ import (
...
@@ -7,11 +7,11 @@ import (
"sync"
"sync"
"time"
"time"
lgbl
"github.com/ipfs/go-libp2p-loggables"
peer
"github.com/ipfs/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
addrutil
"github.com/libp2p/go-addr-util"
addrutil
"github.com/libp2p/go-addr-util"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
lgbl
"github.com/libp2p/go-libp2p-loggables"
peer
"github.com/libp2p/go-libp2p-peer"
ma
"github.com/multiformats/go-multiaddr"
)
)
// Diagram of dial sync:
// Diagram of dial sync:
...
...
p2p/net/swarm/swarm_listen.go
View file @
10689ca6
...
@@ -4,14 +4,14 @@ import (
...
@@ -4,14 +4,14 @@ import (
"context"
"context"
"fmt"
"fmt"
lgbl
"github.com/ipfs/go-libp2p-loggables"
ma
"github.com/jbenet/go-multiaddr"
ps
"github.com/jbenet/go-peerstream"
ps
"github.com/jbenet/go-peerstream"
conn
"github.com/libp2p/go-libp2p-conn"
conn
"github.com/libp2p/go-libp2p-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
iconn
"github.com/libp2p/go-libp2p-interface-conn"
lgbl
"github.com/libp2p/go-libp2p-loggables"
mconn
"github.com/libp2p/go-libp2p-metrics/conn"
mconn
"github.com/libp2p/go-libp2p-metrics/conn"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
transport
"github.com/libp2p/go-libp2p-transport"
transport
"github.com/libp2p/go-libp2p-transport"
ma
"github.com/multiformats/go-multiaddr"
)
)
func
(
s
*
Swarm
)
AddListenAddr
(
a
ma
.
Multiaddr
)
error
{
func
(
s
*
Swarm
)
AddListenAddr
(
a
ma
.
Multiaddr
)
error
{
...
...
p2p/net/swarm/swarm_net.go
View file @
10689ca6
...
@@ -4,12 +4,12 @@ import (
...
@@ -4,12 +4,12 @@ import (
"context"
"context"
"fmt"
"fmt"
peer
"github.com/ipfs/go-libp2p-peer"
pstore
"github.com/ipfs/go-libp2p-peerstore"
ma
"github.com/jbenet/go-multiaddr"
"github.com/jbenet/goprocess"
"github.com/jbenet/goprocess"
metrics
"github.com/libp2p/go-libp2p-metrics"
metrics
"github.com/libp2p/go-libp2p-metrics"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
pstore
"github.com/libp2p/go-libp2p-peerstore"
ma
"github.com/multiformats/go-multiaddr"
)
)
// Network implements the inet.Network interface.
// Network implements the inet.Network interface.
...
...
p2p/net/swarm/swarm_notif_test.go
View file @
10689ca6
...
@@ -5,9 +5,9 @@ import (
...
@@ -5,9 +5,9 @@ import (
"time"
"time"
"context"
"context"
peer
"github.com/ipfs/go-libp2p-peer"
ma
"github.com/jbenet/go-multiaddr"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
ma
"github.com/multiformats/go-multiaddr"
)
)
func
streamsSame
(
a
,
b
inet
.
Stream
)
bool
{
func
streamsSame
(
a
,
b
inet
.
Stream
)
bool
{
...
...
p2p/net/swarm/swarm_test.go
View file @
10689ca6
...
@@ -10,12 +10,12 @@ import (
...
@@ -10,12 +10,12 @@ import (
"testing"
"testing"
"time"
"time"
peer
"github.com/ipfs/go-libp2p-peer"
pstore
"github.com/ipfs/go-libp2p-peerstore"
ma
"github.com/jbenet/go-multiaddr"
metrics
"github.com/libp2p/go-libp2p-metrics"
metrics
"github.com/libp2p/go-libp2p-metrics"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
pstore
"github.com/libp2p/go-libp2p-peerstore"
testutil
"github.com/libp2p/go-testutil"
testutil
"github.com/libp2p/go-testutil"
ma
"github.com/multiformats/go-multiaddr"
)
)
func
EchoStreamHandler
(
stream
inet
.
Stream
)
{
func
EchoStreamHandler
(
stream
inet
.
Stream
)
{
...
...
p2p/protocol/identify/id.go
View file @
10689ca6
...
@@ -9,15 +9,15 @@ import (
...
@@ -9,15 +9,15 @@ import (
semver
"github.com/coreos/go-semver/semver"
semver
"github.com/coreos/go-semver/semver"
ggio
"github.com/gogo/protobuf/io"
ggio
"github.com/gogo/protobuf/io"
ic
"github.com/ipfs/go-libp2p-crypto"
lgbl
"github.com/ipfs/go-libp2p-loggables"
peer
"github.com/ipfs/go-libp2p-peer"
pstore
"github.com/ipfs/go-libp2p-peerstore"
logging
"github.com/ipfs/go-log"
logging
"github.com/ipfs/go-log"
ma
"github.com/
jbenet/go-multiaddr
"
ic
"github.com/
libp2p/go-libp2p-crypto
"
host
"github.com/libp2p/go-libp2p-host"
host
"github.com/libp2p/go-libp2p-host"
lgbl
"github.com/libp2p/go-libp2p-loggables"
mstream
"github.com/libp2p/go-libp2p-metrics/stream"
mstream
"github.com/libp2p/go-libp2p-metrics/stream"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
pstore
"github.com/libp2p/go-libp2p-peerstore"
ma
"github.com/multiformats/go-multiaddr"
msmux
"github.com/whyrusleeping/go-multistream"
msmux
"github.com/whyrusleeping/go-multistream"
)
)
...
...
p2p/protocol/identify/id_test.go
View file @
10689ca6
...
@@ -5,13 +5,13 @@ import (
...
@@ -5,13 +5,13 @@ import (
"testing"
"testing"
"time"
"time"
ic
"github.com/
ipfs
/go-libp2p-crypto"
ic
"github.com/
libp2p
/go-libp2p-crypto"
peer
"github.com/
ipfs
/go-libp2p-peer"
peer
"github.com/
libp2p
/go-libp2p-peer"
identify
"github.com/libp2p/go-libp2p/p2p/protocol/identify"
identify
"github.com/libp2p/go-libp2p/p2p/protocol/identify"
testutil
"github.com/libp2p/go-libp2p/p2p/test/util"
testutil
"github.com/libp2p/go-libp2p/p2p/test/util"
ma
"github.com/jbenet/go-multiaddr"
host
"github.com/libp2p/go-libp2p-host"
host
"github.com/libp2p/go-libp2p-host"
ma
"github.com/multiformats/go-multiaddr"
)
)
func
subtestIDService
(
t
*
testing
.
T
,
postDialWait
time
.
Duration
)
{
func
subtestIDService
(
t
*
testing
.
T
,
postDialWait
time
.
Duration
)
{
...
...
p2p/protocol/identify/obsaddr.go
View file @
10689ca6
...
@@ -4,8 +4,8 @@ import (
...
@@ -4,8 +4,8 @@ import (
"sync"
"sync"
"time"
"time"
pstore
"github.com/
ipfs
/go-libp2p-peerstore"
pstore
"github.com/
libp2p
/go-libp2p-peerstore"
ma
"github.com/
jbenet
/go-multiaddr"
ma
"github.com/
multiformats
/go-multiaddr"
)
)
// ObservedAddr is an entry for an address reported by our peers.
// ObservedAddr is an entry for an address reported by our peers.
...
...
p2p/protocol/identify/obsaddr_test.go
View file @
10689ca6
...
@@ -4,7 +4,7 @@ import (
...
@@ -4,7 +4,7 @@ import (
"testing"
"testing"
"time"
"time"
ma
"github.com/
jbenet
/go-multiaddr"
ma
"github.com/
multiformats
/go-multiaddr"
)
)
// TestObsAddrSet
// TestObsAddrSet
...
...
p2p/protocol/ping/ping.go
View file @
10689ca6
...
@@ -8,10 +8,10 @@ import (
...
@@ -8,10 +8,10 @@ import (
"time"
"time"
u
"github.com/ipfs/go-ipfs-util"
u
"github.com/ipfs/go-ipfs-util"
peer
"github.com/ipfs/go-libp2p-peer"
logging
"github.com/ipfs/go-log"
logging
"github.com/ipfs/go-log"
host
"github.com/libp2p/go-libp2p-host"
host
"github.com/libp2p/go-libp2p-host"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
)
)
var
log
=
logging
.
Logger
(
"ping"
)
var
log
=
logging
.
Logger
(
"ping"
)
...
...
p2p/protocol/ping/ping_test.go
View file @
10689ca6
...
@@ -7,8 +7,8 @@ import (
...
@@ -7,8 +7,8 @@ import (
netutil
"github.com/libp2p/go-libp2p/p2p/test/util"
netutil
"github.com/libp2p/go-libp2p/p2p/test/util"
"context"
"context"
peer
"github.com/
ipfs
/go-libp2p-peer"
peer
"github.com/
libp2p
/go-libp2p-peer"
pstore
"github.com/
ipfs
/go-libp2p-peerstore"
pstore
"github.com/
libp2p
/go-libp2p-peerstore"
)
)
func
TestPing
(
t
*
testing
.
T
)
{
func
TestPing
(
t
*
testing
.
T
)
{
...
...
p2p/protocol/relay/relay.go
View file @
10689ca6
...
@@ -8,10 +8,10 @@ import (
...
@@ -8,10 +8,10 @@ import (
host
"github.com/libp2p/go-libp2p-host"
host
"github.com/libp2p/go-libp2p-host"
peer
"github.com/ipfs/go-libp2p-peer"
logging
"github.com/ipfs/go-log"
logging
"github.com/ipfs/go-log"
mh
"github.com/jbenet/go-multihash"
mh
"github.com/jbenet/go-multihash"
inet
"github.com/libp2p/go-libp2p-net"
inet
"github.com/libp2p/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer"
protocol
"github.com/libp2p/go-libp2p-protocol"
protocol
"github.com/libp2p/go-libp2p-protocol"
)
)
...
...
Prev
1
2
3
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