/dports/www/node10/node-v10.24.1/src/ |
H A D | node_file.cc | 496 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 D | stream_wrap.cc | 305 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 D | req_wrap-inl.h | 105 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 D | connection_wrap.cc | 80 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 D | udp_wrap.cc | 351 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 D | stream_base-inl.h | 173 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 D | stream_base.cc | 382 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 D | cares_wrap.cc | 1816 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 D | tcp_wrap.cc | 319 ConnectWrap* req_wrap = in Connect() local 321 err = req_wrap->Dispatch(uv_tcp_connect, in Connect() 326 delete req_wrap; in Connect()
|
H A D | js_stream.h | 24 int DoShutdown(ShutdownWrap* req_wrap) override;
|
H A D | js_stream.cc | 86 int JSStream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown() argument 91 req_wrap->object() in DoShutdown()
|
H A D | pipe_wrap.cc | 234 ConnectWrap* req_wrap = in Connect() local 236 req_wrap->Dispatch(uv_pipe_connect, in Connect()
|
H A D | stream_base.h | 176 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 D | io_posix.cc | 713 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 D | io_posix.cc | 713 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 D | io_posix.cc | 710 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 D | io_posix.cc | 710 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 D | io_posix.cc | 710 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 D | io_posix.cc | 555 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 D | io_posix.cc | 555 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 D | io_posix.cc | 555 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 D | io_posix.cc | 555 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 D | io_posix.cc | 555 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 D | io_posix.cc | 555 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 D | io_posix.cc | 555 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 …]
|