Fix error handling
This commit is contained in:
@@ -81,6 +81,7 @@ func (ws *WSConnection) Open() {
|
|||||||
log.Printf("Client connected")
|
log.Printf("Client connected")
|
||||||
ws.ReadChan = make(chan string, 1024)
|
ws.ReadChan = make(chan string, 1024)
|
||||||
ws.WriteChan = make(chan string, 1024)
|
ws.WriteChan = make(chan string, 1024)
|
||||||
|
ws.ErrorChan = make(chan error, 16)
|
||||||
|
|
||||||
ws.conn.SetReadLimit(1024)
|
ws.conn.SetReadLimit(1024)
|
||||||
ws.conn.SetReadDeadline(time.Now().Add(IDLE_TIMEOUT))
|
ws.conn.SetReadDeadline(time.Now().Add(IDLE_TIMEOUT))
|
||||||
@@ -103,6 +104,7 @@ func (ws *WSConnection) Open() {
|
|||||||
case err := <-ws.ErrorChan:
|
case err := <-ws.ErrorChan:
|
||||||
log.Printf("Error: %v", err)
|
log.Printf("Error: %v", err)
|
||||||
ws.conn.Close()
|
ws.conn.Close()
|
||||||
|
log.Printf("Client disconnected")
|
||||||
connections[ws] = false
|
connections[ws] = false
|
||||||
return
|
return
|
||||||
// case msg := <-wsBroadcast:
|
// case msg := <-wsBroadcast:
|
||||||
|
Reference in New Issue
Block a user