/src/node/src/req_wrap-inl.h

Source
#ifndef SRC_REQ_WRAP_INL_H_
#define SRC_REQ_WRAP_INL_H_

#if defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS

#include "req_wrap.h"
#include "async_wrap-inl.h"
#include "uv.h"

namespace node {

ReqWrapBase::ReqWrapBase(Environment* env) {
  CHECK(env->has_run_bootstrapping_code());
  env->req_wrap_queue()->PushBack(this);
}

template <typename T>
ReqWrap<T>::ReqWrap(Environment* env,
                    v8::Local<v8::Object> object,
                    AsyncWrap::ProviderType provider)
    : AsyncWrap(env, object, provider),
      ReqWrapBase(env) {
  MakeWeak();
  Reset();
}

template <typename T>
ReqWrap<T>::~ReqWrap() {}

template <typename T>
void ReqWrap<T>::Dispatched() {
  req_.data = this;
}

template <typename T>
void ReqWrap<T>::Reset() {
  original_callback_ = nullptr;
  req_.data = nullptr;
}

template <typename T>
ReqWrap<T>* ReqWrap<T>::from_req(T* req) {
  return ContainerOf(&ReqWrap<T>::req_, req);
}

template <typename T>
void ReqWrap<T>::Cancel() {
  if (req_.data == this)  // Only cancel if already dispatched.
    uv_cancel(reinterpret_cast<uv_req_t*>(&req_));
}

template <typename T>
bool ReqWrap<T>::IsDispatched() {
  return req_.data != nullptr;
}

template <typename T>
AsyncWrap* ReqWrap<T>::GetAsyncWrap() {
  return this;
}

// Below is dark template magic designed to invoke libuv functions that
// initialize uv_req_t instances in a unified fashion, to allow easier
// tracking of active/inactive requests.

// Invoke a generic libuv function that initializes uv_req_t instances.
// This is, unfortunately, necessary since they come in three different
// variants that can not all be invoked in the same way:
// - int uv_foo(uv_loop_t* loop, uv_req_t* request, ...);
// - int uv_foo(uv_req_t* request, ...);
// - void uv_foo(uv_req_t* request, ...);
template <typename ReqT, typename T>
struct CallLibuvFunction;

// Detect `int uv_foo(uv_loop_t* loop, uv_req_t* request, ...);`.
template <typename ReqT, typename... Args>
struct CallLibuvFunction<ReqT, int(*)(uv_loop_t*, ReqT*, Args...)> {
  using T = int(*)(uv_loop_t*, ReqT*, Args...);
  template <typename... PassedArgs>
  static int Call(T fn, uv_loop_t* loop, ReqT* req, PassedArgs... args) {
    return fn(loop, req, args...);
  }
};

// Detect `int uv_foo(uv_req_t* request, ...);`.
template <typename ReqT, typename... Args>
struct CallLibuvFunction<ReqT, int(*)(ReqT*, Args...)> {
  using T = int(*)(ReqT*, Args...);
  template <typename... PassedArgs>
  static int Call(T fn, uv_loop_t* loop, ReqT* req, PassedArgs... args) {
    return fn(req, args...);
  }
};

// Detect `void uv_foo(uv_req_t* request, ...);`.
template <typename ReqT, typename... Args>
struct CallLibuvFunction<ReqT, void(*)(ReqT*, Args...)> {
  using T = void(*)(ReqT*, Args...);
  template <typename... PassedArgs>
  static int Call(T fn, uv_loop_t* loop, ReqT* req, PassedArgs... args) {
    fn(req, args...);
    return 0;
  }
};

// This is slightly darker magic: This template is 'applied' to each parameter
// passed to the libuv function. If the parameter type (aka `T`) is a
// function type, it is assumed that this it is the request callback, and a
// wrapper that calls the original callback is created.
// If not, the parameter is passed through verbatim.
template <typename ReqT, typename T>
struct MakeLibuvRequestCallback {
  static T For(ReqWrap<ReqT>* req_wrap, T v) {
    static_assert(!is_callable<T>,
                  "MakeLibuvRequestCallback missed a callback");
    return v;
  }
};

// Match the `void callback(uv_req_t*, ...);` signature that all libuv
// callbacks use.
template <typename ReqT, typename... Args>
struct MakeLibuvRequestCallback<ReqT, void(*)(ReqT*, Args...)> {
  using F = void(*)(ReqT* req, Args... args);

