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

amend restart config

Browse Source
This commit is contained in:
Anton Evangelatov 2021-03-19 14:08:50 +02:00
parent 86772a09c7
commit ac576c75d4
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
node/modules/client.go
View File

@ -138,15 +138,14 @@ func NewClientGraphsyncDataTransfer(lc fx.Lifecycle, h host.Host, gs dtypes.Grap
// data-transfer push channel restart configuration // data-transfer push channel restart configuration
dtRestartConf := dtimpl.ChannelRestartConfig(channelmonitor.Config{ dtRestartConf := dtimpl.ChannelRestartConfig(channelmonitor.Config{
AcceptTimeout: 100 * time.Millisecond, AcceptTimeout: 30 * time.Second,
Interval: 100 * time.Millisecond, Interval: 1 * time.Minute,
MinBytesTransferred: 1, MinBytesTransferred: 1024,
ChecksPerInterval: 10, ChecksPerInterval: 10,
RestartBackoff: 500 * time.Millisecond, RestartBackoff: 10 * time.Minute,
MaxConsecutiveRestarts: 5, MaxConsecutiveRestarts: 3,
CompleteTimeout: 100 * time.Millisecond, CompleteTimeout: 30 * time.Second,
}) })
//dtRestartConfig := dtimpl.PushChannelRestartConfig(time.Minute, 10, 1024, 10*time.Minute, 3)
dt, err := dtimpl.NewDataTransfer(dtDs, filepath.Join(r.Path(), "data-transfer"), net, transport, sc, dtRestartConf) dt, err := dtimpl.NewDataTransfer(dtDs, filepath.Join(r.Path(), "data-transfer"), net, transport, sc, dtRestartConf)
if err != nil { if err != nil {
return nil, err return nil, err