Skip to content

Commit 761f320

Browse files
committed
fork boxo again
1 parent f82bf26 commit 761f320

File tree

3 files changed

+9
-3
lines changed

3 files changed

+9
-3
lines changed

go.mod

+2
Original file line numberDiff line numberDiff line change
@@ -363,3 +363,5 @@ replace (
363363
github.com/syndtr/goleveldb => github.com/syndtr/goleveldb v1.0.1-0.20210819022825-2ae1ddf74ef7
364364
github.com/tendermint/tendermint => github.com/celestiaorg/celestia-core v1.47.0-tm-v0.34.35
365365
)
366+
367+
replace github.com/ipfs/boxo => github.com/celestiaorg/boxo 20d792b5

go.sum

+2-2
Original file line numberDiff line numberDiff line change
@@ -345,6 +345,8 @@ github.com/c-bata/go-prompt v0.2.2/go.mod h1:VzqtzE2ksDBcdln8G7mk2RX9QyGjH+OVqOC
345345
github.com/casbin/casbin/v2 v2.1.2/go.mod h1:YcPU1XXisHhLzuxH9coDNf2FbKpjGlbCg3n9yuLkIJQ=
346346
github.com/celestiaorg/blobstream-contracts/v3 v3.1.0 h1:h1Y4V3EMQ2mFmNtWt2sIhZIuyASInj1a9ExI8xOsTOw=
347347
github.com/celestiaorg/blobstream-contracts/v3 v3.1.0/go.mod h1:x4DKyfKOSv1ZJM9NwV+Pw01kH2CD7N5zTFclXIVJ6GQ=
348+
github.com/celestiaorg/boxo v0.0.0-20250306072016-a7558897aa5b h1:xCMaOmFtMnuExdD/cN2Yoo2zhqL2AzNrCJa59vIFCUA=
349+
github.com/celestiaorg/boxo v0.0.0-20250306072016-a7558897aa5b/go.mod h1:c3R52nMlgMsN1tADffYcogKoVRsX1RJE1TMYSpJ4uVs=
348350
github.com/celestiaorg/celestia-app/v3 v3.3.1 h1:e0iSWbf84mMOGU3aVCDd+I7a7wUQLXurHXhcmG6lyQI=
349351
github.com/celestiaorg/celestia-app/v3 v3.3.1/go.mod h1:FSv7/cIGoZIzcQIQPxTYYDeCO78A4VmC20jxf3Oqn4Y=
350352
github.com/celestiaorg/celestia-core v1.47.0-tm-v0.34.35 h1:K0kSVRlKfsPwfiA4o8GNUNPfZ+wF1MnYajom4CzJxpQ=
@@ -995,8 +997,6 @@ github.com/influxdata/tdigest v0.0.0-20181121200506-bf2b5ad3c0a9/go.mod h1:Js0mq
995997
github.com/influxdata/usage-client v0.0.0-20160829180054-6d3895376368/go.mod h1:Wbbw6tYNvwa5dlB6304Sd+82Z3f7PmVZHVKU637d4po=
996998
github.com/ipfs/bbloom v0.0.4 h1:Gi+8EGJ2y5qiD5FbsbpX/TMNcJw8gSqr7eyjHa4Fhvs=
997999
github.com/ipfs/bbloom v0.0.4/go.mod h1:cS9YprKXpoZ9lT0n/Mw/a6/aFV6DTjTLYHeA+gyqMG0=
998-
github.com/ipfs/boxo v0.29.0 h1:clzd7PglUcE+Ufq1KucS3aKID7pzGVaSgcdRsW395t4=
999-
github.com/ipfs/boxo v0.29.0/go.mod h1:c3R52nMlgMsN1tADffYcogKoVRsX1RJE1TMYSpJ4uVs=
10001000
github.com/ipfs/go-block-format v0.2.0 h1:ZqrkxBA2ICbDRbK8KJs/u0O3dlp6gmAuuXUJNiW1Ycs=
10011001
github.com/ipfs/go-block-format v0.2.0/go.mod h1:+jpL11nFx5A/SPpsoBn6Bzkra/zaArfSmsknbPMYgzM=
10021002
github.com/ipfs/go-cid v0.0.2/go.mod h1:GHWU/WuQdMPmIosc4Yn1bcCT7dSeX4lBafM7iqUPQvM=

share/shwap/p2p/bitswap/bitswap.go

+5-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,10 @@ const (
3333
// broadcasting of live WANTs to all the peers. We offset this for longer than the default to minimize
3434
// unnecessary broadcasting as in most cases we already have peers connected with needed data on
3535
// a new request.
36-
broadcastDelay = time.Second * 10
36+
// disablePerPeerRetries disables rebroadcasting of WANTs with no response in peer message queue.
37+
// We rely on DASer retries instead.
38+
disablePerPeerRetries = true
39+
broadcastDelay = time.Second * 10
3740
// provSearchDelay is similar to the broadcastDelay, but it targets DHT/ContentRouting
3841
// peer discovery and a gentle broadcast of a single random live WANT to all connected peers.
3942
// Considering no DHT usage and broadcasting configured by broadcastDelay, we set
@@ -121,6 +124,7 @@ func NewClient(
121124
opts := []client.Option{
122125
client.SetSimulateDontHavesOnTimeout(simulateDontHaves),
123126
client.WithDontHaveTimeoutConfig(simulateDontHaveConfig),
127+
client.WithPerPeerRebroadcastDisabled(disablePerPeerRetries),
124128
// Prevents Has calls to Blockstore for metric that counts duplicates
125129
// Unnecessary for our use case, so we can save some disk lookups.
126130
client.WithoutDuplicatedBlockStats(),

0 commit comments

Comments
 (0)