mirror of
https://github.com/openlibrecommunity/olcrtc.git
synced 2026-07-03 14:05:39 +02:00
perf: Increase buffer sizes and reduce ticker intervals
This commit is contained in:
@@ -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 {
|
||||
|
||||
+1
-1
@@ -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) {
|
||||
|
||||
@@ -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 {
|
||||
|
||||
Reference in New Issue
Block a user