(msg any)
| 74 | } |
| 75 | |
| 76 | func (sess *Session) sendMessageGrpc(msg any) bool { |
| 77 | if len(sess.send) > sendQueueLimit { |
| 78 | logs.Err.Println("grpc: outbound queue limit exceeded", sess.sid) |
| 79 | return false |
| 80 | } |
| 81 | statsInc("OutgoingMessagesGrpcTotal", 1) |
| 82 | if err := grpcWrite(sess, msg); err != nil { |
| 83 | logs.Err.Println("grpc: write", sess.sid, err) |
| 84 | return false |
| 85 | } |
| 86 | return true |
| 87 | } |
| 88 | |
| 89 | func (sess *Session) writeGrpcLoop() { |
| 90 | defer func() { |
no test coverage detected