diff --git a/proxy/direct.go b/proxy/direct.go index 6d01c0d..2d13a13 100644 --- a/proxy/direct.go +++ b/proxy/direct.go @@ -13,15 +13,6 @@ import ( const directPipeBufferSize = 1024 -var ( - directPipePool = sync.Pool{ - New: func() interface{} { - rv := make([]byte, directPipeBufferSize) - return &rv - }, - } -) - func directConnection(request *protocol.TelegramRequest) error { telegramConnRaw, err := obfuscated2.TelegramProtocol(request) if err != nil { @@ -51,10 +42,9 @@ func directPipe(dst io.WriteCloser, src io.ReadCloser, wg *sync.WaitGroup, logge wg.Done() }() - buf := directPipePool.Get().(*[]byte) - defer directPipePool.Put(buf) + buf := [directPipeBufferSize]byte{} - if _, err := io.CopyBuffer(dst, src, *buf); err != nil { + if _, err := io.CopyBuffer(dst, src, buf[:]); err != nil { logger.Debugw("Cannot pump sockets", "error", err) } }