• Home
  • Raw
  • Download

Lines Matching refs:req

90         uv_fs_t *req = &ioContext->fs;  in SimpleFileIO()  local
93 req->data = ioContext; in SimpleFileIO()
97 uv_fs_read(context->loop, req, context->fsOpenReq.result, &iov, 1, index, context->cb); in SimpleFileIO()
106 uv_fs_write(context->loop, req, context->fsOpenReq.result, &iov, 1, index, context->cb); in SimpleFileIO()
122 void HdcTransferBase::OnFileClose(uv_fs_t *req) in OnFileClose() argument
125 uv_fs_req_cleanup(req); in OnFileClose()
126 CtxFile *context = (CtxFile *)req->data; in OnFileClose()
203 void HdcTransferBase::OnFileIO(uv_fs_t *req) in OnFileIO() argument
205 CtxFileIO *contextIO = reinterpret_cast<CtxFileIO *>(req->data); in OnFileIO()
210 uv_fs_req_cleanup(req); in OnFileIO()
215 if (req->result < 0) { in OnFileIO()
218 uv_strerror_r((int)req->result, buf, bufSize); in OnFileIO()
221 context->lastErrno = abs(req->result); in OnFileIO()
225 context->indexIO += req->result; in OnFileIO()
226 if (req->fs_type == UV_FS_READ) { in OnFileIO()
231 … if (!thisClass->SendIOPayload(context, context->indexIO - req->result, bufIO, req->result)) { in OnFileIO()
241 } else if (req->fs_type == UV_FS_WRITE) { // write in OnFileIO()
261 if (req->fs_type == UV_FS_WRITE) { in OnFileIO()
281 void HdcTransferBase::OnFileOpen(uv_fs_t *req) in OnFileOpen() argument
283 CtxFile *context = (CtxFile *)req->data; in OnFileOpen()
286 uv_fs_req_cleanup(req); in OnFileOpen()
290 if (req->result < 0) { in OnFileOpen()
293 uv_strerror_r((int)req->result, buf, bufSize); in OnFileOpen()
372 uv_fs_t req = {}; in GetSubFiles() local
382 if (uv_fs_scandir(nullptr, &req, path, 0, nullptr) < 0) { in GetSubFiles()
383 uv_fs_req_cleanup(&req); in GetSubFiles()
386 while (uv_fs_scandir_next(&req, &dent) != UV_EOF) { in GetSubFiles()
405 uv_fs_req_cleanup(&req); in GetSubFiles()
413 uv_fs_t req = {}; in GetSubFilesRecursively() local
422 if (uv_fs_scandir(nullptr, &req, path.c_str(), 0, nullptr) < 0) { in GetSubFilesRecursively()
423 uv_fs_req_cleanup(&req); in GetSubFilesRecursively()
448 while (uv_fs_scandir_next(&req, &dent) != UV_EOF) { in GetSubFilesRecursively()
464 uv_fs_req_cleanup(&req); in GetSubFilesRecursively()
478 uv_fs_t req; in CheckLocalPath() local
479 int r = uv_fs_lstat(nullptr, &req, localPath.c_str(), nullptr); in CheckLocalPath()
480 mode_t mode = req.statbuf.st_mode; in CheckLocalPath()
481 uv_fs_req_cleanup(&req); in CheckLocalPath()
613 uv_fs_t req; in SmartSlavePath() local
614 int r = uv_fs_lstat(nullptr, &req, localPath.c_str(), nullptr); in SmartSlavePath()
615 uv_fs_req_cleanup(&req); in SmartSlavePath()
616 if (r == 0 && req.statbuf.st_mode & S_IFDIR) { // is dir in SmartSlavePath()