moth11.net / lrcd
websocket-based lrcproto server
fork atom

add debugging

moth11.net 80ff42ea 1031f11a

+6
unified split
+6
server.go
··· 210 for { 211 select { 212 case <-client.ctx.Done(): 213 return 214 case <-s.ctx.Done(): 215 return 216 default: 217 _, data, err := client.conn.ReadMessage() 218 if err != nil { 219 client.cancel() 220 return 221 } ··· 235 for { 236 select { 237 case <-client.ctx.Done(): 238 return 239 case <-s.ctx.Done(): 240 return 241 case data, ok := <-client.dataChan: 242 if !ok { 243 client.cancel() 244 return 245 }
··· 210 for { 211 select { 212 case <-client.ctx.Done(): 213 + s.logDebug("exiting listenToWS: client done") 214 return 215 case <-s.ctx.Done(): 216 + s.logDebug("exiting listenToWS: server done") 217 return 218 default: 219 _, data, err := client.conn.ReadMessage() 220 if err != nil { 221 + s.logDebug("canceling client: read error") 222 client.cancel() 223 return 224 } ··· 238 for { 239 select { 240 case <-client.ctx.Done(): 241 + s.logDebug("exiting wsWriter: client done") 242 return 243 case <-s.ctx.Done(): 244 + s.logDebug("exiting wsWriter: server done") 245 return 246 case data, ok := <-client.dataChan: 247 if !ok { 248 + s.logDebug("canceling client: dataChan closed") 249 client.cancel() 250 return 251 }