  static void Wrapper(ReqT* req, Args... args) {
    BaseObjectPtr<ReqWrap<ReqT>> req_wrap{ReqWrap<ReqT>::from_req(req)};
    req_wrap->Detach();
    req_wrap->env()->DecreaseWaitingRequestCounter();
    F original_callback = reinterpret_cast<F>(req_wrap->original_callback_);
    original_callback(req, args...);
  }

  static F For(ReqWrap<ReqT>* req_wrap, F v) {
    CHECK_NULL(req_wrap->original_callback_);
    req_wrap->original_callback_ =
        reinterpret_cast<typename ReqWrap<ReqT>::callback_t>(v);
    return Wrapper;
  }
};

template <typename T>
template <typename LibuvFunction, typename... Args>
int ReqWrap<T>::Dispatch(LibuvFunction fn, Args... args) {
  Dispatched();
  // This expands as:
  //
  // int err = fn(env()->event_loop(), req(), arg1, arg2, Wrapper, arg3, ...)
  //              ^                                       ^        ^
  //              |                                       |        |
  //              \-- Omitted if `fn` has no              |        |
  //                  first `uv_loop_t*` argument         |        |
  //                                                      |        |
  //        A function callback whose first argument      |        |
  //        matches the libuv request type is replaced ---/        |
  //        by the `Wrapper` method defined above                  |
  //                                                               |
  //               Other (non-function) arguments are passed  -----/
  //               through verbatim
  int err = CallLibuvFunction<T, LibuvFunction>::Call(
      fn,
      env()->event_loop(),
      req(),
      MakeLibuvRequestCallback<T, Args>::For(this, args)...);
  if (err >= 0) {
    ClearWeak();
    env()->IncreaseWaitingRequestCounter();
  }
  return err;
}

}  // namespace node

#endif  // defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS

#endif  // SRC_REQ_WRAP_INL_H_

