This commit is contained in:
poiuty 2023-07-03 23:44:02 +03:00
parent 06f4b6c002
commit e55475d944

View file

@ -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,8 @@ func socketHandler() {
select {
case b := <-socketServer:
if conn == nil {
conn, err = net.Dial("unix", "/tmp/echo.sock")
if conn == nil || conn.RemoteAddr() == nil {
conn, err = net.DialTimeout("unix", "/tmp/echo.sock", time.Millisecond * 10)
if err != nil {
fmt.Println(err.Error())
continue