Lines Matching refs:req
100 uv_udp_send_t* req;
110 req = QUEUE_DATA(q, uv_udp_send_t, queue);
111 req->status = UV_ECANCELED;
112 QUEUE_INSERT_TAIL(&handle->write_completed_queue, &req->queue);
128 uv_udp_send_t* req;
138 req = QUEUE_DATA(q, uv_udp_send_t, queue);
139 uv__req_unregister(handle->loop, req);
141 handle->send_queue_size -= uv__count_bufs(req->bufs, req->nbufs);
144 if (req->bufs != req->bufsml)
145 uv__free(req->bufs);
146 req->bufs = NULL;
148 if (req->send_cb == NULL)
151 /* req->status >= 0 == bytes written
152 * req->status < 0 == errno
154 if (req->status >= 0)
155 req->send_cb(req, 0);
157 req->send_cb(req, req->status);
316 uv_udp_send_t* req;
332 req = QUEUE_DATA(q, uv_udp_send_t, queue);
333 assert(req != NULL);
337 if (req->addr.ss_family == AF_UNSPEC) {
341 p->msg_hdr.msg_name = &req->addr;
342 if (req->addr.ss_family == AF_INET6)
344 else if (req->addr.ss_family == AF_INET)
346 else if (req->addr.ss_family == AF_UNIX)
353 h[pkts].msg_hdr.msg_iov = (struct iovec*) req->bufs;
354 h[pkts].msg_hdr.msg_iovlen = req->nbufs;
368 req = QUEUE_DATA(q, uv_udp_send_t, queue);
369 assert(req != NULL);
371 req->status = UV__ERR(errno);
372 QUEUE_REMOVE(&req->queue);
373 QUEUE_INSERT_TAIL(&handle->write_completed_queue, &req->queue);
386 req = QUEUE_DATA(q, uv_udp_send_t, queue);
387 assert(req != NULL);
389 req->status = req->bufs[0].len;
396 QUEUE_REMOVE(&req->queue);
397 QUEUE_INSERT_TAIL(&handle->write_completed_queue, &req->queue);
409 uv_udp_send_t* req;
426 req = QUEUE_DATA(q, uv_udp_send_t, queue);
427 assert(req != NULL);
430 if (req->addr.ss_family == AF_UNSPEC) {
434 h.msg_name = &req->addr;
435 if (req->addr.ss_family == AF_INET6)
437 else if (req->addr.ss_family == AF_INET)
439 else if (req->addr.ss_family == AF_UNIX)
446 h.msg_iov = (struct iovec*) req->bufs;
447 h.msg_iovlen = req->nbufs;
458 req->status = (size == -1 ? UV__ERR(errno) : size);
465 QUEUE_REMOVE(&req->queue);
466 QUEUE_INSERT_TAIL(&handle->write_completed_queue, &req->queue);
732 int uv__udp_send(uv_udp_send_t* req,
756 uv__req_init(handle->loop, req, UV_UDP_SEND);
757 assert(addrlen <= sizeof(req->addr));
759 req->addr.ss_family = AF_UNSPEC;
761 memcpy(&req->addr, addr, addrlen);
762 req->send_cb = send_cb;
763 req->handle = handle;
764 req->nbufs = nbufs;
766 req->bufs = req->bufsml;
767 if (nbufs > ARRAY_SIZE(req->bufsml))
768 req->bufs = uv__malloc(nbufs * sizeof(bufs[0]));
770 if (req->bufs == NULL) {
771 uv__req_unregister(handle->loop, req);
775 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0]));
776 handle->send_queue_size += uv__count_bufs(req->bufs, req->nbufs);
778 QUEUE_INSERT_TAIL(&handle->write_queue, &req->queue);