mirror of
https://github.com/e1732a364fed/v2ray_simple.git
synced 2025-11-01 20:42:39 +08:00
移除-bl参数。buf尺寸过小的话,反倒会导致更大的内存泄漏问题
This commit is contained in:
2
main.go
2
main.go
@@ -112,8 +112,6 @@ func main() {
|
|||||||
defer p.Stop()
|
defer p.Stop()
|
||||||
}
|
}
|
||||||
|
|
||||||
utils.AdjustBufSize()
|
|
||||||
|
|
||||||
ll_beforeLoadConfigFile := utils.LogLevel
|
ll_beforeLoadConfigFile := utils.LogLevel
|
||||||
usereadv_beforeLoadConfigFile := netLayer.UseReadv
|
usereadv_beforeLoadConfigFile := netLayer.UseReadv
|
||||||
|
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ package utils
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"flag"
|
|
||||||
"sync"
|
"sync"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -25,12 +24,9 @@ const StandardBytesLength int = 1500
|
|||||||
// https://en.wikipedia.org/wiki/Maximum_transmission_unit
|
// https://en.wikipedia.org/wiki/Maximum_transmission_unit
|
||||||
|
|
||||||
//本作设定的最大buf大小,64k
|
//本作设定的最大buf大小,64k
|
||||||
var MaxBufLen = DefaultMaxBufLen
|
const MaxBufLen = 64 * 1024
|
||||||
|
|
||||||
const DefaultMaxBufLen = 64 * 1024
|
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
flag.IntVar(&MaxBufLen, "bl", DefaultMaxBufLen, "buf len")
|
|
||||||
|
|
||||||
standardBytesPool = sync.Pool{
|
standardBytesPool = sync.Pool{
|
||||||
New: func() interface{} {
|
New: func() interface{} {
|
||||||
@@ -51,15 +47,6 @@ func init() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//给了参数调节buf大小后,需要更新pool
|
|
||||||
func AdjustBufSize() {
|
|
||||||
standardPacketPool = sync.Pool{
|
|
||||||
New: func() interface{} {
|
|
||||||
return make([]byte, MaxBufLen)
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//从Pool中获取一个 *bytes.Buffer
|
//从Pool中获取一个 *bytes.Buffer
|
||||||
func GetBuf() *bytes.Buffer {
|
func GetBuf() *bytes.Buffer {
|
||||||
return bufPool.Get().(*bytes.Buffer)
|
return bufPool.Get().(*bytes.Buffer)
|
||||||
|
|||||||
Reference in New Issue
Block a user