Lines Matching refs:req
78 static size_t uv__write_req_size(uv_write_t* req);
441 uv_write_t* req; in uv__stream_flush_write_queue() local
447 req = uv__queue_data(q, uv_write_t, queue); in uv__stream_flush_write_queue()
448 req->error = error; in uv__stream_flush_write_queue()
450 uv__queue_insert_tail(&stream->write_completed_queue, &req->queue); in uv__stream_flush_write_queue()
627 uv_shutdown_t* req; in uv__drain() local
639 req = stream->shutdown_req; in uv__drain()
640 assert(req); in uv__drain()
645 uv__req_unregister(stream->loop, req); in uv__drain()
656 if (req->cb != NULL) in uv__drain()
657 req->cb(req, err); in uv__drain()
670 static size_t uv__write_req_size(uv_write_t* req) { in uv__write_req_size() argument
673 assert(req->bufs != NULL); in uv__write_req_size()
674 size = uv__count_bufs(req->bufs + req->write_index, in uv__write_req_size()
675 req->nbufs - req->write_index); in uv__write_req_size()
676 assert(req->handle->write_queue_size >= size); in uv__write_req_size()
689 uv_write_t* req, in uv__write_req_update() argument
697 buf = req->bufs + req->write_index; in uv__write_req_update()
707 req->write_index = buf - req->bufs; in uv__write_req_update()
709 return req->write_index == req->nbufs; in uv__write_req_update()
713 static void uv__write_req_finish(uv_write_t* req) { in uv__write_req_finish() argument
714 uv_stream_t* stream = req->handle; in uv__write_req_finish()
717 uv__queue_remove(&req->queue); in uv__write_req_finish()
725 if (req->error == 0) { in uv__write_req_finish()
726 if (req->bufs != req->bufsml) in uv__write_req_finish()
727 uv__free(req->bufs); in uv__write_req_finish()
728 req->bufs = NULL; in uv__write_req_finish()
734 uv__queue_insert_tail(&stream->write_completed_queue, &req->queue); in uv__write_req_finish()
841 uv_write_t* req; in uv__write() local
858 req = uv__queue_data(q, uv_write_t, queue); in uv__write()
859 assert(req->handle == stream); in uv__write()
862 &(req->bufs[req->write_index]), in uv__write()
863 req->nbufs - req->write_index, in uv__write()
864 req->send_handle); in uv__write()
868 req->send_handle = NULL; in uv__write()
869 if (uv__write_req_update(stream, req, n)) { in uv__write()
870 uv__write_req_finish(req); in uv__write()
893 req->error = n; in uv__write()
894 uv__write_req_finish(req); in uv__write()
901 uv_write_t* req; in uv__write_callbacks() local
913 req = uv__queue_data(q, uv_write_t, queue); in uv__write_callbacks()
915 uv__req_unregister(stream->loop, req); in uv__write_callbacks()
917 if (req->bufs != NULL) { in uv__write_callbacks()
918 stream->write_queue_size -= uv__write_req_size(req); in uv__write_callbacks()
919 if (req->bufs != req->bufsml) in uv__write_callbacks()
920 uv__free(req->bufs); in uv__write_callbacks()
921 req->bufs = NULL; in uv__write_callbacks()
925 if (req->cb) in uv__write_callbacks()
926 req->cb(req, req->error); in uv__write_callbacks()
1159 int uv_shutdown(uv_shutdown_t* req, uv_stream_t* stream, uv_shutdown_cb cb) { in uv_shutdown() argument
1175 uv__req_init(stream->loop, req, UV_SHUTDOWN); in uv_shutdown()
1176 req->handle = stream; in uv_shutdown()
1177 req->cb = cb; in uv_shutdown()
1178 stream->shutdown_req = req; in uv_shutdown()
1247 uv_connect_t* req = stream->connect_req; in uv__stream_connect() local
1251 assert(req); in uv__stream_connect()
1275 uv__req_unregister(stream->loop, req); in uv__stream_connect()
1281 if (req->cb) in uv__stream_connect()
1282 req->cb(req, error); in uv__stream_connect()
1332 int uv_write2(uv_write_t* req, in uv_write2() argument
1354 uv__req_init(stream->loop, req, UV_WRITE); in uv_write2()
1355 req->cb = cb; in uv_write2()
1356 req->handle = stream; in uv_write2()
1357 req->error = 0; in uv_write2()
1358 req->send_handle = send_handle; in uv_write2()
1359 uv__queue_init(&req->queue); in uv_write2()
1361 req->bufs = req->bufsml; in uv_write2()
1362 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_write2()
1363 req->bufs = uv__malloc(nbufs * sizeof(bufs[0])); in uv_write2()
1365 if (req->bufs == NULL) in uv_write2()
1368 memcpy(req->bufs, bufs, nbufs * sizeof(bufs[0])); in uv_write2()
1369 req->nbufs = nbufs; in uv_write2()
1370 req->write_index = 0; in uv_write2()
1374 uv__queue_insert_tail(&stream->write_queue, &req->queue); in uv_write2()
1404 int uv_write(uv_write_t* req, in uv_write() argument
1409 return uv_write2(req, handle, bufs, nbufs, NULL, cb); in uv_write()
