Lines Matching defs:client

166 msg_generate_packet_id(mqtt_client_t *client)  in msg_generate_packet_id()
505 mqtt_close(mqtt_client_t *client, mqtt_connection_status_t reason) in mqtt_close()
547 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_cyclic_timer() local
603 pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos) in pub_ack_rec_rel_response()
640 …mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_idx, u16_t length, u32_t remaining_len… in mqtt_message_received()
778 mqtt_parse_incoming(mqtt_client_t *client, struct pbuf *p) in mqtt_parse_incoming()
861 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_recv_cb() local
905 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_sent_cb() local
938 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_err_cb() local
956 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_poll_cb() local
973 mqtt_client_t* client = (mqtt_client_t *)arg; in mqtt_tcp_connect_cb() local
1024 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u… in mqtt_publish()
1099 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg,… in mqtt_sub_unsub()
1163 mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t pub_cb, in mqtt_set_inpub_callback()
1180 mqtt_client_t *client = (mqtt_client_t *)mem_malloc(sizeof(mqtt_client_t)); in mqtt_client_new() local
1200 mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ip_addr, u16_t port, mqtt_connection_cb… in mqtt_client_connect()
1317 mqtt_disconnect(mqtt_client_t *client) in mqtt_disconnect()
1335 mqtt_client_is_connected(mqtt_client_t *client) in mqtt_client_is_connected()