refactor: apply renamed NewBytesPool with GetBytesPool

This commit is contained in:
yusing
2025-09-02 22:46:16 +08:00
parent c128557c81
commit b051987a1c
5 changed files with 5 additions and 5 deletions

View File

@@ -76,7 +76,7 @@ const (
errBurst = 5
)
var lineBufPool = synk.NewBytesPool()
var lineBufPool = synk.GetBytesPool()
func NewAccessLogger(parent task.Parent, cfg AnyConfig) (*AccessLogger, error) {
io, err := cfg.IO()

View File

@@ -66,7 +66,7 @@ type lineInfo struct {
Size int64 // Size of this line
}
var rotateBytePool = synk.NewBytesPool()
var rotateBytePool = synk.GetBytesPool()
// rotateLogFile rotates the log file based on the retention policy.
// It returns the result of the rotation and an error if any.

View File

@@ -9,7 +9,7 @@ import (
"github.com/yusing/go-proxy/internal/utils/synk"
)
var bufPool = synk.NewBytesPool()
var bufPool = synk.GetBytesPool()
// explicitly implement MarshalJSON to avoid reflection.
func (s *SystemInfo) MarshalJSON() ([]byte, error) {

View File

@@ -21,7 +21,7 @@ type modifyHTML struct {
var ModifyHTML = NewMiddleware[modifyHTML]()
var bytePool = synk.NewBytesPool()
var bytePool = synk.GetBytesPool()
func (m *modifyHTML) before(_ http.ResponseWriter, req *http.Request) bool {
req.Header.Set("Accept-Encoding", "")

View File

@@ -47,7 +47,7 @@ const (
udpReadTimeout = 30 * time.Second
)
var bufPool = synk.NewBytesPool()
var bufPool = synk.GetBytesPool()
func NewUDPUDPStream(listenAddr, dstAddr string) (nettypes.Stream, error) {
dst, err := net.ResolveUDPAddr("udp", dstAddr)