Skip to content

Commit ca6b07e

Browse files
committed
transfer: adjust transfer parameters
1 parent 94eeffd commit ca6b07e

1 file changed

Lines changed: 14 additions & 14 deletions

File tree

transfer.go

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ func DefaultClientSettings() *ClientSettings {
7474
SendBufferSize: DefaultTransferBufferSize,
7575
ForwardBufferSize: DefaultTransferBufferSize,
7676
ReadTimeout: 30 * time.Second,
77-
BufferTimeout: 30 * time.Second,
77+
BufferTimeout: 15 * time.Second,
7878
ControlPingTimeout: time.Duration(0),
7979
SendBufferSettings: DefaultSendBufferSettings(),
8080
ReceiveBufferSettings: DefaultReceiveBufferSettings(),
@@ -96,32 +96,32 @@ func DefaultClientSettingsNoNetworkEvents() *ClientSettings {
9696
func DefaultSendBufferSettings() *SendBufferSettings {
9797
return &SendBufferSettings{
9898
CreateContractTimeout: 30 * time.Second,
99-
CreateContractRetryInterval: 15 * time.Second,
100-
MinResendInterval: 1 * time.Second,
101-
MaxResendInterval: 5 * time.Second,
99+
CreateContractRetryInterval: 5 * time.Second,
100+
MinResendInterval: 2 * time.Second,
101+
MaxResendInterval: 8 * time.Second,
102102
// no backoff
103103
// ResendBackoffScale: 0,
104104
RttScale: 1.2,
105105
RttWindowSize: 128,
106-
RttWindowTimeout: 5 * time.Second,
107-
AckTimeout: 30 * time.Second,
108-
IdleTimeout: 60 * time.Second,
106+
RttWindowTimeout: 60 * time.Second,
107+
AckTimeout: 60 * time.Second,
108+
IdleTimeout: 300 * time.Second,
109109
// pause on resend for selectively acked messaged
110-
SelectiveAckTimeout: 30 * time.Second,
110+
SelectiveAckTimeout: 60 * time.Second,
111111
SequenceBufferSize: DefaultTransferBufferSize,
112112
AckBufferSize: DefaultTransferBufferSize,
113113
MinMessageByteCount: ByteCount(1),
114114
// this includes transport reconnections
115-
WriteTimeout: 30 * time.Second,
115+
WriteTimeout: 15 * time.Second,
116116
ResendQueueMaxByteCount: mib(2),
117-
ContractFillFraction: 0.5,
117+
ContractFillFraction: 0.8,
118118
ProtocolVersion: DefaultProtocolVersion,
119119
}
120120
}
121121

122122
func DefaultReceiveBufferSettings() *ReceiveBufferSettings {
123123
return &ReceiveBufferSettings{
124-
GapTimeout: 30 * time.Second,
124+
GapTimeout: 60 * time.Second,
125125
// the receive idle timeout should be a bit longer than the send idle timeout
126126
IdleTimeout: 120 * time.Second,
127127
SequenceBufferSize: DefaultTransferBufferSize,
@@ -132,7 +132,7 @@ func DefaultReceiveBufferSettings() *ReceiveBufferSettings {
132132
// ResendAbuseMultiple: 0.5,
133133
MaxPeerAuditDuration: 60 * time.Second,
134134
// this includes transport reconnections
135-
WriteTimeout: 30 * time.Second,
135+
WriteTimeout: 15 * time.Second,
136136
ReceiveQueueMaxByteCount: mib(2) + kib(512),
137137
AllowLegacyNack: true,
138138
MaxOpenReceiveContract: 4,
@@ -142,9 +142,9 @@ func DefaultReceiveBufferSettings() *ReceiveBufferSettings {
142142

143143
func DefaultForwardBufferSettings() *ForwardBufferSettings {
144144
return &ForwardBufferSettings{
145-
IdleTimeout: 60 * time.Second,
145+
IdleTimeout: 300 * time.Second,
146146
SequenceBufferSize: DefaultTransferBufferSize,
147-
WriteTimeout: 30 * time.Second,
147+
WriteTimeout: 15 * time.Second,
148148
}
149149
}
150150

0 commit comments

Comments
 (0)