Lines Matching defs:req
41 #include "req-inl.h"
438 uv_req_t* req;
443 req = (uv_req_t*) data;
444 handle = (uv_tty_t*) req->data;
450 SET_REQ_SUCCESS(req);
451 POST_COMPLETION_FOR_REQ(loop, req);
456 uv_read_t* req;
466 req = &handle->read_req;
467 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped));
472 (void*) req,
477 SET_REQ_ERROR(req, GetLastError());
478 uv__insert_pending_req(loop, (uv_req_t*)req);
489 uv_req_t* req;
499 req = (uv_req_t*) data;
500 handle = (uv_tty_t*) req->data;
519 SET_REQ_SUCCESS(req);
521 req->u.io.overlapped.InternalHigh = 0;
522 POST_COMPLETION_FOR_REQ(loop, req);
541 SET_REQ_SUCCESS(req);
542 req->u.io.overlapped.InternalHigh = read_bytes;
544 SET_REQ_ERROR(req, GetLastError());
577 POST_COMPLETION_FOR_REQ(loop, req);
583 uv_read_t* req;
590 req = &handle->read_req;
591 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped));
610 (void*) req,
613 SET_REQ_ERROR(req, GetLastError());
614 uv__insert_pending_req(loop, (uv_req_t*)req);
698 uv_req_t* req) {
715 if (!REQ_SUCCESS(req)) {
720 uv_translate_sys_error(GET_REQ_ERROR(req)),
961 uv_req_t* req) {
972 if (!REQ_SUCCESS(req)) {
979 uv_translate_sys_error(GET_REQ_ERROR(req)),
984 req->u.io.overlapped.InternalHigh != 0) {
986 DWORD bytes = req->u.io.overlapped.InternalHigh;
1003 uv_req_t* req) {
1011 uv_process_tty_read_raw_req(loop, handle, req);
1013 uv_process_tty_read_line_req(loop, handle, req);
2184 uv_write_t* req,
2191 UV_REQ_INIT(req, UV_WRITE);
2192 req->handle = (uv_stream_t*) handle;
2193 req->cb = cb;
2197 REGISTER_HANDLE_REQ(loop, handle, req);
2199 req->u.io.queued_bytes = 0;
2202 SET_REQ_SUCCESS(req);
2204 SET_REQ_ERROR(req, error);
2207 uv__insert_pending_req(loop, (uv_req_t*) req);
2229 uv_write_t* req) {
2232 handle->write_queue_size -= req->u.io.queued_bytes;
2233 UNREGISTER_HANDLE_REQ(loop, handle, req);
2235 if (req->cb) {
2236 err = GET_REQ_ERROR(req);
2237 req->cb(req, uv_translate_sys_error(err));
2272 void uv__process_tty_shutdown_req(uv_loop_t* loop, uv_tty_t* stream, uv_shutdown_t* req) {
2274 assert(req);
2278 UNREGISTER_HANDLE_REQ(loop, stream, req);
2281 if (req->cb) {
2283 req->cb(req, UV_ECANCELED);
2285 req->cb(req, 0);
2322 uv_connect_t* req) {