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
p2p
go-p2p-swarm
Commits
2e26ef20
Commit
2e26ef20
authored
Feb 03, 2017
by
Jeromy
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
gx publish 1.6.8
parent
64a2e447
Changes
20
Hide whitespace changes
Inline
Side-by-side
Showing
20 changed files
with
104 additions
and
104 deletions
+104
-104
.gx/lastpubver
.gx/lastpubver
+1
-1
dial_sync.go
dial_sync.go
+1
-1
dial_sync_test.go
dial_sync_test.go
+1
-1
dial_test.go
dial_test.go
+7
-7
limiter.go
limiter.go
+4
-4
limiter_test.go
limiter_test.go
+4
-4
package.json
package.json
+6
-6
peers_test.go
peers_test.go
+3
-3
simul_test.go
simul_test.go
+4
-4
swarm.go
swarm.go
+23
-23
swarm_addr.go
swarm_addr.go
+3
-3
swarm_addr_test.go
swarm_addr_test.go
+5
-5
swarm_conn.go
swarm_conn.go
+6
-6
swarm_dial.go
swarm_dial.go
+5
-5
swarm_listen.go
swarm_listen.go
+8
-8
swarm_net.go
swarm_net.go
+7
-7
swarm_net_test.go
swarm_net_test.go
+4
-4
swarm_notif_test.go
swarm_notif_test.go
+3
-3
swarm_stream.go
swarm_stream.go
+3
-3
swarm_test.go
swarm_test.go
+6
-6
No files found.
.gx/lastpubver
View file @
2e26ef20
1.6.
7
: Qm
QsvGjndzoDPYYdFkiFhxCdKmSrvhwfigPaNfHuDoytgU
1.6.
8
: Qm
ULAo6HNy44a42EFu4XAYGijM8LXoKu44FKxWvCgTJvhG
dial_sync.go
View file @
2e26ef20
...
...
@@ -4,7 +4,7 @@ import (
"context"
"sync"
peer
"g
ithub.com/libp2p
/go-libp2p-peer"
peer
"g
x/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe
/go-libp2p-peer"
)
type
DialFunc
func
(
context
.
Context
,
peer
.
ID
)
(
*
Conn
,
error
)
...
...
dial_sync_test.go
View file @
2e26ef20
...
...
@@ -7,7 +7,7 @@ import (
"testing"
"time"
peer
"g
ithub.com/libp2p
/go-libp2p-peer"
peer
"g
x/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe
/go-libp2p-peer"
)
func
getMockDialFunc
()
(
DialFunc
,
func
(),
context
.
Context
,
<-
chan
struct
{})
{
...
...
dial_test.go
View file @
2e26ef20
...
...
@@ -7,13 +7,13 @@ import (
"testing"
"time"
addrutil
"github.com/libp2p/go-addr-util
"
peer
"github.com/libp2p/go-libp2p-peer
"
pstore
"github.com/libp2p/go-libp2p-peerstore
"
testutil
"github.com/libp2p/go-testutil
"
ci
"github.com/libp2p
/go-testutil
/ci
"
ma
"g
ithub.com/multiformats/go-multiaddr
"
manet
"github.com/multiformats/go-multiaddr-net
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
manet
"gx/ipfs/QmVCNGTyD4EkvNYaAp253uMQ9Rjsjy2oGMvcdJJUoVRfja/go-multiaddr-net
"
addrutil
"gx/ipfs/Qmb86KiitngVm5AGQ18viwCBwwcTvULAtz3X74YWKAevnc/go-addr-util
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-peer
"
testutil
"gx/ipfs/QmbN6CcaGuVSWwhYq5nDQs98hWHgu5PTBgVjnGV28YeGRk
/go-testutil"
ci
"g
x/ipfs/QmbN6CcaGuVSWwhYq5nDQs98hWHgu5PTBgVjnGV28YeGRk/go-testutil/ci
"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
func
closeSwarms
(
swarms
[]
*
Swarm
)
{
...
...
limiter.go
View file @
2e26ef20
...
...
@@ -4,10 +4,10 @@ import (
"context"
"sync"
addrutil
"github.com/libp2p/go-addr-util
"
iconn
"github.com/libp2p/go-libp2p-interface-conn
"
peer
"github.com/libp2p/go-libp2p-peer
"
ma
"github.com/multiformats/go-multiadd
r"
iconn
"gx/ipfs/QmNmKcQiJB5cUTXXXS1o44s4PdeYevmH8aHhQJCGYjwBj3/go-libp2p-interface-conn
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
addrutil
"gx/ipfs/Qmb86KiitngVm5AGQ18viwCBwwcTvULAtz3X74YWKAevnc/go-addr-util
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-pee
r"
)
type
dialResult
struct
{
...
...
limiter_test.go
View file @
2e26ef20
...
...
@@ -9,10 +9,10 @@ import (
"testing"
"time"
iconn
"g
ithub.com/libp2p
/go-libp2p-interface-conn"
peer
"github.com/libp2p/go-libp2p-pee
r"
ma
"github.com/multiformats/go-multiaddr
"
mafmt
"github.com/whyrusleeping/mafmt
"
iconn
"g
x/ipfs/QmNmKcQiJB5cUTXXXS1o44s4PdeYevmH8aHhQJCGYjwBj3
/go-libp2p-interface-conn"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiadd
r"
ma
fmt
"gx/ipfs/QmYjJnSTfXWhYL2cV1xFphPqjqowJqH7ZKLA1As8QrPHbn/mafmt
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-peer
"
)
func
mustAddr
(
t
*
testing
.
T
,
s
string
)
ma
.
Multiaddr
{
...
...
package.json
View file @
2e26ef20
...
...
@@ -9,7 +9,7 @@
"gxDependencies"
:
[
{
"author"
:
"whyrusleeping"
,
"hash"
:
"Qm
PjQZJQBByepHmxM7u9vqPyjno4RQrdKU1Q92tvdkWzCx
"
,
"hash"
:
"Qm
TWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
"
,
"name"
:
"go-libp2p-net"
,
"version"
:
"1.6.1"
},
...
...
@@ -21,7 +21,7 @@
},
{
"author"
:
"whyrusleeping"
,
"hash"
:
"Qm
U8iiXVwobZ366qAezD62VDxxnUe9Ss7K2skzYs7vy73B
"
,
"hash"
:
"Qm
ekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf
"
,
"name"
:
"go-libp2p-peerstore"
,
"version"
:
"1.4.0"
},
...
...
@@ -75,19 +75,19 @@
},
{
"author"
:
"whyrusleeping"
,
"hash"
:
"Qm
QekK8Xb2Sya6bwXcidYG7CnDubAY4nt7EY1rSoAzgFir
"
,
"hash"
:
"Qm
PfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm
"
,
"name"
:
"go-libp2p-metrics"
,
"version"
:
"1.6.1"
},
{
"author"
:
"whyrusleeping"
,
"hash"
:
"Qm
WQs2ipc93aQ6LfU5PXfKapWXouQqagoFyjpUzXW84Y2X
"
,
"hash"
:
"Qm
f8Br5gq5XgMrSA6Y6dzY3kaBWwJu6aqXJxxuxCCKsbyD
"
,
"name"
:
"go-libp2p-conn"
,
"version"
:
"1.5.6"
},
{
"author"
:
"whyrusleeping"
,
"hash"
:
"Qm
W1qqxEMaDhpk26mDc9pKygbwwnfYWYweAAJnDmV5q8tE
"
,
"hash"
:
"Qm
XJfmGL3GycHcuqft7vvhf6Xhzad6nuTiEnoEWwAv3zcd
"
,
"name"
:
"go-tcp-transport"
,
"version"
:
"1.1.0"
}
...
...
@@ -97,6 +97,6 @@
"license"
:
""
,
"name"
:
"go-libp2p-swarm"
,
"releaseCmd"
:
"git commit -a -m
\"
gx publish $VERSION
\"
"
,
"version"
:
"1.6.
7
"
"version"
:
"1.6.
8
"
}
peers_test.go
View file @
2e26ef20
...
...
@@ -4,9 +4,9 @@ import (
"testing"
"context"
peer
"github.com/libp2p/go-libp2p-pee
r"
p
store
"github.com/libp2p
/go-libp2p-peer
store
"
ma
"github.com/multiformats/go-multiaddr
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiadd
r"
p
eer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe
/go-libp2p-peer"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
func
TestPeers
(
t
*
testing
.
T
)
{
...
...
simul_test.go
View file @
2e26ef20
...
...
@@ -7,10 +7,10 @@ import (
"testing"
"time"
peer
"github.com/libp2p/go-libp2p-pee
r"
p
store
"github.com/libp2p
/go-libp2p-peer
store
"
ci
"g
ithub.com/libp2p
/go-testutil/ci"
ma
"github.com/multiformats/go-multiaddr
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiadd
r"
p
eer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe
/go-libp2p-peer"
ci
"g
x/ipfs/QmbN6CcaGuVSWwhYq5nDQs98hWHgu5PTBgVjnGV28YeGRk
/go-testutil/ci"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
func
TestSimultOpen
(
t
*
testing
.
T
)
{
...
...
swarm.go
View file @
2e26ef20
...
...
@@ -11,29 +11,29 @@ import (
"sync"
"time"
logging
"github.com/ipfs/go-log
"
pst
"github.com/jbenet/go-stream-muxer
"
"github.com/jbenet/goprocess
"
goprocessctx
"github.com/jbenet/goprocess/context
"
addrutil
"github.com/libp2p/go-addr-util
"
conn
"github.com/libp2p/go-libp2p-conn
"
ci
"github.com/libp2p/go-libp2p-crypto
"
ipnet
"github.com/libp2p/go-libp2p-interface-pnet
"
metrics
"github.com/libp2p/go-libp2p-metrics
"
mconn
"github.com/libp2p/go-libp2p-metrics/conn
"
inet
"g
ithub.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-transpor
t"
filter
"github.com/libp2p/go-maddr-filter
"
ps
"github.com/libp2p/go-peerstream
"
tcpt
"github.com/libp2p/go-tcp-transport
"
ma
"github.com/multiformats/go-multiadd
r"
psmss
"github.com/whyrusleeping/go-smux-multistream
"
spdy
"github.com/whyrusleeping/go-smux-spdystream
"
yamux
"github.com/whyrusleeping/go-smux-ya
mux"
mafilter
"github.com/whyrusleeping/multiaddr-filter
"
ws
"github.com/whyrusleeping/ws-transport
"
metrics
"gx/ipfs/QmPfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm/go-libp2p-metrics
"
mconn
"gx/ipfs/QmPfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm/go-libp2p-metrics/conn
"
transport
"gx/ipfs/QmR4YrM1DdvYmox249o8aday8oiotkcsT1Qzv42ujPEQDb/go-libp2p-transport
"
psmss
"gx/ipfs/QmRVYfZ7tWNHPBzWiG6KWGzvT2hcGems8srihsQE29x1U5/go-smux-multistream
"
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess
"
goprocessctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context
"
mafilter
"gx/ipfs/QmSMZwvs3n4GBikZ7hKzT17c3bk65FmyZo2JqtJ16swqCv/multiaddr-filter
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log
"
ps
"gx/ipfs/QmSxPTJ2Jb3nekq3AGMgDyXZR3dhPrSPVSggT3FqJWw4Sa/go-peerstream
"
inet
"g
x/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-net"
ci
"gx/ipfs/QmTuX6VtWTbWgPwd5PMXHyp411RKsW5nBqLKVVRfJMNneb
/go-libp2p-
crypto
"
filter
"gx/ipfs/QmUuCcuet4eneEzto6PxvoC1MrHcxszy7MALrWSKH9inLy/go-maddr-filter
"
ipnet
"gx/ipfs/QmWNwP8oYzPUK6LqYEH1hoTMuVmQUUbhKQgHeT1AENGkEm/go-libp2p-interface-pne
t"
spdy
"gx/ipfs/QmWUNsat6Jb19nC5CiJCDXepTkxjdxi3eZqeoB6mrmmaGu/go-smux-spdystream
"
tcpt
"gx/ipfs/QmXJfmGL3GycHcuqft7vvhf6Xhzad6nuTiEnoEWwAv3zcd/go-tcp-transport
"
addrutil
"gx/ipfs/Qmb86KiitngVm5AGQ18viwCBwwcTvULAtz3X74YWKAevnc/go-addr-util
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-pee
r"
yamux
"gx/ipfs/Qmbn7RYyWzBVXiUp9jZ1dA4VADHy9DtS7iZLwfhEUQvm3U/go-smux-yamux
"
ws
"gx/ipfs/QmeHbitozRtLYuPrtpcAoJFJixZzTctPtkSsBQGSQuz8pG/ws-transport
"
pst
"gx/ipfs/QmeZBgYBHvxMukGK5ojg28BCNLB9SeXqT7XXg6o7r2GbJy/go-stream-
mux
er
"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
conn
"gx/ipfs/Qmf8Br5gq5XgMrSA6Y6dzY3kaBWwJu6aqXJxxuxCCKsbyD/go-libp2p-conn
"
)
var
log
=
logging
.
Logger
(
"swarm2"
)
...
...
swarm_addr.go
View file @
2e26ef20
package
swarm
import
(
addrutil
"github.com/libp2p/go-addr-util
"
iconn
"github.com/libp2p/go-libp2p-interface-conn
"
ma
"github.com/multiformats/go-multiaddr
"
iconn
"gx/ipfs/QmNmKcQiJB5cUTXXXS1o44s4PdeYevmH8aHhQJCGYjwBj3/go-libp2p-interface-conn
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
addrutil
"gx/ipfs/Qmb86KiitngVm5AGQ18viwCBwwcTvULAtz3X74YWKAevnc/go-addr-util
"
)
// ListenAddresses returns a list of addresses at which this swarm listens.
...
...
swarm_addr_test.go
View file @
2e26ef20
...
...
@@ -4,11 +4,11 @@ import (
"context"
"testing"
addrutil
"github.com/libp2p/go-addr-util
"
m
etrics
"github.com/libp2p/go-libp2p-metrics
"
pstore
"github.com/libp2p/go-libp2p-peerstore
"
testutil
"g
ithub.com/libp2p
/go-testutil"
ma
"github.com/multiformats/go-multiaddr
"
metrics
"gx/ipfs/QmPfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm/go-libp2p-metrics
"
m
a
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
addrutil
"gx/ipfs/Qmb86KiitngVm5AGQ18viwCBwwcTvULAtz3X74YWKAevnc/go-addr-util
"
testutil
"g
x/ipfs/QmbN6CcaGuVSWwhYq5nDQs98hWHgu5PTBgVjnGV28YeGRk
/go-testutil"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
func
TestFilterAddrs
(
t
*
testing
.
T
)
{
...
...
swarm_conn.go
View file @
2e26ef20
...
...
@@ -4,12 +4,12 @@ import (
"context"
"fmt"
ic
"github.com/libp2p/go-libp2p-crypto
"
iconn
"github.com/libp2p/go-libp2p-interface-conn
"
inet
"github.com/libp2p/go-libp2p-net
"
peer
"github.com/libp2p
/go-libp2p-
peer
"
ps
"g
ithub.com/libp2p/go-peerstream
"
ma
"github.com/multiformats/go-multiadd
r"
ic
onn
"gx/ipfs/QmNmKcQiJB5cUTXXXS1o44s4PdeYevmH8aHhQJCGYjwBj3/go-libp2p-interface-conn
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
ps
"gx/ipfs/QmSxPTJ2Jb3nekq3AGMgDyXZR3dhPrSPVSggT3FqJWw4Sa/go-peerstream
"
inet
"gx/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-
net
"
ic
"g
x/ipfs/QmTuX6VtWTbWgPwd5PMXHyp411RKsW5nBqLKVVRfJMNneb/go-libp2p-crypto
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-pee
r"
)
// Conn is a simple wrapper around a ps.Conn that also exposes
...
...
swarm_dial.go
View file @
2e26ef20
...
...
@@ -7,11 +7,11 @@ import (
"sync"
"time"
addrutil
"github.com/libp2p/go-addr-util
"
iconn
"github.com/libp2p/go-libp2p-interface-conn
"
lgbl
"g
ithub.com/libp2p
/go-libp2p-loggables"
peer
"github.com/libp2p/go-libp2p-peer
"
ma
"github.com/multiformats/go-multiadd
r"
iconn
"gx/ipfs/QmNmKcQiJB5cUTXXXS1o44s4PdeYevmH8aHhQJCGYjwBj3/go-libp2p-interface-conn
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
lgbl
"g
x/ipfs/Qma1v2AjS7d2ceYgye4wUVBFFSdB6UPp7jgL8kNtxvFzWu
/go-libp2p-loggables"
addrutil
"gx/ipfs/Qmb86KiitngVm5AGQ18viwCBwwcTvULAtz3X74YWKAevnc/go-addr-util
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-pee
r"
)
// Diagram of dial sync:
...
...
swarm_listen.go
View file @
2e26ef20
...
...
@@ -4,14 +4,14 @@ import (
"context"
"fmt"
conn
"g
ithub.com/libp2p/go-libp2p
-conn"
i
conn
"g
ithub.com/libp2p/go-libp2p-interface-
conn"
lgbl
"github.com/libp2p
/go-libp2p-
loggables
"
m
conn
"github.com/libp2p/go-libp2p-metrics/conn
"
inet
"github.com/libp2p/go-libp2p-net
"
transport
"github.com/libp2p
/go-libp2p-
transpor
t"
ps
"github.com/libp2p/go-peerstream
"
ma
"github.com/multiformats/go-multiaddr
"
i
conn
"g
x/ipfs/QmNmKcQiJB5cUTXXXS1o44s4PdeYevmH8aHhQJCGYjwBj3/go-libp2p-interface
-conn"
m
conn
"g
x/ipfs/QmPfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm/go-libp2p-metrics/
conn"
transport
"gx/ipfs/QmR4YrM1DdvYmox249o8aday8oiotkcsT1Qzv42ujPEQDb
/go-libp2p-
transport
"
m
a
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
ps
"gx/ipfs/QmSxPTJ2Jb3nekq3AGMgDyXZR3dhPrSPVSggT3FqJWw4Sa/go-peerstream
"
inet
"gx/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-
ne
t"
lgbl
"gx/ipfs/Qma1v2AjS7d2ceYgye4wUVBFFSdB6UPp7jgL8kNtxvFzWu/go-libp2p-loggables
"
conn
"gx/ipfs/Qmf8Br5gq5XgMrSA6Y6dzY3kaBWwJu6aqXJxxuxCCKsbyD/go-libp2p-conn
"
)
func
(
s
*
Swarm
)
AddListenAddr
(
a
ma
.
Multiaddr
)
error
{
...
...
swarm_net.go
View file @
2e26ef20
...
...
@@ -4,13 +4,13 @@ import (
"context"
"fmt"
"github.com/jbenet/goproces
s"
ipnet
"github.com/libp2p/go-libp2p-interface-pnet
"
m
etrics
"github.com/libp2p/go-libp2p-metrics
"
inet
"g
ithub.com/libp2p
/go-libp2p-net"
peer
"github.com/libp2p/go-libp2p-peer
"
p
store
"github.com/libp2p
/go-libp2p-peer
store
"
ma
"github.com/multiformats/go-multiaddr
"
metrics
"gx/ipfs/QmPfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm/go-libp2p-metric
s"
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess
"
m
a
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
inet
"g
x/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-net"
ipnet
"gx/ipfs/QmWNwP8oYzPUK6LqYEH1hoTMuVmQUUbhKQgHeT1AENGkEm/go-libp2p-interface-pnet
"
p
eer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe
/go-libp2p-peer"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
// Network implements the inet.Network interface.
...
...
swarm_net_test.go
View file @
2e26ef20
...
...
@@ -6,10 +6,10 @@ import (
"testing"
"time"
inet
"github.com/libp2p/go-libp2p-net
"
pstore
"github.com/libp2p
/go-libp2p-
peerstore
"
tu
"g
ithub.com/libp2p
/go-testutil"
ma
"github.com/multiformats/go-multiaddr
"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
inet
"gx/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-
net
"
tu
"g
x/ipfs/QmbN6CcaGuVSWwhYq5nDQs98hWHgu5PTBgVjnGV28YeGRk
/go-testutil"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
func
GenSwarmNetwork
(
t
*
testing
.
T
,
ctx
context
.
Context
)
*
Network
{
...
...
swarm_notif_test.go
View file @
2e26ef20
...
...
@@ -5,9 +5,9 @@ import (
"time"
"context"
inet
"github.com/libp2p/go-libp2p-net
"
peer
"github.com/libp2p
/go-libp2p-
peer
"
ma
"github.com/multiformats/go-multiadd
r"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
inet
"gx/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-
net
"
peer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe/go-libp2p-pee
r"
)
func
streamsSame
(
a
,
b
inet
.
Stream
)
bool
{
...
...
swarm_stream.go
View file @
2e26ef20
...
...
@@ -3,9 +3,9 @@ package swarm
import
(
"time"
inet
"github.com/libp2p/go-libp2p-net
"
protocol
"github.com/libp2p
/go-libp2p-
protocol
"
p
s
"github.com/libp2p/go-peerstream
"
ps
"gx/ipfs/QmSxPTJ2Jb3nekq3AGMgDyXZR3dhPrSPVSggT3FqJWw4Sa/go-peerstream
"
inet
"gx/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-
net
"
p
rotocol
"gx/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN/go-libp2p-protocol
"
)
// Stream is a wrapper around a ps.Stream that exposes a way to get
...
...
swarm_test.go
View file @
2e26ef20
...
...
@@ -10,12 +10,12 @@ import (
"testing"
"time"
metrics
"g
ithub.com/libp2p
/go-libp2p-metrics"
inet
"github.com/libp2p/go-libp2p-net
"
peer
"github.com/libp2p
/go-libp2p-
peer
"
p
store
"github.com/libp2p
/go-libp2p-peer
store
"
testutil
"g
ithub.com/libp2p
/go-testutil"
ma
"github.com/multiformats/go-multiaddr
"
metrics
"g
x/ipfs/QmPfeoLzBPsiwbHLwev8ecgjd1RPCYfsAHhdFA8avEnXQm
/go-libp2p-metrics"
ma
"gx/ipfs/QmSWLfmj5frN9xVLMMN846dMDriy5wN5jeghUm7aTW3DAG/go-multiaddr
"
inet
"gx/ipfs/QmTWdBq4ZaLGbXcMiNasSR5ywomkgQiJDqQknEU16z3pZR
/go-libp2p-
net
"
p
eer
"gx/ipfs/QmbKtZxyDqUJp7Ad8tGr5nrLqoi9nfgqFxcNbmLJbfaHPe
/go-libp2p-peer"
testutil
"g
x/ipfs/QmbN6CcaGuVSWwhYq5nDQs98hWHgu5PTBgVjnGV28YeGRk
/go-testutil"
pstore
"gx/ipfs/QmekwEJM81TqzKzupMvK68hVNfBNvBengWkpc8nAw2bjBf/go-libp2p-peerstore
"
)
func
EchoStreamHandler
(
stream
inet
.
Stream
)
{
...
...
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