Lines Matching refs:cur
34 buf->cur = client->tx_buf; in tx_buf_init()
92 err_code = mqtt_transport_write(client, packet.cur, in client_connect()
93 packet.end - packet.cur); in client_connect()
269 io_vector[0].iov_base = packet.cur; in mqtt_publish()
270 io_vector[0].iov_len = packet.end - packet.cur; in mqtt_publish()
316 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos1_ack()
353 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos2_receive()
390 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos2_release()
427 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos2_complete()
462 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_disconnect()
502 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_subscribe()
536 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_unsubscribe()
565 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_ping()