Lines Matching refs:req
195 struct buffered_data *req; in free_buffered_data() local
206 list_for_each_entry(req, &conn->out_list, list) { in free_buffered_data()
207 if (req->timeout_msec) { in free_buffered_data()
208 conn->timeout_msec = req->timeout_msec; in free_buffered_data()
218 req = out->pend.req; in free_buffered_data()
219 if (req) { in free_buffered_data()
220 req->pend.ref.event_cnt--; in free_buffered_data()
221 if (!req->pend.ref.event_cnt && !req->on_out_list) { in free_buffered_data()
222 if (req->on_ref_list) { in free_buffered_data()
224 req->pend.ref.domid); in free_buffered_data()
225 list_del(&req->list); in free_buffered_data()
227 talloc_free(req); in free_buffered_data()
354 struct delayed_request *req = _req; in undelay_request() local
356 list_del(&req->list); in undelay_request()
362 static void call_delayed(struct delayed_request *req) in call_delayed() argument
364 if (req->func(req)) { in call_delayed()
365 undelay_request(req); in call_delayed()
366 talloc_set_destructor(req, NULL); in call_delayed()
374 struct delayed_request *req; in delay_request() local
384 req = talloc(in, struct delayed_request); in delay_request()
385 if (!req) in delay_request()
389 talloc_set_destructor(req, undelay_request); in delay_request()
391 req->in = in; in delay_request()
392 req->func = func; in delay_request()
393 req->data = data; in delay_request()
396 list_add(&req->list, &conn->delayed); in delay_request()
408 struct buffered_data *req; in destroy_conn() local
425 list_for_each_entry(req, &conn->ref_list, list) in destroy_conn()
426 req->on_ref_list = false; in destroy_conn()
1122 void send_event(struct buffered_data *req, struct connection *conn, in send_event() argument
1175 bdata->pend.req = req; in send_event()
1176 if (req) in send_event()
1177 req->pend.ref.event_cnt++; in send_event()
2097 static bool process_delayed_message(struct delayed_request *req) in process_delayed_message() argument
2099 struct connection *conn = req->data; in process_delayed_message()
2110 conn->in = req->in; in process_delayed_message()
2111 process_message(req->data, req->in); in process_delayed_message()
2852 struct delayed_request *req, *tmp; in main() local
2854 list_for_each_entry_safe(req, tmp, in main()
2856 call_delayed(req); in main()
2906 struct delayed_request *req; in dump_state_buffered_data() local
2910 list_for_each_entry(req, &c->delayed, list) { in dump_state_buffered_data()
2916 if (req->func != process_delayed_message) in dump_state_buffered_data()
2919 assert(!req->in->inhdr); in dump_state_buffered_data()
2920 if ((ret = dump_input_buffered_data(fp, req->in, &len))) in dump_state_buffered_data()