176 /* Output ring buffer */
200  * Try send as many bytes as possible from output ring buffer
201  * @param rb Output ring buffer
221     /* Space in TCP output buffer is larger than available in ring buffer linear portion */  in mqtt_output_send()
415 /* Output message build helpers */
453  * @param rb Output ring buffer
476  * Check output buffer space
477  * @param rb Output ring buffer
576         if (mqtt_output_check_space(&client->output, 0) != 0) {  in mqtt_cyclic_timer()
577           mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PINGREQ, 0, 0, 0, 0);  in mqtt_cyclic_timer()
606   if (mqtt_output_check_space(&client->output, 2)) {  in pub_ack_rec_rel_response()
607     mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2);  in pub_ack_rec_rel_response()
608     mqtt_output_append_u16(&client->output, pkt_id);  in pub_ack_rec_rel_response()
609     mqtt_output_send(&client->output, client->conn);  in pub_ack_rec_rel_response()
924     /* Try send any remaining buffers from output queue */  in mqtt_tcp_sent_cb()
925     mqtt_output_send(&client->output, client->conn);  in mqtt_tcp_sent_cb()
939   LWIP_UNUSED_ARG(err); /* only used for debug output */  in mqtt_tcp_err_cb()
958     /* Try send any remaining buffers from output queue */  in mqtt_tcp_poll_cb()
959     mqtt_output_send(&client->output, tpcb);  in mqtt_tcp_poll_cb()
996   /* Start transmission from output queue, connect message is the first one out*/  in mqtt_tcp_connect_cb()
997   mqtt_output_send(&client->output, client->conn);  in mqtt_tcp_connect_cb()
1061   if (mqtt_output_check_space(&client->output, remaining_length) == 0) {  in mqtt_publish()
1066 …mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain, remaining_…  in mqtt_publish()
1069   mqtt_output_append_string(&client->output, topic, topic_len);  in mqtt_publish()
1073     mqtt_output_append_u16(&client->output, pkt_id);  in mqtt_publish()
1078     mqtt_output_append_buf(&client->output, payload, payload_length);  in mqtt_publish()
1082   mqtt_output_send(&client->output, client->conn);  in mqtt_publish()
1131   if (mqtt_output_check_space(&client->output, remaining_length) == 0) {  in mqtt_sub_unsub()
1138 …mqtt_output_append_fixed_header(&client->output, sub ? MQTT_MSG_TYPE_SUBSCRIBE : MQTT_MSG_TYPE_UNS…  in mqtt_sub_unsub()
1140   mqtt_output_append_u16(&client->output, pkt_id);  in mqtt_sub_unsub()
1142   mqtt_output_append_string(&client->output, topic, topic_len);  in mqtt_sub_unsub()
1145     mqtt_output_append_u8(&client->output, LWIP_MIN(qos, 2));  in mqtt_sub_unsub()
1149   mqtt_output_send(&client->output, client->conn);  in mqtt_sub_unsub()
1256   if (mqtt_output_check_space(&client->output, remaining_length) == 0) {  in mqtt_client_connect()
1286 …mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_CONNECT, 0, 0, 0, remaining_length);  in mqtt_client_connect()
1288   mqtt_output_append_string(&client->output, "MQTT", 4);  in mqtt_client_connect()
1290   mqtt_output_append_u8(&client->output, 4);  in mqtt_client_connect()
1292   mqtt_output_append_u8(&client->output, flags);  in mqtt_client_connect()
1294   mqtt_output_append_u16(&client->output, client_info->keep_alive);  in mqtt_client_connect()
1296   mqtt_output_append_string(&client->output, client_info->client_id, client_id_length);  in mqtt_client_connect()
1299     mqtt_output_append_string(&client->output, client_info->will_topic, will_topic_len);  in mqtt_client_connect()
1300     mqtt_output_append_string(&client->output, client_info->will_msg, will_msg_len);  in mqtt_client_connect()