76 	struct buf_ctx packet;  in client_connect()  local
83 	tx_buf_init(client, &packet);  in client_connect()
86 	err_code = connect_request_encode(client, &packet);  in client_connect()
92 	err_code = mqtt_transport_write(client, packet.cur,  in client_connect()
93 					packet.end - packet.cur);  in client_connect()
243 	struct buf_ctx packet;  in mqtt_publish()  local
257 	tx_buf_init(client, &packet);  in mqtt_publish()
264 	err_code = publish_encode(param, &packet);  in mqtt_publish()
269 	io_vector[0].iov_base = packet.cur;  in mqtt_publish()
270 	io_vector[0].iov_len = packet.end - packet.cur;  in mqtt_publish()
294 	struct buf_ctx packet;  in mqtt_publish_qos1_ack()  local
304 	tx_buf_init(client, &packet);  in mqtt_publish_qos1_ack()
311 	err_code = publish_ack_encode(param, &packet);  in mqtt_publish_qos1_ack()
316 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_publish_qos1_ack()
331 	struct buf_ctx packet;  in mqtt_publish_qos2_receive()  local
341 	tx_buf_init(client, &packet);  in mqtt_publish_qos2_receive()
348 	err_code = publish_receive_encode(param, &packet);  in mqtt_publish_qos2_receive()
353 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_publish_qos2_receive()
368 	struct buf_ctx packet;  in mqtt_publish_qos2_release()  local
378 	tx_buf_init(client, &packet);  in mqtt_publish_qos2_release()
385 	err_code = publish_release_encode(param, &packet);  in mqtt_publish_qos2_release()
390 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_publish_qos2_release()
405 	struct buf_ctx packet;  in mqtt_publish_qos2_complete()  local
415 	tx_buf_init(client, &packet);  in mqtt_publish_qos2_complete()
422 	err_code = publish_complete_encode(param, &packet);  in mqtt_publish_qos2_complete()
427 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_publish_qos2_complete()
444 	struct buf_ctx packet;  in mqtt_disconnect()  local
450 	tx_buf_init(client, &packet);  in mqtt_disconnect()
457 	err_code = disconnect_encode(&packet);  in mqtt_disconnect()
462 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_disconnect()
479 	struct buf_ctx packet;  in mqtt_subscribe()  local
490 	tx_buf_init(client, &packet);  in mqtt_subscribe()
497 	err_code = subscribe_encode(param, &packet);  in mqtt_subscribe()
502 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_subscribe()
517 	struct buf_ctx packet;  in mqtt_unsubscribe()  local
524 	tx_buf_init(client, &packet);  in mqtt_unsubscribe()
531 	err_code = unsubscribe_encode(param, &packet);  in mqtt_unsubscribe()
536 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_unsubscribe()
547 	struct buf_ctx packet;  in mqtt_ping()  local
553 	tx_buf_init(client, &packet);  in mqtt_ping()
560 	err_code = ping_request_encode(&packet);  in mqtt_ping()
565 	err_code = client_write(client, packet.cur, packet.end - packet.cur);  in mqtt_ping()