diff --git a/main.go b/main.go index 7f42fd7..d7987c0 100644 --- a/main.go +++ b/main.go @@ -112,8 +112,6 @@ func main() { defer p.Stop() } - utils.AdjustBufSize() - ll_beforeLoadConfigFile := utils.LogLevel usereadv_beforeLoadConfigFile := netLayer.UseReadv diff --git a/utils/pool.go b/utils/pool.go index fbf4303..8dee7e6 100644 --- a/utils/pool.go +++ b/utils/pool.go @@ -2,7 +2,6 @@ package utils import ( "bytes" - "flag" "sync" ) @@ -25,12 +24,9 @@ const StandardBytesLength int = 1500 // https://en.wikipedia.org/wiki/Maximum_transmission_unit //本作设定的最大buf大小,64k -var MaxBufLen = DefaultMaxBufLen - -const DefaultMaxBufLen = 64 * 1024 +const MaxBufLen = 64 * 1024 func init() { - flag.IntVar(&MaxBufLen, "bl", DefaultMaxBufLen, "buf len") standardBytesPool = sync.Pool{ 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 func GetBuf() *bytes.Buffer { return bufPool.Get().(*bytes.Buffer)