mirror of
https://github.com/Sagit-chu/flvx.git
synced 2026-10-04 01:06:36 +08:00
fix(udp): mark connection active on WriteQueue to prevent idle timeout race
This commit is contained in:
@@ -227,6 +227,7 @@ func (c *conn) SetIdle(idle bool) {
|
|||||||
func (c *conn) WriteQueue(b []byte) error {
|
func (c *conn) WriteQueue(b []byte) error {
|
||||||
select {
|
select {
|
||||||
case c.rc <- b:
|
case c.rc <- b:
|
||||||
|
c.SetIdle(false)
|
||||||
return nil
|
return nil
|
||||||
|
|
||||||
case <-c.closed:
|
case <-c.closed:
|
||||||
|
|||||||
Reference in New Issue
Block a user