Gecko [ oric.aiou.edu.pk ]

Name	Size	Permission
aliased_buffer.h	6.42 KB	-rw-r--r--
async_wrap-inl.h	3.33 KB	-rw-r--r--
async_wrap.h	9.16 KB	-rw-r--r--
base64.h	5.82 KB	-rw-r--r--
base_object-inl.h	4.02 KB	-rw-r--r--
base_object.h	4.43 KB	-rw-r--r--
connect_wrap.h	617 B	-rw-r--r--
connection_wrap.h	699 B	-rw-r--r--
debug_utils.h	4.29 KB	-rw-r--r--
env-inl.h	30.64 KB	-rw-r--r--
env.h	46.48 KB	-rw-r--r--
handle_wrap.h	3.91 KB	-rw-r--r--
inspector_agent.h	4.13 KB	-rw-r--r--
inspector_io.h	2.63 KB	-rw-r--r--
inspector_socket.h	1.46 KB	-rw-r--r--
inspector_socket_server.h	3.21 KB	-rw-r--r--
js_stream.h	1.58 KB	-rw-r--r--
memory_tracker-inl.h	10.83 KB	-rw-r--r--
memory_tracker.h	9.96 KB	-rw-r--r--
module_wrap.h	3.07 KB	-rw-r--r--
node.h	35.16 KB	-rw-r--r--
node_api.h	35.44 KB	-rw-r--r--
node_api_types.h	4.16 KB	-rw-r--r--
node_buffer.h	3.4 KB	-rw-r--r--
node_code_cache.h	432 B	-rw-r--r--
node_constants.h	3.11 KB	-rw-r--r--
node_context_data.h	1.14 KB	-rw-r--r--
node_contextify.h	4.81 KB	-rw-r--r--
node_counters.h	2.37 KB	-rw-r--r--
node_crypto.h	23.92 KB	-rw-r--r--
node_crypto_bio.h	5.44 KB	-rw-r--r--
node_crypto_clienthello-inl.h	2.62 KB	-rw-r--r--
node_crypto_clienthello.h	4 KB	-rw-r--r--
node_crypto_groups.h	23.12 KB	-rw-r--r--
node_dtrace.h	2.91 KB	-rw-r--r--
node_errors.h	6.06 KB	-rw-r--r--
node_file.h	10.16 KB	-rw-r--r--
node_http2.h	47.76 KB	-rw-r--r--
node_http2_state.h	4.72 KB	-rw-r--r--
node_i18n.h	2.4 KB	-rw-r--r--
node_internals.h	28.47 KB	-rw-r--r--
node_javascript.h	1.72 KB	-rw-r--r--
node_messaging.h	8.38 KB	-rw-r--r--
node_mutex.h	4.42 KB	-rw-r--r--
node_object_wrap.h	3.7 KB	-rw-r--r--
node_options-inl.h	14.78 KB	-rw-r--r--
node_options.h	12.25 KB	-rw-r--r--
node_perf.h	3.64 KB	-rw-r--r--
node_perf_common.h	3 KB	-rw-r--r--
node_persistent.h	936 B	-rw-r--r--
node_platform.h	5.14 KB	-rw-r--r--
node_revert.h	2.21 KB	-rw-r--r--
node_root_certs.h	223.29 KB	-rw-r--r--
node_stat_watcher.h	2.15 KB	-rw-r--r--
node_url.h	6.16 KB	-rw-r--r--
node_version.h	3.79 KB	-rw-r--r--
node_watchdog.h	3.03 KB	-rw-r--r--
node_win32_etw_provider-inl.h	11.67 KB	-rw-r--r--
node_win32_etw_provider.h	3.67 KB	-rw-r--r--
node_win32_perfctr_provider.h	2.14 KB	-rw-r--r--
node_worker.h	2.88 KB	-rw-r--r--
pipe_wrap.h	2.62 KB	-rw-r--r--
req_wrap-inl.h	5.44 KB	-rw-r--r--
req_wrap.h	1.87 KB	-rw-r--r--
sharedarraybuffer_metadata.h	2.34 KB	-rw-r--r--
spawn_sync.h	6.82 KB	-rw-r--r--
stream_base-inl.h	14.08 KB	-rw-r--r--
stream_base.h	13.46 KB	-rw-r--r--
stream_pipe.h	2 KB	-rw-r--r--
stream_wrap.h	4.03 KB	-rw-r--r--
string_bytes.h	5.14 KB	-rw-r--r--
string_decoder-inl.h	876 B	-rw-r--r--
string_decoder.h	1.5 KB	-rw-r--r--
string_search.h	20.53 KB	-rw-r--r--
tcp_wrap.h	3.59 KB	-rw-r--r--
tls_wrap.h	6.61 KB	-rw-r--r--
tty_wrap.h	2.22 KB	-rw-r--r--
udp_wrap.h	4.12 KB	-rw-r--r--
util-inl.h	14.06 KB	-rw-r--r--
util.h	15.9 KB	-rw-r--r--
v8abbr.h	5.03 KB	-rw-r--r--

Code Editor : req_wrap-inl.h

#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 "env-inl.h"
#include "util-inl.h"
#include "uv.h"

namespace node {

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

// FIXME(bnoordhuis) The fact that a reinterpret_cast is needed is
  // arguably a good indicator that there should be more than one queue.
  env->req_wrap_queue()->PushBack(reinterpret_cast<ReqWrap<uv_req_t>*>(this));

Reset();
}

template <typename T>
ReqWrap<T>::~ReqWrap() {
  CHECK_EQ(false, persistent().IsEmpty());
}

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_));
}

// 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>::value,
                  "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) {
    ReqWrap<ReqT>* req_wrap = ContainerOf(&ReqWrap<ReqT>::req_, req);
    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)
    env()->IncreaseWaitingRequestCounter();
  return err;
}

}  // namespace node

#endif  // defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS

#endif  // SRC_REQ_WRAP_INL_H_

${this.title}

Code Editor : req_wrap-inl.h