From 926814260d500ec4a2c0bfe613d52f9ff8fd4252 Mon Sep 17 00:00:00 2001
From: poiuty <poiuty@protonmail.com>
Date: Mon, 3 Jul 2023 22:50:23 +0300
Subject: [PATCH] update timeout and buffer size

---
 app/main.go | 10 ++++++----
 app/save.go |  1 +
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/app/main.go b/app/main.go
index 6d3d92f..4316133 100644
--- a/app/main.go
+++ b/app/main.go
@@ -28,10 +28,10 @@ var (
 
 	json = jsoniter.ConfigCompatibleWithStandardLibrary
 
-	socketServer = make(chan []byte, 100)
+	socketServer = make(chan []byte, 1)
 
-	save = make(chan saveData, 100)
-	slog = make(chan saveLog, 100)
+	save = make(chan saveData, 1)
+	slog = make(chan saveLog, 32)
 
 	rooms = &Rooms{
 		Count: make(chan int),
@@ -99,8 +99,10 @@ func socketHandler() {
 		select {
 		case b := <-socketServer:
 
+			//fmt.Println("socketServer", len(socketServer), cap(socketServer))
+
 			if conn == nil || conn.RemoteAddr() == nil {
-				conn, err = net.DialTimeout("unix", "/tmp/echo.sock", time.Second*5)
+				conn, err = net.DialTimeout("unix", "/tmp/echo.sock", time.Millisecond*10)
 				if err != nil {
 					fmt.Println(err.Error())
 					continue
diff --git a/app/save.go b/app/save.go
index 16344e7..fa76c97 100644
--- a/app/save.go
+++ b/app/save.go
@@ -204,6 +204,7 @@ func saveLogs() {
 				bulk = nil
 			}
 		case m := <-slog:
+			//fmt.Println("slog", len(slog), cap(slog))
 			if len(m.Mes) > 0 {
 				bulk = append(bulk, m)
 			}