udp.c - OpenGrok cross reference for /third

Lines Matching refs:req
64   uv_udp_send_t* req;
74     req = uv__queue_data(q, uv_udp_send_t, queue);
75     req->status = UV_ECANCELED;
76     uv__queue_insert_tail(&handle->write_completed_queue, &req->queue);
92   uv_udp_send_t* req;
102     req = uv__queue_data(q, uv_udp_send_t, queue);
103     uv__req_unregister(handle->loop, req);
105     handle->send_queue_size -= uv__count_bufs(req->bufs, req->nbufs);
108     if (req->bufs != req->bufsml)
109       uv__free(req->bufs);
110     req->bufs = NULL;
112     if (req->send_cb == NULL)
115     /* req->status >= 0 == bytes written
116      * req->status <  0 == errno
118     if (req->status >= 0)
119       req->send_cb(req, 0);
121       req->send_cb(req, req->status);
280   uv_udp_send_t* req;
296     req = uv__queue_data(q, uv_udp_send_t, queue);
297     assert(req != NULL);
301     if (req->addr.ss_family == AF_UNSPEC) {
305       p->msg_hdr.msg_name = &req->addr;
306       if (req->addr.ss_family == AF_INET6)
308       else if (req->addr.ss_family == AF_INET)
310       else if (req->addr.ss_family == AF_UNIX)
317     h[pkts].msg_hdr.msg_iov = (struct iovec*) req->bufs;
318     h[pkts].msg_hdr.msg_iovlen = req->nbufs;
332       req = uv__queue_data(q, uv_udp_send_t, queue);
333       assert(req != NULL);
335       req->status = UV__ERR(errno);
336       uv__queue_remove(&req->queue);
337       uv__queue_insert_tail(&handle->write_completed_queue, &req->queue);
350     req = uv__queue_data(q, uv_udp_send_t, queue);
351     assert(req != NULL);
353     req->status = req->bufs[0].len;
360     uv__queue_remove(&req->queue);
361     uv__queue_insert_tail(&handle->write_completed_queue, &req->queue);
369   uv_udp_send_t* req;
378     req = uv__queue_data(q, uv_udp_send_t, queue);
379     assert(req != NULL);
382     if (req->addr.ss_family == AF_UNSPEC) {
386       h.msg_name = &req->addr;
387       if (req->addr.ss_family == AF_INET6)
389       else if (req->addr.ss_family == AF_INET)
391       else if (req->addr.ss_family == AF_UNIX)
398     h.msg_iov = (struct iovec*) req->bufs;
399     h.msg_iovlen = req->nbufs;
410     req->status = (size == -1 ? UV__ERR(errno) : size);
417     uv__queue_remove(&req->queue);
418     uv__queue_insert_tail(&handle->write_completed_queue, &req->queue);
686 int uv__udp_send(uv_udp_send_t* req,
710   uv__req_init(handle->loop, req, UV_UDP_SEND);
711   assert(addrlen <= sizeof(req->addr));
713     req->addr.ss_family = AF_UNSPEC;
715     memcpy(&req->addr, addr, addrlen);
716   req->send_cb = send_cb;
717   req->handle = handle;
718   req->nbufs = nbufs;
720   req->bufs = req->bufsml;
721   if (nbufs > ARRAY_SIZE(req->bufsml))
722     req->bufs = uv__malloc(nbufs * sizeof(bufs[0]));
724   if (req->bufs == NULL) {
725     uv__req_unregister(handle->loop, req);
729   memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0]));
730   handle->send_queue_size += uv__count_bufs(req->bufs, req->nbufs);
732   uv__queue_insert_tail(&handle->write_queue, &req->queue);