Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
dms3
go-bitswap
Commits
c80a3ae8
Commit
c80a3ae8
authored
May 03, 2018
by
Steven Allen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update deps
License: MIT Signed-off-by:
Steven Allen
<
steven@stebalien.com
>
parent
1d83343d
Changes
21
Hide whitespace changes
Inline
Side-by-side
Showing
21 changed files
with
62 additions
and
62 deletions
+62
-62
bitswap.go
bitswap.go
+3
-3
bitswap_test.go
bitswap_test.go
+5
-5
decision/bench_test.go
decision/bench_test.go
+2
-2
decision/engine.go
decision/engine.go
+3
-3
decision/engine_test.go
decision/engine_test.go
+5
-5
decision/ledger.go
decision/ledger.go
+1
-1
decision/peer_request_queue.go
decision/peer_request_queue.go
+1
-1
decision/peer_request_queue_test.go
decision/peer_request_queue_test.go
+1
-1
get.go
get.go
+1
-1
message/message.go
message/message.go
+1
-1
network/interface.go
network/interface.go
+2
-2
network/ipfs_impl.go
network/ipfs_impl.go
+7
-7
session.go
session.go
+3
-3
session_test.go
session_test.go
+1
-1
testnet/interface.go
testnet/interface.go
+2
-2
testnet/network_test.go
testnet/network_test.go
+3
-3
testnet/peernet.go
testnet/peernet.go
+5
-5
testnet/virtual.go
testnet/virtual.go
+6
-6
testutils.go
testutils.go
+7
-7
wantmanager.go
wantmanager.go
+1
-1
workers.go
workers.go
+2
-2
No files found.
bitswap.go
View file @
c80a3ae8
...
@@ -17,12 +17,12 @@ import (
...
@@ -17,12 +17,12 @@ import (
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
flags
"gx/ipfs/QmRMGdC6HKdLsPDABL9aXPDidrpmEHzJqFWSvshkbn9Hj8/go-ipfs-flags"
flags
"gx/ipfs/QmRMGdC6HKdLsPDABL9aXPDidrpmEHzJqFWSvshkbn9Hj8/go-ipfs-flags"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
metrics
"gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
metrics
"gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
process
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
process
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
procctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
procctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
logging
"gx/ipfs/QmTG23dvpBCBjqQwyDxV8CQT6jmS4PSftNr1VqHhE3MLy7/go-log"
blockstore
"gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
blockstore
"gx/ipfs/QmayRSLCiM2gWR7Kay8vqu3Yy5mf7yPqocF9ZRgDUPYMcc/go-ipfs-blockstore"
peer
"gx/ipfs/QmcJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
exchange
"gx/ipfs/QmdcAXgEHUueP4A7b5hjabKn2EooeHgMreMvFC249dGCgc/go-ipfs-exchange-interface"
exchange
"gx/ipfs/QmdcAXgEHUueP4A7b5hjabKn2EooeHgMreMvFC249dGCgc/go-ipfs-exchange-interface"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
...
...
bitswap_test.go
View file @
c80a3ae8
...
@@ -11,12 +11,12 @@ import (
...
@@ -11,12 +11,12 @@ import (
decision
"github.com/ipfs/go-ipfs/exchange/bitswap/decision"
decision
"github.com/ipfs/go-ipfs/exchange/bitswap/decision"
tn
"github.com/ipfs/go-ipfs/exchange/bitswap/testnet"
tn
"github.com/ipfs/go-ipfs/exchange/bitswap/testnet"
mockrouting
"gx/ipfs/QmPuPdzoG4b5uyYSQCjLEHB8NM593m3BW19UHX2jZ6Wzfm/go-ipfs-routing/mock"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
tu
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
tu
"gx/ipfs/QmUJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq/go-testutil"
travis
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil/ci/travis"
travis
"gx/ipfs/QmUJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq/go-testutil/ci/travis"
mockrouting
"gx/ipfs/QmXtoXbu9ReyV6Q4kDQ5CF9wXQNDY1PdHc4HhfxRR5AHB3/go-ipfs-routing/mock"
blockstore
"gx/ipfs/QmayRSLCiM2gWR7Kay8vqu3Yy5mf7yPqocF9ZRgDUPYMcc/go-ipfs-blockstore"
p2ptestutil
"gx/ipfs/QmYVR3C8DWPHdHxvLtNFYfjsXgaRAdh6hPMNH3KiwCgu4o/go-libp2p-netutil"
p2ptestutil
"gx/ipfs/Qmb6BsZf6Y3kxffXMNTubGPF1w1bkHtpvhfYbmnwP3NQyw/go-libp2p-netutil"
blockstore
"gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
detectrace
"gx/ipfs/Qmf7HqcW7LtCi1W8y2bdx2eJpze74jkbKqpByxgXikdbLF/go-detect-race"
detectrace
"gx/ipfs/Qmf7HqcW7LtCi1W8y2bdx2eJpze74jkbKqpByxgXikdbLF/go-detect-race"
...
...
decision/bench_test.go
View file @
c80a3ae8
...
@@ -7,8 +7,8 @@ import (
...
@@ -7,8 +7,8 @@ import (
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
)
...
...
decision/engine.go
View file @
c80a3ae8
...
@@ -9,9 +9,9 @@ import (
...
@@ -9,9 +9,9 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
wl
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
wl
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
logging
"gx/ipfs/Qm
Rb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8
/go-log"
logging
"gx/ipfs/Qm
TG23dvpBCBjqQwyDxV8CQT6jmS4PSftNr1VqHhE3MLy7
/go-log"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer
"
bstore
"gx/ipfs/Qm
ayRSLCiM2gWR7Kay8vqu3Yy5mf7yPqocF9ZRgDUPYMcc/go-ipfs-blockstore
"
bstore
"gx/ipfs/Qm
aG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore
"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer
"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
)
)
...
...
decision/engine_test.go
View file @
c80a3ae8
...
@@ -11,11 +11,11 @@ import (
...
@@ -11,11 +11,11 @@ import (
message
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
message
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
testutil
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
testutil
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
ds
"gx/ipfs/Qm
XRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-data
store"
blockstore
"gx/ipfs/Qm
ayRSLCiM2gWR7Kay8vqu3Yy5mf7yPqocF9ZRgDUPYMcc/go-ipfs-block
store"
dssync
"gx/ipfs/Qm
XRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync
"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer
"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer
"
ds
"gx/ipfs/Qm
eiCcJfDW1GJnWUArudsv5rQsihpi4oyddPhdqo3CfX6i/go-datastore
"
blockstore
"gx/ipfs/Qm
aG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore
"
dssync
"gx/ipfs/Qm
eiCcJfDW1GJnWUArudsv5rQsihpi4oyddPhdqo3CfX6i/go-datastore/sync
"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
)
)
...
...
decision/ledger.go
View file @
c80a3ae8
...
@@ -6,7 +6,7 @@ import (
...
@@ -6,7 +6,7 @@ import (
wl
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
wl
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
)
...
...
decision/peer_request_queue.go
View file @
c80a3ae8
...
@@ -7,7 +7,7 @@ import (
...
@@ -7,7 +7,7 @@ import (
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
pq
"gx/ipfs/QmZUbTDJ39JpvtFCSubiWeUTQRvMA1tVE5RZCJrY4oeAsC/go-ipfs-pq"
pq
"gx/ipfs/QmZUbTDJ39JpvtFCSubiWeUTQRvMA1tVE5RZCJrY4oeAsC/go-ipfs-pq"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
)
...
...
decision/peer_request_queue_test.go
View file @
c80a3ae8
...
@@ -10,7 +10,7 @@ import (
...
@@ -10,7 +10,7 @@ import (
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
)
...
...
get.go
View file @
c80a3ae8
...
@@ -6,7 +6,7 @@ import (
...
@@ -6,7 +6,7 @@ import (
notifications
"github.com/ipfs/go-ipfs/exchange/bitswap/notifications"
notifications
"github.com/ipfs/go-ipfs/exchange/bitswap/notifications"
blockstore
"gx/ipfs/Qma
G4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY
/go-ipfs-blockstore"
blockstore
"gx/ipfs/Qma
yRSLCiM2gWR7Kay8vqu3Yy5mf7yPqocF9ZRgDUPYMcc
/go-ipfs-blockstore"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
)
)
...
...
message/message.go
View file @
c80a3ae8
...
@@ -8,7 +8,7 @@ import (
...
@@ -8,7 +8,7 @@ import (
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
inet
"gx/ipfs/QmX
fkENeeBvh3zYA51MaSdGUdBjhQ99cP5WQe8zgr6wchG
/go-libp2p-net"
inet
"gx/ipfs/QmX
oz9o2PT3tEzf7hicegwex5UgVP54n3k82K7jrWFyN86
/go-libp2p-net"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
...
...
network/interface.go
View file @
c80a3ae8
...
@@ -6,9 +6,9 @@ import (
...
@@ -6,9 +6,9 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
protocol
"gx/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN/go-libp2p-protocol"
protocol
"gx/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN/go-libp2p-protocol"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
peer
"gx/ipfs/QmcJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer"
ifconnmgr
"gx/ipfs/Qmax8X1Kfahf5WfSB68EWDG3d3qyS3Sqs1v412fjPTfRwx/go-libp2p-interface-connmgr"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
ifconnmgr
"gx/ipfs/QmfQNieWBPwmnUjXWPZbjJPzhNwFFabTb5RQ79dyVWGujQ/go-libp2p-interface-connmgr"
)
)
var
(
var
(
...
...
network/ipfs_impl.go
View file @
c80a3ae8
...
@@ -8,16 +8,16 @@ import (
...
@@ -8,16 +8,16 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
host
"gx/ipfs/QmNmJZL7FQySMtE2BQuLMuZg2EB2CLEunJJUSVSc9YnnbV/go-libp2p-host"
logging
"gx/ipfs/QmTG23dvpBCBjqQwyDxV8CQT6jmS4PSftNr1VqHhE3MLy7/go-log"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
routing
"gx/ipfs/QmUHRKTeaoASDvDj7cTAXsmjAY7KQ13ErtzkQHZQq6uFUz/go-libp2p-routing"
routing
"gx/ipfs/QmTiWLZ6Fo5j4KcTVutZJ5KWRRJrbxzmxA4td8NfEdrPh7/go-libp2p-routing"
ma
"gx/ipfs/QmWWQ2Txc2c6tqjsBpzg5Ar652cHPGNsQQp2SejkNmkUMb/go-multiaddr"
ma
"gx/ipfs/QmWWQ2Txc2c6tqjsBpzg5Ar652cHPGNsQQp2SejkNmkUMb/go-multiaddr"
pstore
"gx/ipfs/QmXauCuJzmzapetmC6W4TuDJLL1yFFrVzSHoWv8YdbmnxH/go-libp2p-peerstore"
inet
"gx/ipfs/QmXoz9o2PT3tEzf7hicegwex5UgVP54n3k82K7jrWFyN86/go-libp2p-net"
inet
"gx/ipfs/QmXfkENeeBvh3zYA51MaSdGUdBjhQ99cP5WQe8zgr6wchG/go-libp2p-net"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
peer
"gx/ipfs/QmcJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer"
ifconnmgr
"gx/ipfs/Qmax8X1Kfahf5WfSB68EWDG3d3qyS3Sqs1v412fjPTfRwx/go-libp2p-interface-connmgr"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
pstore
"gx/ipfs/QmdeiKhUy1TVGBaKxt7y1QmBDLBdisSrLJ1x58Eoj4PXUh/go-libp2p-peerstore"
ifconnmgr
"gx/ipfs/QmfQNieWBPwmnUjXWPZbjJPzhNwFFabTb5RQ79dyVWGujQ/go-libp2p-interface-connmgr"
host
"gx/ipfs/QmfZTdmunzKzAGJrSvXXQbQ5kLLUiEMX5vdwux7iXkdk7D/go-libp2p-host"
)
)
var
log
=
logging
.
Logger
(
"bitswap_network"
)
var
log
=
logging
.
Logger
(
"bitswap_network"
)
...
...
session.go
View file @
c80a3ae8
...
@@ -7,12 +7,12 @@ import (
...
@@ -7,12 +7,12 @@ import (
notifications
"github.com/ipfs/go-ipfs/exchange/bitswap/notifications"
notifications
"github.com/ipfs/go-ipfs/exchange/bitswap/notifications"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
loggables
"gx/ipfs/QmPDZJxtWGfcwLPazJxD4h3v3aDs43V7UNAVs3Jz1Wo7o4/go-libp2p-loggables"
logging
"gx/ipfs/QmTG23dvpBCBjqQwyDxV8CQT6jmS4PSftNr1VqHhE3MLy7/go-log"
lru
"gx/ipfs/QmVYxfoJQiZijTgPNHCHgHELvQpbsJNTg6Crmc3dQkj3yy/golang-lru"
lru
"gx/ipfs/QmVYxfoJQiZijTgPNHCHgHELvQpbsJNTg6Crmc3dQkj3yy/golang-lru"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
loggables
"gx/ipfs/Qmf9JgVLz46pxPXwG2eWSJpkqVCcjD4rp7zCRi2KP6GTNB/go-libp2p-loggables"
)
)
const
activeWantsLimit
=
16
const
activeWantsLimit
=
16
...
...
session_test.go
View file @
c80a3ae8
...
@@ -6,7 +6,7 @@ import (
...
@@ -6,7 +6,7 @@ import (
"testing"
"testing"
"time"
"time"
tu
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
tu
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocksutil
"gx/ipfs/Qmf951DP11mCoctpyF3ZppPZdo2oAxuNi2vnkVDgHJ8Fqk/go-ipfs-blocksutil"
blocksutil
"gx/ipfs/Qmf951DP11mCoctpyF3ZppPZdo2oAxuNi2vnkVDgHJ8Fqk/go-ipfs-blocksutil"
...
...
testnet/interface.go
View file @
c80a3ae8
...
@@ -2,8 +2,8 @@ package bitswap
...
@@ -2,8 +2,8 @@ package bitswap
import
(
import
(
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74
/go-libp2p-peer"
)
)
type
Network
interface
{
type
Network
interface
{
...
...
testnet/network_test.go
View file @
c80a3ae8
...
@@ -8,10 +8,10 @@ import (
...
@@ -8,10 +8,10 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
mockrouting
"gx/ipfs/QmPuPdzoG4b5uyYSQCjLEHB8NM593m3BW19UHX2jZ6Wzfm/go-ipfs-routing/mock"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
testutil
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
testutil
"gx/ipfs/QmUJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq/go-testutil"
mockrouting
"gx/ipfs/QmXtoXbu9ReyV6Q4kDQ5CF9wXQNDY1PdHc4HhfxRR5AHB3/go-ipfs-routing/mock"
peer
"gx/ipfs/QmcJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
)
)
...
...
testnet/peernet.go
View file @
c80a3ae8
...
@@ -5,11 +5,11 @@ import (
...
@@ -5,11 +5,11 @@ import (
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
mock
peernet
"gx/ipfs/Qm
Nh1kGFFdsPu79KNSaL4NUKUPb4Eiz4KHdMtFY6664RDp/go-libp2p/p2p/net
/mock"
mock
routing
"gx/ipfs/Qm
PuPdzoG4b5uyYSQCjLEHB8NM593m3BW19UHX2jZ6Wzfm/go-ipfs-routing
/mock"
testutil
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
testutil
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
ds
"gx/ipfs/Qm
XRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore
"
mockpeernet
"gx/ipfs/Qm
WsV6kzPaYGBDVyuUfWBvyQygEc9Qrv9vzo8vZ7X4mdLN/go-libp2p/p2p/net/mock
"
mockrouting
"gx/ipfs/Qm
XtoXbu9ReyV6Q4kDQ5CF9wXQNDY1PdHc4HhfxRR5AHB3/go-ipfs-routing/mock
"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer
"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer
"
ds
"gx/ipfs/Qm
eiCcJfDW1GJnWUArudsv5rQsihpi4oyddPhdqo3CfX6i/go-datastore
"
)
)
type
peernet
struct
{
type
peernet
struct
{
...
...
testnet/virtual.go
View file @
c80a3ae8
...
@@ -9,14 +9,14 @@ import (
...
@@ -9,14 +9,14 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
mockrouting
"gx/ipfs/QmPuPdzoG4b5uyYSQCjLEHB8NM593m3BW19UHX2jZ6Wzfm/go-ipfs-routing/mock"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
logging
"gx/ipfs/QmTG23dvpBCBjqQwyDxV8CQT6jmS4PSftNr1VqHhE3MLy7/go-log"
routing
"gx/ipfs/QmTiWLZ6Fo5j4KcTVutZJ5KWRRJrbxzmxA4td8NfEdrPh7/go-libp2p-routing"
routing
"gx/ipfs/QmUHRKTeaoASDvDj7cTAXsmjAY7KQ13ErtzkQHZQq6uFUz/go-libp2p-routing"
testutil
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
testutil
"gx/ipfs/QmUJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq/go-testutil"
mockrouting
"gx/ipfs/QmXtoXbu9ReyV6Q4kDQ5CF9wXQNDY1PdHc4HhfxRR5AHB3/go-ipfs-routing/mock"
peer
"gx/ipfs/QmcJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
ifconnmgr
"gx/ipfs/Qmax8X1Kfahf5WfSB68EWDG3d3qyS3Sqs1v412fjPTfRwx/go-libp2p-interface-connmgr"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
ifconnmgr
"gx/ipfs/QmfQNieWBPwmnUjXWPZbjJPzhNwFFabTb5RQ79dyVWGujQ/go-libp2p-interface-connmgr"
)
)
var
log
=
logging
.
Logger
(
"bstestnet"
)
var
log
=
logging
.
Logger
(
"bstestnet"
)
...
...
testutils.go
View file @
c80a3ae8
...
@@ -7,13 +7,13 @@ import (
...
@@ -7,13 +7,13 @@ import (
tn
"github.com/ipfs/go-ipfs/exchange/bitswap/testnet"
tn
"github.com/ipfs/go-ipfs/exchange/bitswap/testnet"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
delay
"gx/ipfs/QmRJVNatYJwTAHgdSM1Xef9QVQ1Ch3XHdmcrykjP5Y4soL/go-ipfs-delay"
testutil
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
testutil
"gx/ipfs/Qm
UJzxQQ2kzwQubsMqBTr1NGDpLfh7pGA2E1oaJULcKDPq
/go-testutil"
ds
"gx/ipfs/Qm
XRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-data
store"
blockstore
"gx/ipfs/Qm
ayRSLCiM2gWR7Kay8vqu3Yy5mf7yPqocF9ZRgDUPYMcc/go-ipfs-block
store"
delayed
"gx/ipfs/Qm
XRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/delayed
"
p2ptestutil
"gx/ipfs/Qm
b6BsZf6Y3kxffXMNTubGPF1w1bkHtpvhfYbmnwP3NQyw/go-libp2p-netutil
"
ds_sync
"gx/ipfs/Qm
XRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync
"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer
"
p2ptestutil
"gx/ipfs/Qm
YVR3C8DWPHdHxvLtNFYfjsXgaRAdh6hPMNH3KiwCgu4o/go-libp2p-netutil
"
ds
"gx/ipfs/Qm
eiCcJfDW1GJnWUArudsv5rQsihpi4oyddPhdqo3CfX6i/go-datastore
"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer
"
delayed
"gx/ipfs/Qm
eiCcJfDW1GJnWUArudsv5rQsihpi4oyddPhdqo3CfX6i/go-datastore/delayed
"
blockstore
"gx/ipfs/Qm
aG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore
"
ds_sync
"gx/ipfs/Qm
eiCcJfDW1GJnWUArudsv5rQsihpi4oyddPhdqo3CfX6i/go-datastore/sync
"
)
)
// WARNING: this uses RandTestBogusIdentity DO NOT USE for NON TESTS!
// WARNING: this uses RandTestBogusIdentity DO NOT USE for NON TESTS!
...
...
wantmanager.go
View file @
c80a3ae8
...
@@ -11,7 +11,7 @@ import (
...
@@ -11,7 +11,7 @@ import (
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
metrics
"gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
metrics
"gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
peer
"gx/ipfs/Qm
cJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
)
...
...
workers.go
View file @
c80a3ae8
...
@@ -8,10 +8,10 @@ import (
...
@@ -8,10 +8,10 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
process
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
process
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
procctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
procctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
logging
"gx/ipfs/QmTG23dvpBCBjqQwyDxV8CQT6jmS4PSftNr1VqHhE3MLy7/go-log"
peer
"gx/ipfs/QmcJukH2sAFjY3HdBKq35WDzWoL3UUu2gt9wdfqZTUyM74/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
)
...
...
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