Lines Matching defs:req_wrap
33 #include "req_wrap-inl.h"
466 CloseReq* req_wrap = CloseReq::from_req(req);
468 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
469 BaseObjectPtr<CloseReq> close(req_wrap);
588 FileHandleReadWrap* req_wrap = FileHandleReadWrap::from_req(req);
590 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
591 handle = req_wrap->file_handle_;
592 CHECK_EQ(handle->current_read_.get(), req_wrap);
656 int FileHandle::DoShutdown(ShutdownWrap* req_wrap) {
658 req_wrap->Done(0);
661 FileHandleCloseWrap* wrap = static_cast<FileHandleCloseWrap*>(req_wrap);
768 FSReqBase* req_wrap = FSReqBase::from_req(req);
769 FSReqAfterScope after(req_wrap, req);
771 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
773 req_wrap->Resolve(Undefined(req_wrap->env()->isolate()));
777 FSReqBase* req_wrap = FSReqBase::from_req(req);
778 FSReqAfterScope after(req_wrap, req);
780 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
782 req_wrap->ResolveStat(&req->statbuf);
787 FSReqBase* req_wrap = FSReqBase::from_req(req);
788 FSReqAfterScope after(req_wrap, req);
790 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
792 req_wrap->ResolveStatFs(static_cast<uv_statfs_t*>(req->ptr));
797 FSReqBase* req_wrap = FSReqBase::from_req(req);
798 FSReqAfterScope after(req_wrap, req);
800 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
802 if (result >= 0 && req_wrap->is_plain_open())
803 req_wrap->env()->AddUnmanagedFd(result);
806 req_wrap->Resolve(Integer::New(req_wrap->env()->isolate(), result));
810 FSReqBase* req_wrap = FSReqBase::from_req(req);
811 FSReqAfterScope after(req_wrap, req);
813 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
815 FileHandle* fd = FileHandle::New(req_wrap->binding_data(),
818 req_wrap->Resolve(fd->object());
836 FSReqBase* req_wrap = FSReqBase::from_req(req);
837 FSReqAfterScope after(req_wrap, req);
839 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
841 std::string first_path(req_wrap->continuation_data()->first_path());
843 return req_wrap->Resolve(Undefined(req_wrap->env()->isolate()));
847 if (!StringBytes::Encode(req_wrap->env()->isolate(), first_path.c_str(),
848 req_wrap->encoding(),
850 return req_wrap->Reject(error);
852 return req_wrap->Resolve(path);
857 FSReqBase* req_wrap = FSReqBase::from_req(req);
858 FSReqAfterScope after(req_wrap, req);
860 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
865 link = StringBytes::Encode(req_wrap->env()->isolate(),
867 req_wrap->encoding(),
870 req_wrap->Reject(error);
872 req_wrap->Resolve(link.ToLocalChecked());
877 FSReqBase* req_wrap = FSReqBase::from_req(req);
878 FSReqAfterScope after(req_wrap, req);
880 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
885 link = StringBytes::Encode(req_wrap->env()->isolate(),
887 req_wrap->encoding(),
890 req_wrap->Reject(error);
892 req_wrap->Resolve(link.ToLocalChecked());
897 FSReqBase* req_wrap = FSReqBase::from_req(req);
898 FSReqAfterScope after(req_wrap, req);
900 req->fs_type, req_wrap, "result", static_cast<int>(req->result))
905 Environment* env = req_wrap->env();
913 const bool with_file_types = req_wrap->with_file_types();
922 return req_wrap->Reject(
923 UVException(isolate, r, nullptr, req_wrap->syscall(), req->path));
927 if (!StringBytes::Encode(isolate, ent.name, req_wrap->encoding(), &error)
929 return req_wrap->Reject(error);
939 req_wrap->Resolve(Array::New(isolate, result, arraysize(result)));
941 req_wrap->Resolve(Array::New(isolate, name_v.data(), name_v.size()));
1529 FSReqWrapSync* req_wrap = ContainerOf(&FSReqWrapSync::req, req);
1532 if (req_wrap->continuation_data() == nullptr) {
1533 req_wrap->set_continuation_data(
1535 req_wrap->continuation_data()->PushPath(std::move(path));
1538 while (req_wrap->continuation_data()->paths().size() > 0) {
1539 std::string next_path = req_wrap->continuation_data()->PopPath();
1546 req_wrap->continuation_data()->MaybeSetFirstPath(next_path);
1547 if (req_wrap->continuation_data()->paths().size() == 0) {
1561 req_wrap->continuation_data()->PushPath(std::move(next_path));
1562 req_wrap->continuation_data()->PushPath(std::move(dirname));
1563 } else if (req_wrap->continuation_data()->paths().size() == 0) {
1576 req_wrap->continuation_data()->paths().size() > 0) {
1597 FSReqBase* req_wrap = FSReqBase::from_req(req);
1599 if (req_wrap->continuation_data() == nullptr) {
1600 req_wrap->set_continuation_data(
1602 req_wrap->continuation_data()->PushPath(std::move(path));
1606 std::string next_path = req_wrap->continuation_data()->PopPath();
1609 FSReqBase* req_wrap = FSReqBase::from_req(req);
1610 Environment* env = req_wrap->env();
1620 if (req_wrap->continuation_data()->paths().size() == 0) {
1621 req_wrap->continuation_data()->MaybeSetFirstPath(path);
1622 req_wrap->continuation_data()->Done(0);
1624 req_wrap->continuation_data()->MaybeSetFirstPath(path);
1627 req_wrap->continuation_data()->mode(), nullptr);
1634 req_wrap->continuation_data()->Done(err);
1641 req_wrap->continuation_data()->PushPath(path);
1642 req_wrap->continuation_data()->PushPath(std::move(dirname));
1643 } else if (req_wrap->continuation_data()->paths().size() == 0) {
1649 req_wrap->continuation_data()->mode(), nullptr);
1658 FSReqBase* req_wrap = FSReqBase::from_req(req);
1661 req_wrap->continuation_data()->paths().size() > 0) {
1663 Environment* env = req_wrap->env();
1668 req_wrap->continuation_data()->mode(), nullptr);
1675 req_wrap->continuation_data()->Done(err);
1677 if (err < 0) req_wrap->continuation_data()->Done(err);
1688 FSReqWrapSync* req_wrap, const char* path, int mode) {
1690 int err = MKDirpSync(env->event_loop(), &req_wrap->req, path, mode,