Просмотр исходного кода

Decrease relay buffer size

Even if it makes sense to have a huge buffers, we do artificial delays
now. In that case we could achieve the same results with a lower buffer.
If not, then we won't send a packet bigger that this value
tags/v2.2.0^2^2
9seconds 1 месяц назад
Родитель
Сommit
bb90bcc127
2 измененных файлов: 2 добавлений и 5 удалений
  1. 0
    4
      mtglib/internal/relay/init.go
  2. 2
    1
      mtglib/internal/relay/relay.go

+ 0
- 4
mtglib/internal/relay/init.go Просмотреть файл

1
 package relay
1
 package relay
2
 
2
 
3
-const (
4
-	copyBufferSize = 64 * 1024
5
-)
6
-
7
 type Logger interface {
3
 type Logger interface {
8
 	Printf(msg string, args ...any)
4
 	Printf(msg string, args ...any)
9
 }
5
 }

+ 2
- 1
mtglib/internal/relay/relay.go Просмотреть файл

6
 	"io"
6
 	"io"
7
 
7
 
8
 	"github.com/9seconds/mtg/v2/essentials"
8
 	"github.com/9seconds/mtg/v2/essentials"
9
+	"github.com/9seconds/mtg/v2/mtglib/internal/tls"
9
 )
10
 )
10
 
11
 
11
 func Relay(ctx context.Context, log Logger, telegramConn, clientConn essentials.Conn) {
12
 func Relay(ctx context.Context, log Logger, telegramConn, clientConn essentials.Conn) {
35
 }
36
 }
36
 
37
 
37
 func pump(log Logger, src, dst essentials.Conn, direction string) {
38
 func pump(log Logger, src, dst essentials.Conn, direction string) {
38
-	var buf [copyBufferSize]byte
39
+	var buf [tls.MaxRecordPayloadSize]byte
39
 
40
 
40
 	defer src.CloseRead()  //nolint: errcheck
41
 	defer src.CloseRead()  //nolint: errcheck
41
 	defer dst.CloseWrite() //nolint: errcheck
42
 	defer dst.CloseWrite() //nolint: errcheck

Загрузка…
Отмена
Сохранить