Browse Source

src: simplify HandleWrap initialization

v0.11.3-release
Ben Noordhuis 12 years ago
parent
commit
448adaa456
  1. 1
      src/fs_event_wrap.cc
  2. 10
      src/handle_wrap.cc
  3. 2
      src/handle_wrap.h
  4. 1
      src/pipe_wrap.cc
  5. 9
      src/process_wrap.cc
  6. 10
      src/stream_wrap.cc
  7. 1
      src/stream_wrap.h
  8. 1
      src/timer_wrap.cc
  9. 1
      src/udp_wrap.cc

1
src/fs_event_wrap.cc

@ -53,7 +53,6 @@ private:
FSEventWrap::FSEventWrap(Handle<Object> object) FSEventWrap::FSEventWrap(Handle<Object> object)
: HandleWrap(object, reinterpret_cast<uv_handle_t*>(&handle_)) { : HandleWrap(object, reinterpret_cast<uv_handle_t*>(&handle_)) {
handle_.data = static_cast<void*>(this);
initialized_ = false; initialized_ = false;
} }

10
src/handle_wrap.cc

@ -108,9 +108,7 @@ Handle<Value> HandleWrap::Close(const Arguments& args) {
HandleWrap::HandleWrap(Handle<Object> object, uv_handle_t* h) { HandleWrap::HandleWrap(Handle<Object> object, uv_handle_t* h) {
flags_ = 0; flags_ = 0;
handle__ = h; handle__ = h;
if (h) { handle__->data = this;
h->data = this;
}
HandleScope scope(node_isolate); HandleScope scope(node_isolate);
assert(object_.IsEmpty()); assert(object_.IsEmpty());
@ -121,12 +119,6 @@ HandleWrap::HandleWrap(Handle<Object> object, uv_handle_t* h) {
} }
void HandleWrap::SetHandle(uv_handle_t* h) {
handle__ = h;
h->data = this;
}
HandleWrap::~HandleWrap() { HandleWrap::~HandleWrap() {
assert(object_.IsEmpty()); assert(object_.IsEmpty());
ngx_queue_remove(&handle_wrap_queue_); ngx_queue_remove(&handle_wrap_queue_);

2
src/handle_wrap.h

@ -65,8 +65,6 @@ class HandleWrap {
HandleWrap(v8::Handle<v8::Object> object, uv_handle_t* handle); HandleWrap(v8::Handle<v8::Object> object, uv_handle_t* handle);
virtual ~HandleWrap(); virtual ~HandleWrap();
virtual void SetHandle(uv_handle_t* h);
v8::Persistent<v8::Object> object_; v8::Persistent<v8::Object> object_;
private: private:

1
src/pipe_wrap.cc

@ -139,7 +139,6 @@ PipeWrap::PipeWrap(Handle<Object> object, bool ipc)
int r = uv_pipe_init(uv_default_loop(), &handle_, ipc); int r = uv_pipe_init(uv_default_loop(), &handle_, ipc);
assert(r == 0); // How do we proxy this error up to javascript? assert(r == 0); // How do we proxy this error up to javascript?
// Suggestion: uv_pipe_init() returns void. // Suggestion: uv_pipe_init() returns void.
handle_.data = static_cast<void*>(this);
UpdateWriteQueueSize(); UpdateWriteQueueSize();
} }

9
src/process_wrap.cc

@ -87,8 +87,12 @@ class ProcessWrap : public HandleWrap {
return scope.Close(args.This()); return scope.Close(args.This());
} }
ProcessWrap(Handle<Object> object) : HandleWrap(object, NULL) { } ProcessWrap(Handle<Object> object)
~ProcessWrap() { } : HandleWrap(object, reinterpret_cast<uv_handle_t*>(&process_)) {
}
~ProcessWrap() {
}
static void ParseStdioOptions(Local<Object> js_options, static void ParseStdioOptions(Local<Object> js_options,
uv_process_options_t* options) { uv_process_options_t* options) {
@ -248,7 +252,6 @@ class ProcessWrap : public HandleWrap {
SetErrno(uv_last_error(uv_default_loop())); SetErrno(uv_last_error(uv_default_loop()));
} }
else { else {
wrap->SetHandle(reinterpret_cast<uv_handle_t*>(&wrap->process_));
assert(wrap->process_.data == wrap); assert(wrap->process_.data == wrap);
wrap->object_->Set(String::New("pid"), wrap->object_->Set(String::New("pid"),
Integer::New(wrap->process_.pid, node_isolate)); Integer::New(wrap->process_.pid, node_isolate));

10
src/stream_wrap.cc

@ -112,9 +112,6 @@ void StreamWrap::Initialize(Handle<Object> target) {
StreamWrap::StreamWrap(Handle<Object> object, uv_stream_t* stream) StreamWrap::StreamWrap(Handle<Object> object, uv_stream_t* stream)
: HandleWrap(object, reinterpret_cast<uv_handle_t*>(stream)) { : HandleWrap(object, reinterpret_cast<uv_handle_t*>(stream)) {
stream_ = stream; stream_ = stream;
if (stream) {
stream->data = this;
}
} }
@ -131,13 +128,6 @@ Handle<Value> StreamWrap::GetFD(Local<String>, const AccessorInfo& args) {
} }
void StreamWrap::SetHandle(uv_handle_t* h) {
HandleWrap::SetHandle(h);
stream_ = reinterpret_cast<uv_stream_t*>(h);
stream_->data = this;
}
void StreamWrap::UpdateWriteQueueSize() { void StreamWrap::UpdateWriteQueueSize() {
HandleScope scope(node_isolate); HandleScope scope(node_isolate);
object_->Set(write_queue_size_sym, object_->Set(write_queue_size_sym,

1
src/stream_wrap.h

@ -57,7 +57,6 @@ class StreamWrap : public HandleWrap {
static size_t WriteBuffer(v8::Handle<v8::Value> val, uv_buf_t* buf); static size_t WriteBuffer(v8::Handle<v8::Value> val, uv_buf_t* buf);
StreamWrap(v8::Handle<v8::Object> object, uv_stream_t* stream); StreamWrap(v8::Handle<v8::Object> object, uv_stream_t* stream);
virtual void SetHandle(uv_handle_t* h);
void StateChange() { } void StateChange() { }
void UpdateWriteQueueSize(); void UpdateWriteQueueSize();

1
src/timer_wrap.cc

@ -86,7 +86,6 @@ class TimerWrap : public HandleWrap {
: HandleWrap(object, reinterpret_cast<uv_handle_t*>(&handle_)) { : HandleWrap(object, reinterpret_cast<uv_handle_t*>(&handle_)) {
int r = uv_timer_init(uv_default_loop(), &handle_); int r = uv_timer_init(uv_default_loop(), &handle_);
assert(r == 0); assert(r == 0);
handle_.data = this;
} }
~TimerWrap() { ~TimerWrap() {

1
src/udp_wrap.cc

@ -69,7 +69,6 @@ UDPWrap::UDPWrap(Handle<Object> object)
: HandleWrap(object, reinterpret_cast<uv_handle_t*>(&handle_)) { : HandleWrap(object, reinterpret_cast<uv_handle_t*>(&handle_)) {
int r = uv_udp_init(uv_default_loop(), &handle_); int r = uv_udp_init(uv_default_loop(), &handle_);
assert(r == 0); // can't fail anyway assert(r == 0); // can't fail anyway
handle_.data = reinterpret_cast<void*>(this);
} }

Loading…
Cancel
Save