删除无用的服务
This commit is contained in:
parent
8fc19e1fb2
commit
a495e4e459
|
@ -402,7 +402,7 @@ func (w *wsConnectItem) sendToOutChan(data []byte) {
|
|||
return
|
||||
case w.outChan <- data:
|
||||
return
|
||||
case <-time.After(time.Millisecond * 200): //阻塞超过200ms丢弃
|
||||
case <-time.After(time.Millisecond * 50): //阻塞超过50ms丢弃
|
||||
logx.Error("failed to send to out chan,time expired,data:", string(data))
|
||||
return
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue
Block a user