// Copyright Joyent, Inc. and other Node contributors. // // Permission is hereby granted, free of charge, to any person obtaining a // copy of this software and associated documentation files (the // "Software"), to deal in the Software without restriction, including // without limitation the rights to use, copy, modify, merge, publish, // distribute, sublicense, and/or sell copies of the Software, and to permit // persons to whom the Software is furnished to do so, subject to the // following conditions: // // The above copyright notice and this permission notice shall be included // in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN // NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, // DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR // OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE // USE OR OTHER DEALINGS IN THE SOFTWARE. #include "handle_wrap.h" #include "async-wrap.h" #include "async-wrap-inl.h" #include "env.h" #include "env-inl.h" #include "util.h" #include "util-inl.h" #include "node.h" #include "queue.h" namespace node { using v8::Context; using v8::FunctionCallbackInfo; using v8::Handle; using v8::HandleScope; using v8::Local; using v8::Object; using v8::Value; // defined in node.cc extern QUEUE handle_wrap_queue; void HandleWrap::Ref(const FunctionCallbackInfo& args) { HandleScope scope(node_isolate); HandleWrap* wrap = Unwrap(args.This()); if (wrap != NULL && wrap->handle__ != NULL) { uv_ref(wrap->handle__); wrap->flags_ &= ~kUnref; } } void HandleWrap::Unref(const FunctionCallbackInfo& args) { HandleScope scope(node_isolate); HandleWrap* wrap = Unwrap(args.This()); if (wrap != NULL && wrap->handle__ != NULL) { uv_unref(wrap->handle__); wrap->flags_ |= kUnref; } } void HandleWrap::Close(const FunctionCallbackInfo& args) { HandleScope scope(node_isolate); HandleWrap* wrap = Unwrap(args.This()); // guard against uninitialized handle or double close if (wrap == NULL || wrap->handle__ == NULL) return; Environment* env = wrap->env(); assert(!wrap->persistent().IsEmpty()); uv_close(wrap->handle__, OnClose); wrap->handle__ = NULL; if (args[0]->IsFunction()) { wrap->object()->Set(env->close_string(), args[0]); wrap->flags_ |= kCloseCallback; } } HandleWrap::HandleWrap(Environment* env, Handle object, uv_handle_t* handle, AsyncWrap::ProviderType provider) : AsyncWrap(env, object, provider), flags_(0), handle__(handle) { handle__->data = this; HandleScope scope(node_isolate); Wrap(object, this); QUEUE_INSERT_TAIL(&handle_wrap_queue, &handle_wrap_queue_); } HandleWrap::~HandleWrap() { assert(persistent().IsEmpty()); QUEUE_REMOVE(&handle_wrap_queue_); } void HandleWrap::OnClose(uv_handle_t* handle) { HandleScope scope(node_isolate); HandleWrap* wrap = static_cast(handle->data); Environment* env = wrap->env(); // The wrap object should still be there. assert(wrap->persistent().IsEmpty() == false); // But the handle pointer should be gone. assert(wrap->handle__ == NULL); HandleScope handle_scope(env->isolate()); Context::Scope context_scope(env->context()); Local object = wrap->object(); if (wrap->flags_ & kCloseCallback) { wrap->MakeCallback(env->close_string(), 0, NULL); } object->SetAlignedPointerInInternalField(0, NULL); wrap->persistent().Dispose(); delete wrap; } } // namespace node