Home
last modified time | relevance | path

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

12

/dports/www/node10/node-v10.24.1/src/
H A Dnode_file.cc496 req_wrap->Resolve(Undefined(req_wrap->env()->isolate())); in AfterNoArgs()
513 req_wrap->Resolve(Integer::New(req_wrap->env()->isolate(), req->result)); in AfterInteger()
539 req_wrap->Reject(error); in AfterStringPath()
558 req_wrap->Reject(error); in AfterStringPtr()
616 req_wrap->Resolve(names); in AfterScanDir()
701 req_wrap->Resolve(result); in AfterScanDirWithTypes()
720 FSReqBase* req_wrap, in AsyncDestCall() argument
724 CHECK_NOT_NULL(req_wrap); in AsyncDestCall()
732 req_wrap = nullptr; in AsyncDestCall()
737 return req_wrap; in AsyncDestCall()
[all …]
H A Dstream_wrap.cc305 LibuvShutdownWrap* req_wrap = static_cast<LibuvShutdownWrap*>( in AfterUvShutdown() local
307 CHECK_NOT_NULL(req_wrap); in AfterUvShutdown()
308 HandleScope scope(req_wrap->env()->isolate()); in AfterUvShutdown()
309 Context::Scope context_scope(req_wrap->env()->context()); in AfterUvShutdown()
310 req_wrap->Done(status); in AfterUvShutdown()
354 int LibuvStreamWrap::DoWrite(std::unique_ptr<WriteWrap>& req_wrap, in DoWrite() argument
388 LibuvWriteWrap* req_wrap = static_cast<LibuvWriteWrap*>( in AfterUvWrite() local
390 CHECK_NOT_NULL(req_wrap); in AfterUvWrite()
391 HandleScope scope(req_wrap->env()->isolate()); in AfterUvWrite()
392 Context::Scope context_scope(req_wrap->env()->context()); in AfterUvWrite()
[all …]
H A Dreq_wrap-inl.h105 static T For(ReqWrap<ReqT>* req_wrap, T v) {
119 ReqWrap<ReqT>* req_wrap = ContainerOf(&ReqWrap<ReqT>::req_, req);
120 req_wrap->env()->DecreaseWaitingRequestCounter();
121 F original_callback = reinterpret_cast<F>(req_wrap->original_callback_);
125 static F For(ReqWrap<ReqT>* req_wrap, F v) {
126 CHECK_NULL(req_wrap->original_callback_);
127 req_wrap->original_callback_ =
H A 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()
H A Dudp_wrap.cc351 SendWrap* req_wrap; in DoSend() local
354 req_wrap = new SendWrap(env, req_wrap_obj, have_callback); in DoSend()
370 req_wrap->msg_size = msg_size; in DoSend()
375 err = req_wrap->Dispatch(uv_udp_send, in DoSend()
384 delete req_wrap; in DoSend()
424 SendWrap* req_wrap = static_cast<SendWrap*>(req->data); in OnSend() local
425 if (req_wrap->have_callback()) { in OnSend()
426 Environment* env = req_wrap->env(); in OnSend()
431 Integer::New(env->isolate(), req_wrap->msg_size), in OnSend()
433 req_wrap->MakeCallback(env->oncomplete_string(), 2, arg); in OnSend()
[all …]
H A Dstream_base-inl.h173 ShutdownWrap* req_wrap = CreateShutdownWrap(req_wrap_obj); in Shutdown() local
174 int err = DoShutdown(req_wrap); in Shutdown()
177 req_wrap->Dispose(); in Shutdown()
219 std::unique_ptr<WriteWrap> req_wrap{CreateWriteWrap(req_wrap_obj)}; in Write()
221 err = DoWrite(req_wrap, bufs, count, send_handle); in Write()
224 if (!async && req_wrap != nullptr) { in Write()
225 req_wrap->Dispose(); in Write()
226 req_wrap.release(); in Write()
235 return StreamWriteResult { async, err, req_wrap.release(), total_bytes }; in Write()
H A Dstream_base.cc382 StreamReq* req_wrap, int status) { in OnStreamAfterReqFinished() argument
385 AsyncWrap* async_wrap = req_wrap->GetAsyncWrap(); in OnStreamAfterReqFinished()
408 WriteWrap* req_wrap, int status) { in OnStreamAfterWrite() argument
409 OnStreamAfterReqFinished(req_wrap, status); in OnStreamAfterWrite()
413 ShutdownWrap* req_wrap, int status) { in OnStreamAfterShutdown() argument
414 OnStreamAfterReqFinished(req_wrap, status); in OnStreamAfterShutdown()
H A Dcares_wrap.cc1816 std::unique_ptr<GetAddrInfoReqWrap> req_wrap { in AfterGetAddrInfo() local
1818 Environment* env = req_wrap->env(); in AfterGetAddrInfo()
1829 const bool verbatim = req_wrap->verbatim(); in AfterGetAddrInfo()
1874 TRACING_CATEGORY_NODE2(dns, native), "lookup", req_wrap.get(), in AfterGetAddrInfo()
1886 std::unique_ptr<GetNameInfoReqWrap> req_wrap { in AfterGetNameInfo() local
1888 Environment* env = req_wrap->env(); in AfterGetNameInfo()
1973 auto req_wrap = std::make_unique<GetAddrInfoReqWrap>(env, in GetAddrInfo() local
1989 int err = req_wrap->Dispatch(uv_getaddrinfo, in GetAddrInfo()
1996 USE(req_wrap.release()); in GetAddrInfo()
2022 int err = req_wrap->Dispatch(uv_getnameinfo, in GetNameInfo()
[all …]
H A Dtcp_wrap.cc319 ConnectWrap* req_wrap = in Connect() local
321 err = req_wrap->Dispatch(uv_tcp_connect, in Connect()
326 delete req_wrap; in Connect()
H A Djs_stream.h24 int DoShutdown(ShutdownWrap* req_wrap) override;
H A Djs_stream.cc86 int JSStream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument
91 req_wrap->object() in DoShutdown()
H A Dpipe_wrap.cc234 ConnectWrap* req_wrap = in Connect() local
236 req_wrap->Dispatch(uv_pipe_connect, in Connect()
H A Dstream_base.h176 void OnStreamAfterReqFinished(StreamReq* req_wrap, int status);
211 virtual int DoShutdown(ShutdownWrap* req_wrap) = 0;
/dports/databases/rocksdb-lite/rocksdb-6.26.1/env/
H A Dio_posix.cc713 WrappedReadRequest* req_wrap; in MultiRead() local
733 auto wrap_check = wrap_cache.find(req_wrap); in MultiRead()
738 req_wrap); in MultiRead()
741 ToString((uint64_t)req_wrap)); in MultiRead()
746 FSReadRequest* req = req_wrap->req; in MultiRead()
754 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
763 !IsSectorAligned(req_wrap->finished_len, in MultiRead()
772 Read(req->offset + req_wrap->finished_len, in MultiRead()
778 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
781 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/rocksdb/rocksdb-6.26.1/env/
H A Dio_posix.cc713 WrappedReadRequest* req_wrap; in MultiRead() local
733 auto wrap_check = wrap_cache.find(req_wrap); in MultiRead()
738 req_wrap); in MultiRead()
741 ToString((uint64_t)req_wrap)); in MultiRead()
746 FSReadRequest* req = req_wrap->req; in MultiRead()
754 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
763 !IsSectorAligned(req_wrap->finished_len, in MultiRead()
772 Read(req->offset + req_wrap->finished_len, in MultiRead()
778 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
781 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc710 WrappedReadRequest* req_wrap; in MultiRead() local
727 FSReadRequest* req = req_wrap->req; in MultiRead()
735 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
744 !IsSectorAligned(req_wrap->finished_len, in MultiRead()
748 req->result = Slice(req->scratch, req_wrap->finished_len); in MultiRead()
753 Read(req->offset + req_wrap->finished_len, in MultiRead()
755 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
759 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
761 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
762 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc710 WrappedReadRequest* req_wrap; in MultiRead() local
727 FSReadRequest* req = req_wrap->req; in MultiRead()
735 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
744 !IsSectorAligned(req_wrap->finished_len, in MultiRead()
748 req->result = Slice(req->scratch, req_wrap->finished_len); in MultiRead()
753 Read(req->offset + req_wrap->finished_len, in MultiRead()
755 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
759 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
761 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
762 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc710 WrappedReadRequest* req_wrap; in MultiRead() local
727 FSReadRequest* req = req_wrap->req; in MultiRead()
735 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
744 !IsSectorAligned(req_wrap->finished_len, in MultiRead()
748 req->result = Slice(req->scratch, req_wrap->finished_len); in MultiRead()
753 Read(req->offset + req_wrap->finished_len, in MultiRead()
755 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
759 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
761 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
762 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap; in MultiRead() local
563 FSReadRequest* req = req_wrap->req; in MultiRead()
571 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
581 Read(req->offset + req_wrap->finished_len, in MultiRead()
582 req->len - req_wrap->finished_len, options, &tmp_slice, in MultiRead()
583 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size()); in MultiRead()
586 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
588 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
589 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap; in MultiRead() local
563 FSReadRequest* req = req_wrap->req; in MultiRead()
571 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
581 Read(req->offset + req_wrap->finished_len, in MultiRead()
582 req->len - req_wrap->finished_len, options, &tmp_slice, in MultiRead()
583 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size()); in MultiRead()
586 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
588 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
589 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap; in MultiRead() local
563 FSReadRequest* req = req_wrap->req; in MultiRead()
571 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
581 Read(req->offset + req_wrap->finished_len, in MultiRead()
582 req->len - req_wrap->finished_len, options, &tmp_slice, in MultiRead()
583 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size()); in MultiRead()
586 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
588 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
589 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap; in MultiRead() local
563 FSReadRequest* req = req_wrap->req; in MultiRead()
571 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
581 Read(req->offset + req_wrap->finished_len, in MultiRead()
582 req->len - req_wrap->finished_len, options, &tmp_slice, in MultiRead()
583 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size()); in MultiRead()
586 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
588 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
589 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap;
563 FSReadRequest* req = req_wrap->req;
571 if (bytes_read == req_wrap->iov.iov_len) {
581 Read(req->offset + req_wrap->finished_len,
582 req->len - req_wrap->finished_len, options, &tmp_slice,
583 req->scratch + req_wrap->finished_len, dbg);
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size());
586 } else if (bytes_read < req_wrap->iov.iov_len) {
588 assert(bytes_read + req_wrap->finished_len < req->len);
589 req_wrap->finished_len += bytes_read;
[all …]
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap; in test_c11_atomic_fetch_add_int_ptr()
563 FSReadRequest* req = req_wrap->req; in test_c11_atomic_fetch_add_int_ptr()
571 if (bytes_read == req_wrap->iov.iov_len) { in test_c11_atomic_fetch_add_int_ptr()
581 Read(req->offset + req_wrap->finished_len, in test_c11_atomic_fetch_add_int_ptr()
582 req->len - req_wrap->finished_len, options, &tmp_slice, in test_c11_atomic_fetch_add_int_ptr()
583 req->scratch + req_wrap->finished_len, dbg); in test_c11_atomic_fetch_add_int_ptr()
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size()); in test_c11_atomic_fetch_add_int_ptr()
586 } else if (bytes_read < req_wrap->iov.iov_len) { in test_c11_atomic_fetch_add_int_ptr()
588 assert(bytes_read + req_wrap->finished_len < req->len); in test_c11_atomic_fetch_add_int_ptr()
589 req_wrap->finished_len += bytes_read; in test_c11_atomic_fetch_add_int_ptr()
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/env/
H A Dio_posix.cc555 WrappedReadRequest* req_wrap; in MultiRead() local
563 FSReadRequest* req = req_wrap->req; in MultiRead()
571 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
581 Read(req->offset + req_wrap->finished_len, in MultiRead()
582 req->len - req_wrap->finished_len, options, &tmp_slice, in MultiRead()
583 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
585 Slice(req->scratch, req_wrap->finished_len + tmp_slice.size()); in MultiRead()
586 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
588 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
589 req_wrap->finished_len += bytes_read; in MultiRead()
[all …]

12