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
c26feecf
Commit
c26feecf
authored
Jan 31, 2018
by
Steven Allen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
gx: update go-log
License: MIT Signed-off-by:
Steven Allen
<
steven@stebalien.com
>
parent
defd3665
Changes
19
Hide whitespace changes
Inline
Side-by-side
Showing
19 changed files
with
45 additions
and
45 deletions
+45
-45
bitswap.go
bitswap.go
+2
-2
bitswap_test.go
bitswap_test.go
+3
-3
decision/bench_test.go
decision/bench_test.go
+2
-2
decision/engine.go
decision/engine.go
+2
-2
decision/engine_test.go
decision/engine_test.go
+2
-2
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
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
testnet/interface.go
testnet/interface.go
+2
-2
testnet/network_test.go
testnet/network_test.go
+2
-2
testnet/peernet.go
testnet/peernet.go
+3
-3
testnet/virtual.go
testnet/virtual.go
+5
-5
testutils.go
testutils.go
+3
-3
wantmanager.go
wantmanager.go
+1
-1
workers.go
workers.go
+2
-2
No files found.
bitswap.go
View file @
c26feecf
...
...
@@ -19,11 +19,11 @@ import (
flags
"github.com/ipfs/go-ipfs/flags"
"github.com/ipfs/go-ipfs/thirdparty/delay"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
metrics
"gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
process
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
procctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
peer
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
)
...
...
bitswap_test.go
View file @
c26feecf
...
...
@@ -17,11 +17,11 @@ import (
detectrace
"github.com/ipfs/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-detect-race"
p2ptestutil
"gx/ipfs/QmWUugnJBbcuin8qdfiCYKAsNkG8NeDLhzoBqRaqXhAHd4/go-libp2p-netutil"
tu
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
travis
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil/ci/travis"
p2ptestutil
"gx/ipfs/QmYVR3C8DWPHdHxvLtNFYfjsXgaRAdh6hPMNH3KiwCgu4o/go-libp2p-netutil"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
tu
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil"
travis
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil/ci/travis"
)
// FIXME the tests are really sensitive to the network delay. fix them to work
...
...
decision/bench_test.go
View file @
c26feecf
...
...
@@ -7,9 +7,9 @@ import (
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil"
)
// FWIW: At the time of this commit, including a timestamp in task increases
...
...
decision/engine.go
View file @
c26feecf
...
...
@@ -9,8 +9,8 @@ import (
bstore
"github.com/ipfs/go-ipfs/blocks/blockstore"
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
wl
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
logging
"gx/ipfs/Qm
SpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52
/go-log"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-peer"
logging
"gx/ipfs/Qm
Rb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8
/go-log"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
)
...
...
decision/engine_test.go
View file @
c26feecf
...
...
@@ -13,9 +13,9 @@ import (
message
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
ds
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore"
dssync
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore/sync"
peer
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
testutil
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
testutil
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil"
)
type
peerAndEngine
struct
{
...
...
decision/ledger.go
View file @
c26feecf
...
...
@@ -6,7 +6,7 @@ import (
wl
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-peer"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
...
...
decision/peer_request_queue.go
View file @
c26feecf
...
...
@@ -7,7 +7,7 @@ import (
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
pq
"github.com/ipfs/go-ipfs/thirdparty/pq"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-peer"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
...
...
decision/peer_request_queue_test.go
View file @
c26feecf
...
...
@@ -10,8 +10,8 @@ import (
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil"
)
func
TestPushPop
(
t
*
testing
.
T
)
{
...
...
message/message.go
View file @
c26feecf
...
...
@@ -8,7 +8,7 @@ import (
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
inet
"gx/ipfs/Qm
Qm7WmgYCa4RSz76tKEYpRjApjnRw8ZTUVQC15b8JM4a2
/go-libp2p-net"
inet
"gx/ipfs/Qm
XfkENeeBvh3zYA51MaSdGUdBjhQ99cP5WQe8zgr6wchG
/go-libp2p-net"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
...
...
network/interface.go
View file @
c26feecf
...
...
@@ -6,8 +6,8 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
protocol
"gx/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN/go-libp2p-protocol"
ifconnmg
r
"gx/ipfs/QmZ
dqgq4h6AdodSmPwb5FZzhwnmhchu1hhJgv8tnFdod1o/go-libp2p-interface-connmg
r"
pee
r
"gx/ipfs/Qma
7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-pee
r"
pee
r
"gx/ipfs/QmZ
oWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-pee
r"
ifconnmg
r
"gx/ipfs/Qma
x8X1Kfahf5WfSB68EWDG3d3qyS3Sqs1v412fjPTfRwx/go-libp2p-interface-connmg
r"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
...
...
network/ipfs_impl.go
View file @
c26feecf
...
...
@@ -8,16 +8,16 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
ine
t
"gx/ipfs/Qm
Qm7WmgYCa4RSz76tKEYpRjApjnRw8ZTUVQC15b8JM4a2
/go-libp2p-
ne
t"
rout
ing
"gx/ipfs/QmR
ijoA6zGS98ELTDbGsLWPZbVotYsGbjp3RbXcKCYBeon/go-libp2p-routin
g"
logg
ing
"gx/ipfs/Qm
SpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-lo
g"
hos
t
"gx/ipfs/Qm
NmJZL7FQySMtE2BQuLMuZg2EB2CLEunJJUSVSc9YnnbV
/go-libp2p-
hos
t"
logg
ing
"gx/ipfs/QmR
b5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-lo
g"
rout
ing
"gx/ipfs/Qm
TiWLZ6Fo5j4KcTVutZJ5KWRRJrbxzmxA4td8NfEdrPh7/go-libp2p-routin
g"
ma
"gx/ipfs/QmWWQ2Txc2c6tqjsBpzg5Ar652cHPGNsQQp2SejkNmkUMb/go-multiaddr"
pstore
"gx/ipfs/QmXauCuJzmzapetmC6W4TuDJLL1yFFrVzSHoWv8YdbmnxH/go-libp2p-peerstore"
inet
"gx/ipfs/QmXfkENeeBvh3zYA51MaSdGUdBjhQ99cP5WQe8zgr6wchG/go-libp2p-net"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
ifconnmg
r
"gx/ipfs/QmZ
dqgq4h6AdodSmPwb5FZzhwnmhchu1hhJgv8tnFdod1o/go-libp2p-interface-connmg
r"
pee
r
"gx/ipfs/Qma
7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-pee
r"
pee
r
"gx/ipfs/QmZ
oWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-pee
r"
ifconnmg
r
"gx/ipfs/Qma
x8X1Kfahf5WfSB68EWDG3d3qyS3Sqs1v412fjPTfRwx/go-libp2p-interface-connmg
r"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
pstore
"gx/ipfs/QmeZVQzUrXqaszo24DAoHfGzcmCptN9JyngLkGAiEfk2x7/go-libp2p-peerstore"
host
"gx/ipfs/QmfCtHMCd9xFvehvHeVxtKVXJTMVTuHhyPRVHEXetn87vL/go-libp2p-host"
)
var
log
=
logging
.
Logger
(
"bitswap_network"
)
...
...
session.go
View file @
c26feecf
...
...
@@ -7,12 +7,12 @@ import (
notifications
"github.com/ipfs/go-ipfs/exchange/bitswap/notifications"
loggables
"gx/ipfs/QmQ3c5AP6yjqD3E4get5atkvfaUU4rubWquoL2e8ycjUSu/go-libp2p-loggables"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
lru
"gx/ipfs/QmVYxfoJQiZijTgPNHCHgHELvQpbsJNTg6Crmc3dQkj3yy/golang-lru"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-peer"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
loggables
"gx/ipfs/Qmf9JgVLz46pxPXwG2eWSJpkqVCcjD4rp7zCRi2KP6GTNB/go-libp2p-loggables"
)
const
activeWantsLimit
=
16
...
...
testnet/interface.go
View file @
c26feecf
...
...
@@ -2,8 +2,8 @@ package bitswap
import
(
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer
"
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil
"
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil
"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer
"
)
type
Network
interface
{
...
...
testnet/network_test.go
View file @
c26feecf
...
...
@@ -9,9 +9,9 @@ import (
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
mockrouting
"github.com/ipfs/go-ipfs/routing/mock"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
peer
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
testutil
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
blocks
"gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
testutil
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil"
)
func
TestSendMessageAsyncButWaitForResponse
(
t
*
testing
.
T
)
{
...
...
testnet/peernet.go
View file @
c26feecf
...
...
@@ -5,10 +5,10 @@ import (
bsnet
"github.com/ipfs/go-ipfs/exchange/bitswap/network"
mockrouting
"github.com/ipfs/go-ipfs/routing/mock"
mockpeernet
"gx/ipfs/Qm
Pd5qhppUqewTQMfStvNNCFtcxiWGsnE6Vs3va6788gsX
/go-libp2p/p2p/net/mock"
mockpeernet
"gx/ipfs/Qm
Nh1kGFFdsPu79KNSaL4NUKUPb4Eiz4KHdMtFY6664RDp
/go-libp2p/p2p/net/mock"
ds
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer
"
testutil
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil
"
testutil
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil
"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer
"
)
type
peernet
struct
{
...
...
testnet/virtual.go
View file @
c26feecf
...
...
@@ -10,12 +10,12 @@ import (
mockrouting
"github.com/ipfs/go-ipfs/routing/mock"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
routing
"gx/ipfs/QmRijoA6zGS98ELTDbGsLWPZbVotYsGbjp3RbXcKCYBeon/go-libp2p-routing"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
ifconnmgr
"gx/ipfs/QmZdqgq4h6AdodSmPwb5FZzhwnmhchu1hhJgv8tnFdod1o/go-libp2p-interface-connmgr"
peer
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
routing
"gx/ipfs/QmTiWLZ6Fo5j4KcTVutZJ5KWRRJrbxzmxA4td8NfEdrPh7/go-libp2p-routing"
testutil
"gx/ipfs/QmVvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf/go-testutil"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
ifconnmgr
"gx/ipfs/Qmax8X1Kfahf5WfSB68EWDG3d3qyS3Sqs1v412fjPTfRwx/go-libp2p-interface-connmgr"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
testutil
"gx/ipfs/QmfB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG/go-testutil"
)
var
log
=
logging
.
Logger
(
"bstestnet"
)
...
...
testutils.go
View file @
c26feecf
...
...
@@ -8,12 +8,12 @@ import (
tn
"github.com/ipfs/go-ipfs/exchange/bitswap/testnet"
datastore2
"github.com/ipfs/go-ipfs/thirdparty/datastore2"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
testutil
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG
/go-testutil"
testutil
"gx/ipfs/Qm
VvkK7s5imCiq3JVbL3pGfnhcCnf3LrFJPF4GE2sAoGZf
/go-testutil"
ds
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore"
ds_sync
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore/sync"
p2ptestutil
"gx/ipfs/Qm
WUugnJBbcuin8qdfiCYKAsNkG8NeDLhzoBqRaqXhAHd4
/go-libp2p-netutil"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-peer"
p2ptestutil
"gx/ipfs/Qm
YVR3C8DWPHdHxvLtNFYfjsXgaRAdh6hPMNH3KiwCgu4o
/go-libp2p-netutil"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
)
// WARNING: this uses RandTestBogusIdentity DO NOT USE for NON TESTS!
...
...
wantmanager.go
View file @
c26feecf
...
...
@@ -11,7 +11,7 @@ import (
wantlist
"github.com/ipfs/go-ipfs/exchange/bitswap/wantlist"
metrics
"gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-peer"
peer
"gx/ipfs/Qm
ZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS
/go-libp2p-peer"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
)
...
...
workers.go
View file @
c26feecf
...
...
@@ -8,10 +8,10 @@ import (
bsmsg
"github.com/ipfs/go-ipfs/exchange/bitswap/message"
logging
"gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
process
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
procctx
"gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
peer
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
peer
"gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
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