gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Tweak flow control and slow start

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-03-10 17:30:25 -05:00
parent 27f51d4028
commit c783bf1bed
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server/consumer.go
View File

@@ -236,7 +236,7 @@ const (
JsDeleteWaitTimeDefault = 5 * time.Second
// JsFlowControlMaxPending specifies default pending bytes during flow control that can be
// outstanding.
JsFlowControlMaxPending = 32 * 1024 * 1024
JsFlowControlMaxPending = 16 * 1024 * 1024
)
func (mset *stream) addConsumer(config *ConsumerConfig) (*consumer, error) {
@@ -2091,14 +2091,8 @@ func (o *consumer) needFlowControl() bool {
return false
}
// Decide whether to send a flow control message which we will need the user to respond.
// We send if we are at the limit or over, and at 25%, 50% and 75%.
if o.pbytes >= o.maxpb {
return true
} else if o.pfcs == 0 && o.pbytes > o.maxpb/4 {
return true
} else if o.pfcs == 1 && o.pbytes > o.maxpb/2 {
return true
} else if o.pfcs == 2 && o.pbytes > o.maxpb*3/4 {
// We send when we are over 50% of the current window.
if o.pfcs == 0 && o.pbytes > o.maxpb/2 {
return true
}
return false