180 /* Output ring buffer */
229  * Try send as many bytes as possible from output ring buffer
230  * @param rb Output ring buffer
250     /* Space in TCP output buffer is larger than available in ring buffer linear portion */  in mqtt_output_send()
447 /* Output message build helpers */
485  * @param rb Output ring buffer
508  * Check output buffer space
509  * @param rb Output ring buffer
608         if (mqtt_output_check_space(&client->output, 0) != 0) {  in mqtt_cyclic_timer()
609           mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PINGREQ, 0, 0, 0, 0);  in mqtt_cyclic_timer()
638   if (mqtt_output_check_space(&client->output, 2)) {  in pub_ack_rec_rel_response()
639     mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2);  in pub_ack_rec_rel_response()
640     mqtt_output_append_u16(&client->output, pkt_id);  in pub_ack_rec_rel_response()
641     mqtt_output_send(&client->output, client->conn);  in pub_ack_rec_rel_response()
997     /* Try send any remaining buffers from output queue */  in mqtt_tcp_sent_cb()
998     mqtt_output_send(&client->output, client->conn);  in mqtt_tcp_sent_cb()
1012   LWIP_UNUSED_ARG(err); /* only used for debug output */  in mqtt_tcp_err_cb()
1031     /* Try send any remaining buffers from output queue */  in mqtt_tcp_poll_cb()
1032     mqtt_output_send(&client->output, tpcb);  in mqtt_tcp_poll_cb()
1069   /* Start transmission from output queue, connect message is the first one out*/  in mqtt_tcp_connect_cb()
1070   mqtt_output_send(&client->output, client->conn);  in mqtt_tcp_connect_cb()
1135   if (mqtt_output_check_space(&client->output, remaining_length) == 0) {  in mqtt_publish()
1140 …mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain, remaining_…  in mqtt_publish()
1143   mqtt_output_append_string(&client->output, topic, topic_len);  in mqtt_publish()
1147     mqtt_output_append_u16(&client->output, pkt_id);  in mqtt_publish()
1152     mqtt_output_append_buf(&client->output, payload, payload_length);  in mqtt_publish()
1156   mqtt_output_send(&client->output, client->conn);  in mqtt_publish()
1206   if (mqtt_output_check_space(&client->output, remaining_length) == 0) {  in mqtt_sub_unsub()
1213 …mqtt_output_append_fixed_header(&client->output, sub ? MQTT_MSG_TYPE_SUBSCRIBE : MQTT_MSG_TYPE_UNS…  in mqtt_sub_unsub()
1215   mqtt_output_append_u16(&client->output, pkt_id);  in mqtt_sub_unsub()
1217   mqtt_output_append_string(&client->output, topic, topic_len);  in mqtt_sub_unsub()
1220     mqtt_output_append_u8(&client->output, LWIP_MIN(qos, 2));  in mqtt_sub_unsub()
1224   mqtt_output_send(&client->output, client->conn);  in mqtt_sub_unsub()
1361   if (mqtt_output_check_space(&client->output, remaining_length) == 0) {  in mqtt_client_connect()
1398 …mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_CONNECT, 0, 0, 0, remaining_length);  in mqtt_client_connect()
1400   mqtt_output_append_string(&client->output, "MQTT", 4);  in mqtt_client_connect()
1402   mqtt_output_append_u8(&client->output, 4);  in mqtt_client_connect()
1404   mqtt_output_append_u8(&client->output, flags);  in mqtt_client_connect()
1406   mqtt_output_append_u16(&client->output, client_info->keep_alive);  in mqtt_client_connect()
1408   mqtt_output_append_string(&client->output, client_info->client_id, client_id_length);  in mqtt_client_connect()
1411     mqtt_output_append_string(&client->output, client_info->will_topic, will_topic_len);  in mqtt_client_connect()
1412     mqtt_output_append_string(&client->output, client_info->will_msg, will_msg_len);  in mqtt_client_connect()
1416     mqtt_output_append_string(&client->output, client_info->client_user, client_user_len);  in mqtt_client_connect()
1420     mqtt_output_append_string(&client->output, client_info->client_pass, client_pass_len);  in mqtt_client_connect()