Function dm_update_unreplied_req

modules/aaa_diameter/dm_impl.c:169–205

static inline void dm_update_unreplied_req(struct msg *req)
{
	struct list_head *it, *aux;
	struct fd_msg_list *rit, *ml;
	unsigned int now = get_ticks();

	lock_get(&dm_unreplied_req_lk);

	list_for_each_safe (it, aux, &dm_unreplied_req) {
		rit = list_entry(it, struct fd_msg_list, list);

		if (rit->timeout_jf <= now) {
			LM_DBG("Diameter request timeout (unhandled), cleaning up\n");
			list_del(&rit->list);
			fd_msg_free(rit->req);
			pkg_free(rit);
		} else {
			break;
		}
	}

	lock_release(&dm_unreplied_req_lk);

	ml = pkg_malloc(sizeof *ml);
	if (!ml) {
		LM_ERR("oom\n");
		return;
	}
	memset(ml, 0, sizeof *ml);

	ml->req = req;
	ml->timeout_jf = get_ticks() + dm_unreplied_req_timeout;

	lock_get(&dm_unreplied_req_lk);
	list_add_tail(&ml->list, &dm_unreplied_req);
	lock_release(&dm_unreplied_req_lk);
}


int dm_remove_unreplied_req(struct msg *req)