Home
last modified time | relevance | path

Searched refs:req_wrap (Results 1 – 25 of 27) sorted by relevance

12

/third_party/node/src/
Dnode_file.cc482 FileHandleReadWrap* req_wrap = FileHandleReadWrap::from_req(req); in ReadStart() local
483 handle = req_wrap->file_handle_; in ReadStart()
484 CHECK_EQ(handle->current_read_.get(), req_wrap); in ReadStart()
548 int FileHandle::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
549 FileHandleCloseWrap* wrap = static_cast<FileHandleCloseWrap*>(req_wrap); in DoShutdown()
645 FSReqBase* req_wrap = FSReqBase::from_req(req); in AfterNoArgs() local
646 FSReqAfterScope after(req_wrap, req); in AfterNoArgs()
649 req_wrap->Resolve(Undefined(req_wrap->env()->isolate())); in AfterNoArgs()
653 FSReqBase* req_wrap = FSReqBase::from_req(req); in AfterStat() local
654 FSReqAfterScope after(req_wrap, req); in AfterStat()
[all …]
Dnode_dir.cc132 FSReqBase* req_wrap = FSReqBase::from_req(req); in AfterClose() local
133 FSReqAfterScope after(req_wrap, req); in AfterClose()
136 req_wrap->Resolve(Undefined(req_wrap->env()->isolate())); in AfterClose()
196 BaseObjectPtr<FSReqBase> req_wrap { FSReqBase::from_req(req) }; in AfterDirRead() local
197 FSReqAfterScope after(req_wrap.get(), req); in AfterDirRead()
203 Environment* env = req_wrap->env(); in AfterDirRead()
210 req_wrap->Resolve(done); in AfterDirRead()
221 req_wrap->encoding(), in AfterDirRead()
226 return req_wrap->Reject(error); in AfterDirRead()
230 req_wrap->Resolve(js_array); in AfterDirRead()
[all …]
Dstream_wrap.cc316 LibuvShutdownWrap* req_wrap = static_cast<LibuvShutdownWrap*>(req_wrap_); in DoShutdown() local
317 return req_wrap->Dispatch(uv_shutdown, stream(), AfterUvShutdown); in DoShutdown()
322 LibuvShutdownWrap* req_wrap = static_cast<LibuvShutdownWrap*>( in AfterUvShutdown() local
324 CHECK_NOT_NULL(req_wrap); in AfterUvShutdown()
325 HandleScope scope(req_wrap->env()->isolate()); in AfterUvShutdown()
326 Context::Scope context_scope(req_wrap->env()->context()); in AfterUvShutdown()
327 req_wrap->Done(status); in AfterUvShutdown()
371 int LibuvStreamWrap::DoWrite(WriteWrap* req_wrap, in DoWrite() argument
375 LibuvWriteWrap* w = static_cast<LibuvWriteWrap*>(req_wrap); in DoWrite()
387 LibuvWriteWrap* req_wrap = static_cast<LibuvWriteWrap*>( in AfterUvWrite() local
[all …]
Dstream_base-inl.h142 ShutdownWrap* req_wrap = CreateShutdownWrap(req_wrap_obj); in Shutdown() local
143 if (req_wrap != nullptr) in Shutdown()
144 req_wrap_ptr.reset(req_wrap->GetAsyncWrap()); in Shutdown()
145 int err = DoShutdown(req_wrap); in Shutdown()
147 if (err != 0 && req_wrap != nullptr) { in Shutdown()
148 req_wrap->Dispose(); in Shutdown()
194 WriteWrap* req_wrap = CreateWriteWrap(req_wrap_obj); in Write() local
195 BaseObjectPtr<AsyncWrap> req_wrap_ptr(req_wrap->GetAsyncWrap()); in Write()
197 err = DoWrite(req_wrap, bufs, count, send_handle); in Write()
201 req_wrap->Dispose(); in Write()
[all …]
Dreq_wrap-inl.h109 static T For(ReqWrap<ReqT>* req_wrap, T v) {
123 ReqWrap<ReqT>* req_wrap = ReqWrap<ReqT>::from_req(req);
124 req_wrap->env()->DecreaseWaitingRequestCounter();
125 F original_callback = reinterpret_cast<F>(req_wrap->original_callback_);
129 static F For(ReqWrap<ReqT>* req_wrap, F v) {
130 CHECK_NULL(req_wrap->original_callback_);
131 req_wrap->original_callback_ =
Dnode_file-inl.h244 FSReqBase* AsyncDestCall(Environment* env, FSReqBase* req_wrap, in AsyncDestCall() argument
249 CHECK_NOT_NULL(req_wrap); in AsyncDestCall()
250 req_wrap->Init(syscall, dest, len, enc); in AsyncDestCall()
251 int err = req_wrap->Dispatch(fn, fn_args..., after); in AsyncDestCall()
253 uv_fs_t* uv_req = req_wrap->req(); in AsyncDestCall()
257 req_wrap = nullptr; in AsyncDestCall()
259 req_wrap->SetReturnValue(args); in AsyncDestCall()
262 return req_wrap; in AsyncDestCall()
268 FSReqBase* req_wrap, in AsyncCall() argument
272 return AsyncDestCall(env, req_wrap, args, in AsyncCall()
[all …]
Dconnection_wrap.cc80 std::unique_ptr<ConnectWrap> req_wrap in AfterConnect() local
82 CHECK_NOT_NULL(req_wrap); in AfterConnect()
84 CHECK_EQ(req_wrap->env(), wrap->env()); in AfterConnect()
91 CHECK_EQ(req_wrap->persistent().IsEmpty(), false); in AfterConnect()
106 req_wrap->object(), in AfterConnect()
111 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv); in AfterConnect()
Dudp_wrap.cc578 ReqWrap<uv_udp_send_t>* req_wrap = listener()->CreateSendWrap(msg_size); in Send() local
579 if (req_wrap == nullptr) return UV_ENOSYS; in Send()
581 err = req_wrap->Dispatch( in Send()
593 delete req_wrap; in Send()
601 SendWrap* req_wrap = new SendWrap(env(), in CreateSendWrap() local
604 req_wrap->msg_size = msg_size; in CreateSendWrap()
605 return req_wrap; in CreateSendWrap()
658 std::unique_ptr<SendWrap> req_wrap{static_cast<SendWrap*>(req)}; in OnSendDone() local
659 if (req_wrap->have_callback()) { in OnSendDone()
660 Environment* env = req_wrap->env(); in OnSendDone()
[all …]
Djs_udp_wrap.cc176 ReqWrap<uv_udp_send_t>* req_wrap; in OnSendDone() local
177 ASSIGN_OR_RETURN_UNWRAP(&req_wrap, args[0].As<Object>()); in OnSendDone()
180 wrap->listener()->OnSendDone(req_wrap, status); in OnSendDone()
Dcares_wrap.cc1431 std::unique_ptr<GetAddrInfoReqWrap> req_wrap { in AfterGetAddrInfo() local
1433 Environment* env = req_wrap->env(); in AfterGetAddrInfo()
1444 const bool verbatim = req_wrap->verbatim(); in AfterGetAddrInfo()
1494 TRACING_CATEGORY_NODE2(dns, native), "lookup", req_wrap.get(), in AfterGetAddrInfo()
1498 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv); in AfterGetAddrInfo()
1506 std::unique_ptr<GetNameInfoReqWrap> req_wrap { in AfterGetNameInfo() local
1508 Environment* env = req_wrap->env(); in AfterGetNameInfo()
1528 TRACING_CATEGORY_NODE2(dns, native), "lookupService", req_wrap.get(), in AfterGetNameInfo()
1533 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv); in AfterGetNameInfo()
1594 auto req_wrap = std::make_unique<GetAddrInfoReqWrap>(env, in GetAddrInfo() local
[all …]
Dstream_base.cc549 StreamReq* req_wrap, int status) { in OnStreamAfterReqFinished() argument
552 AsyncWrap* async_wrap = req_wrap->GetAsyncWrap(); in OnStreamAfterReqFinished()
575 WriteWrap* req_wrap, int status) { in OnStreamAfterWrite() argument
576 OnStreamAfterReqFinished(req_wrap, status); in OnStreamAfterWrite()
580 ShutdownWrap* req_wrap, int status) { in OnStreamAfterShutdown() argument
581 OnStreamAfterReqFinished(req_wrap, status); in OnStreamAfterShutdown()
Dnode_file.h264 int DoShutdown(ShutdownWrap* req_wrap) override;
392 inline FSReqBase* AsyncDestCall(Environment* env, FSReqBase* req_wrap,
401 FSReqBase* req_wrap,
412 FSReqWrapSync* req_wrap, const char* syscall,
Djs_stream.h25 int DoShutdown(ShutdownWrap* req_wrap) override;
Djs_stream.cc87 int JSStream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
92 req_wrap->object() in DoShutdown()
Dpipe_wrap.cc225 ConnectWrap* req_wrap = in Connect() local
227 req_wrap->Dispatch(uv_pipe_connect, in Connect()
Dtcp_wrap.cc312 ConnectWrap* req_wrap = in Connect() local
314 err = req_wrap->Dispatch(uv_tcp_connect, in Connect()
319 delete req_wrap; in Connect()
Dstream_wrap.h52 int DoShutdown(ShutdownWrap* req_wrap) override;
Dnode_http2.h147 BaseObjectPtr<AsyncWrap> req_wrap; member
151 inline NgHttp2StreamWrite(BaseObjectPtr<AsyncWrap> req_wrap, uv_buf_t buf_) : in NgHttp2StreamWrite()
152 req_wrap(std::move(req_wrap)), buf(buf_) {} in NgHttp2StreamWrite()
294 int DoShutdown(ShutdownWrap* req_wrap) override;
Dnode_http2.cc1534 BaseObjectPtr<AsyncWrap> wrap = std::move(wr.req_wrap); in ClearOutgoing()
1822 if (wr.req_wrap && WriteWrap::FromObject(wr.req_wrap)->stream() == stream) in HasWritesOnSocketForStream()
1963 int Http2Stream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
2002 if (head.req_wrap) in Destroy()
2003 WriteWrap::FromObject(head.req_wrap)->Done(UV_ECANCELED); in Destroy()
2236 int Http2Stream::DoWrite(WriteWrap* req_wrap, in DoWrite() argument
2243 req_wrap->Done(UV_EOF); in DoWrite()
2252 i == nbufs - 1 ? req_wrap->GetAsyncWrap() : nullptr), in DoWrite()
2347 std::move(stream->queue_.front().req_wrap); in OnRead()
2995 if (req_wrap) in MemoryInfo()
[all …]
Dstream_base.h189 void OnStreamAfterReqFinished(StreamReq* req_wrap, int status);
240 virtual int DoShutdown(ShutdownWrap* req_wrap) = 0;
Dtls_wrap.h73 int DoShutdown(ShutdownWrap* req_wrap) override;
Dnode_process_methods.cc276 for (ReqWrapBase* req_wrap : *env->req_wrap_queue()) { in GetActiveRequests()
277 AsyncWrap* w = req_wrap->GetAsyncWrap(); in GetActiveRequests()
Dtls_wrap.cc374 void TLSWrap::OnStreamAfterWrite(WriteWrap* req_wrap, int status) { in OnStreamAfterWrite() argument
888 int TLSWrap::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
897 return stream_->DoShutdown(req_wrap); in DoShutdown()
Dheap_utils.cc281 int DoShutdown(ShutdownWrap* req_wrap) override { in DoShutdown() argument
/third_party/node/
Dnode.gyp526 'src/req_wrap.h',
527 'src/req_wrap-inl.h',

12