Searched refs:pend_req_queue (Results 1 – 2 of 2) sorted by relevance
87 struct mqtt_request_t *pend_req_queue; member
556 mqtt_clear_requests(&client->pend_req_queue); in mqtt_close()592 mqtt_request_time_elapsed(&client->pend_req_queue, MQTT_CYCLIC_TIMER_INTERVAL); in mqtt_cyclic_timer()806 struct mqtt_request_t *r = mqtt_take_request(&client->pend_req_queue, pkt_id); in mqtt_message_received()996 while ((r = mqtt_take_request(&client->pend_req_queue, 0)) != NULL) { in mqtt_tcp_sent_cb()1161 mqtt_append_request(&client->pend_req_queue, r); in mqtt_publish()1229 mqtt_append_request(&client->pend_req_queue, r); in mqtt_sub_unsub()