| /third_party/node/src/ |
| D | node_file.cc | 466 CloseReq* req_wrap = CloseReq::from_req(req); in ClosePromise() local
468 req->fs_type, req_wrap, "result", static_cast<int>(req->result)) in ClosePromise()
469 BaseObjectPtr<CloseReq> close(req_wrap); in ClosePromise()
588 FileHandleReadWrap* req_wrap = FileHandleReadWrap::from_req(req); in ReadStart() local
590 req->fs_type, req_wrap, "result", static_cast<int>(req->result)) in ReadStart()
591 handle = req_wrap->file_handle_; in ReadStart()
592 CHECK_EQ(handle->current_read_.get(), req_wrap); in ReadStart()
656 int FileHandle::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
658 req_wrap->Done(0); in DoShutdown()
661 FileHandleCloseWrap* wrap = static_cast<FileHandleCloseWrap*>(req_wrap); in DoShutdown()
[all …]
|
| D | node_dir.cc | 174 FSReqBase* req_wrap = FSReqBase::from_req(req); in AfterClose() local
175 FSReqAfterScope after(req_wrap, req); in AfterClose()
177 req->fs_type, req_wrap, "result", static_cast<int>(req->result)) in AfterClose()
179 req_wrap->Resolve(Undefined(req_wrap->env()->isolate())); in AfterClose()
240 BaseObjectPtr<FSReqBase> req_wrap { FSReqBase::from_req(req) }; in AfterDirRead() local
241 FSReqAfterScope after(req_wrap.get(), req); in AfterDirRead()
243 req->fs_type, req_wrap, "result", static_cast<int>(req->result)) in AfterDirRead()
248 Environment* env = req_wrap->env(); in AfterDirRead()
255 req_wrap->Resolve(done); in AfterDirRead()
266 req_wrap->encoding(), in AfterDirRead()
[all …]
|
| D | stream_wrap.cc | 337 LibuvShutdownWrap* req_wrap = static_cast<LibuvShutdownWrap*>(req_wrap_); in DoShutdown() local
338 return req_wrap->Dispatch(uv_shutdown, stream(), AfterUvShutdown); in DoShutdown()
343 LibuvShutdownWrap* req_wrap = static_cast<LibuvShutdownWrap*>( in AfterUvShutdown() local
345 CHECK_NOT_NULL(req_wrap); in AfterUvShutdown()
346 HandleScope scope(req_wrap->env()->isolate()); in AfterUvShutdown()
347 Context::Scope context_scope(req_wrap->env()->context()); in AfterUvShutdown()
348 req_wrap->Done(status); in AfterUvShutdown()
392 int LibuvStreamWrap::DoWrite(WriteWrap* req_wrap, in DoWrite() argument
396 LibuvWriteWrap* w = static_cast<LibuvWriteWrap*>(req_wrap); in DoWrite()
408 LibuvWriteWrap* req_wrap = static_cast<LibuvWriteWrap*>( in AfterUvWrite() local
[all …]
|
| D | req_wrap-inl.h | 108 static T For(ReqWrap<ReqT>* req_wrap, T v) {
122 BaseObjectPtr<ReqWrap<ReqT>> req_wrap{ReqWrap<ReqT>::from_req(req)};
123 req_wrap->Detach();
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_ =
|
| D | connection_wrap.cc | 80 BaseObjectPtr<ConnectWrap> req_wrap{static_cast<ConnectWrap*>(req->data)}; in AfterConnect() local
81 CHECK(req_wrap); in AfterConnect()
83 CHECK_EQ(req_wrap->env(), wrap->env()); in AfterConnect()
90 CHECK_EQ(req_wrap->persistent().IsEmpty(), false); in AfterConnect()
105 req_wrap->object(), in AfterConnect()
112 req_wrap.get(), in AfterConnect()
116 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv); in AfterConnect()
|
| D | node_file-inl.h | 294 FSReqBase* AsyncDestCall(Environment* env, FSReqBase* req_wrap, in AsyncDestCall() argument
299 CHECK_NOT_NULL(req_wrap); in AsyncDestCall()
300 req_wrap->Init(syscall, dest, len, enc); in AsyncDestCall()
301 int err = req_wrap->Dispatch(fn, fn_args..., after); in AsyncDestCall()
303 uv_fs_t* uv_req = req_wrap->req(); in AsyncDestCall()
307 req_wrap = nullptr; in AsyncDestCall()
309 req_wrap->SetReturnValue(args); in AsyncDestCall()
312 return req_wrap; in AsyncDestCall()
318 FSReqBase* req_wrap, in AsyncCall() argument
322 return AsyncDestCall(env, req_wrap, args, in AsyncCall()
[all …]
|
| D | stream_base.cc | 59 ShutdownWrap* req_wrap = CreateShutdownWrap(req_wrap_obj); in Shutdown() local
60 if (req_wrap != nullptr) req_wrap_ptr.reset(req_wrap->GetAsyncWrap()); in Shutdown()
61 int err = DoShutdown(req_wrap); in Shutdown()
63 if (err != 0 && req_wrap != nullptr) { in Shutdown()
64 req_wrap->Dispose(); in Shutdown()
113 WriteWrap* req_wrap = CreateWriteWrap(req_wrap_obj); in Write() local
114 BaseObjectPtr<AsyncWrap> req_wrap_ptr(req_wrap->GetAsyncWrap()); in Write()
116 err = DoWrite(req_wrap, bufs, count, send_handle); in Write()
120 req_wrap->Dispose(); in Write()
121 req_wrap = nullptr; in Write()
[all …]
|
| D | udp_wrap.cc | 592 ReqWrap<uv_udp_send_t>* req_wrap = listener()->CreateSendWrap(msg_size); in Send() local
593 if (req_wrap == nullptr) return UV_ENOSYS; in Send()
595 err = req_wrap->Dispatch( in Send()
607 delete req_wrap; in Send()
615 SendWrap* req_wrap = new SendWrap(env(), in CreateSendWrap() local
618 req_wrap->msg_size = msg_size; in CreateSendWrap()
619 return req_wrap; in CreateSendWrap()
672 BaseObjectPtr<SendWrap> req_wrap{static_cast<SendWrap*>(req)}; in OnSendDone() local
673 if (req_wrap->have_callback()) { in OnSendDone()
674 Environment* env = req_wrap->env(); in OnSendDone()
[all …]
|
| D | cares_wrap.cc | 1435 BaseObjectPtr<GetAddrInfoReqWrap> req_wrap{ in AfterGetAddrInfo() local
1437 Environment* env = req_wrap->env(); in AfterGetAddrInfo()
1448 const bool verbatim = req_wrap->verbatim(); in AfterGetAddrInfo()
1496 TRACING_CATEGORY_NODE2(dns, native), "lookup", req_wrap.get(), in AfterGetAddrInfo()
1500 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv); in AfterGetAddrInfo()
1508 BaseObjectPtr<GetNameInfoReqWrap> req_wrap{ in AfterGetNameInfo() local
1510 Environment* env = req_wrap->env(); in AfterGetNameInfo()
1530 TRACING_CATEGORY_NODE2(dns, native), "lookupService", req_wrap.get(), in AfterGetNameInfo()
1535 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv); in AfterGetNameInfo()
1587 auto req_wrap = std::make_unique<GetAddrInfoReqWrap>(env, in GetAddrInfo() local
[all …]
|
| D | pipe_wrap.cc | 238 ConnectWrap* req_wrap = in Connect() local
240 req_wrap->Dispatch(uv_pipe_connect, in Connect()
247 req_wrap, in Connect()
|
| D | js_udp_wrap.cc | 183 ReqWrap<uv_udp_send_t>* req_wrap; in OnSendDone() local
184 ASSIGN_OR_RETURN_UNWRAP(&req_wrap, args[0].As<Object>()); in OnSendDone()
187 wrap->listener()->OnSendDone(req_wrap, status); in OnSendDone()
|
| D | node_file.h | 327 int DoShutdown(ShutdownWrap* req_wrap) override;
455 inline FSReqBase* AsyncDestCall(Environment* env, FSReqBase* req_wrap,
464 FSReqBase* req_wrap,
475 FSReqWrapSync* req_wrap, const char* syscall,
|
| D | tcp_wrap.cc | 338 ConnectWrap* req_wrap = in Connect() local
340 err = req_wrap->Dispatch(uv_tcp_connect, in Connect()
345 delete req_wrap; in Connect()
351 req_wrap, in Connect()
|
| D | js_stream.cc | 88 int JSStream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
93 req_wrap->object() in DoShutdown()
|
| D | node_http2.h | 148 BaseObjectPtr<AsyncWrap> req_wrap; member
152 inline NgHttp2StreamWrite(BaseObjectPtr<AsyncWrap> req_wrap, uv_buf_t buf_) : in NgHttp2StreamWrite()
153 req_wrap(std::move(req_wrap)), buf(buf_) {} in NgHttp2StreamWrite()
295 int DoShutdown(ShutdownWrap* req_wrap) override;
|
| D | node_process_methods.cc | 257 for (ReqWrapBase* req_wrap : *env->req_wrap_queue()) { in GetActiveRequests()
258 AsyncWrap* w = req_wrap->GetAsyncWrap(); in GetActiveRequests()
288 for (ReqWrapBase* req_wrap : *env->req_wrap_queue()) { in GetActiveResourcesInfo()
289 AsyncWrap* w = req_wrap->GetAsyncWrap(); in GetActiveResourcesInfo()
|
| D | js_stream.h | 25 int DoShutdown(ShutdownWrap* req_wrap) override;
|
| D | stream_wrap.h | 53 int DoShutdown(ShutdownWrap* req_wrap) override;
|
| D | stream_base.h | 191 void OnStreamAfterReqFinished(StreamReq* req_wrap, int status);
242 virtual int DoShutdown(ShutdownWrap* req_wrap) = 0;
|
| D | node_http2.cc | 1679 BaseObjectPtr<AsyncWrap> wrap = std::move(wr.req_wrap); in ClearOutgoing()
1969 if (wr.req_wrap && WriteWrap::FromObject(wr.req_wrap)->stream() == stream) in HasWritesOnSocketForStream()
2114 int Http2Stream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
2153 if (head.req_wrap) in Destroy()
2154 WriteWrap::FromObject(head.req_wrap)->Done(UV_ECANCELED); in Destroy()
2387 int Http2Stream::DoWrite(WriteWrap* req_wrap, in DoWrite() argument
2402 i == nbufs - 1 ? req_wrap->GetAsyncWrap() : nullptr), in DoWrite()
2497 std::move(stream->queue_.front().req_wrap); in OnRead()
3141 if (req_wrap) in MemoryInfo()
3142 tracker->TrackField("req_wrap", req_wrap); in MemoryInfo()
|
| D | heap_utils.cc | 314 int DoShutdown(ShutdownWrap* req_wrap) override { in DoShutdown() argument
|
| /third_party/node/src/quic/ |
| D | logstream.h | 44 int DoShutdown(ShutdownWrap* req_wrap) override;
|
| D | logstream.cc | 116 int LogStream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
|
| /third_party/node/src/crypto/ |
| D | crypto_tls.h | 84 int DoShutdown(ShutdownWrap* req_wrap) override;
|
| D | crypto_tls.cc | 683 void TLSWrap::OnStreamAfterWrite(WriteWrap* req_wrap, int status) { in OnStreamAfterWrite() argument
690 previous_listener_->OnStreamAfterWrite(req_wrap, status); in OnStreamAfterWrite()
1144 int TLSWrap::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
1153 return underlying_stream()->DoShutdown(req_wrap); in DoShutdown()
|