diff options
| author | Trevor Norris <trev.norris@gmail.com> | 2014-01-20 13:33:16 -0800 |
|---|---|---|
| committer | Trevor Norris <trev.norris@gmail.com> | 2014-02-05 13:30:56 -0800 |
| commit | 4a9af3fecb4baf677f265e2e6e34a674a53810a6 (patch) | |
| tree | 3e96cf57bc7f9d47ebe7a177acc7a2d18dc13bdd /src/tcp_wrap.cc | |
| parent | c9abb59638bc4bc64176ded80ebdc05d066ad0db (diff) | |
| download | android-node-v8-4a9af3fecb4baf677f265e2e6e34a674a53810a6.tar.gz android-node-v8-4a9af3fecb4baf677f265e2e6e34a674a53810a6.tar.bz2 android-node-v8-4a9af3fecb4baf677f265e2e6e34a674a53810a6.zip | |
async_wrap: add provider types/pass to constructor
These will be used to allow users to filter for which types of calls
they wish their callbacks to run.
Signed-off-by: Timothy J Fontaine <tjfontaine@gmail.com>
Diffstat (limited to 'src/tcp_wrap.cc')
| -rw-r--r-- | src/tcp_wrap.cc | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/src/tcp_wrap.cc b/src/tcp_wrap.cc index 99d71bffe5..728d87a698 100644 --- a/src/tcp_wrap.cc +++ b/src/tcp_wrap.cc @@ -139,7 +139,10 @@ void TCPWrap::New(const FunctionCallbackInfo<Value>& args) { TCPWrap::TCPWrap(Environment* env, Handle<Object> object) - : StreamWrap(env, object, reinterpret_cast<uv_stream_t*>(&handle_)) { + : StreamWrap(env, + object, + reinterpret_cast<uv_stream_t*>(&handle_), + AsyncWrap::PROVIDER_TCPWRAP) { int r = uv_tcp_init(env->event_loop(), &handle_); assert(r == 0); // How do we proxy this error up to javascript? // Suggestion: uv_tcp_init() returns void. @@ -377,7 +380,9 @@ void TCPWrap::Connect(const FunctionCallbackInfo<Value>& args) { int err = uv_ip4_addr(*ip_address, port, &addr); if (err == 0) { - ConnectWrap* req_wrap = new ConnectWrap(env, req_wrap_obj); + ConnectWrap* req_wrap = new ConnectWrap(env, + req_wrap_obj, + AsyncWrap::PROVIDER_CONNECTWRAP); err = uv_tcp_connect(&req_wrap->req_, &wrap->handle_, reinterpret_cast<const sockaddr*>(&addr), @@ -409,7 +414,9 @@ void TCPWrap::Connect6(const FunctionCallbackInfo<Value>& args) { int err = uv_ip6_addr(*ip_address, port, &addr); if (err == 0) { - ConnectWrap* req_wrap = new ConnectWrap(env, req_wrap_obj); + ConnectWrap* req_wrap = new ConnectWrap(env, + req_wrap_obj, + AsyncWrap::PROVIDER_CONNECTWRAP); err = uv_tcp_connect(&req_wrap->req_, &wrap->handle_, reinterpret_cast<const sockaddr*>(&addr), |