wait for handle message
This commit is contained in:
@@ -128,6 +128,7 @@ func WaitForFrame(conn net.Conn, resultChan chan<- FrameWithPayload) error {
|
|||||||
}
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
log.Println("Checksum mismatch")
|
||||||
return fmt.Errorf("checksum mismatch")
|
return fmt.Errorf("checksum mismatch")
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -165,7 +166,7 @@ func (l *GenericListener) HandleConnection(conn net.Conn) {
|
|||||||
go WaitForFrame(conn, ch)
|
go WaitForFrame(conn, ch)
|
||||||
select {
|
select {
|
||||||
case frame := <-ch:
|
case frame := <-ch:
|
||||||
go l.HandleFrame(conn, &frame)
|
l.HandleFrame(conn, &frame)
|
||||||
case <-time.After(MaxCallDuration):
|
case <-time.After(MaxCallDuration):
|
||||||
close(ch)
|
close(ch)
|
||||||
log.Printf("Timeout waiting for frame\n")
|
log.Printf("Timeout waiting for frame\n")
|
||||||
|
|||||||
Reference in New Issue
Block a user