Lines Matching defs:client
87 static void mqtt_sn_set_state(struct mqtt_sn_client *client, enum mqtt_sn_client_state state) in mqtt_sn_set_state()
108 static int encode_and_send(struct mqtt_sn_client *client, struct mqtt_sn_param *p, in encode_and_send()
164 static void mqtt_sn_publish_destroy(struct mqtt_sn_client *client, struct mqtt_sn_publish *pub) in mqtt_sn_publish_destroy()
170 static void mqtt_sn_publish_destroy_all(struct mqtt_sn_client *client) in mqtt_sn_publish_destroy_all()
207 static struct mqtt_sn_publish *mqtt_sn_publish_find_by_msg_id(struct mqtt_sn_client *client, in mqtt_sn_publish_find_by_msg_id()
221 static struct mqtt_sn_publish *mqtt_sn_publish_find_by_topic(struct mqtt_sn_client *client, in mqtt_sn_publish_find_by_topic()
264 static struct mqtt_sn_topic *mqtt_sn_topic_find_by_name(struct mqtt_sn_client *client, in mqtt_sn_topic_find_by_name()
279 static struct mqtt_sn_topic *mqtt_sn_topic_find_by_msg_id(struct mqtt_sn_client *client, in mqtt_sn_topic_find_by_msg_id()
293 static void mqtt_sn_topic_destroy(struct mqtt_sn_client *client, struct mqtt_sn_topic *topic) in mqtt_sn_topic_destroy()
306 static void mqtt_sn_topic_destroy_all(struct mqtt_sn_client *client) in mqtt_sn_topic_destroy_all()
324 static void mqtt_sn_gw_destroy(struct mqtt_sn_client *client, struct mqtt_sn_gateway *gw) in mqtt_sn_gw_destroy()
331 static void mqtt_sn_gw_destroy_all(struct mqtt_sn_client *client) in mqtt_sn_gw_destroy_all()
371 static struct mqtt_sn_gateway *mqtt_sn_gw_find_by_id(struct mqtt_sn_client *client, uint16_t gw_id) in mqtt_sn_gw_find_by_id()
384 static void mqtt_sn_disconnect_internal(struct mqtt_sn_client *client) in mqtt_sn_disconnect_internal()
403 static void mqtt_sn_sleep_internal(struct mqtt_sn_client *client) in mqtt_sn_sleep_internal()
420 static void mqtt_sn_do_subscribe(struct mqtt_sn_client *client, struct mqtt_sn_topic *topic, in mqtt_sn_do_subscribe()
461 static void mqtt_sn_do_unsubscribe(struct mqtt_sn_client *client, struct mqtt_sn_topic *topic) in mqtt_sn_do_unsubscribe()
499 static void mqtt_sn_do_register(struct mqtt_sn_client *client, struct mqtt_sn_topic *topic) in mqtt_sn_do_register()
536 static void mqtt_sn_do_publish(struct mqtt_sn_client *client, struct mqtt_sn_publish *pub, bool dup) in mqtt_sn_do_publish()
568 static void mqtt_sn_do_searchgw(struct mqtt_sn_client *client) in mqtt_sn_do_searchgw()
582 static void mqtt_sn_do_gwinfo(struct mqtt_sn_client *client) in mqtt_sn_do_gwinfo()
608 static void mqtt_sn_do_ping(struct mqtt_sn_client *client) in mqtt_sn_do_ping()
641 static int process_pubs(struct mqtt_sn_client *client, int64_t *next_cycle) in process_pubs()
708 static int process_topics(struct mqtt_sn_client *client, int64_t *next_cycle) in process_topics()
839 static int process_ping(struct mqtt_sn_client *client, int64_t *next_cycle) in process_ping()
889 static int process_search(struct mqtt_sn_client *client, int64_t *next_cycle) in process_search()
927 static int process_advertise(struct mqtt_sn_client *client, int64_t *next_cycle) in process_advertise()
958 struct mqtt_sn_client *client; in process_work() local
1004 int mqtt_sn_client_init(struct mqtt_sn_client *client, const struct mqtt_sn_data *client_id, in mqtt_sn_client_init()
1036 void mqtt_sn_client_deinit(struct mqtt_sn_client *client) in mqtt_sn_client_deinit()
1053 int mqtt_sn_add_gw(struct mqtt_sn_client *client, uint8_t gw_id, struct mqtt_sn_data gw_addr) in mqtt_sn_add_gw()
1073 int mqtt_sn_search(struct mqtt_sn_client *client, uint8_t radius) in mqtt_sn_search()
1087 int mqtt_sn_connect(struct mqtt_sn_client *client, bool will, bool clean_session) in mqtt_sn_connect()
1115 int mqtt_sn_disconnect(struct mqtt_sn_client *client) in mqtt_sn_disconnect()
1132 int mqtt_sn_sleep(struct mqtt_sn_client *client, uint16_t duration) in mqtt_sn_sleep()
1149 int mqtt_sn_subscribe(struct mqtt_sn_client *client, enum mqtt_sn_qos qos, in mqtt_sn_subscribe()
1184 int mqtt_sn_unsubscribe(struct mqtt_sn_client *client, enum mqtt_sn_qos qos, in mqtt_sn_unsubscribe()
1221 int mqtt_sn_publish(struct mqtt_sn_client *client, enum mqtt_sn_qos qos, in mqtt_sn_publish()
1274 static void handle_advertise(struct mqtt_sn_client *client, struct mqtt_sn_param_advertise *p, in handle_advertise()
1301 static void handle_searchgw(struct mqtt_sn_client *client, struct mqtt_sn_param_searchgw *p) in handle_searchgw()
1322 static void handle_gwinfo(struct mqtt_sn_client *client, struct mqtt_sn_param_gwinfo *p, in handle_gwinfo()
1352 static void handle_connack(struct mqtt_sn_client *client, struct mqtt_sn_param_connack *p) in handle_connack()
1380 static void handle_willtopicreq(struct mqtt_sn_client *client) in handle_willtopicreq()
1392 static void handle_willmsgreq(struct mqtt_sn_client *client) in handle_willmsgreq()
1402 static void handle_register(struct mqtt_sn_client *client, struct mqtt_sn_param_register *p) in handle_register()
1425 static void handle_regack(struct mqtt_sn_client *client, struct mqtt_sn_param_regack *p) in handle_regack()
1443 static void handle_publish(struct mqtt_sn_client *client, struct mqtt_sn_param_publish *p) in handle_publish()
1470 static void handle_puback(struct mqtt_sn_client *client, struct mqtt_sn_param_puback *p) in handle_puback()
1482 static void handle_pubrec(struct mqtt_sn_client *client, struct mqtt_sn_param_pubrec *p) in handle_pubrec()
1500 static void handle_pubrel(struct mqtt_sn_client *client, struct mqtt_sn_param_pubrel *p) in handle_pubrel()
1509 static void handle_pubcomp(struct mqtt_sn_client *client, struct mqtt_sn_param_pubcomp *p) in handle_pubcomp()
1521 static void handle_suback(struct mqtt_sn_client *client, struct mqtt_sn_param_suback *p) in handle_suback()
1539 static void handle_unsuback(struct mqtt_sn_client *client, struct mqtt_sn_param_unsuback *p) in handle_unsuback()
1551 static void handle_pingreq(struct mqtt_sn_client *client) in handle_pingreq()
1558 static void handle_pingresp(struct mqtt_sn_client *client) in handle_pingresp()
1573 static void handle_disconnect(struct mqtt_sn_client *client, struct mqtt_sn_param_disconnect *p) in handle_disconnect()
1579 static int handle_msg(struct mqtt_sn_client *client, struct mqtt_sn_data rx_addr) in handle_msg()
1660 int mqtt_sn_input(struct mqtt_sn_client *client) in mqtt_sn_input()
1704 int mqtt_sn_get_topic_name(struct mqtt_sn_client *client, uint16_t id, in mqtt_sn_get_topic_name()