Lines Matching defs:req
68 static size_t uv__write_req_size(uv_write_t* req);
431 uv_write_t* req;
437 req = QUEUE_DATA(q, uv_write_t, queue);
438 req->error = error;
440 QUEUE_INSERT_TAIL(&stream->write_completed_queue, &req->queue);
659 uv_shutdown_t* req;
671 req = stream->shutdown_req;
672 assert(req);
678 uv__req_unregister(stream->loop, req);
689 if (req->cb != NULL)
690 req->cb(req, err);
703 static size_t uv__write_req_size(uv_write_t* req) {
706 assert(req->bufs != NULL);
707 size = uv__count_bufs(req->bufs + req->write_index,
708 req->nbufs - req->write_index);
709 assert(req->handle->write_queue_size >= size);
722 uv_write_t* req,
730 buf = req->bufs + req->write_index;
740 req->write_index = buf - req->bufs;
742 return req->write_index == req->nbufs;
746 static void uv__write_req_finish(uv_write_t* req) {
747 uv_stream_t* stream = req->handle;
749 /* Pop the req off tcp->write_queue. */
750 QUEUE_REMOVE(&req->queue);
758 if (req->error == 0) {
759 if (req->bufs != req->bufsml)
760 uv__free(req->bufs);
761 req->bufs = NULL;
767 QUEUE_INSERT_TAIL(&stream->write_completed_queue, &req->queue);
885 uv_write_t* req;
895 req = QUEUE_DATA(q, uv_write_t, queue);
896 assert(req->handle == stream);
899 &(req->bufs[req->write_index]),
900 req->nbufs - req->write_index,
901 req->send_handle);
905 req->send_handle = NULL;
906 if (uv__write_req_update(stream, req, n)) {
907 uv__write_req_finish(req);
926 req->error = n;
927 uv__write_req_finish(req);
934 uv_write_t* req;
944 /* Pop a req off write_completed_queue. */
946 req = QUEUE_DATA(q, uv_write_t, queue);
948 uv__req_unregister(stream->loop, req);
950 if (req->bufs != NULL) {
951 stream->write_queue_size -= uv__write_req_size(req);
952 if (req->bufs != req->bufsml)
953 uv__free(req->bufs);
954 req->bufs = NULL;
958 if (req->cb)
959 req->cb(req, req->error);
1221 int uv_shutdown(uv_shutdown_t* req, uv_stream_t* stream, uv_shutdown_cb cb) {
1237 uv__req_init(stream->loop, req, UV_SHUTDOWN);
1238 req->handle = stream;
1239 req->cb = cb;
1240 stream->shutdown_req = req;
1310 uv_connect_t* req = stream->connect_req;
1314 assert(req);
1338 uv__req_unregister(stream->loop, req);
1344 if (req->cb)
1345 req->cb(req, error);
1395 int uv_write2(uv_write_t* req,
1416 /* Initialize the req */
1417 uv__req_init(stream->loop, req, UV_WRITE);
1418 req->cb = cb;
1419 req->handle = stream;
1420 req->error = 0;
1421 req->send_handle = send_handle;
1422 QUEUE_INIT(&req->queue);
1424 req->bufs = req->bufsml;
1425 if (nbufs > ARRAY_SIZE(req->bufsml))
1426 req->bufs = uv__malloc(nbufs * sizeof(bufs[0]));
1428 if (req->bufs == NULL)
1431 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0]));
1432 req->nbufs = nbufs;
1433 req->write_index = 0;
1437 QUEUE_INSERT_TAIL(&stream->write_queue, &req->queue);
1467 int uv_write(uv_write_t* req,
1472 return uv_write2(req, handle, bufs, nbufs, NULL, cb);