Lines Matching refs:req
41 static void tdgram_sendto_queue_trigger(struct tevent_req *req,
53 struct tevent_req *req;
57 req = tevent_req_create(mem_ctx, &state,
59 if (!req) {
72 req,
76 tevent_req_nomem(NULL, req);
80 return req;
83 tevent_req_post(req, ev);
84 return req;
87 static void tdgram_sendto_queue_trigger(struct tevent_req *req,
90 struct tdgram_sendto_queue_state *state = tevent_req_data(req,
100 if (tevent_req_nomem(subreq, req)) {
103 tevent_req_set_callback(subreq, tdgram_sendto_queue_done, req);
108 struct tevent_req *req = tevent_req_callback_data(subreq,
110 struct tdgram_sendto_queue_state *state = tevent_req_data(req,
118 tevent_req_error(req, sys_errno);
123 tevent_req_done(req);
126 ssize_t tdgram_sendto_queue_recv(struct tevent_req *req, int *perrno)
128 struct tdgram_sendto_queue_state *state = tevent_req_data(req,
132 ret = tsocket_simple_int_recv(req, perrno);
137 tevent_req_received(req);
169 static void tstream_readv_pdu_ask_for_next_vector(struct tevent_req *req);
178 struct tevent_req *req;
181 req = tevent_req_create(mem_ctx, &state,
183 if (!req) {
196 tstream_readv_pdu_ask_for_next_vector(req);
197 if (!tevent_req_is_in_progress(req)) {
201 return req;
204 return tevent_req_post(req, ev);
207 static void tstream_readv_pdu_ask_for_next_vector(struct tevent_req *req)
209 struct tstream_readv_pdu_state *state = tevent_req_data(req,
223 tevent_req_error(req, errno);
228 tevent_req_done(req);
237 tevent_req_error(req, EMSGSIZE);
249 tevent_req_error(req, EINVAL);
254 tevent_req_error(req, EMSGSIZE);
263 if (tevent_req_nomem(subreq, req)) {
266 tevent_req_set_callback(subreq, tstream_readv_pdu_readv_done, req);
271 struct tevent_req *req = tevent_req_callback_data(subreq,
273 struct tstream_readv_pdu_state *state = tevent_req_data(req,
280 tevent_req_error(req, sys_errno);
287 tstream_readv_pdu_ask_for_next_vector(req);
290 int tstream_readv_pdu_recv(struct tevent_req *req, int *perrno)
292 struct tstream_readv_pdu_state *state = tevent_req_data(req,
296 ret = tsocket_simple_int_recv(req, perrno);
301 tevent_req_received(req);
316 static void tstream_readv_pdu_queue_trigger(struct tevent_req *req,
327 struct tevent_req *req;
331 req = tevent_req_create(mem_ctx, &state,
333 if (!req) {
345 req,
349 tevent_req_nomem(NULL, req);
353 return req;
356 return tevent_req_post(req, ev);
359 static void tstream_readv_pdu_queue_trigger(struct tevent_req *req,
362 struct tstream_readv_pdu_queue_state *state = tevent_req_data(req,
371 if (tevent_req_nomem(subreq, req)) {
374 tevent_req_set_callback(subreq, tstream_readv_pdu_queue_done ,req);
379 struct tevent_req *req = tevent_req_callback_data(subreq,
381 struct tstream_readv_pdu_queue_state *state = tevent_req_data(req,
389 tevent_req_error(req, sys_errno);
394 tevent_req_done(req);
397 int tstream_readv_pdu_queue_recv(struct tevent_req *req, int *perrno)
399 struct tstream_readv_pdu_queue_state *state = tevent_req_data(req,
403 ret = tsocket_simple_int_recv(req, perrno);
408 tevent_req_received(req);
423 static void tstream_writev_queue_trigger(struct tevent_req *req,
434 struct tevent_req *req;
438 req = tevent_req_create(mem_ctx, &state,
440 if (!req) {
452 req,
456 tevent_req_nomem(NULL, req);
460 return req;
463 return tevent_req_post(req, ev);
466 static void tstream_writev_queue_trigger(struct tevent_req *req,
469 struct tstream_writev_queue_state *state = tevent_req_data(req,
478 if (tevent_req_nomem(subreq, req)) {
481 tevent_req_set_callback(subreq, tstream_writev_queue_done ,req);
486 struct tevent_req *req = tevent_req_callback_data(subreq,
488 struct tstream_writev_queue_state *state = tevent_req_data(req,
496 tevent_req_error(req, sys_errno);
501 tevent_req_done(req);
504 int tstream_writev_queue_recv(struct tevent_req *req, int *perrno)
506 struct tstream_writev_queue_state *state = tevent_req_data(req,
510 ret = tsocket_simple_int_recv(req, perrno);
515 tevent_req_received(req);