cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

feat: increase data transfer timeouts

Browse Source
This commit is contained in:
Dirk McCormick 2021-05-19 12:48:28 -06:00
parent 3a99f95f8e
commit 706fdcbb80
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
node/modules/client.go
View File

@ -134,8 +134,8 @@ func NewClientGraphsyncDataTransfer(lc fx.Lifecycle, h host.Host, gs dtypes.Grap
// data-transfer push / pull channel restart configuration: // data-transfer push / pull channel restart configuration:
dtRestartConfig := dtimpl.ChannelRestartConfig(channelmonitor.Config{ dtRestartConfig := dtimpl.ChannelRestartConfig(channelmonitor.Config{
// Wait up to 30s for the other side to respond to an Open channel message // Wait up to 2m for the other side to respond to an Open channel message
AcceptTimeout: 30 * time.Second, AcceptTimeout: 2 * time.Minute,
// When an error occurs, wait a little while until all related errors // When an error occurs, wait a little while until all related errors
// have fired before sending a restart message // have fired before sending a restart message
RestartDebounce: 10 * time.Second, RestartDebounce: 10 * time.Second,
@ -146,9 +146,9 @@ func NewClientGraphsyncDataTransfer(lc fx.Lifecycle, h host.Host, gs dtypes.Grap
// After sending a restart message, the time to wait for the peer to // After sending a restart message, the time to wait for the peer to
// respond with an ack of the restart // respond with an ack of the restart
RestartAckTimeout: 30 * time.Second, RestartAckTimeout: 30 * time.Second,
// Wait up to 30s for the other side to send a Complete message once all // Wait up to 10m for the other side to send a Complete message once all
// data has been sent / received // data has been sent / received
CompleteTimeout: 30 * time.Second, CompleteTimeout: 10 * time.Minute,
}) })
dt, err := dtimpl.NewDataTransfer(dtDs, filepath.Join(r.Path(), "data-transfer"), net, transport, dtRestartConfig) dt, err := dtimpl.NewDataTransfer(dtDs, filepath.Join(r.Path(), "data-transfer"), net, transport, dtRestartConfig)
if err != nil { if err != nil {