1 Star 0 Fork 0

zhangjungang/beats

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
.github
auditbeat
deploy/kubernetes
dev-tools
docs/devguide
filebeat
generator
heartbeat
libbeat
_meta
api
beat
cfgfile
cloudid
cmd
common
dashboards
docs
logp
ml-importer
mock
monitoring
outputs
codec
console
elasticsearch
fileout
kafka
logstash
async.go
async_test.go
ca_invalid_test.key
ca_invalid_test.pem
ca_test.key
ca_test.pem
client_test.go
common_test.go
config.go
enc.go
logstash.go
logstash_integration_test.go
logstash_test.go
sync.go
sync_test.go
window.go
window_test.go
outest
outil
redis
transport
backoff.go
failover.go
hosts.go
metrics.go
output_reg.go
outputs.go
plugin.go
tls.go
tls_test.go
util.go
paths
plugin
processors
publisher
scripts
service
setup/kibana
template
testing
tests
version
.gitignore
Dockerfile
Makefile
README.md
docker-compose.yml
libbeat.go
libbeat_test.go
metricbeat
packetbeat
script
testing/environments
vendor
winlogbeat
.appveyor.yml
.editorconfig
.gitattributes
.gitignore
.go-version
.pylintrc
.travis.yml
CHANGELOG.asciidoc
CONTRIBUTING.md
LICENSE.txt
Makefile
NOTICE.txt
README.md
Vagrantfile
codecov.yml
reviewdog.yml
setup.yml
克隆/下载
window.go 1.57 KB
一键复制 编辑 原始数据 按行查看 历史
package logstash
import (
"math"
"sync/atomic"
)
type window struct {
windowSize int32
maxOkWindowSize int // max window size sending was successful for
maxWindowSize int
}
func newWindower(start, max int) *window {
w := &window{}
w.init(start, max)
return w
}
func (w *window) init(start, max int) {
*w = window{
windowSize: int32(start),
maxWindowSize: max,
}
}
func (w *window) get() int {
return int(atomic.LoadInt32(&w.windowSize))
}
// Increase window size by factor 1.5 until max window size
// (window size grows exponentially)
// TODO: use duration until ACK to estimate an ok max window size value
func (w *window) tryGrowWindow(batchSize int) {
windowSize := w.get()
if windowSize <= batchSize {
if w.maxOkWindowSize < windowSize {
w.maxOkWindowSize = windowSize
newWindowSize := int(math.Ceil(1.5 * float64(windowSize)))
if windowSize <= batchSize && batchSize < newWindowSize {
newWindowSize = batchSize
}
if newWindowSize > w.maxWindowSize {
newWindowSize = int(w.maxWindowSize)
}
windowSize = newWindowSize
} else if windowSize < w.maxOkWindowSize {
windowSize = int(math.Ceil(1.5 * float64(windowSize)))
if windowSize > w.maxOkWindowSize {
windowSize = w.maxOkWindowSize
}
}
atomic.StoreInt32(&w.windowSize, int32(windowSize))
}
}
func (w *window) shrinkWindow() {
windowSize := w.get()
orig := windowSize
windowSize = windowSize / 2
if windowSize < minWindowSize {
windowSize = minWindowSize
if windowSize == orig {
return
}
}
atomic.StoreInt32(&w.windowSize, int32(windowSize))
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/zhangjungang/beats.git
git@gitee.com:zhangjungang/beats.git
zhangjungang
beats
beats
v6.0.1

搜索帮助