Lines Matching refs:output
577 if (mqtt_output_check_space(&client->output, 0) != 0) { in mqtt_cyclic_timer()
578 mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PINGREQ, 0, 0, 0, 0); in mqtt_cyclic_timer()
607 if (mqtt_output_check_space(&client->output, 2)) { in pub_ack_rec_rel_response()
608 mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2); in pub_ack_rec_rel_response()
609 mqtt_output_append_u16(&client->output, pkt_id); in pub_ack_rec_rel_response()
610 mqtt_output_send(&client->output, client->conn); in pub_ack_rec_rel_response()
926 mqtt_output_send(&client->output, client->conn); in mqtt_tcp_sent_cb()
960 mqtt_output_send(&client->output, tpcb); in mqtt_tcp_poll_cb()
998 mqtt_output_send(&client->output, client->conn); in mqtt_tcp_connect_cb()
1062 if (mqtt_output_check_space(&client->output, remaining_length) == 0) { in mqtt_publish()
1067 …mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain, remaining_… in mqtt_publish()
1070 mqtt_output_append_string(&client->output, topic, topic_len); in mqtt_publish()
1074 mqtt_output_append_u16(&client->output, pkt_id); in mqtt_publish()
1079 mqtt_output_append_buf(&client->output, payload, payload_length); in mqtt_publish()
1083 mqtt_output_send(&client->output, client->conn); in mqtt_publish()
1132 if (mqtt_output_check_space(&client->output, remaining_length) == 0) { in mqtt_sub_unsub()
1139 …mqtt_output_append_fixed_header(&client->output, sub ? MQTT_MSG_TYPE_SUBSCRIBE : MQTT_MSG_TYPE_UNS… in mqtt_sub_unsub()
1141 mqtt_output_append_u16(&client->output, pkt_id); in mqtt_sub_unsub()
1143 mqtt_output_append_string(&client->output, topic, topic_len); in mqtt_sub_unsub()
1146 mqtt_output_append_u8(&client->output, LWIP_MIN(qos, 2)); in mqtt_sub_unsub()
1150 mqtt_output_send(&client->output, client->conn); in mqtt_sub_unsub()
1257 if (mqtt_output_check_space(&client->output, remaining_length) == 0) { in mqtt_client_connect()
1287 …mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_CONNECT, 0, 0, 0, remaining_length); in mqtt_client_connect()
1289 mqtt_output_append_string(&client->output, "MQTT", 4); in mqtt_client_connect()
1291 mqtt_output_append_u8(&client->output, 4); in mqtt_client_connect()
1293 mqtt_output_append_u8(&client->output, flags); in mqtt_client_connect()
1295 mqtt_output_append_u16(&client->output, client_info->keep_alive); in mqtt_client_connect()
1297 mqtt_output_append_string(&client->output, client_info->client_id, client_id_length); in mqtt_client_connect()
1300 mqtt_output_append_string(&client->output, client_info->will_topic, will_topic_len); in mqtt_client_connect()
1301 mqtt_output_append_string(&client->output, client_info->will_msg, will_msg_len); in mqtt_client_connect()