|
@ -367,6 +367,9 @@ void IOWatcher::Dump() { |
|
|
DEBUG_PRINT("<%d> got fd to send: %d", io->watcher_.fd, fd_to_send); |
|
|
DEBUG_PRINT("<%d> got fd to send: %d", io->watcher_.fd, fd_to_send); |
|
|
assert(fd_to_send >= 0); |
|
|
assert(fd_to_send >= 0); |
|
|
} |
|
|
} |
|
|
|
|
|
// Already set this to null. We will readd the fd later if there was
|
|
|
|
|
|
// an error.
|
|
|
|
|
|
bucket->Set(fd_sym, Null()); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -410,6 +413,14 @@ void IOWatcher::Dump() { |
|
|
written); |
|
|
written); |
|
|
|
|
|
|
|
|
if (written < 0) { |
|
|
if (written < 0) { |
|
|
|
|
|
|
|
|
|
|
|
// Some sort of error. Must set the fd_to_send back in the bucket.
|
|
|
|
|
|
if (fd_to_send >= 0) { |
|
|
|
|
|
Local<Value> bucket_v = watcher->Get(first_bucket_sym); |
|
|
|
|
|
assert(bucket_v->IsObject()); |
|
|
|
|
|
bucket_v->ToObject()->Set(fd_sym, Integer::New(fd_to_send)); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
// Allow EAGAIN.
|
|
|
// Allow EAGAIN.
|
|
|
// TODO: handle EMSGSIZE after sendmsg().
|
|
|
// TODO: handle EMSGSIZE after sendmsg().
|
|
|
if (errno == EAGAIN) { |
|
|
if (errno == EAGAIN) { |
|
@ -471,10 +482,6 @@ void IOWatcher::Dump() { |
|
|
// serialized onto a buffer.
|
|
|
// serialized onto a buffer.
|
|
|
size_t bucket_len = Buffer::Length(data_v->ToObject()); |
|
|
size_t bucket_len = Buffer::Length(data_v->ToObject()); |
|
|
|
|
|
|
|
|
if (unix_socket && bucket->Has(fd_sym)) { |
|
|
|
|
|
bucket->Set(fd_sym, Null()); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
DEBUG_PRINT("<%d,%ld> bucket_len: %ld, offset: %ld", |
|
|
DEBUG_PRINT("<%d,%ld> bucket_len: %ld, offset: %ld", |
|
|
io->watcher_.fd, |
|
|
io->watcher_.fd, |
|
|
bucket_index, |
|
|
bucket_index, |
|
|