Lines Matching defs:req
29 #include "req-inl.h"
263 uv_req_t* req;
271 req = &handle->recv_req;
272 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped));
285 &req->u.io.overlapped,
289 /* Process the req without IOCP. */
291 req->u.io.overlapped.InternalHigh = bytes;
293 uv__insert_pending_req(loop, req);
295 /* The req will be processed with IOCP. */
299 /* Make this req pending reporting an error. */
300 SET_REQ_ERROR(req, WSAGetLastError());
301 uv__insert_pending_req(loop, req);
348 static int uv__send(uv_udp_send_t* req,
358 UV_REQ_INIT(req, UV_UDP_SEND);
359 req->handle = handle;
360 req->cb = cb;
361 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped));
370 &req->u.io.overlapped,
375 req->u.io.queued_bytes = 0;
377 handle->send_queue_size += req->u.io.queued_bytes;
379 REGISTER_HANDLE_REQ(loop, handle, req);
380 uv__insert_pending_req(loop, (uv_req_t*)req);
383 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs);
385 handle->send_queue_size += req->u.io.queued_bytes;
387 REGISTER_HANDLE_REQ(loop, handle, req);
398 uv_req_t* req) {
406 if (!REQ_SUCCESS(req)) {
407 DWORD err = GET_REQ_SOCK_ERROR(req);
434 partial = !REQ_SUCCESS(req);
436 req->u.io.overlapped.InternalHigh,
520 uv_udp_send_t* req) {
525 assert(handle->send_queue_size >= req->u.io.queued_bytes);
527 handle->send_queue_size -= req->u.io.queued_bytes;
530 UNREGISTER_HANDLE_REQ(loop, handle, req);
532 if (req->cb) {
534 if (!REQ_SUCCESS(req)) {
535 err = GET_REQ_SOCK_ERROR(req);
537 req->cb(req, uv_translate_sys_error(err));
1057 int uv__udp_send(uv_udp_send_t* req,
1080 err = uv__send(req, handle, bufs, nbufs, addr, addrlen, send_cb);