Commit 4f209e64 authored by nanahira's avatar nanahira

add timeout for global guest read

parent c688449c
Pipeline #838 passed with stage
in 4 minutes and 8 seconds
...@@ -157,19 +157,15 @@ func listenUDP(ws *websocket.Conn) { ...@@ -157,19 +157,15 @@ func listenUDP(ws *websocket.Conn) {
ws.Write([]byte(reply)) ws.Write([]byte(reply))
for { for {
message := make([]byte, 2048) message := make([]byte, 2048)
/*derr := guest.SetReadDeadline(time.Now().Add(2 * time.Minute)) derr := guest.SetReadDeadline(time.Now().Add(10 * time.Minute))
if derr != nil { if derr != nil {
log.Println("Guest deadline error: ", derr) log.Println("Guest deadline error: ", guest.LocalAddr().(*net.UDPAddr).Port, derr)
return return
}*/ }
length, guestAddr, err := guest.ReadFromUDP(message) length, guestAddr, err := guest.ReadFromUDP(message)
if err != nil { if err != nil {
log.Println("Guest read error: ", err) log.Println("Guest read error: ", guest.LocalAddr().(*net.UDPAddr).Port, err)
/*if ok { return
channel <- GuestToHostMessage{data: nil, exit: true}
guestChannelList[guestAddr.String()] = nil
}*/
continue
} }
channel, ok := guestChannelList[guestAddr.String()] channel, ok := guestChannelList[guestAddr.String()]
if !ok { if !ok {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment