Lines Matching defs:req
78 static size_t uv__write_req_size(uv_write_t* req);
441 uv_write_t* req;
447 req = uv__queue_data(q, uv_write_t, queue);
448 req->error = error;
450 uv__queue_insert_tail(&stream->write_completed_queue, &req->queue);
627 uv_shutdown_t* req;
639 req = stream->shutdown_req;
640 assert(req);
645 uv__req_unregister(stream->loop, req);
656 if (req->cb != NULL)
657 req->cb(req, err);
670 static size_t uv__write_req_size(uv_write_t* req) {
673 assert(req->bufs != NULL);
674 size = uv__count_bufs(req->bufs + req->write_index,
675 req->nbufs - req->write_index);
676 assert(req->handle->write_queue_size >= size);
689 uv_write_t* req,
697 buf = req->bufs + req->write_index;
707 req->write_index = buf - req->bufs;
709 return req->write_index == req->nbufs;
713 static void uv__write_req_finish(uv_write_t* req) {
714 uv_stream_t* stream = req->handle;
716 /* Pop the req off tcp->write_queue. */
717 uv__queue_remove(&req->queue);
725 if (req->error == 0) {
726 if (req->bufs != req->bufsml)
727 uv__free(req->bufs);
728 req->bufs = NULL;
734 uv__queue_insert_tail(&stream->write_completed_queue, &req->queue);
841 uv_write_t* req;
858 req = uv__queue_data(q, uv_write_t, queue);
859 assert(req->handle == stream);
862 &(req->bufs[req->write_index]),
863 req->nbufs - req->write_index,
864 req->send_handle);
868 req->send_handle = NULL;
869 if (uv__write_req_update(stream, req, n)) {
870 uv__write_req_finish(req);
893 req->error = n;
894 uv__write_req_finish(req);
901 uv_write_t* req;
911 /* Pop a req off write_completed_queue. */
913 req = uv__queue_data(q, uv_write_t, queue);
915 uv__req_unregister(stream->loop, req);
917 if (req->bufs != NULL) {
918 stream->write_queue_size -= uv__write_req_size(req);
919 if (req->bufs != req->bufsml)
920 uv__free(req->bufs);
921 req->bufs = NULL;
925 if (req->cb)
926 req->cb(req, req->error);
1155 int uv_shutdown(uv_shutdown_t* req, uv_stream_t* stream, uv_shutdown_cb cb) {
1171 uv__req_init(stream->loop, req, UV_SHUTDOWN);
1172 req->handle = stream;
1173 req->cb = cb;
1174 stream->shutdown_req = req;
1243 uv_connect_t* req = stream->connect_req;
1247 assert(req);
1271 uv__req_unregister(stream->loop, req);
1277 if (req->cb)
1278 req->cb(req, error);
1328 int uv_write2(uv_write_t* req,
1349 /* Initialize the req */
1350 uv__req_init(stream->loop, req, UV_WRITE);
1351 req->cb = cb;
1352 req->handle = stream;
1353 req->error = 0;
1354 req->send_handle = send_handle;
1355 uv__queue_init(&req->queue);
1357 req->bufs = req->bufsml;
1358 if (nbufs > ARRAY_SIZE(req->bufsml))
1359 req->bufs = uv__malloc(nbufs * sizeof(bufs[0]));
1361 if (req->bufs == NULL)
1364 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0]));
1365 req->nbufs = nbufs;
1366 req->write_index = 0;
1370 uv__queue_insert_tail(&stream->write_queue, &req->queue);
1400 int uv_write(uv_write_t* req,
1405 return uv_write2(req, handle, bufs, nbufs, NULL, cb);