diff --git a/internal/client/client.go b/internal/client/client.go index b04d379..91c0810 100644 --- a/internal/client/client.go +++ b/internal/client/client.go @@ -254,7 +254,7 @@ func (c *Client) handleSOCKS5(conn net.Conn) { go func() { defer close(done) - buf := make([]byte, 4096) + buf := make([]byte, 32768) for { n, err := conn.Read(buf) if err != nil { @@ -269,7 +269,7 @@ func (c *Client) handleSOCKS5(conn net.Conn) { go func() { defer close(streamClosed) - ticker := time.NewTicker(10 * time.Millisecond) + ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for { diff --git a/internal/mux/mux.go b/internal/mux/mux.go index 9149cb1..2760d7b 100644 --- a/internal/mux/mux.go +++ b/internal/mux/mux.go @@ -74,7 +74,7 @@ func (m *Multiplexer) SendData(sid uint16, data []byte) error { return nil } - const chunkSize = 7168 + const chunkSize = 16384 for i := 0; i < len(data); i += chunkSize { end := i + chunkSize if end > len(data) { diff --git a/internal/server/server.go b/internal/server/server.go index 0621be9..e37079b 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -152,7 +152,7 @@ func (s *Server) onData(data []byte) { } func (s *Server) run() error { - ticker := time.NewTicker(10 * time.Millisecond) + ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for range ticker.C { @@ -234,7 +234,7 @@ func (s *Server) handleConnect(sid uint16, req ConnectRequest) { s.connMu.Unlock() }() - buf := make([]byte, 4096) + buf := make([]byte, 32768) for { n, err := conn.Read(buf) if err != nil {