Lines Matching refs:r
259 struct mqtt_request_t *r = NULL; in mqtt_create_request() local
265 r = &r_objs[n]; in mqtt_create_request()
266 r->next = NULL; in mqtt_create_request()
267 r->cb = cb; in mqtt_create_request()
268 r->arg = arg; in mqtt_create_request()
269 r->pkt_id = pkt_id; in mqtt_create_request()
273 return r; in mqtt_create_request()
283 mqtt_append_request(struct mqtt_request_t **tail, struct mqtt_request_t *r) in mqtt_append_request() argument
298 r->timeout_diff = MQTT_REQ_TIMEOUT - time_before; in mqtt_append_request()
300 *tail = r; in mqtt_append_request()
302 head->next = r; in mqtt_append_request()
312 mqtt_delete_request(struct mqtt_request_t *r) in mqtt_delete_request() argument
314 if (r != NULL) { in mqtt_delete_request()
315 r->next = r; in mqtt_delete_request()
363 struct mqtt_request_t *r; in mqtt_request_time_elapsed() local
365 r = *tail; in mqtt_request_time_elapsed()
366 while (t > 0 && r != NULL) { in mqtt_request_time_elapsed()
367 if (t >= r->timeout_diff) { in mqtt_request_time_elapsed()
368 t -= (u8_t)r->timeout_diff; in mqtt_request_time_elapsed()
370 *tail = r->next; in mqtt_request_time_elapsed()
372 if (r->cb != NULL) { in mqtt_request_time_elapsed()
373 r->cb(r->arg, ERR_TIMEOUT); in mqtt_request_time_elapsed()
375 mqtt_delete_request(r); in mqtt_request_time_elapsed()
377 r = *(struct mqtt_request_t * const volatile *)tail; in mqtt_request_time_elapsed()
379 r->timeout_diff -= t; in mqtt_request_time_elapsed()
625 mqtt_incomming_suback(struct mqtt_request_t *r, u8_t result) in mqtt_incomming_suback() argument
627 if (r->cb != NULL) { in mqtt_incomming_suback()
628 r->cb(r->arg, result < 3 ? ERR_OK : ERR_ABRT); in mqtt_incomming_suback()
744 struct mqtt_request_t *r = mqtt_take_request(&client->pend_req_queue, pkt_id); in mqtt_message_received() local
745 if (r != NULL) { in mqtt_message_received()
752 mqtt_incomming_suback(r, var_hdr_payload[2]); in mqtt_message_received()
754 } else if (r->cb != NULL) { in mqtt_message_received()
755 r->cb(r->arg, ERR_OK); in mqtt_message_received()
757 mqtt_delete_request(r); in mqtt_message_received()
912 struct mqtt_request_t *r; in mqtt_tcp_sent_cb() local
918 while ((r = mqtt_take_request(&client->pend_req_queue, 0)) != NULL) { in mqtt_tcp_sent_cb()
920 if (r->cb != NULL) { in mqtt_tcp_sent_cb()
921 r->cb(r->arg, ERR_OK); in mqtt_tcp_sent_cb()
923 mqtt_delete_request(r); in mqtt_tcp_sent_cb()
1028 struct mqtt_request_t *r; in mqtt_publish() local
1057 r = mqtt_create_request(client->req_list, pkt_id, cb, arg); in mqtt_publish()
1058 if (r == NULL) { in mqtt_publish()
1063 mqtt_delete_request(r); in mqtt_publish()
1082 mqtt_append_request(&client->pend_req_queue, r); in mqtt_publish()
1107 struct mqtt_request_t *r; in mqtt_sub_unsub() local
1127 r = mqtt_create_request(client->req_list, pkt_id, cb, arg); in mqtt_sub_unsub()
1128 if (r == NULL) { in mqtt_sub_unsub()
1133 mqtt_delete_request(r); in mqtt_sub_unsub()
1149 mqtt_append_request(&client->pend_req_queue, r); in mqtt_sub_unsub()