Line	Count	Source
1		#ifndef SRC_REQ_WRAP_INL_H_
2		#define SRC_REQ_WRAP_INL_H_
3
4		#if defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS
5
6		#include "req_wrap.h"
7		#include "async_wrap-inl.h"
8		#include "uv.h"
9
10		namespace node {
11
12	0	ReqWrapBase::ReqWrapBase(Environment* env) {
13	0	CHECK(env->has_run_bootstrapping_code());
14	0	env->req_wrap_queue()->PushBack(this);
15	0	}
16
17		template <typename T>
18		ReqWrap<T>::ReqWrap(Environment* env,
19		v8::Local<v8::Object> object,
20		AsyncWrap::ProviderType provider)
21	0	: AsyncWrap(env, object, provider),
22	0	ReqWrapBase(env) {
23	0	MakeWeak();
24	0	Reset();
25	0	} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::ReqWrap(node::Environment, v8::Local<v8::Object>, node::AsyncWrap::ProviderType) Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::ReqWrap(node::Environment, v8::Local<v8::Object>, node::AsyncWrap::ProviderType) Unexecuted instantiation: node::ReqWrap<uv_write_s>::ReqWrap(node::Environment, v8::Local<v8::Object>, node::AsyncWrap::ProviderType) Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::ReqWrap(node::Environment, v8::Local<v8::Object>, node::AsyncWrap::ProviderType) Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::ReqWrap(node::Environment, v8::Local<v8::Object>, node::AsyncWrap::ProviderType) Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::ReqWrap(node::Environment, v8::Local<v8::Object>, node::AsyncWrap::ProviderType) Unexecuted instantiation: node::ReqWrap<uv_connect_s>::ReqWrap(node::Environment*, v8::Local<v8::Object>, node::AsyncWrap::ProviderType)
26
27		template <typename T>
28	0	ReqWrap<T>::~ReqWrap() {} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::~ReqWrap() Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::~ReqWrap() Unexecuted instantiation: node::ReqWrap<uv_write_s>::~ReqWrap() Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::~ReqWrap() Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::~ReqWrap() Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::~ReqWrap() Unexecuted instantiation: node::ReqWrap<uv_connect_s>::~ReqWrap()
29
30		template <typename T>
31	0	void ReqWrap<T>::Dispatched() {
32	0	req_.data = this;
33	0	} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::Dispatched() Unexecuted instantiation: node::ReqWrap<uv_connect_s>::Dispatched() Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::Dispatched() Unexecuted instantiation: node::ReqWrap<uv_write_s>::Dispatched() Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::Dispatched() Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::Dispatched() Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::Dispatched()
34
35		template <typename T>
36	0	void ReqWrap<T>::Reset() {
37	0	original_callback_ = nullptr;
38	0	req_.data = nullptr;
39	0	} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::Reset() Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::Reset() Unexecuted instantiation: node::ReqWrap<uv_write_s>::Reset() Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::Reset() Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::Reset() Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::Reset() Unexecuted instantiation: node::ReqWrap<uv_connect_s>::Reset()
40
41		template <typename T>
42	0	ReqWrap<T>* ReqWrap<T>::from_req(T* req) {
43	0	return ContainerOf(&ReqWrap<T>::req_, req);
44	0	} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::from_req(uv_fs_s) Unexecuted instantiation: node::ReqWrap<uv_connect_s>::from_req(uv_connect_s) Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::from_req(uv_shutdown_s) Unexecuted instantiation: node::ReqWrap<uv_write_s>::from_req(uv_write_s) Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::from_req(uv_udp_send_s) Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::from_req(uv_getaddrinfo_s) Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::from_req(uv_getnameinfo_s*)
45
46		template <typename T>
47	0	void ReqWrap<T>::Cancel() {
48	0	if (req_.data == this) // Only cancel if already dispatched.
49	0	uv_cancel(reinterpret_cast<uv_req_t*>(&req_));
50	0	} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::Cancel() Unexecuted instantiation: node::ReqWrap<uv_connect_s>::Cancel() Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::Cancel() Unexecuted instantiation: node::ReqWrap<uv_write_s>::Cancel() Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::Cancel() Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::Cancel() Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::Cancel()
51
52		template <typename T>
53	0	bool ReqWrap<T>::IsDispatched() {
54	0	return req_.data != nullptr;
55	0	}
56
57		template <typename T>
58	0	AsyncWrap* ReqWrap<T>::GetAsyncWrap() {
59	0	return this;
60	0	} Unexecuted instantiation: node::ReqWrap<uv_fs_s>::GetAsyncWrap() Unexecuted instantiation: node::ReqWrap<uv_connect_s>::GetAsyncWrap() Unexecuted instantiation: node::ReqWrap<uv_shutdown_s>::GetAsyncWrap() Unexecuted instantiation: node::ReqWrap<uv_write_s>::GetAsyncWrap() Unexecuted instantiation: node::ReqWrap<uv_udp_send_s>::GetAsyncWrap() Unexecuted instantiation: node::ReqWrap<uv_getaddrinfo_s>::GetAsyncWrap() Unexecuted instantiation: node::ReqWrap<uv_getnameinfo_s>::GetAsyncWrap()
61
62		// Below is dark template magic designed to invoke libuv functions that
63		// initialize uv_req_t instances in a unified fashion, to allow easier
64		// tracking of active/inactive requests.
65
66		// Invoke a generic libuv function that initializes uv_req_t instances.
67		// This is, unfortunately, necessary since they come in three different
68		// variants that can not all be invoked in the same way:
69		// - int uv_foo(uv_loop_t* loop, uv_req_t* request, ...);
70		// - int uv_foo(uv_req_t* request, ...);
71		// - void uv_foo(uv_req_t* request, ...);
72		template <typename ReqT, typename T>
73		struct CallLibuvFunction;
74
75		// Detect `int uv_foo(uv_loop_t* loop, uv_req_t* request, ...);`.
76		template <typename ReqT, typename... Args>
77		struct CallLibuvFunction<ReqT, int()(uv_loop_t, ReqT*, Args...)> {
78		using T = int()(uv_loop_t, ReqT*, Args...);
79		template <typename... PassedArgs>
80	0	static int Call(T fn, uv_loop_t* loop, ReqT* req, PassedArgs... args) {
81	0	return fn(loop, req, args...);
82	0	} Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, void ()(uv_fs_s))>::Call<char, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, uv_dir_s, void ()(uv_fs_s))>::Call<uv_dir_s, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, uv_dir_s, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, uv_dir_s, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, int, int, void ()(uv_fs_s))>::Call<char, int, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, int, int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, int, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s))>::Call<int, uv_buf_t, unsigned long, long, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, uv_buf_t, unsigned long, long, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, char const, void ()(uv_fs_s))>::Call<char, char, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, char const, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, char, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, long, void ()(uv_fs_s))>::Call<int, long, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, long, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, long, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, char const, int, void ()(uv_fs_s))>::Call<char, char, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, char const, int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, char, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, int, void ()(uv_fs_s))>::Call<int, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, unsigned int, unsigned int, void ()(uv_fs_s))>::Call<char, unsigned int, unsigned int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, unsigned int, unsigned int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, unsigned int, unsigned int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, unsigned int, unsigned int, void ()(uv_fs_s))>::Call<int, unsigned int, unsigned int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, unsigned int, unsigned int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, unsigned int, unsigned int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, double, double, void ()(uv_fs_s))>::Call<char, double, double, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, double, double, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, double, double, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, double, double, void ()(uv_fs_s))>::Call<int, double, double, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, double, double, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, double, double, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, void ()(uv_fs_s))>::Call<int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s))>::Call<int, uv_buf_t, int, long, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, int, uv_buf_t, int, long, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_fs_s, int ()(uv_loop_s, uv_fs_s, char const, int, void ()(uv_fs_s))>::Call<char, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, int, void ()(uv_fs_s)), uv_loop_s, uv_fs_s, char, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::CallLibuvFunction<uv_getaddrinfo_s, int ()(uv_loop_s, uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo), char const, char const, addrinfo const)>::Call<void ()(uv_getaddrinfo_s, int, addrinfo), char, decltype(nullptr), addrinfo>(int ()(uv_loop_s, uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo), char const, char const, addrinfo const), uv_loop_s, uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo), char, decltype(nullptr), addrinfo) Unexecuted instantiation: int node::CallLibuvFunction<uv_getnameinfo_s, int ()(uv_loop_s, uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const), sockaddr const, int)>::Call<void ()(uv_getnameinfo_s, int, char const, char const), sockaddr, int>(int ()(uv_loop_s, uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const), sockaddr const, int), uv_loop_s, uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const), sockaddr, int)
83		};
84
85		// Detect `int uv_foo(uv_req_t* request, ...);`.
86		template <typename ReqT, typename... Args>
87		struct CallLibuvFunction<ReqT, int()(ReqT, Args...)> {
88		using T = int()(ReqT, Args...);
89		template <typename... PassedArgs>
90	0	static int Call(T fn, uv_loop_t* loop, ReqT* req, PassedArgs... args) {
91	0	return fn(req, args...);
92	0	} Unexecuted instantiation: pipe_wrap.cc:int node::CallLibuvFunction<uv_connect_s, int ()(uv_connect_s, uv_pipe_s, char const, unsigned long, unsigned int, void ()(uv_connect_s, int))>::Call<uv_pipe_s, char, unsigned long, $_0, void ()(uv_connect_s, int)>(int ()(uv_connect_s, uv_pipe_s, char const, unsigned long, unsigned int, void ()(uv_connect_s, int)), uv_loop_s, uv_connect_s, uv_pipe_s, char, unsigned long, $_0, void ()(uv_connect_s, int)) Unexecuted instantiation: int node::CallLibuvFunction<uv_shutdown_s, int ()(uv_shutdown_s, uv_stream_s, void ()(uv_shutdown_s, int))>::Call<uv_stream_s, void ()(uv_shutdown_s, int)>(int ()(uv_shutdown_s, uv_stream_s, void ()(uv_shutdown_s, int)), uv_loop_s, uv_shutdown_s, uv_stream_s, void ()(uv_shutdown_s, int)) Unexecuted instantiation: int node::CallLibuvFunction<uv_write_s, int ()(uv_write_s, uv_stream_s, uv_buf_t const, unsigned int, uv_stream_s, void ()(uv_write_s, int))>::Call<uv_stream_s, uv_buf_t, unsigned long, uv_stream_s, void ()(uv_write_s, int)>(int ()(uv_write_s, uv_stream_s, uv_buf_t const, unsigned int, uv_stream_s, void ()(uv_write_s, int)), uv_loop_s, uv_write_s, uv_stream_s, uv_buf_t, unsigned long, uv_stream_s, void ()(uv_write_s, int)) Unexecuted instantiation: int node::CallLibuvFunction<uv_connect_s, int ()(uv_connect_s, uv_tcp_s, sockaddr const, void ()(uv_connect_s, int))>::Call<uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)>(int ()(uv_connect_s, uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)), uv_loop_s, uv_connect_s, uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)) Unexecuted instantiation: int node::CallLibuvFunction<uv_udp_send_s, int ()(uv_udp_send_s, uv_udp_s, uv_buf_t const, unsigned int, sockaddr const, void ()(uv_udp_send_s, int))>::Call<uv_udp_s, uv_buf_t, unsigned long, sockaddr const, void ()(uv_udp_send_s, int)>(int ()(uv_udp_send_s, uv_udp_s, uv_buf_t const, unsigned int, sockaddr const, void ()(uv_udp_send_s, int)), uv_loop_s, uv_udp_send_s, uv_udp_s, uv_buf_t, unsigned long, sockaddr const, void ()(uv_udp_send_s, int))
93		};
94
95		// Detect `void uv_foo(uv_req_t* request, ...);`.
96		template <typename ReqT, typename... Args>
97		struct CallLibuvFunction<ReqT, void()(ReqT, Args...)> {
98		using T = void()(ReqT, Args...);
99		template <typename... PassedArgs>
100		static int Call(T fn, uv_loop_t* loop, ReqT* req, PassedArgs... args) {
101		fn(req, args...);
102		return 0;
103		}
104		};
105
106		// This is slightly darker magic: This template is 'applied' to each parameter
107		// passed to the libuv function. If the parameter type (aka `T`) is a
108		// function type, it is assumed that this it is the request callback, and a
109		// wrapper that calls the original callback is created.
110		// If not, the parameter is passed through verbatim.
111		template <typename ReqT, typename T>
112		struct MakeLibuvRequestCallback {
113	0	static T For(ReqWrap<ReqT>* req_wrap, T v) {
114	0	static_assert(!is_callable<T>,
115	0	"MakeLibuvRequestCallback missed a callback");
116	0	return v;
117	0	} Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, char>::For(node::ReqWrap<uv_fs_s>, char) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, uv_dir_s>::For(node::ReqWrap<uv_fs_s>, uv_dir_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, int>::For(node::ReqWrap<uv_fs_s>, int) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, uv_buf_t>::For(node::ReqWrap<uv_fs_s>, uv_buf_t) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, unsigned long>::For(node::ReqWrap<uv_fs_s>, unsigned long) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, long>::For(node::ReqWrap<uv_fs_s>, long) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, unsigned int>::For(node::ReqWrap<uv_fs_s>, unsigned int) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, double>::For(node::ReqWrap<uv_fs_s>, double) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, uv_pipe_s>::For(node::ReqWrap<uv_connect_s>, uv_pipe_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, char>::For(node::ReqWrap<uv_connect_s>, char) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, unsigned long>::For(node::ReqWrap<uv_connect_s>, unsigned long) Unexecuted instantiation: pipe_wrap.cc:node::MakeLibuvRequestCallback<uv_connect_s, $_0>::For(node::ReqWrap<uv_connect_s>, $_0) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_shutdown_s, uv_stream_s>::For(node::ReqWrap<uv_shutdown_s>, uv_stream_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_write_s, uv_stream_s>::For(node::ReqWrap<uv_write_s>, uv_stream_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_write_s, uv_buf_t>::For(node::ReqWrap<uv_write_s>, uv_buf_t) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_write_s, unsigned long>::For(node::ReqWrap<uv_write_s>, unsigned long) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, uv_tcp_s>::For(node::ReqWrap<uv_connect_s>, uv_tcp_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, sockaddr const>::For(node::ReqWrap<uv_connect_s>, sockaddr const) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_udp_send_s, uv_udp_s>::For(node::ReqWrap<uv_udp_send_s>, uv_udp_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_udp_send_s, uv_buf_t>::For(node::ReqWrap<uv_udp_send_s>, uv_buf_t) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_udp_send_s, unsigned long>::For(node::ReqWrap<uv_udp_send_s>, unsigned long) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_udp_send_s, sockaddr const>::For(node::ReqWrap<uv_udp_send_s>, sockaddr const) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getaddrinfo_s, char>::For(node::ReqWrap<uv_getaddrinfo_s>, char) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getaddrinfo_s, decltype(nullptr)>::For(node::ReqWrap<uv_getaddrinfo_s>, decltype(nullptr)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getaddrinfo_s, addrinfo>::For(node::ReqWrap<uv_getaddrinfo_s>, addrinfo) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getnameinfo_s, sockaddr>::For(node::ReqWrap<uv_getnameinfo_s>, sockaddr) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getnameinfo_s, int>::For(node::ReqWrap<uv_getnameinfo_s>*, int)
118		};
119
120		// Match the `void callback(uv_req_t*, ...);` signature that all libuv
121		// callbacks use.
122		template <typename ReqT, typename... Args>
123		struct MakeLibuvRequestCallback<ReqT, void()(ReqT, Args...)> {
124		using F = void()(ReqT req, Args... args);
125
126	0	static void Wrapper(ReqT* req, Args... args) {
127	0	BaseObjectPtr<ReqWrap<ReqT>> req_wrap{ReqWrap<ReqT>::from_req(req)};
128	0	req_wrap->Detach();
129	0	req_wrap->env()->DecreaseWaitingRequestCounter();
130	0	F original_callback = reinterpret_cast<F>(req_wrap->original_callback_);
131	0	original_callback(req, args...);
132	0	} Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, void ()(uv_fs_s)>::Wrapper(uv_fs_s) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, void ()(uv_connect_s, int)>::Wrapper(uv_connect_s, int) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_shutdown_s, void ()(uv_shutdown_s, int)>::Wrapper(uv_shutdown_s, int) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_write_s, void ()(uv_write_s, int)>::Wrapper(uv_write_s, int) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_udp_send_s, void ()(uv_udp_send_s, int)>::Wrapper(uv_udp_send_s, int) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo)>::Wrapper(uv_getaddrinfo_s, int, addrinfo) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const)>::Wrapper(uv_getnameinfo_s, int, char const, char const*)
133
134	0	static F For(ReqWrap<ReqT>* req_wrap, F v) {
135	0	CHECK_NULL(req_wrap->original_callback_);
136	0	req_wrap->original_callback_ =
137	0	reinterpret_cast<typename ReqWrap<ReqT>::callback_t>(v);
138	0	return Wrapper;
139	0	} Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_fs_s, void ()(uv_fs_s)>::For(node::ReqWrap<uv_fs_s>, void ()(uv_fs_s)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_connect_s, void ()(uv_connect_s, int)>::For(node::ReqWrap<uv_connect_s>, void ()(uv_connect_s, int)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_shutdown_s, void ()(uv_shutdown_s, int)>::For(node::ReqWrap<uv_shutdown_s>, void ()(uv_shutdown_s, int)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_write_s, void ()(uv_write_s, int)>::For(node::ReqWrap<uv_write_s>, void ()(uv_write_s, int)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_udp_send_s, void ()(uv_udp_send_s, int)>::For(node::ReqWrap<uv_udp_send_s>, void ()(uv_udp_send_s, int)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo)>::For(node::ReqWrap<uv_getaddrinfo_s>, void ()(uv_getaddrinfo_s, int, addrinfo)) Unexecuted instantiation: node::MakeLibuvRequestCallback<uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const)>::For(node::ReqWrap<uv_getnameinfo_s>, void ()(uv_getnameinfo_s, int, char const, char const*))
140		};
141
142		template <typename T>
143		template <typename LibuvFunction, typename... Args>
144	0	int ReqWrap<T>::Dispatch(LibuvFunction fn, Args... args) {
145	0	Dispatched();
146		// This expands as:
147		//
148		// int err = fn(env()->event_loop(), req(), arg1, arg2, Wrapper, arg3, ...)
149		// ^ ^ ^
150		// \| \| \|
151		// \-- Omitted if `fn` has no \| \|
152		// first `uv_loop_t*` argument \| \|
153		// \| \|
154		// A function callback whose first argument \| \|
155		// matches the libuv request type is replaced ---/ \|
156		// by the `Wrapper` method defined above \|
157		// \|
158		// Other (non-function) arguments are passed -----/
159		// through verbatim
160	0	int err = CallLibuvFunction<T, LibuvFunction>::Call(
161	0	fn,
162	0	env()->event_loop(),
163	0	req(),
164	0	MakeLibuvRequestCallback<T, Args>::For(this, args)...);
165	0	if (err >= 0) {
166	0	ClearWeak();
167	0	env()->IncreaseWaitingRequestCounter();
168	0	}
169	0	return err;
170	0	} Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, void ()(uv_fs_s)), char, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, void ()(uv_fs_s)), char, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, uv_dir_s, void ()(uv_fs_s)), uv_dir_s, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, uv_dir_s, void ()(uv_fs_s)), uv_dir_s, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, int, int, void ()(uv_fs_s)), char, int, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, int, int, void ()(uv_fs_s)), char, int, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s)), int, uv_buf_t, unsigned long, long, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s)), int, uv_buf_t, unsigned long, long, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, char const, void ()(uv_fs_s)), char, char, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, char const, void ()(uv_fs_s)), char, char, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, long, void ()(uv_fs_s)), int, long, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, long, void ()(uv_fs_s)), int, long, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, char const, int, void ()(uv_fs_s)), char, char, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, char const, int, void ()(uv_fs_s)), char, char, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, int, void ()(uv_fs_s)), int, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, int, void ()(uv_fs_s)), int, int, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, unsigned int, unsigned int, void ()(uv_fs_s)), char, unsigned int, unsigned int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, unsigned int, unsigned int, void ()(uv_fs_s)), char, unsigned int, unsigned int, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, unsigned int, unsigned int, void ()(uv_fs_s)), int, unsigned int, unsigned int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, unsigned int, unsigned int, void ()(uv_fs_s)), int, unsigned int, unsigned int, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, double, double, void ()(uv_fs_s)), char, double, double, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, double, double, void ()(uv_fs_s)), char, double, double, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, double, double, void ()(uv_fs_s)), int, double, double, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, double, double, void ()(uv_fs_s)), int, double, double, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, void ()(uv_fs_s)), int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, void ()(uv_fs_s)), int, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s)), int, uv_buf_t, int, long, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, int, uv_buf_t const, unsigned int, long, void ()(uv_fs_s)), int, uv_buf_t, int, long, void ()(uv_fs_s)) Unexecuted instantiation: int node::ReqWrap<uv_fs_s>::Dispatch<int ()(uv_loop_s, uv_fs_s, char const, int, void ()(uv_fs_s)), char, int, void ()(uv_fs_s)>(int ()(uv_loop_s, uv_fs_s, char const, int, void ()(uv_fs_s)), char, int, void ()(uv_fs_s)) Unexecuted instantiation: pipe_wrap.cc:int node::ReqWrap<uv_connect_s>::Dispatch<int ()(uv_connect_s, uv_pipe_s, char const, unsigned long, unsigned int, void ()(uv_connect_s, int)), uv_pipe_s, char, unsigned long, $_0, void ()(uv_connect_s, int)>(int ()(uv_connect_s, uv_pipe_s, char const, unsigned long, unsigned int, void ()(uv_connect_s, int)), uv_pipe_s, char, unsigned long, $_0, void ()(uv_connect_s, int)) Unexecuted instantiation: int node::ReqWrap<uv_shutdown_s>::Dispatch<int ()(uv_shutdown_s, uv_stream_s, void ()(uv_shutdown_s, int)), uv_stream_s, void ()(uv_shutdown_s, int)>(int ()(uv_shutdown_s, uv_stream_s, void ()(uv_shutdown_s, int)), uv_stream_s, void ()(uv_shutdown_s, int)) Unexecuted instantiation: int node::ReqWrap<uv_write_s>::Dispatch<int ()(uv_write_s, uv_stream_s, uv_buf_t const, unsigned int, uv_stream_s, void ()(uv_write_s, int)), uv_stream_s, uv_buf_t, unsigned long, uv_stream_s, void ()(uv_write_s, int)>(int ()(uv_write_s, uv_stream_s, uv_buf_t const, unsigned int, uv_stream_s, void ()(uv_write_s, int)), uv_stream_s, uv_buf_t, unsigned long, uv_stream_s, void ()(uv_write_s, int)) Unexecuted instantiation: int node::ReqWrap<uv_connect_s>::Dispatch<int ()(uv_connect_s, uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)), uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)>(int ()(uv_connect_s, uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)), uv_tcp_s, sockaddr const, void ()(uv_connect_s, int)) Unexecuted instantiation: int node::ReqWrap<uv_udp_send_s>::Dispatch<int ()(uv_udp_send_s, uv_udp_s, uv_buf_t const, unsigned int, sockaddr const, void ()(uv_udp_send_s, int)), uv_udp_s, uv_buf_t, unsigned long, sockaddr const, void ()(uv_udp_send_s, int)>(int ()(uv_udp_send_s, uv_udp_s, uv_buf_t const, unsigned int, sockaddr const, void ()(uv_udp_send_s, int)), uv_udp_s, uv_buf_t, unsigned long, sockaddr const, void ()(uv_udp_send_s, int)) Unexecuted instantiation: int node::ReqWrap<uv_getaddrinfo_s>::Dispatch<int ()(uv_loop_s, uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo), char const, char const, addrinfo const), void ()(uv_getaddrinfo_s, int, addrinfo), char, decltype(nullptr), addrinfo>(int ()(uv_loop_s, uv_getaddrinfo_s, void ()(uv_getaddrinfo_s, int, addrinfo), char const, char const, addrinfo const), void ()(uv_getaddrinfo_s, int, addrinfo), char, decltype(nullptr), addrinfo) Unexecuted instantiation: int node::ReqWrap<uv_getnameinfo_s>::Dispatch<int ()(uv_loop_s, uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const), sockaddr const, int), void ()(uv_getnameinfo_s, int, char const, char const), sockaddr, int>(int ()(uv_loop_s, uv_getnameinfo_s, void ()(uv_getnameinfo_s, int, char const, char const), sockaddr const, int), void ()(uv_getnameinfo_s, int, char const, char const), sockaddr, int)
171
172		} // namespace node
173
174		#endif // defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS
175
176		#endif // SRC_REQ_WRAP_INL_H_

Coverage Report

Created: 2025-12-30 08:42