ScuroNeko/mtg
1
0
Fork 0
mirror of https://github.com/ScuroNeko/mtg.git synced 2026-09-01 16:01:55 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #363 from 9seconds/relay-buffer

Browse Source 
Decrease relay buffer size
This commit is contained in:
Sergei Arkhipov
2026-03-14 14:15:52 +01:00
committed by GitHub
parent 879ebd132d bb90bcc127
commit ed4e511560
2 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mtglib/internal/relay/init.go
-4
View File
@@ -1,9 +1,5 @@
package relay package relay
const (
copyBufferSize = 64 * 1024
)
type Logger interface { type Logger interface {
Printf(msg string, args ...any) Printf(msg string, args ...any)
} }
mtglib/internal/relay/relay.go
+2 -1
View File
@@ -6,6 +6,7 @@ import (
"io" "io"
"github.com/9seconds/mtg/v2/essentials" "github.com/9seconds/mtg/v2/essentials"
"github.com/9seconds/mtg/v2/mtglib/internal/tls"
) )
func Relay(ctx context.Context, log Logger, telegramConn, clientConn essentials.Conn) { func Relay(ctx context.Context, log Logger, telegramConn, clientConn essentials.Conn) {
@@ -35,7 +36,7 @@ func Relay(ctx context.Context, log Logger, telegramConn, clientConn essentials.
} }
func pump(log Logger, src, dst essentials.Conn, direction string) { func pump(log Logger, src, dst essentials.Conn, direction string) {
var buf [copyBufferSize]byte var buf [tls.MaxRecordPayloadSize]byte
defer src.CloseRead() //nolint: errcheck defer src.CloseRead() //nolint: errcheck
defer dst.CloseWrite() //nolint: errcheck defer dst.CloseWrite() //nolint: errcheck