(wrt http.ResponseWriter, msg any)
| 20 | ) |
| 21 | |
| 22 | func (sess *Session) sendMessageLp(wrt http.ResponseWriter, msg any) bool { |
| 23 | if len(sess.send) > sendQueueLimit { |
| 24 | logs.Err.Println("longPoll: outbound queue limit exceeded", sess.sid) |
| 25 | return false |
| 26 | } |
| 27 | |
| 28 | statsInc("OutgoingMessagesLongpollTotal", 1) |
| 29 | if err := lpWrite(wrt, msg); err != nil { |
| 30 | logs.Err.Println("longPoll: writeOnce failed", sess.sid, err) |
| 31 | return false |
| 32 | } |
| 33 | |
| 34 | return true |
| 35 | } |
| 36 | |
| 37 | func (sess *Session) writeOnce(wrt http.ResponseWriter, req *http.Request) { |
| 38 | for { |