src/node.cc

   1 // Copyright Joyent, Inc. and other Node contributors.
   2 //
   3 // Permission is hereby granted, free of charge, to any person obtaining a
   4 // copy of this software and associated documentation files (the
   5 // "Software"), to deal in the Software without restriction, including
   6 // without limitation the rights to use, copy, modify, merge, publish,
   7 // distribute, sublicense, and/or sell copies of the Software, and to permit
   8 // persons to whom the Software is furnished to do so, subject to the
   9 // following conditions:
  10 //
  11 // The above copyright notice and this permission notice shall be included
  12 // in all copies or substantial portions of the Software.
  13 //
  14 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
  15 // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  16 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
  17 // NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
  18 // DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
  19 // OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
  20 // USE OR OTHER DEALINGS IN THE SOFTWARE.
  21
  22 #include "node.h"
  23 #include "node_buffer.h"
  24 #include "node_constants.h"
  25 #include "node_file.h"
  26 #include "node_http_parser.h"
  27 #include "node_javascript.h"
  28 #include "node_version.h"
  29
  30 #if defined HAVE_PERFCTR
  31 #include "node_counters.h"
  32 #endif
  33
  34 #if HAVE_OPENSSL
  35 #include "node_crypto.h"
  36 #endif
  37
  38 #if defined HAVE_DTRACE || defined HAVE_ETW
  39 #include "node_dtrace.h"
  40 #endif
  41
  42 #include "ares.h"
  43 #include "async-wrap.h"
  44 #include "async-wrap-inl.h"
  45 #include "env.h"
  46 #include "env-inl.h"
  47 #include "handle_wrap.h"
  48 #include "req_wrap.h"
  49 #include "string_bytes.h"
  50 #include "uv.h"
  51 #include "v8-debug.h"
  52 #include "v8-profiler.h"
  53 #include "zlib.h"
  54
  55 #include <assert.h>
  56 #include <errno.h>
  57 #include <limits.h>  // PATH_MAX
  58 #include <locale.h>
  59 #include <signal.h>
  60 #include <stdio.h>
  61 #include <stdlib.h>
  62 #include <string.h>
  63 #include <sys/types.h>
  64
  65 #if defined(_MSC_VER)
  66 #include <direct.h>
  67 #include <io.h>
  68 #include <process.h>
  69 #define strcasecmp _stricmp
  70 #define getpid _getpid
  71 #define umask _umask
  72 typedef int mode_t;
  73 #else
  74 #include <sys/resource.h>  // getrlimit, setrlimit
  75 #include <unistd.h>  // setuid, getuid
  76 #endif
  77
  78 #if defined(__POSIX__) && !defined(__ANDROID__)
  79 #include <pwd.h>  // getpwnam()
  80 #include <grp.h>  // getgrnam()
  81 #endif
  82
  83 #ifdef __APPLE__
  84 #include <crt_externs.h>
  85 #define environ (*_NSGetEnviron())
  86 #elif !defined(_MSC_VER)
  87 extern char **environ;
  88 #endif
  89
  90 namespace node {
  91
  92 using v8::Array;
  93 using v8::ArrayBuffer;
  94 using v8::Boolean;
  95 using v8::Context;
  96 using v8::Exception;
  97 using v8::Function;
  98 using v8::FunctionCallbackInfo;
  99 using v8::FunctionTemplate;
 100 using v8::Handle;
 101 using v8::HandleScope;
 102 using v8::HeapStatistics;
 103 using v8::Integer;
 104 using v8::Isolate;
 105 using v8::Local;
 106 using v8::Locker;
 107 using v8::Message;
 108 using v8::Number;
 109 using v8::Object;
 110 using v8::ObjectTemplate;
 111 using v8::PropertyCallbackInfo;
 112 using v8::String;
 113 using v8::ThrowException;
 114 using v8::TryCatch;
 115 using v8::Uint32;
 116 using v8::V8;
 117 using v8::Value;
 118 using v8::kExternalUnsignedIntArray;
 119
 120 // FIXME(bnoordhuis) Make these per-context?
 121 QUEUE handle_wrap_queue = { &handle_wrap_queue, &handle_wrap_queue };
 122 QUEUE req_wrap_queue = { &req_wrap_queue, &req_wrap_queue };
 123
 124 static bool print_eval = false;
 125 static bool force_repl = false;
 126 static bool trace_deprecation = false;
 127 static bool throw_deprecation = false;
 128 static const char* eval_string = NULL;
 129 static bool use_debug_agent = false;
 130 static bool debug_wait_connect = false;
 131 static int debug_port = 5858;
 132 static bool v8_is_profiling = false;
 133
 134 // used by C++ modules as well
 135 bool no_deprecation = false;
 136
 137 // process-relative uptime base, initialized at start-up
 138 static double prog_start_time;
 139 static bool debugger_running;
 140 static uv_async_t dispatch_debug_messages_async;
 141
 142 // Declared in node_internals.h
 143 Isolate* node_isolate = NULL;
 144
 145
 146 class ArrayBufferAllocator : public ArrayBuffer::Allocator {
 147  public:
 148   // Impose an upper limit to avoid out of memory errors that bring down
 149   // the process.
 150   static const size_t kMaxLength = 0x3fffffff;
 151   static ArrayBufferAllocator the_singleton;
 152   virtual ~ArrayBufferAllocator() {}
 153   virtual void* Allocate(size_t length);
 154   virtual void* AllocateUninitialized(size_t length);
 155   virtual void Free(void* data, size_t length);
 156  private:
 157   ArrayBufferAllocator() {}
 158   ArrayBufferAllocator(const ArrayBufferAllocator&);
 159   void operator=(const ArrayBufferAllocator&);
 160 };
 161
 162 ArrayBufferAllocator ArrayBufferAllocator::the_singleton;
 163
 164
 165 void* ArrayBufferAllocator::Allocate(size_t length) {
 166   if (length > kMaxLength)
 167     return NULL;
 168   char* data = new char[length];
 169   memset(data, 0, length);
 170   return data;
 171 }
 172
 173
 174 void* ArrayBufferAllocator::AllocateUninitialized(size_t length) {
 175   if (length > kMaxLength)
 176     return NULL;
 177   return new char[length];
 178 }
 179
 180
 181 void ArrayBufferAllocator::Free(void* data, size_t length) {
 182   delete[] static_cast<char*>(data);
 183 }
 184
 185
 186 static void CheckImmediate(uv_check_t* handle, int status) {
 187   HandleScope scope(node_isolate);
 188   Environment* env = Environment::from_immediate_check_handle(handle);
 189   Context::Scope context_scope(env->context());
 190   MakeCallback(env, env->process_object(), env->immediate_callback_string());
 191 }
 192
 193
 194 static void IdleImmediateDummy(uv_idle_t*, int) {
 195   // Do nothing. Only for maintaining event loop.
 196   // TODO(bnoordhuis) Maybe make libuv accept NULL idle callbacks.
 197 }
 198
 199
 200 static inline const char *errno_string(int errorno) {
 201 #define ERRNO_CASE(e)  case e: return #e;
 202   switch (errorno) {
 203 #ifdef EACCES
 204   ERRNO_CASE(EACCES);
 205 #endif
 206
 207 #ifdef EADDRINUSE
 208   ERRNO_CASE(EADDRINUSE);
 209 #endif
 210
 211 #ifdef EADDRNOTAVAIL
 212   ERRNO_CASE(EADDRNOTAVAIL);
 213 #endif
 214
 215 #ifdef EAFNOSUPPORT
 216   ERRNO_CASE(EAFNOSUPPORT);
 217 #endif
 218
 219 #ifdef EAGAIN
 220   ERRNO_CASE(EAGAIN);
 221 #endif
 222
 223 #ifdef EWOULDBLOCK
 224 # if EAGAIN != EWOULDBLOCK
 225   ERRNO_CASE(EWOULDBLOCK);
 226 # endif
 227 #endif
 228
 229 #ifdef EALREADY
 230   ERRNO_CASE(EALREADY);
 231 #endif
 232
 233 #ifdef EBADF
 234   ERRNO_CASE(EBADF);
 235 #endif
 236
 237 #ifdef EBADMSG
 238   ERRNO_CASE(EBADMSG);
 239 #endif
 240
 241 #ifdef EBUSY
 242   ERRNO_CASE(EBUSY);
 243 #endif
 244
 245 #ifdef ECANCELED
 246   ERRNO_CASE(ECANCELED);
 247 #endif
 248
 249 #ifdef ECHILD
 250   ERRNO_CASE(ECHILD);
 251 #endif
 252
 253 #ifdef ECONNABORTED
 254   ERRNO_CASE(ECONNABORTED);
 255 #endif
 256
 257 #ifdef ECONNREFUSED
 258   ERRNO_CASE(ECONNREFUSED);
 259 #endif
 260
 261 #ifdef ECONNRESET
 262   ERRNO_CASE(ECONNRESET);
 263 #endif
 264
 265 #ifdef EDEADLK
 266   ERRNO_CASE(EDEADLK);
 267 #endif
 268
 269 #ifdef EDESTADDRREQ
 270   ERRNO_CASE(EDESTADDRREQ);
 271 #endif
 272
 273 #ifdef EDOM
 274   ERRNO_CASE(EDOM);
 275 #endif
 276
 277 #ifdef EDQUOT
 278   ERRNO_CASE(EDQUOT);
 279 #endif
 280
 281 #ifdef EEXIST
 282   ERRNO_CASE(EEXIST);
 283 #endif
 284
 285 #ifdef EFAULT
 286   ERRNO_CASE(EFAULT);
 287 #endif
 288
 289 #ifdef EFBIG
 290   ERRNO_CASE(EFBIG);
 291 #endif
 292
 293 #ifdef EHOSTUNREACH
 294   ERRNO_CASE(EHOSTUNREACH);
 295 #endif
 296
 297 #ifdef EIDRM
 298   ERRNO_CASE(EIDRM);
 299 #endif
 300
 301 #ifdef EILSEQ
 302   ERRNO_CASE(EILSEQ);
 303 #endif
 304
 305 #ifdef EINPROGRESS
 306   ERRNO_CASE(EINPROGRESS);
 307 #endif
 308
 309 #ifdef EINTR
 310   ERRNO_CASE(EINTR);
 311 #endif
 312
 313 #ifdef EINVAL
 314   ERRNO_CASE(EINVAL);
 315 #endif
 316
 317 #ifdef EIO
 318   ERRNO_CASE(EIO);
 319 #endif
 320
 321 #ifdef EISCONN
 322   ERRNO_CASE(EISCONN);
 323 #endif
 324
 325 #ifdef EISDIR
 326   ERRNO_CASE(EISDIR);
 327 #endif
 328
 329 #ifdef ELOOP
 330   ERRNO_CASE(ELOOP);
 331 #endif
 332
 333 #ifdef EMFILE
 334   ERRNO_CASE(EMFILE);
 335 #endif
 336
 337 #ifdef EMLINK
 338   ERRNO_CASE(EMLINK);
 339 #endif
 340
 341 #ifdef EMSGSIZE
 342   ERRNO_CASE(EMSGSIZE);
 343 #endif
 344
 345 #ifdef EMULTIHOP
 346   ERRNO_CASE(EMULTIHOP);
 347 #endif
 348
 349 #ifdef ENAMETOOLONG
 350   ERRNO_CASE(ENAMETOOLONG);
 351 #endif
 352
 353 #ifdef ENETDOWN
 354   ERRNO_CASE(ENETDOWN);
 355 #endif
 356
 357 #ifdef ENETRESET
 358   ERRNO_CASE(ENETRESET);
 359 #endif
 360
 361 #ifdef ENETUNREACH
 362   ERRNO_CASE(ENETUNREACH);
 363 #endif
 364
 365 #ifdef ENFILE
 366   ERRNO_CASE(ENFILE);
 367 #endif
 368
 369 #ifdef ENOBUFS
 370   ERRNO_CASE(ENOBUFS);
 371 #endif
 372
 373 #ifdef ENODATA
 374   ERRNO_CASE(ENODATA);
 375 #endif
 376
 377 #ifdef ENODEV
 378   ERRNO_CASE(ENODEV);
 379 #endif
 380
 381 #ifdef ENOENT
 382   ERRNO_CASE(ENOENT);
 383 #endif
 384
 385 #ifdef ENOEXEC
 386   ERRNO_CASE(ENOEXEC);
 387 #endif
 388
 389 #ifdef ENOLINK
 390   ERRNO_CASE(ENOLINK);
 391 #endif
 392
 393 #ifdef ENOLCK
 394 # if ENOLINK != ENOLCK
 395   ERRNO_CASE(ENOLCK);
 396 # endif
 397 #endif
 398
 399 #ifdef ENOMEM
 400   ERRNO_CASE(ENOMEM);
 401 #endif
 402
 403 #ifdef ENOMSG
 404   ERRNO_CASE(ENOMSG);
 405 #endif
 406
 407 #ifdef ENOPROTOOPT
 408   ERRNO_CASE(ENOPROTOOPT);
 409 #endif
 410
 411 #ifdef ENOSPC
 412   ERRNO_CASE(ENOSPC);
 413 #endif
 414
 415 #ifdef ENOSR
 416   ERRNO_CASE(ENOSR);
 417 #endif
 418
 419 #ifdef ENOSTR
 420   ERRNO_CASE(ENOSTR);
 421 #endif
 422
 423 #ifdef ENOSYS
 424   ERRNO_CASE(ENOSYS);
 425 #endif
 426
 427 #ifdef ENOTCONN
 428   ERRNO_CASE(ENOTCONN);
 429 #endif
 430
 431 #ifdef ENOTDIR
 432   ERRNO_CASE(ENOTDIR);
 433 #endif
 434
 435 #ifdef ENOTEMPTY
 436   ERRNO_CASE(ENOTEMPTY);
 437 #endif
 438
 439 #ifdef ENOTSOCK
 440   ERRNO_CASE(ENOTSOCK);
 441 #endif
 442
 443 #ifdef ENOTSUP
 444   ERRNO_CASE(ENOTSUP);
 445 #else
 446 # ifdef EOPNOTSUPP
 447   ERRNO_CASE(EOPNOTSUPP);
 448 # endif
 449 #endif
 450
 451 #ifdef ENOTTY
 452   ERRNO_CASE(ENOTTY);
 453 #endif
 454
 455 #ifdef ENXIO
 456   ERRNO_CASE(ENXIO);
 457 #endif
 458
 459
 460 #ifdef EOVERFLOW
 461   ERRNO_CASE(EOVERFLOW);
 462 #endif
 463
 464 #ifdef EPERM
 465   ERRNO_CASE(EPERM);
 466 #endif
 467
 468 #ifdef EPIPE
 469   ERRNO_CASE(EPIPE);
 470 #endif
 471
 472 #ifdef EPROTO
 473   ERRNO_CASE(EPROTO);
 474 #endif
 475
 476 #ifdef EPROTONOSUPPORT
 477   ERRNO_CASE(EPROTONOSUPPORT);
 478 #endif
 479
 480 #ifdef EPROTOTYPE
 481   ERRNO_CASE(EPROTOTYPE);
 482 #endif
 483
 484 #ifdef ERANGE
 485   ERRNO_CASE(ERANGE);
 486 #endif
 487
 488 #ifdef EROFS
 489   ERRNO_CASE(EROFS);
 490 #endif
 491
 492 #ifdef ESPIPE
 493   ERRNO_CASE(ESPIPE);
 494 #endif
 495
 496 #ifdef ESRCH
 497   ERRNO_CASE(ESRCH);
 498 #endif
 499
 500 #ifdef ESTALE
 501   ERRNO_CASE(ESTALE);
 502 #endif
 503
 504 #ifdef ETIME
 505   ERRNO_CASE(ETIME);
 506 #endif
 507
 508 #ifdef ETIMEDOUT
 509   ERRNO_CASE(ETIMEDOUT);
 510 #endif
 511
 512 #ifdef ETXTBSY
 513   ERRNO_CASE(ETXTBSY);
 514 #endif
 515
 516 #ifdef EXDEV
 517   ERRNO_CASE(EXDEV);
 518 #endif
 519
 520   default: return "";
 521   }
 522 }
 523
 524 const char *signo_string(int signo) {
 525 #define SIGNO_CASE(e)  case e: return #e;
 526   switch (signo) {
 527 #ifdef SIGHUP
 528   SIGNO_CASE(SIGHUP);
 529 #endif
 530
 531 #ifdef SIGINT
 532   SIGNO_CASE(SIGINT);
 533 #endif
 534
 535 #ifdef SIGQUIT
 536   SIGNO_CASE(SIGQUIT);
 537 #endif
 538
 539 #ifdef SIGILL
 540   SIGNO_CASE(SIGILL);
 541 #endif
 542
 543 #ifdef SIGTRAP
 544   SIGNO_CASE(SIGTRAP);
 545 #endif
 546
 547 #ifdef SIGABRT
 548   SIGNO_CASE(SIGABRT);
 549 #endif
 550
 551 #ifdef SIGIOT
 552 # if SIGABRT != SIGIOT
 553   SIGNO_CASE(SIGIOT);
 554 # endif
 555 #endif
 556
 557 #ifdef SIGBUS
 558   SIGNO_CASE(SIGBUS);
 559 #endif
 560
 561 #ifdef SIGFPE
 562   SIGNO_CASE(SIGFPE);
 563 #endif
 564
 565 #ifdef SIGKILL
 566   SIGNO_CASE(SIGKILL);
 567 #endif
 568
 569 #ifdef SIGUSR1
 570   SIGNO_CASE(SIGUSR1);
 571 #endif
 572
 573 #ifdef SIGSEGV
 574   SIGNO_CASE(SIGSEGV);
 575 #endif
 576
 577 #ifdef SIGUSR2
 578   SIGNO_CASE(SIGUSR2);
 579 #endif
 580
 581 #ifdef SIGPIPE
 582   SIGNO_CASE(SIGPIPE);
 583 #endif
 584
 585 #ifdef SIGALRM
 586   SIGNO_CASE(SIGALRM);
 587 #endif
 588
 589   SIGNO_CASE(SIGTERM);
 590
 591 #ifdef SIGCHLD
 592   SIGNO_CASE(SIGCHLD);
 593 #endif
 594
 595 #ifdef SIGSTKFLT
 596   SIGNO_CASE(SIGSTKFLT);
 597 #endif
 598
 599
 600 #ifdef SIGCONT
 601   SIGNO_CASE(SIGCONT);
 602 #endif
 603
 604 #ifdef SIGSTOP
 605   SIGNO_CASE(SIGSTOP);
 606 #endif
 607
 608 #ifdef SIGTSTP
 609   SIGNO_CASE(SIGTSTP);
 610 #endif
 611
 612 #ifdef SIGBREAK
 613   SIGNO_CASE(SIGBREAK);
 614 #endif
 615
 616 #ifdef SIGTTIN
 617   SIGNO_CASE(SIGTTIN);
 618 #endif
 619
 620 #ifdef SIGTTOU
 621   SIGNO_CASE(SIGTTOU);
 622 #endif
 623
 624 #ifdef SIGURG
 625   SIGNO_CASE(SIGURG);
 626 #endif
 627
 628 #ifdef SIGXCPU
 629   SIGNO_CASE(SIGXCPU);
 630 #endif
 631
 632 #ifdef SIGXFSZ
 633   SIGNO_CASE(SIGXFSZ);
 634 #endif
 635
 636 #ifdef SIGVTALRM
 637   SIGNO_CASE(SIGVTALRM);
 638 #endif
 639
 640 #ifdef SIGPROF
 641   SIGNO_CASE(SIGPROF);
 642 #endif
 643
 644 #ifdef SIGWINCH
 645   SIGNO_CASE(SIGWINCH);
 646 #endif
 647
 648 #ifdef SIGIO
 649   SIGNO_CASE(SIGIO);
 650 #endif
 651
 652 #ifdef SIGPOLL
 653 # if SIGPOLL != SIGIO
 654   SIGNO_CASE(SIGPOLL);
 655 # endif
 656 #endif
 657
 658 #ifdef SIGLOST
 659   SIGNO_CASE(SIGLOST);
 660 #endif
 661
 662 #ifdef SIGPWR
 663 # if SIGPWR != SIGLOST
 664   SIGNO_CASE(SIGPWR);
 665 # endif
 666 #endif
 667
 668 #ifdef SIGSYS
 669   SIGNO_CASE(SIGSYS);
 670 #endif
 671
 672   default: return "";
 673   }
 674 }
 675
 676
 677 Local<Value> ErrnoException(int errorno,
 678                             const char *syscall,
 679                             const char *msg,
 680                             const char *path) {
 681   Environment* env = Environment::GetCurrent(node_isolate);
 682
 683   Local<Value> e;
 684   Local<String> estring = OneByteString(node_isolate, errno_string(errorno));
 685   if (msg == NULL || msg[0] == '\0') {
 686     msg = strerror(errorno);
 687   }
 688   Local<String> message = OneByteString(node_isolate, msg);
 689
 690   Local<String> cons1 =
 691       String::Concat(estring, FIXED_ONE_BYTE_STRING(node_isolate, ", "));
 692   Local<String> cons2 = String::Concat(cons1, message);
 693
 694   if (path) {
 695     Local<String> cons3 =
 696         String::Concat(cons2, FIXED_ONE_BYTE_STRING(node_isolate, " '"));
 697     Local<String> cons4 =
 698         String::Concat(cons3, String::NewFromUtf8(node_isolate, path));
 699     Local<String> cons5 =
 700         String::Concat(cons4, FIXED_ONE_BYTE_STRING(node_isolate, "'"));
 701     e = Exception::Error(cons5);
 702   } else {
 703     e = Exception::Error(cons2);
 704   }
 705
 706   Local<Object> obj = e->ToObject();
 707   obj->Set(env->errno_string(), Integer::New(errorno, node_isolate));
 708   obj->Set(env->code_string(), estring);
 709
 710   if (path != NULL) {
 711     obj->Set(env->path_string(), String::NewFromUtf8(node_isolate, path));
 712   }
 713
 714   if (syscall != NULL) {
 715     obj->Set(env->syscall_string(), OneByteString(node_isolate, syscall));
 716   }
 717
 718   return e;
 719 }
 720
 721
 722 // hack alert! copy of ErrnoException, tuned for uv errors
 723 Local<Value> UVException(int errorno,
 724                          const char *syscall,
 725                          const char *msg,
 726                          const char *path) {
 727   Environment* env = Environment::GetCurrent(node_isolate);
 728
 729   if (!msg || !msg[0])
 730     msg = uv_strerror(errorno);
 731
 732   Local<String> estring = OneByteString(node_isolate, uv_err_name(errorno));
 733   Local<String> message = OneByteString(node_isolate, msg);
 734   Local<String> cons1 =
 735       String::Concat(estring, FIXED_ONE_BYTE_STRING(node_isolate, ", "));
 736   Local<String> cons2 = String::Concat(cons1, message);
 737
 738   Local<Value> e;
 739
 740   Local<String> path_str;
 741
 742   if (path) {
 743 #ifdef _WIN32
 744     if (strncmp(path, "\\\\?\\UNC\\", 8) == 0) {
 745       path_str = String::Concat(FIXED_ONE_BYTE_STRING(node_isolate, "\\\\"),
 746                                 String::NewFromUtf8(node_isolate, path + 8));
 747     } else if (strncmp(path, "\\\\?\\", 4) == 0) {
 748       path_str = String::NewFromUtf8(node_isolate, path + 4);
 749     } else {
 750       path_str = String::NewFromUtf8(node_isolate, path);
 751     }
 752 #else
 753     path_str = String::NewFromUtf8(node_isolate, path);
 754 #endif
 755
 756     Local<String> cons3 =
 757         String::Concat(cons2, FIXED_ONE_BYTE_STRING(node_isolate, " '"));
 758     Local<String> cons4 =
 759         String::Concat(cons3, path_str);
 760     Local<String> cons5 =
 761         String::Concat(cons4, FIXED_ONE_BYTE_STRING(node_isolate, "'"));
 762     e = Exception::Error(cons5);
 763   } else {
 764     e = Exception::Error(cons2);
 765   }
 766
 767   Local<Object> obj = e->ToObject();
 768   // TODO(piscisaureus) errno should probably go
 769   obj->Set(env->errno_string(), Integer::New(errorno, node_isolate));
 770   obj->Set(env->code_string(), estring);
 771
 772   if (path != NULL) {
 773     obj->Set(env->path_string(), path_str);
 774   }
 775
 776   if (syscall != NULL) {
 777     obj->Set(env->syscall_string(), OneByteString(node_isolate, syscall));
 778   }
 779
 780   return e;
 781 }
 782
 783
 784 #ifdef _WIN32
 785 // Does about the same as strerror(),
 786 // but supports all windows error messages
 787 static const char *winapi_strerror(const int errorno) {
 788   char *errmsg = NULL;
 789
 790   FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM |
 791       FORMAT_MESSAGE_IGNORE_INSERTS, NULL, errorno,
 792       MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), (LPTSTR)&errmsg, 0, NULL);
 793
 794   if (errmsg) {
 795     // Remove trailing newlines
 796     for (int i = strlen(errmsg) - 1;
 797         i >= 0 && (errmsg[i] == '\n' || errmsg[i] == '\r'); i--) {
 798       errmsg[i] = '\0';
 799     }
 800
 801     return errmsg;
 802   } else {
 803     // FormatMessage failed
 804     return "Unknown error";
 805   }
 806 }
 807
 808
 809 Local<Value> WinapiErrnoException(int errorno,
 810                                   const char* syscall,
 811                                   const char* msg,
 812                                   const char* path) {
 813   Environment* env = Environment::GetCurrent(node_isolate);
 814
 815   Local<Value> e;
 816   if (!msg || !msg[0]) {
 817     msg = winapi_strerror(errorno);
 818   }
 819   Local<String> message = OneByteString(node_isolate, msg);
 820
 821   if (path) {
 822     Local<String> cons1 =
 823         String::Concat(message, FIXED_ONE_BYTE_STRING(node_isolate, " '"));
 824     Local<String> cons2 =
 825         String::Concat(cons1, String::NewFromUtf8(node_isolate, path));
 826     Local<String> cons3 =
 827         String::Concat(cons2, FIXED_ONE_BYTE_STRING(node_isolate, "'"));
 828     e = Exception::Error(cons3);
 829   } else {
 830     e = Exception::Error(message);
 831   }
 832
 833   Local<Object> obj = e->ToObject();
 834   obj->Set(env->errno_string(), Integer::New(errorno, node_isolate));
 835
 836   if (path != NULL) {
 837     obj->Set(env->path_string(), String::NewFromUtf8(node_isolate, path));
 838   }
 839
 840   if (syscall != NULL) {
 841     obj->Set(env->syscall_string(), OneByteString(node_isolate, syscall));
 842   }
 843
 844   return e;
 845 }
 846 #endif
 847
 848
 849 void SetupAsyncListener(const FunctionCallbackInfo<Value>& args) {
 850   HandleScope handle_scope(args.GetIsolate());
 851   Environment* env = Environment::GetCurrent(args.GetIsolate());
 852
 853   assert(args[0]->IsObject());
 854   assert(args[1]->IsFunction());
 855   assert(args[2]->IsFunction());
 856   assert(args[3]->IsFunction());
 857   assert(args[4]->IsFunction());
 858   assert(args[5]->IsFunction());
 859
 860   env->set_async_listener_run_function(args[1].As<Function>());
 861   env->set_async_listener_load_function(args[2].As<Function>());
 862   env->set_async_listener_unload_function(args[3].As<Function>());
 863   env->set_async_listener_push_function(args[4].As<Function>());
 864   env->set_async_listener_strip_function(args[5].As<Function>());
 865
 866   Local<Object> async_listener_flag_obj = args[0].As<Object>();
 867   Environment::AsyncListener* async_listener = env->async_listener();
 868   async_listener_flag_obj->SetIndexedPropertiesToExternalArrayData(
 869       async_listener->fields(),
 870       kExternalUnsignedIntArray,
 871       async_listener->fields_count());
 872
 873   // Do a little housekeeping.
 874   env->process_object()->Delete(
 875       FIXED_ONE_BYTE_STRING(args.GetIsolate(), "_setupAsyncListener"));
 876 }
 877
 878
 879 void SetupDomainUse(const FunctionCallbackInfo<Value>& args) {
 880   Environment* env = Environment::GetCurrent(args.GetIsolate());
 881
 882   if (env->using_domains())
 883     return;
 884   env->set_using_domains(true);
 885
 886   HandleScope scope(node_isolate);
 887   Local<Object> process_object = env->process_object();
 888
 889   Local<String> tick_callback_function_key =
 890       FIXED_ONE_BYTE_STRING(node_isolate, "_tickDomainCallback");
 891   Local<Function> tick_callback_function =
 892       process_object->Get(tick_callback_function_key).As<Function>();
 893
 894   if (!tick_callback_function->IsFunction()) {
 895     fprintf(stderr, "process._tickDomainCallback assigned to non-function\n");
 896     abort();
 897   }
 898
 899   process_object->Set(FIXED_ONE_BYTE_STRING(node_isolate, "_tickCallback"),
 900                       tick_callback_function);
 901   env->set_tick_callback_function(tick_callback_function);
 902
 903   assert(args[0]->IsArray());
 904   assert(args[1]->IsObject());
 905
 906   env->set_domain_array(args[0].As<Array>());
 907
 908   Local<Object> domain_flag_obj = args[1].As<Object>();
 909   Environment::DomainFlag* domain_flag = env->domain_flag();
 910   domain_flag_obj->SetIndexedPropertiesToExternalArrayData(
 911       domain_flag->fields(),
 912       kExternalUnsignedIntArray,
 913       domain_flag->fields_count());
 914
 915   // Do a little housekeeping.
 916   env->process_object()->Delete(
 917       FIXED_ONE_BYTE_STRING(args.GetIsolate(), "_setupDomainUse"));
 918 }
 919
 920
 921 void SetupNextTick(const FunctionCallbackInfo<Value>& args) {
 922   HandleScope handle_scope(args.GetIsolate());
 923   Environment* env = Environment::GetCurrent(args.GetIsolate());
 924
 925   assert(args[0]->IsObject());
 926   assert(args[1]->IsFunction());
 927
 928   // Values use to cross communicate with processNextTick.
 929   Local<Object> tick_info_obj = args[0].As<Object>();
 930   tick_info_obj->SetIndexedPropertiesToExternalArrayData(
 931       env->tick_info()->fields(),
 932       kExternalUnsignedIntArray,
 933       env->tick_info()->fields_count());
 934
 935   env->set_tick_callback_function(args[1].As<Function>());
 936
 937   // Do a little housekeeping.
 938   env->process_object()->Delete(
 939       FIXED_ONE_BYTE_STRING(args.GetIsolate(), "_setupNextTick"));
 940 }
 941
 942
 943 Handle<Value> MakeDomainCallback(Environment* env,
 944                                  Handle<Object> object,
 945                                  const Handle<Function> callback,
 946                                  int argc,
 947                                  Handle<Value> argv[]) {
 948   // If you hit this assertion, you forgot to enter the v8::Context first.
 949   assert(env->context() == env->isolate()->GetCurrentContext());
 950
 951   Local<Object> process = env->process_object();
 952   Local<Value> domain_v = object->Get(env->domain_string());
 953   Local<Object> domain;
 954
 955   TryCatch try_catch;
 956   try_catch.SetVerbose(true);
 957
 958   // TODO(trevnorris): This is sucky for performance. Fix it.
 959   bool has_async_queue = object->Has(env->async_queue_string());
 960   if (has_async_queue) {
 961     Local<Value> argv[] = { object };
 962     env->async_listener_load_function()->Call(process, ARRAY_SIZE(argv), argv);
 963
 964     if (try_catch.HasCaught())
 965       return Undefined(node_isolate);
 966   }
 967
 968   bool has_domain = domain_v->IsObject();
 969   if (has_domain) {
 970     domain = domain_v.As<Object>();
 971
 972     if (domain->Get(env->disposed_string())->IsTrue()) {
 973       // domain has been disposed of.
 974       return Undefined(node_isolate);
 975     }
 976
 977     Local<Function> enter =
 978         domain->Get(env->enter_string()).As<Function>();
 979     assert(enter->IsFunction());
 980     enter->Call(domain, 0, NULL);
 981
 982     if (try_catch.HasCaught()) {
 983       return Undefined(node_isolate);
 984     }
 985   }
 986
 987   Local<Value> ret = callback->Call(object, argc, argv);
 988
 989   if (try_catch.HasCaught()) {
 990     return Undefined(node_isolate);
 991   }
 992
 993   if (has_domain) {
 994     Local<Function> exit =
 995         domain->Get(env->exit_string()).As<Function>();
 996     assert(exit->IsFunction());
 997     exit->Call(domain, 0, NULL);
 998
 999     if (try_catch.HasCaught()) {
1000       return Undefined(node_isolate);
1001     }
1002   }
1003
1004   if (has_async_queue) {
1005     Local<Value> val = object.As<Value>();
1006     env->async_listener_unload_function()->Call(process, 1, &val);
1007
1008     if (try_catch.HasCaught())
1009       return Undefined(node_isolate);
1010   }
1011
1012   Environment::TickInfo* tick_info = env->tick_info();
1013
1014   if (tick_info->last_threw() == 1) {
1015     tick_info->set_last_threw(0);
1016     return ret;
1017   }
1018
1019   if (tick_info->in_tick()) {
1020     return ret;
1021   }
1022
1023   if (tick_info->length() == 0) {
1024     tick_info->set_index(0);
1025     return ret;
1026   }
1027
1028   tick_info->set_in_tick(true);
1029
1030   env->tick_callback_function()->Call(process, 0, NULL);
1031
1032   tick_info->set_in_tick(false);
1033
1034   if (try_catch.HasCaught()) {
1035     tick_info->set_last_threw(true);
1036     return Undefined(node_isolate);
1037   }
1038
1039   return ret;
1040 }
1041
1042
1043 Handle<Value> MakeCallback(Environment* env,
1044                            Handle<Object> object,
1045                            const Handle<Function> callback,
1046                            int argc,
1047                            Handle<Value> argv[]) {
1048   if (env->using_domains())
1049     return MakeDomainCallback(env, object, callback, argc, argv);
1050
1051   // If you hit this assertion, you forgot to enter the v8::Context first.
1052   assert(env->context() == env->isolate()->GetCurrentContext());
1053
1054   Local<Object> process = env->process_object();
1055
1056   TryCatch try_catch;
1057   try_catch.SetVerbose(true);
1058
1059   // TODO(trevnorris): This is sucky for performance. Fix it.
1060   bool has_async_queue = object->Has(env->async_queue_string());
1061   if (has_async_queue) {
1062     Local<Value> argv[] = { object };
1063     env->async_listener_load_function()->Call(process, ARRAY_SIZE(argv), argv);
1064
1065     if (try_catch.HasCaught())
1066       return Undefined(node_isolate);
1067   }
1068
1069   Local<Value> ret = callback->Call(object, argc, argv);
1070
1071   if (try_catch.HasCaught()) {
1072     return Undefined(node_isolate);
1073   }
1074
1075   if (has_async_queue) {
1076     Local<Value> val = object.As<Value>();
1077     env->async_listener_unload_function()->Call(process, 1, &val);
1078
1079     if (try_catch.HasCaught())
1080       return Undefined(node_isolate);
1081   }
1082
1083   Environment::TickInfo* tick_info = env->tick_info();
1084
1085   if (tick_info->in_tick()) {
1086     return ret;
1087   }
1088
1089   if (tick_info->length() == 0) {
1090     tick_info->set_index(0);
1091     return ret;
1092   }
1093
1094   tick_info->set_in_tick(true);
1095
1096   // process nextTicks after call
1097   env->tick_callback_function()->Call(process, 0, NULL);
1098
1099   tick_info->set_in_tick(false);
1100
1101   if (try_catch.HasCaught()) {
1102     tick_info->set_last_threw(true);
1103     return Undefined(node_isolate);
1104   }
1105
1106   return ret;
1107 }
1108
1109
1110 // Internal only.
1111 Handle<Value> MakeCallback(Environment* env,
1112                            const Handle<Object> object,
1113                            uint32_t index,
1114                            int argc,
1115                            Handle<Value> argv[]) {
1116   Local<Function> callback = object->Get(index).As<Function>();
1117   assert(callback->IsFunction());
1118
1119   return MakeCallback(env, object, callback, argc, argv);
1120 }
1121
1122
1123 Handle<Value> MakeCallback(Environment* env,
1124                            const Handle<Object> object,
1125                            const Handle<String> symbol,
1126                            int argc,
1127                            Handle<Value> argv[]) {
1128   Local<Function> callback = object->Get(symbol).As<Function>();
1129   assert(callback->IsFunction());
1130   return MakeCallback(env, object, callback, argc, argv);
1131 }
1132
1133
1134 Handle<Value> MakeCallback(Environment* env,
1135                            const Handle<Object> object,
1136                            const char* method,
1137                            int argc,
1138                            Handle<Value> argv[]) {
1139   Local<String> method_string = OneByteString(node_isolate, method);
1140   return MakeCallback(env, object, method_string, argc, argv);
1141 }
1142
1143
1144 Handle<Value> MakeCallback(const Handle<Object> object,
1145                            const char* method,
1146                            int argc,
1147                            Handle<Value> argv[]) {
1148   Local<Context> context = object->CreationContext();
1149   Environment* env = Environment::GetCurrent(context);
1150   Context::Scope context_scope(context);
1151   HandleScope handle_scope(env->isolate());
1152   return handle_scope.Close(MakeCallback(env, object, method, argc, argv));
1153 }
1154
1155
1156 Handle<Value> MakeCallback(const Handle<Object> object,
1157                            const Handle<String> symbol,
1158                            int argc,
1159                            Handle<Value> argv[]) {
1160   Local<Context> context = object->CreationContext();
1161   Environment* env = Environment::GetCurrent(context);
1162   Context::Scope context_scope(context);
1163   HandleScope handle_scope(env->isolate());
1164   return handle_scope.Close(MakeCallback(env, object, symbol, argc, argv));
1165 }
1166
1167
1168 Handle<Value> MakeCallback(const Handle<Object> object,
1169                            const Handle<Function> callback,
1170                            int argc,
1171                            Handle<Value> argv[]) {
1172   Local<Context> context = object->CreationContext();
1173   Environment* env = Environment::GetCurrent(context);
1174   Context::Scope context_scope(context);
1175   HandleScope handle_scope(env->isolate());
1176   return handle_scope.Close(MakeCallback(env, object, callback, argc, argv));
1177 }
1178
1179
1180 Handle<Value> MakeDomainCallback(const Handle<Object> object,
1181                                  const Handle<Function> callback,
1182                                  int argc,
1183                                  Handle<Value> argv[]) {
1184   Local<Context> context = object->CreationContext();
1185   Environment* env = Environment::GetCurrent(context);
1186   Context::Scope context_scope(context);
1187   HandleScope handle_scope(env->isolate());
1188   return handle_scope.Close(
1189       MakeDomainCallback(env, object, callback, argc, argv));
1190 }
1191
1192
1193 enum encoding ParseEncoding(Handle<Value> encoding_v, enum encoding _default) {
1194   HandleScope scope(node_isolate);
1195
1196   if (!encoding_v->IsString())
1197     return _default;
1198
1199   String::Utf8Value encoding(encoding_v);
1200
1201   if (strcasecmp(*encoding, "utf8") == 0) {
1202     return UTF8;
1203   } else if (strcasecmp(*encoding, "utf-8") == 0) {
1204     return UTF8;
1205   } else if (strcasecmp(*encoding, "ascii") == 0) {
1206     return ASCII;
1207   } else if (strcasecmp(*encoding, "base64") == 0) {
1208     return BASE64;
1209   } else if (strcasecmp(*encoding, "ucs2") == 0) {
1210     return UCS2;
1211   } else if (strcasecmp(*encoding, "ucs-2") == 0) {
1212     return UCS2;
1213   } else if (strcasecmp(*encoding, "utf16le") == 0) {
1214     return UCS2;
1215   } else if (strcasecmp(*encoding, "utf-16le") == 0) {
1216     return UCS2;
1217   } else if (strcasecmp(*encoding, "binary") == 0) {
1218     return BINARY;
1219   } else if (strcasecmp(*encoding, "buffer") == 0) {
1220     return BUFFER;
1221   } else if (strcasecmp(*encoding, "hex") == 0) {
1222     return HEX;
1223   } else if (strcasecmp(*encoding, "raw") == 0) {
1224     if (!no_deprecation) {
1225       fprintf(stderr, "'raw' (array of integers) has been removed. "
1226                       "Use 'binary'.\n");
1227     }
1228     return BINARY;
1229   } else if (strcasecmp(*encoding, "raws") == 0) {
1230     if (!no_deprecation) {
1231       fprintf(stderr, "'raws' encoding has been renamed to 'binary'. "
1232                       "Please update your code.\n");
1233     }
1234     return BINARY;
1235   } else {
1236     return _default;
1237   }
1238 }
1239
1240 Local<Value> Encode(const void *buf, size_t len, enum encoding encoding) {
1241   return StringBytes::Encode(static_cast<const char*>(buf),
1242                              len,
1243                              encoding);
1244 }
1245
1246 // Returns -1 if the handle was not valid for decoding
1247 ssize_t DecodeBytes(v8::Handle<v8::Value> val, enum encoding encoding) {
1248   HandleScope scope(node_isolate);
1249
1250   if (val->IsArray()) {
1251     fprintf(stderr, "'raw' encoding (array of integers) has been removed. "
1252                     "Use 'binary'.\n");
1253     assert(0);
1254     return -1;
1255   }
1256
1257   return StringBytes::Size(val, encoding);
1258 }
1259
1260 #ifndef MIN
1261 # define MIN(a, b) ((a) < (b) ? (a) : (b))
1262 #endif
1263
1264 // Returns number of bytes written.
1265 ssize_t DecodeWrite(char *buf,
1266                     size_t buflen,
1267                     v8::Handle<v8::Value> val,
1268                     enum encoding encoding) {
1269   return StringBytes::Write(buf, buflen, val, encoding, NULL);
1270 }
1271
1272 void DisplayExceptionLine(Handle<Message> message) {
1273   // Prevent re-entry into this function.  For example, if there is
1274   // a throw from a program in vm.runInThisContext(code, filename, true),
1275   // then we want to show the original failure, not the secondary one.
1276   static bool displayed_error = false;
1277
1278   if (displayed_error)
1279     return;
1280   displayed_error = true;
1281
1282   uv_tty_reset_mode();
1283
1284   fprintf(stderr, "\n");
1285
1286   if (!message.IsEmpty()) {
1287     // Print (filename):(line number): (message).
1288     String::Utf8Value filename(message->GetScriptResourceName());
1289     const char* filename_string = *filename;
1290     int linenum = message->GetLineNumber();
1291     fprintf(stderr, "%s:%i\n", filename_string, linenum);
1292     // Print line of source code.
1293     String::Utf8Value sourceline(message->GetSourceLine());
1294     const char* sourceline_string = *sourceline;
1295
1296     // Because of how node modules work, all scripts are wrapped with a
1297     // "function (module, exports, __filename, ...) {"
1298     // to provide script local variables.
1299     //
1300     // When reporting errors on the first line of a script, this wrapper
1301     // function is leaked to the user. There used to be a hack here to
1302     // truncate off the first 62 characters, but it caused numerous other
1303     // problems when vm.runIn*Context() methods were used for non-module
1304     // code.
1305     //
1306     // If we ever decide to re-instate such a hack, the following steps
1307     // must be taken:
1308     //
1309     // 1. Pass a flag around to say "this code was wrapped"
1310     // 2. Update the stack frame output so that it is also correct.
1311     //
1312     // It would probably be simpler to add a line rather than add some
1313     // number of characters to the first line, since V8 truncates the
1314     // sourceline to 78 characters, and we end up not providing very much
1315     // useful debugging info to the user if we remove 62 characters.
1316
1317     int start = message->GetStartColumn();
1318     int end = message->GetEndColumn();
1319
1320     fprintf(stderr, "%s\n", sourceline_string);
1321     // Print wavy underline (GetUnderline is deprecated).
1322     for (int i = 0; i < start; i++) {
1323       fputc((sourceline_string[i] == '\t') ? '\t' : ' ', stderr);
1324     }
1325     for (int i = start; i < end; i++) {
1326       fputc('^', stderr);
1327     }
1328     fputc('\n', stderr);
1329   }
1330 }
1331
1332
1333 static void ReportException(Handle<Value> er, Handle<Message> message) {
1334   HandleScope scope(node_isolate);
1335
1336   DisplayExceptionLine(message);
1337
1338   Local<Value> trace_value;
1339
1340   if (er->IsUndefined() || er->IsNull()) {
1341     trace_value = Undefined(node_isolate);
1342   } else {
1343     trace_value =
1344         er->ToObject()->Get(FIXED_ONE_BYTE_STRING(node_isolate, "stack"));
1345   }
1346
1347   String::Utf8Value trace(trace_value);
1348
1349   // range errors have a trace member set to undefined
1350   if (trace.length() > 0 && !trace_value->IsUndefined()) {
1351     fprintf(stderr, "%s\n", *trace);
1352   } else {
1353     // this really only happens for RangeErrors, since they're the only
1354     // kind that won't have all this info in the trace, or when non-Error
1355     // objects are thrown manually.
1356     Local<Value> message;
1357     Local<Value> name;
1358
1359     if (er->IsObject()) {
1360       Local<Object> err_obj = er.As<Object>();
1361       message = err_obj->Get(FIXED_ONE_BYTE_STRING(node_isolate, "message"));
1362       name = err_obj->Get(FIXED_ONE_BYTE_STRING(node_isolate, "name"));
1363     }
1364
1365     if (message.IsEmpty() ||
1366         message->IsUndefined() ||
1367         name.IsEmpty() ||
1368         name->IsUndefined()) {
1369       // Not an error object. Just print as-is.
1370       String::Utf8Value message(er);
1371       fprintf(stderr, "%s\n", *message);
1372     } else {
1373       String::Utf8Value name_string(name);
1374       String::Utf8Value message_string(message);
1375       fprintf(stderr, "%s: %s\n", *name_string, *message_string);
1376     }
1377   }
1378
1379   fflush(stderr);
1380 }
1381
1382
1383 static void ReportException(const TryCatch& try_catch) {
1384   ReportException(try_catch.Exception(), try_catch.Message());
1385 }
1386
1387
1388 // Executes a str within the current v8 context.
1389 Local<Value> ExecuteString(Handle<String> source, Handle<Value> filename) {
1390   HandleScope scope(node_isolate);
1391   TryCatch try_catch;
1392
1393   // try_catch must be nonverbose to disable FatalException() handler,
1394   // we will handle exceptions ourself.
1395   try_catch.SetVerbose(false);
1396
1397   Local<v8::Script> script = v8::Script::Compile(source, filename);
1398   if (script.IsEmpty()) {
1399     ReportException(try_catch);
1400     exit(3);
1401   }
1402
1403   Local<Value> result = script->Run();
1404   if (result.IsEmpty()) {
1405     ReportException(try_catch);
1406     exit(4);
1407   }
1408
1409   return scope.Close(result);
1410 }
1411
1412
1413 static void GetActiveRequests(const FunctionCallbackInfo<Value>& args) {
1414   HandleScope scope(node_isolate);
1415
1416   Local<Array> ary = Array::New();
1417   QUEUE* q = NULL;
1418   int i = 0;
1419
1420   QUEUE_FOREACH(q, &req_wrap_queue) {
1421     ReqWrap<uv_req_t>* w = CONTAINER_OF(q, ReqWrap<uv_req_t>, req_wrap_queue_);
1422     if (w->persistent().IsEmpty())
1423       continue;
1424     ary->Set(i++, w->object());
1425   }
1426
1427   args.GetReturnValue().Set(ary);
1428 }
1429
1430
1431 // Non-static, friend of HandleWrap. Could have been a HandleWrap method but
1432 // implemented here for consistency with GetActiveRequests().
1433 void GetActiveHandles(const FunctionCallbackInfo<Value>& args) {
1434   HandleScope scope(node_isolate);
1435
1436   Local<Array> ary = Array::New();
1437   QUEUE* q = NULL;
1438   int i = 0;
1439
1440   Local<String> owner_sym = FIXED_ONE_BYTE_STRING(node_isolate, "owner");
1441
1442   QUEUE_FOREACH(q, &handle_wrap_queue) {
1443     HandleWrap* w = CONTAINER_OF(q, HandleWrap, handle_wrap_queue_);
1444     if (w->persistent().IsEmpty() || (w->flags_ & HandleWrap::kUnref))
1445       continue;
1446     Local<Object> object = w->object();
1447     Local<Value> owner = object->Get(owner_sym);
1448     if (owner->IsUndefined())
1449       owner = object;
1450     ary->Set(i++, owner);
1451   }
1452
1453   args.GetReturnValue().Set(ary);
1454 }
1455
1456
1457 static void Abort(const FunctionCallbackInfo<Value>& args) {
1458   abort();
1459 }
1460
1461
1462 static void Chdir(const FunctionCallbackInfo<Value>& args) {
1463   HandleScope scope(node_isolate);
1464
1465   if (args.Length() != 1 || !args[0]->IsString()) {
1466     return ThrowError("Bad argument.");  // FIXME(bnoordhuis) ThrowTypeError?
1467   }
1468
1469   String::Utf8Value path(args[0]);
1470   int err = uv_chdir(*path);
1471   if (err) {
1472     return ThrowUVException(err, "uv_chdir");
1473   }
1474 }
1475
1476
1477 static void Cwd(const FunctionCallbackInfo<Value>& args) {
1478   HandleScope scope(node_isolate);
1479 #ifdef _WIN32
1480   /* MAX_PATH is in characters, not bytes. Make sure we have enough headroom. */
1481   char buf[MAX_PATH * 4 + 1];
1482 #else
1483   char buf[PATH_MAX + 1];
1484 #endif
1485
1486   int err = uv_cwd(buf, ARRAY_SIZE(buf) - 1);
1487   if (err) {
1488     return ThrowUVException(err, "uv_cwd");
1489   }
1490
1491   buf[ARRAY_SIZE(buf) - 1] = '\0';
1492   Local<String> cwd = String::NewFromUtf8(node_isolate, buf);
1493
1494   args.GetReturnValue().Set(cwd);
1495 }
1496
1497
1498 static void Umask(const FunctionCallbackInfo<Value>& args) {
1499   HandleScope scope(node_isolate);
1500   uint32_t old;
1501
1502   if (args.Length() < 1 || args[0]->IsUndefined()) {
1503     old = umask(0);
1504     umask(static_cast<mode_t>(old));
1505   } else if (!args[0]->IsInt32() && !args[0]->IsString()) {
1506     return ThrowTypeError("argument must be an integer or octal string.");
1507   } else {
1508     int oct;
1509     if (args[0]->IsInt32()) {
1510       oct = args[0]->Uint32Value();
1511     } else {
1512       oct = 0;
1513       String::Utf8Value str(args[0]);
1514
1515       // Parse the octal string.
1516       for (int i = 0; i < str.length(); i++) {
1517         char c = (*str)[i];
1518         if (c > '7' || c < '0') {
1519           return ThrowTypeError("invalid octal string");
1520         }
1521         oct *= 8;
1522         oct += c - '0';
1523       }
1524     }
1525     old = umask(static_cast<mode_t>(oct));
1526   }
1527
1528   args.GetReturnValue().Set(old);
1529 }
1530
1531
1532 #if defined(__POSIX__) && !defined(__ANDROID__)
1533
1534 static const uid_t uid_not_found = static_cast<uid_t>(-1);
1535 static const gid_t gid_not_found = static_cast<gid_t>(-1);
1536
1537
1538 static uid_t uid_by_name(const char* name) {
1539   struct passwd pwd;
1540   struct passwd* pp;
1541   char buf[8192];
1542
1543   errno = 0;
1544   pp = NULL;
1545
1546   if (getpwnam_r(name, &pwd, buf, sizeof(buf), &pp) == 0 && pp != NULL) {
1547     return pp->pw_uid;
1548   }
1549
1550   return uid_not_found;
1551 }
1552
1553
1554 static char* name_by_uid(uid_t uid) {
1555   struct passwd pwd;
1556   struct passwd* pp;
1557   char buf[8192];
1558   int rc;
1559
1560   errno = 0;
1561   pp = NULL;
1562
1563   if ((rc = getpwuid_r(uid, &pwd, buf, sizeof(buf), &pp)) == 0 && pp != NULL) {
1564     return strdup(pp->pw_name);
1565   }
1566
1567   if (rc == 0) {
1568     errno = ENOENT;
1569   }
1570
1571   return NULL;
1572 }
1573
1574
1575 static gid_t gid_by_name(const char* name) {
1576   struct group pwd;
1577   struct group* pp;
1578   char buf[8192];
1579
1580   errno = 0;
1581   pp = NULL;
1582
1583   if (getgrnam_r(name, &pwd, buf, sizeof(buf), &pp) == 0 && pp != NULL) {
1584     return pp->gr_gid;
1585   }
1586
1587   return gid_not_found;
1588 }
1589
1590
1591 #if 0  // For future use.
1592 static const char* name_by_gid(gid_t gid) {
1593   struct group pwd;
1594   struct group* pp;
1595   char buf[8192];
1596   int rc;
1597
1598   errno = 0;
1599   pp = NULL;
1600
1601   if ((rc = getgrgid_r(gid, &pwd, buf, sizeof(buf), &pp)) == 0 && pp != NULL) {
1602     return strdup(pp->gr_name);
1603   }
1604
1605   if (rc == 0) {
1606     errno = ENOENT;
1607   }
1608
1609   return NULL;
1610 }
1611 #endif
1612
1613
1614 static uid_t uid_by_name(Handle<Value> value) {
1615   if (value->IsUint32()) {
1616     return static_cast<uid_t>(value->Uint32Value());
1617   } else {
1618     String::Utf8Value name(value);
1619     return uid_by_name(*name);
1620   }
1621 }
1622
1623
1624 static gid_t gid_by_name(Handle<Value> value) {
1625   if (value->IsUint32()) {
1626     return static_cast<gid_t>(value->Uint32Value());
1627   } else {
1628     String::Utf8Value name(value);
1629     return gid_by_name(*name);
1630   }
1631 }
1632
1633
1634 static void GetUid(const FunctionCallbackInfo<Value>& args) {
1635   // uid_t is an uint32_t on all supported platforms.
1636   args.GetReturnValue().Set(static_cast<uint32_t>(getuid()));
1637 }
1638
1639
1640 static void GetGid(const FunctionCallbackInfo<Value>& args) {
1641   // gid_t is an uint32_t on all supported platforms.
1642   args.GetReturnValue().Set(static_cast<uint32_t>(getgid()));
1643 }
1644
1645
1646 static void SetGid(const FunctionCallbackInfo<Value>& args) {
1647   HandleScope scope(node_isolate);
1648
1649   if (!args[0]->IsUint32() && !args[0]->IsString()) {
1650     return ThrowTypeError("setgid argument must be a number or a string");
1651   }
1652
1653   gid_t gid = gid_by_name(args[0]);
1654
1655   if (gid == gid_not_found) {
1656     return ThrowError("setgid group id does not exist");
1657   }
1658
1659   if (setgid(gid)) {
1660     return ThrowErrnoException(errno, "setgid");
1661   }
1662 }
1663
1664
1665 static void SetUid(const FunctionCallbackInfo<Value>& args) {
1666   HandleScope scope(node_isolate);
1667
1668   if (!args[0]->IsUint32() && !args[0]->IsString()) {
1669     return ThrowTypeError("setuid argument must be a number or a string");
1670   }
1671
1672   uid_t uid = uid_by_name(args[0]);
1673
1674   if (uid == uid_not_found) {
1675     return ThrowError("setuid user id does not exist");
1676   }
1677
1678   if (setuid(uid)) {
1679     return ThrowErrnoException(errno, "setuid");
1680   }
1681 }
1682
1683
1684 static void GetGroups(const FunctionCallbackInfo<Value>& args) {
1685   HandleScope scope(node_isolate);
1686
1687   int ngroups = getgroups(0, NULL);
1688
1689   if (ngroups == -1) {
1690     return ThrowErrnoException(errno, "getgroups");
1691   }
1692
1693   gid_t* groups = new gid_t[ngroups];
1694
1695   ngroups = getgroups(ngroups, groups);
1696
1697   if (ngroups == -1) {
1698     delete[] groups;
1699     return ThrowErrnoException(errno, "getgroups");
1700   }
1701
1702   Local<Array> groups_list = Array::New(ngroups);
1703   bool seen_egid = false;
1704   gid_t egid = getegid();
1705
1706   for (int i = 0; i < ngroups; i++) {
1707     groups_list->Set(i, Integer::New(groups[i], node_isolate));
1708     if (groups[i] == egid)
1709       seen_egid = true;
1710   }
1711
1712   delete[] groups;
1713
1714   if (seen_egid == false) {
1715     groups_list->Set(ngroups, Integer::New(egid, node_isolate));
1716   }
1717
1718   args.GetReturnValue().Set(groups_list);
1719 }
1720
1721
1722 static void SetGroups(const FunctionCallbackInfo<Value>& args) {
1723   HandleScope scope(node_isolate);
1724
1725   if (!args[0]->IsArray()) {
1726     return ThrowTypeError("argument 1 must be an array");
1727   }
1728
1729   Local<Array> groups_list = args[0].As<Array>();
1730   size_t size = groups_list->Length();
1731   gid_t* groups = new gid_t[size];
1732
1733   for (size_t i = 0; i < size; i++) {
1734     gid_t gid = gid_by_name(groups_list->Get(i));
1735
1736     if (gid == gid_not_found) {
1737       delete[] groups;
1738       return ThrowError("group name not found");
1739     }
1740
1741     groups[i] = gid;
1742   }
1743
1744   int rc = setgroups(size, groups);
1745   delete[] groups;
1746
1747   if (rc == -1) {
1748     return ThrowErrnoException(errno, "setgroups");
1749   }
1750 }
1751
1752
1753 static void InitGroups(const FunctionCallbackInfo<Value>& args) {
1754   HandleScope scope(node_isolate);
1755
1756   if (!args[0]->IsUint32() && !args[0]->IsString()) {
1757     return ThrowTypeError("argument 1 must be a number or a string");
1758   }
1759
1760   if (!args[1]->IsUint32() && !args[1]->IsString()) {
1761     return ThrowTypeError("argument 2 must be a number or a string");
1762   }
1763
1764   String::Utf8Value arg0(args[0]);
1765   gid_t extra_group;
1766   bool must_free;
1767   char* user;
1768
1769   if (args[0]->IsUint32()) {
1770     user = name_by_uid(args[0]->Uint32Value());
1771     must_free = true;
1772   } else {
1773     user = *arg0;
1774     must_free = false;
1775   }
1776
1777   if (user == NULL) {
1778     return ThrowError("initgroups user not found");
1779   }
1780
1781   extra_group = gid_by_name(args[1]);
1782
1783   if (extra_group == gid_not_found) {
1784     if (must_free)
1785       free(user);
1786     return ThrowError("initgroups extra group not found");
1787   }
1788
1789   int rc = initgroups(user, extra_group);
1790
1791   if (must_free) {
1792     free(user);
1793   }
1794
1795   if (rc) {
1796     return ThrowErrnoException(errno, "initgroups");
1797   }
1798 }
1799
1800 #endif  // __POSIX__ && !defined(__ANDROID__)
1801
1802
1803 void Exit(const FunctionCallbackInfo<Value>& args) {
1804   HandleScope scope(node_isolate);
1805   exit(args[0]->IntegerValue());
1806 }
1807
1808
1809 static void Uptime(const FunctionCallbackInfo<Value>& args) {
1810   HandleScope scope(node_isolate);
1811   double uptime;
1812   if (uv_uptime(&uptime))
1813     return;
1814   args.GetReturnValue().Set(uptime - prog_start_time);
1815 }
1816
1817
1818 void MemoryUsage(const FunctionCallbackInfo<Value>& args) {
1819   HandleScope handle_scope(args.GetIsolate());
1820   Environment* env = Environment::GetCurrent(args.GetIsolate());
1821
1822   size_t rss;
1823   int err = uv_resident_set_memory(&rss);
1824   if (err) {
1825     return ThrowUVException(err, "uv_resident_set_memory");
1826   }
1827
1828   // V8 memory usage
1829   HeapStatistics v8_heap_stats;
1830   node_isolate->GetHeapStatistics(&v8_heap_stats);
1831
1832   Local<Integer> heap_total =
1833       Integer::NewFromUnsigned(v8_heap_stats.total_heap_size(), node_isolate);
1834   Local<Integer> heap_used =
1835       Integer::NewFromUnsigned(v8_heap_stats.used_heap_size(), node_isolate);
1836
1837   Local<Object> info = Object::New();
1838   info->Set(env->rss_string(), Number::New(node_isolate, rss));
1839   info->Set(env->heap_total_string(), heap_total);
1840   info->Set(env->heap_used_string(), heap_used);
1841
1842   args.GetReturnValue().Set(info);
1843 }
1844
1845
1846 void Kill(const FunctionCallbackInfo<Value>& args) {
1847   HandleScope scope(node_isolate);
1848
1849   if (args.Length() != 2) {
1850     return ThrowError("Bad argument.");
1851   }
1852
1853   int pid = args[0]->IntegerValue();
1854   int sig = args[1]->Int32Value();
1855   int err = uv_kill(pid, sig);
1856   args.GetReturnValue().Set(err);
1857 }
1858
1859 // used in Hrtime() below
1860 #define NANOS_PER_SEC 1000000000
1861
1862 // Hrtime exposes libuv's uv_hrtime() high-resolution timer.
1863 // The value returned by uv_hrtime() is a 64-bit int representing nanoseconds,
1864 // so this function instead returns an Array with 2 entries representing seconds
1865 // and nanoseconds, to avoid any integer overflow possibility.
1866 // Pass in an Array from a previous hrtime() call to instead get a time diff.
1867 void Hrtime(const FunctionCallbackInfo<Value>& args) {
1868   HandleScope scope(node_isolate);
1869
1870   uint64_t t = uv_hrtime();
1871
1872   if (args.Length() > 0) {
1873     // return a time diff tuple
1874     if (!args[0]->IsArray()) {
1875       return ThrowTypeError("process.hrtime() only accepts an Array tuple.");
1876     }
1877     Local<Array> inArray = Local<Array>::Cast(args[0]);
1878     uint64_t seconds = inArray->Get(0)->Uint32Value();
1879     uint64_t nanos = inArray->Get(1)->Uint32Value();
1880     t -= (seconds * NANOS_PER_SEC) + nanos;
1881   }
1882
1883   Local<Array> tuple = Array::New(2);
1884   tuple->Set(0, Integer::NewFromUnsigned(t / NANOS_PER_SEC, node_isolate));
1885   tuple->Set(1, Integer::NewFromUnsigned(t % NANOS_PER_SEC, node_isolate));
1886   args.GetReturnValue().Set(tuple);
1887 }
1888
1889
1890 typedef void (UV_DYNAMIC* extInit)(Handle<Object> exports);
1891
1892 // DLOpen is process.dlopen(module, filename).
1893 // Used to load 'module.node' dynamically shared objects.
1894 //
1895 // FIXME(bnoordhuis) Not multi-context ready. TBD how to resolve the conflict
1896 // when two contexts try to load the same shared object. Maybe have a shadow
1897 // cache that's a plain C list or hash table that's shared across contexts?
1898 void DLOpen(const FunctionCallbackInfo<Value>& args) {
1899   HandleScope handle_scope(args.GetIsolate());
1900   Environment* env = Environment::GetCurrent(args.GetIsolate());
1901   char symbol[1024], *base, *pos;
1902   uv_lib_t lib;
1903   int r;
1904
1905   if (args.Length() < 2) {
1906     return ThrowError("process.dlopen takes exactly 2 arguments.");
1907   }
1908
1909   Local<Object> module = args[0]->ToObject();  // Cast
1910   String::Utf8Value filename(args[1]);  // Cast
1911
1912   Local<String> exports_string = env->exports_string();
1913   Local<Object> exports = module->Get(exports_string)->ToObject();
1914
1915   if (uv_dlopen(*filename, &lib)) {
1916     Local<String> errmsg = OneByteString(env->isolate(), uv_dlerror(&lib));
1917 #ifdef _WIN32
1918     // Windows needs to add the filename into the error message
1919     errmsg = String::Concat(errmsg, args[1]->ToString());
1920 #endif  // _WIN32
1921     ThrowException(Exception::Error(errmsg));
1922     return;
1923   }
1924
1925   String::Utf8Value path(args[1]);
1926   base = *path;
1927
1928   /* Find the shared library filename within the full path. */
1929 #ifdef __POSIX__
1930   pos = strrchr(base, '/');
1931   if (pos != NULL) {
1932     base = pos + 1;
1933   }
1934 #else  // Windows
1935   for (;;) {
1936     pos = strpbrk(base, "\\/:");
1937     if (pos == NULL) {
1938       break;
1939     }
1940     base = pos + 1;
1941   }
1942 #endif  // __POSIX__
1943
1944   /* Strip the .node extension. */
1945   pos = strrchr(base, '.');
1946   if (pos != NULL) {
1947     *pos = '\0';
1948   }
1949
1950   /* Add the `_module` suffix to the extension name. */
1951   r = snprintf(symbol, sizeof symbol, "%s_module", base);
1952   if (r <= 0 || static_cast<size_t>(r) >= sizeof symbol) {
1953     return ThrowError("Out of memory.");
1954   }
1955
1956   /* Replace dashes with underscores. When loading foo-bar.node,
1957    * look for foo_bar_module, not foo-bar_module.
1958    */
1959   for (pos = symbol; *pos != '\0'; ++pos) {
1960     if (*pos == '-')
1961       *pos = '_';
1962   }
1963
1964   node_module_struct *mod;
1965   if (uv_dlsym(&lib, symbol, reinterpret_cast<void**>(&mod))) {
1966     char errmsg[1024];
1967     snprintf(errmsg, sizeof(errmsg), "Symbol %s not found.", symbol);
1968     return ThrowError(errmsg);
1969   }
1970
1971   if (mod->version != NODE_MODULE_VERSION) {
1972     char errmsg[1024];
1973     snprintf(errmsg,
1974              sizeof(errmsg),
1975              "Module version mismatch. Expected %d, got %d.",
1976              NODE_MODULE_VERSION, mod->version);
1977     return ThrowError(errmsg);
1978   }
1979
1980   // Execute the C++ module
1981   if (mod->register_context_func != NULL) {
1982     mod->register_context_func(exports, module, env->context());
1983   } else if (mod->register_func != NULL) {
1984     mod->register_func(exports, module);
1985   } else {
1986     return ThrowError("Module has no declared entry point.");
1987   }
1988
1989   // Tell coverity that 'handle' should not be freed when we return.
1990   // coverity[leaked_storage]
1991 }
1992
1993
1994 static void OnFatalError(const char* location, const char* message) {
1995   if (location) {
1996     fprintf(stderr, "FATAL ERROR: %s %s\n", location, message);
1997   } else {
1998     fprintf(stderr, "FATAL ERROR: %s\n", message);
1999   }
2000   fflush(stderr);
2001 #if defined(DEBUG)
2002   abort();
2003 #endif
2004   exit(5);
2005 }
2006
2007
2008 NO_RETURN void FatalError(const char* location, const char* message) {
2009   OnFatalError(location, message);
2010   // to supress compiler warning
2011   abort();
2012 }
2013
2014
2015 void FatalException(Handle<Value> error, Handle<Message> message) {
2016   HandleScope scope(node_isolate);
2017
2018   Environment* env = Environment::GetCurrent(node_isolate);
2019   Local<Object> process_object = env->process_object();
2020   Local<String> fatal_exception_string = env->fatal_exception_string();
2021   Local<Function> fatal_exception_function =
2022       process_object->Get(fatal_exception_string).As<Function>();
2023
2024   if (!fatal_exception_function->IsFunction()) {
2025     // failed before the process._fatalException function was added!
2026     // this is probably pretty bad.  Nothing to do but report and exit.
2027     ReportException(error, message);
2028     exit(6);
2029   }
2030
2031   TryCatch fatal_try_catch;
2032
2033   // Do not call FatalException when _fatalException handler throws
2034   fatal_try_catch.SetVerbose(false);
2035
2036   // this will return true if the JS layer handled it, false otherwise
2037   Local<Value> caught =
2038       fatal_exception_function->Call(process_object, 1, &error);
2039
2040   if (fatal_try_catch.HasCaught()) {
2041     // the fatal exception function threw, so we must exit
2042     ReportException(fatal_try_catch);
2043     exit(7);
2044   }
2045
2046   if (false == caught->BooleanValue()) {
2047     ReportException(error, message);
2048     exit(1);
2049   }
2050 }
2051
2052
2053 void FatalException(const TryCatch& try_catch) {
2054   HandleScope scope(node_isolate);
2055   // TODO(bajtos) do not call FatalException if try_catch is verbose
2056   // (requires V8 API to expose getter for try_catch.is_verbose_)
2057   FatalException(try_catch.Exception(), try_catch.Message());
2058 }
2059
2060
2061 void OnMessage(Handle<Message> message, Handle<Value> error) {
2062   // The current version of V8 sends messages for errors only
2063   // (thus `error` is always set).
2064   FatalException(error, message);
2065 }
2066
2067
2068 static void Binding(const FunctionCallbackInfo<Value>& args) {
2069   HandleScope handle_scope(args.GetIsolate());
2070   Environment* env = Environment::GetCurrent(args.GetIsolate());
2071
2072   Local<String> module = args[0]->ToString();
2073   String::Utf8Value module_v(module);
2074
2075   Local<Object> cache = env->binding_cache_object();
2076   Local<Object> exports;
2077
2078   if (cache->Has(module)) {
2079     exports = cache->Get(module)->ToObject();
2080     args.GetReturnValue().Set(exports);
2081     return;
2082   }
2083
2084   // Append a string to process.moduleLoadList
2085   char buf[1024];
2086   snprintf(buf, sizeof(buf), "Binding %s", *module_v);
2087
2088   Local<Array> modules = env->module_load_list_array();
2089   uint32_t l = modules->Length();
2090   modules->Set(l, OneByteString(node_isolate, buf));
2091
2092   node_module_struct* mod = get_builtin_module(*module_v);
2093   if (mod != NULL) {
2094     exports = Object::New();
2095     // Internal bindings don't have a "module" object, only exports.
2096     assert(mod->register_func == NULL);
2097     assert(mod->register_context_func != NULL);
2098     Local<Value> unused = Undefined(env->isolate());
2099     mod->register_context_func(exports, unused, env->context());
2100     cache->Set(module, exports);
2101   } else if (!strcmp(*module_v, "constants")) {
2102     exports = Object::New();
2103     DefineConstants(exports);
2104     cache->Set(module, exports);
2105   } else if (!strcmp(*module_v, "natives")) {
2106     exports = Object::New();
2107     DefineJavaScript(exports);
2108     cache->Set(module, exports);
2109   } else {
2110     return ThrowError("No such module");
2111   }
2112
2113   args.GetReturnValue().Set(exports);
2114 }
2115
2116
2117 static void ProcessTitleGetter(Local<String> property,
2118                                const PropertyCallbackInfo<Value>& info) {
2119   HandleScope scope(node_isolate);
2120   char buffer[512];
2121   uv_get_process_title(buffer, sizeof(buffer));
2122   info.GetReturnValue().Set(String::NewFromUtf8(node_isolate, buffer));
2123 }
2124
2125
2126 static void ProcessTitleSetter(Local<String> property,
2127                                Local<Value> value,
2128                                const PropertyCallbackInfo<void>& info) {
2129   HandleScope scope(node_isolate);
2130   String::Utf8Value title(value);
2131   // TODO(piscisaureus): protect with a lock
2132   uv_set_process_title(*title);
2133 }
2134
2135
2136 static void EnvGetter(Local<String> property,
2137                       const PropertyCallbackInfo<Value>& info) {
2138   HandleScope scope(node_isolate);
2139 #ifdef __POSIX__
2140   String::Utf8Value key(property);
2141   const char* val = getenv(*key);
2142   if (val) {
2143     return info.GetReturnValue().Set(String::NewFromUtf8(node_isolate, val));
2144   }
2145 #else  // _WIN32
2146   String::Value key(property);
2147   WCHAR buffer[32767];  // The maximum size allowed for environment variables.
2148   DWORD result = GetEnvironmentVariableW(reinterpret_cast<WCHAR*>(*key),
2149                                          buffer,
2150                                          ARRAY_SIZE(buffer));
2151   // If result >= sizeof buffer the buffer was too small. That should never
2152   // happen. If result == 0 and result != ERROR_SUCCESS the variable was not
2153   // not found.
2154   if ((result > 0 || GetLastError() == ERROR_SUCCESS) &&
2155       result < ARRAY_SIZE(buffer)) {
2156     const uint16_t* two_byte_buffer = reinterpret_cast<const uint16_t*>(buffer);
2157     Local<String> rc = String::NewFromTwoByte(node_isolate, two_byte_buffer);
2158     return info.GetReturnValue().Set(rc);
2159   }
2160 #endif
2161   // Not found.  Fetch from prototype.
2162   info.GetReturnValue().Set(
2163       info.Data().As<Object>()->Get(property));
2164 }
2165
2166
2167 static void EnvSetter(Local<String> property,
2168                       Local<Value> value,
2169                       const PropertyCallbackInfo<Value>& info) {
2170   HandleScope scope(node_isolate);
2171 #ifdef __POSIX__
2172   String::Utf8Value key(property);
2173   String::Utf8Value val(value);
2174   setenv(*key, *val, 1);
2175 #else  // _WIN32
2176   String::Value key(property);
2177   String::Value val(value);
2178   WCHAR* key_ptr = reinterpret_cast<WCHAR*>(*key);
2179   // Environment variables that start with '=' are read-only.
2180   if (key_ptr[0] != L'=') {
2181     SetEnvironmentVariableW(key_ptr, reinterpret_cast<WCHAR*>(*val));
2182   }
2183 #endif
2184   // Whether it worked or not, always return rval.
2185   info.GetReturnValue().Set(value);
2186 }
2187
2188
2189 static void EnvQuery(Local<String> property,
2190                      const PropertyCallbackInfo<Integer>& info) {
2191   HandleScope scope(node_isolate);
2192   int32_t rc = -1;  // Not found unless proven otherwise.
2193 #ifdef __POSIX__
2194   String::Utf8Value key(property);
2195   if (getenv(*key))
2196     rc = 0;
2197 #else  // _WIN32
2198   String::Value key(property);
2199   WCHAR* key_ptr = reinterpret_cast<WCHAR*>(*key);
2200   if (GetEnvironmentVariableW(key_ptr, NULL, 0) > 0 ||
2201       GetLastError() == ERROR_SUCCESS) {
2202     rc = 0;
2203     if (key_ptr[0] == L'=') {
2204       // Environment variables that start with '=' are hidden and read-only.
2205       rc = static_cast<int32_t>(v8::ReadOnly) |
2206            static_cast<int32_t>(v8::DontDelete) |
2207            static_cast<int32_t>(v8::DontEnum);
2208     }
2209   }
2210 #endif
2211   if (rc != -1)
2212     info.GetReturnValue().Set(rc);
2213 }
2214
2215
2216 static void EnvDeleter(Local<String> property,
2217                        const PropertyCallbackInfo<Boolean>& info) {
2218   HandleScope scope(node_isolate);
2219   bool rc = true;
2220 #ifdef __POSIX__
2221   String::Utf8Value key(property);
2222   rc = getenv(*key) != NULL;
2223   if (rc)
2224     unsetenv(*key);
2225 #else
2226   String::Value key(property);
2227   WCHAR* key_ptr = reinterpret_cast<WCHAR*>(*key);
2228   if (key_ptr[0] == L'=' || !SetEnvironmentVariableW(key_ptr, NULL)) {
2229     // Deletion failed. Return true if the key wasn't there in the first place,
2230     // false if it is still there.
2231     rc = GetEnvironmentVariableW(key_ptr, NULL, NULL) == 0 &&
2232          GetLastError() != ERROR_SUCCESS;
2233   }
2234 #endif
2235   info.GetReturnValue().Set(rc);
2236 }
2237
2238
2239 static void EnvEnumerator(const PropertyCallbackInfo<Array>& info) {
2240   HandleScope scope(node_isolate);
2241 #ifdef __POSIX__
2242   int size = 0;
2243   while (environ[size])
2244     size++;
2245
2246   Local<Array> env = Array::New(size);
2247
2248   for (int i = 0; i < size; ++i) {
2249     const char* var = environ[i];
2250     const char* s = strchr(var, '=');
2251     const int length = s ? s - var : strlen(var);
2252     Local<String> name = String::NewFromUtf8(node_isolate,
2253                                              var,
2254                                              String::kNormalString,
2255                                              length);
2256     env->Set(i, name);
2257   }
2258 #else  // _WIN32
2259   WCHAR* environment = GetEnvironmentStringsW();
2260   if (environment == NULL)
2261     return;  // This should not happen.
2262   Local<Array> env = Array::New();
2263   WCHAR* p = environment;
2264   int i = 0;
2265   while (*p != NULL) {
2266     WCHAR *s;
2267     if (*p == L'=') {
2268       // If the key starts with '=' it is a hidden environment variable.
2269       p += wcslen(p) + 1;
2270       continue;
2271     } else {
2272       s = wcschr(p, L'=');
2273     }
2274     if (!s) {
2275       s = p + wcslen(p);
2276     }
2277     const uint16_t* two_byte_buffer = reinterpret_cast<const uint16_t*>(p);
2278     const size_t two_byte_buffer_len = s - p;
2279     Local<String> value = String::NewFromTwoByte(node_isolate,
2280                                                  two_byte_buffer,
2281                                                  String::kNormalString,
2282                                                  two_byte_buffer_len);
2283     env->Set(i++, value);
2284     p = s + wcslen(s) + 1;
2285   }
2286   FreeEnvironmentStringsW(environment);
2287 #endif
2288
2289   info.GetReturnValue().Set(env);
2290 }
2291
2292
2293 static Handle<Object> GetFeatures() {
2294   HandleScope scope(node_isolate);
2295
2296   Local<Object> obj = Object::New();
2297 #if defined(DEBUG) && DEBUG
2298   Local<Value> debug = True(node_isolate);
2299 #else
2300   Local<Value> debug = False(node_isolate);
2301 #endif  // defined(DEBUG) && DEBUG
2302
2303   obj->Set(FIXED_ONE_BYTE_STRING(node_isolate, "debug"), debug);
2304
2305   obj->Set(FIXED_ONE_BYTE_STRING(node_isolate, "uv"), True(node_isolate));
2306   // TODO(bnoordhuis) ping libuv
2307   obj->Set(FIXED_ONE_BYTE_STRING(node_isolate, "ipv6"), True(node_isolate));
2308
2309 #ifdef OPENSSL_NPN_NEGOTIATED
2310   Local<Boolean> tls_npn = True(node_isolate);
2311 #else
2312   Local<Boolean> tls_npn = False(node_isolate);
2313 #endif
2314   obj->Set(FIXED_ONE_BYTE_STRING(node_isolate, "tls_npn"), tls_npn);
2315
2316 #ifdef SSL_CTRL_SET_TLSEXT_SERVERNAME_CB
2317   Local<Boolean> tls_sni = True(node_isolate);
2318 #else
2319   Local<Boolean> tls_sni = False(node_isolate);
2320 #endif
2321   obj->Set(FIXED_ONE_BYTE_STRING(node_isolate, "tls_sni"), tls_sni);
2322
2323   obj->Set(FIXED_ONE_BYTE_STRING(node_isolate, "tls"),
2324            Boolean::New(get_builtin_module("crypto") != NULL));
2325
2326   return scope.Close(obj);
2327 }
2328
2329
2330 static void DebugPortGetter(Local<String> property,
2331                             const PropertyCallbackInfo<Value>& info) {
2332   HandleScope scope(node_isolate);
2333   info.GetReturnValue().Set(debug_port);
2334 }
2335
2336
2337 static void DebugPortSetter(Local<String> property,
2338                             Local<Value> value,
2339                             const PropertyCallbackInfo<void>& info) {
2340   HandleScope scope(node_isolate);
2341   debug_port = value->NumberValue();
2342 }
2343
2344
2345 static void DebugProcess(const FunctionCallbackInfo<Value>& args);
2346 static void DebugPause(const FunctionCallbackInfo<Value>& args);
2347 static void DebugEnd(const FunctionCallbackInfo<Value>& args);
2348
2349
2350 void NeedImmediateCallbackGetter(Local<String> property,
2351                                  const PropertyCallbackInfo<Value>& info) {
2352   HandleScope handle_scope(info.GetIsolate());
2353   Environment* env = Environment::GetCurrent(info.GetIsolate());
2354   const uv_check_t* immediate_check_handle = env->immediate_check_handle();
2355   bool active = uv_is_active(
2356       reinterpret_cast<const uv_handle_t*>(immediate_check_handle));
2357   info.GetReturnValue().Set(active);
2358 }
2359
2360
2361 static void NeedImmediateCallbackSetter(
2362     Local<String> property,
2363     Local<Value> value,
2364     const PropertyCallbackInfo<void>& info) {
2365   HandleScope handle_scope(info.GetIsolate());
2366   Environment* env = Environment::GetCurrent(info.GetIsolate());
2367
2368   uv_check_t* immediate_check_handle = env->immediate_check_handle();
2369   bool active = uv_is_active(
2370       reinterpret_cast<const uv_handle_t*>(immediate_check_handle));
2371
2372   if (active == value->BooleanValue())
2373     return;
2374
2375   uv_idle_t* immediate_idle_handle = env->immediate_idle_handle();
2376
2377   if (active) {
2378     uv_check_stop(immediate_check_handle);
2379     uv_idle_stop(immediate_idle_handle);
2380   } else {
2381     uv_check_start(immediate_check_handle, CheckImmediate);
2382     // Idle handle is needed only to stop the event loop from blocking in poll.
2383     uv_idle_start(immediate_idle_handle, IdleImmediateDummy);
2384   }
2385 }
2386
2387
2388 void SetIdle(uv_prepare_t* handle, int) {
2389   Environment* env = Environment::from_idle_prepare_handle(handle);
2390   env->isolate()->GetCpuProfiler()->SetIdle(true);
2391 }
2392
2393
2394 void ClearIdle(uv_check_t* handle, int) {
2395   Environment* env = Environment::from_idle_check_handle(handle);
2396   env->isolate()->GetCpuProfiler()->SetIdle(false);
2397 }
2398
2399
2400 void StartProfilerIdleNotifier(Environment* env) {
2401   uv_prepare_start(env->idle_prepare_handle(), SetIdle);
2402   uv_check_start(env->idle_check_handle(), ClearIdle);
2403 }
2404
2405
2406 void StopProfilerIdleNotifier(Environment* env) {
2407   uv_prepare_stop(env->idle_prepare_handle());
2408   uv_check_stop(env->idle_check_handle());
2409 }
2410
2411
2412 void StartProfilerIdleNotifier(const FunctionCallbackInfo<Value>& args) {
2413   HandleScope handle_scope(args.GetIsolate());
2414   Environment* env = Environment::GetCurrent(args.GetIsolate());
2415   StartProfilerIdleNotifier(env);
2416 }
2417
2418
2419 void StopProfilerIdleNotifier(const FunctionCallbackInfo<Value>& args) {
2420   HandleScope handle_scope(args.GetIsolate());
2421   Environment* env = Environment::GetCurrent(args.GetIsolate());
2422   StopProfilerIdleNotifier(env);
2423 }
2424
2425
2426 #define READONLY_PROPERTY(obj, str, var)                                      \
2427   do {                                                                        \
2428     obj->Set(OneByteString(node_isolate, str), var, v8::ReadOnly);            \
2429   } while (0)
2430
2431
2432 void SetupProcessObject(Environment* env,
2433                         int argc,
2434                         const char* const* argv,
2435                         int exec_argc,
2436                         const char* const* exec_argv) {
2437   HandleScope scope(node_isolate);
2438
2439   Local<Object> process = env->process_object();
2440
2441   process->SetAccessor(FIXED_ONE_BYTE_STRING(node_isolate, "title"),
2442                        ProcessTitleGetter,
2443                        ProcessTitleSetter);
2444
2445   // process.version
2446   READONLY_PROPERTY(process,
2447                     "version",
2448                     FIXED_ONE_BYTE_STRING(node_isolate, NODE_VERSION));
2449
2450   // process.moduleLoadList
2451   READONLY_PROPERTY(process,
2452                     "moduleLoadList",
2453                     env->module_load_list_array());
2454
2455   // process.versions
2456   Local<Object> versions = Object::New();
2457   READONLY_PROPERTY(process, "versions", versions);
2458
2459   const char http_parser_version[] = NODE_STRINGIFY(HTTP_PARSER_VERSION_MAJOR)
2460                                      "."
2461                                      NODE_STRINGIFY(HTTP_PARSER_VERSION_MINOR);
2462   READONLY_PROPERTY(versions,
2463                     "http_parser",
2464                     FIXED_ONE_BYTE_STRING(node_isolate, http_parser_version));
2465
2466   // +1 to get rid of the leading 'v'
2467   READONLY_PROPERTY(versions,
2468                     "node",
2469                     OneByteString(node_isolate, NODE_VERSION + 1));
2470   READONLY_PROPERTY(versions,
2471                     "v8",
2472                     OneByteString(node_isolate, V8::GetVersion()));
2473   READONLY_PROPERTY(versions,
2474                     "uv",
2475                     OneByteString(node_isolate, uv_version_string()));
2476   READONLY_PROPERTY(versions,
2477                     "zlib",
2478                     FIXED_ONE_BYTE_STRING(node_isolate, ZLIB_VERSION));
2479
2480   const char node_modules_version[] = NODE_STRINGIFY(NODE_MODULE_VERSION);
2481   READONLY_PROPERTY(versions,
2482                     "modules",
2483                     FIXED_ONE_BYTE_STRING(node_isolate, node_modules_version));
2484
2485 #if HAVE_OPENSSL
2486   // Stupid code to slice out the version string.
2487   {  // NOLINT(whitespace/braces)
2488     size_t i, j, k;
2489     int c;
2490     for (i = j = 0, k = sizeof(OPENSSL_VERSION_TEXT) - 1; i < k; ++i) {
2491       c = OPENSSL_VERSION_TEXT[i];
2492       if ('0' <= c && c <= '9') {
2493         for (j = i + 1; j < k; ++j) {
2494           c = OPENSSL_VERSION_TEXT[j];
2495           if (c == ' ')
2496             break;
2497         }
2498         break;
2499       }
2500     }
2501     READONLY_PROPERTY(
2502         versions,
2503         "openssl",
2504         OneByteString(node_isolate, &OPENSSL_VERSION_TEXT[i], j - i));
2505   }
2506 #endif
2507
2508   // process.arch
2509   READONLY_PROPERTY(process, "arch", OneByteString(node_isolate, ARCH));
2510
2511   // process.platform
2512   READONLY_PROPERTY(process,
2513                     "platform",
2514                     OneByteString(node_isolate, PLATFORM));
2515
2516   // process.argv
2517   Local<Array> arguments = Array::New(argc);
2518   for (int i = 0; i < argc; ++i) {
2519     arguments->Set(i, String::NewFromUtf8(node_isolate, argv[i]));
2520   }
2521   process->Set(FIXED_ONE_BYTE_STRING(node_isolate, "argv"), arguments);
2522
2523   // process.execArgv
2524   Local<Array> exec_arguments = Array::New(exec_argc);
2525   for (int i = 0; i < exec_argc; ++i) {
2526     exec_arguments->Set(i, String::NewFromUtf8(node_isolate, exec_argv[i]));
2527   }
2528   process->Set(FIXED_ONE_BYTE_STRING(node_isolate, "execArgv"), exec_arguments);
2529
2530   // create process.env
2531   Local<ObjectTemplate> process_env_template = ObjectTemplate::New();
2532   process_env_template->SetNamedPropertyHandler(EnvGetter,
2533                                                 EnvSetter,
2534                                                 EnvQuery,
2535                                                 EnvDeleter,
2536                                                 EnvEnumerator,
2537                                                 Object::New());
2538   Local<Object> process_env = process_env_template->NewInstance();
2539   process->Set(FIXED_ONE_BYTE_STRING(node_isolate, "env"), process_env);
2540
2541   READONLY_PROPERTY(process, "pid", Integer::New(getpid(), node_isolate));
2542   READONLY_PROPERTY(process, "features", GetFeatures());
2543   process->SetAccessor(
2544       FIXED_ONE_BYTE_STRING(node_isolate, "_needImmediateCallback"),
2545       NeedImmediateCallbackGetter,
2546       NeedImmediateCallbackSetter);
2547
2548   // -e, --eval
2549   if (eval_string) {
2550     READONLY_PROPERTY(process,
2551                       "_eval",
2552                       String::NewFromUtf8(node_isolate, eval_string));
2553   }
2554
2555   // -p, --print
2556   if (print_eval) {
2557     READONLY_PROPERTY(process, "_print_eval", True(node_isolate));
2558   }
2559
2560   // -i, --interactive
2561   if (force_repl) {
2562     READONLY_PROPERTY(process, "_forceRepl", True(node_isolate));
2563   }
2564
2565   // --no-deprecation
2566   if (no_deprecation) {
2567     READONLY_PROPERTY(process, "noDeprecation", True(node_isolate));
2568   }
2569
2570   // --throw-deprecation
2571   if (throw_deprecation) {
2572     READONLY_PROPERTY(process, "throwDeprecation", True(node_isolate));
2573   }
2574
2575   // --trace-deprecation
2576   if (trace_deprecation) {
2577     READONLY_PROPERTY(process, "traceDeprecation", True(node_isolate));
2578   }
2579
2580   size_t exec_path_len = 2 * PATH_MAX;
2581   char* exec_path = new char[exec_path_len];
2582   Local<String> exec_path_value;
2583   if (uv_exepath(exec_path, &exec_path_len) == 0) {
2584     exec_path_value = String::NewFromUtf8(node_isolate,
2585                                           exec_path,
2586                                           String::kNormalString,
2587                                           exec_path_len);
2588   } else {
2589     exec_path_value = String::NewFromUtf8(node_isolate, argv[0]);
2590   }
2591   process->Set(FIXED_ONE_BYTE_STRING(node_isolate, "execPath"),
2592                exec_path_value);
2593   delete[] exec_path;
2594
2595   process->SetAccessor(FIXED_ONE_BYTE_STRING(node_isolate, "debugPort"),
2596                        DebugPortGetter,
2597                        DebugPortSetter);
2598
2599   // define various internal methods
2600   NODE_SET_METHOD(process,
2601                   "_startProfilerIdleNotifier",
2602                   StartProfilerIdleNotifier);
2603   NODE_SET_METHOD(process,
2604                   "_stopProfilerIdleNotifier",
2605                   StopProfilerIdleNotifier);
2606   NODE_SET_METHOD(process, "_getActiveRequests", GetActiveRequests);
2607   NODE_SET_METHOD(process, "_getActiveHandles", GetActiveHandles);
2608   NODE_SET_METHOD(process, "reallyExit", Exit);
2609   NODE_SET_METHOD(process, "abort", Abort);
2610   NODE_SET_METHOD(process, "chdir", Chdir);
2611   NODE_SET_METHOD(process, "cwd", Cwd);
2612
2613   NODE_SET_METHOD(process, "umask", Umask);
2614
2615 #if defined(__POSIX__) && !defined(__ANDROID__)
2616   NODE_SET_METHOD(process, "getuid", GetUid);
2617   NODE_SET_METHOD(process, "setuid", SetUid);
2618
2619   NODE_SET_METHOD(process, "setgid", SetGid);
2620   NODE_SET_METHOD(process, "getgid", GetGid);
2621
2622   NODE_SET_METHOD(process, "getgroups", GetGroups);
2623   NODE_SET_METHOD(process, "setgroups", SetGroups);
2624   NODE_SET_METHOD(process, "initgroups", InitGroups);
2625 #endif  // __POSIX__ && !defined(__ANDROID__)
2626
2627   NODE_SET_METHOD(process, "_kill", Kill);
2628
2629   NODE_SET_METHOD(process, "_debugProcess", DebugProcess);
2630   NODE_SET_METHOD(process, "_debugPause", DebugPause);
2631   NODE_SET_METHOD(process, "_debugEnd", DebugEnd);
2632
2633   NODE_SET_METHOD(process, "hrtime", Hrtime);
2634
2635   NODE_SET_METHOD(process, "dlopen", DLOpen);
2636
2637   NODE_SET_METHOD(process, "uptime", Uptime);
2638   NODE_SET_METHOD(process, "memoryUsage", MemoryUsage);
2639
2640   NODE_SET_METHOD(process, "binding", Binding);
2641
2642   NODE_SET_METHOD(process, "_setupAsyncListener", SetupAsyncListener);
2643   NODE_SET_METHOD(process, "_setupNextTick", SetupNextTick);
2644   NODE_SET_METHOD(process, "_setupDomainUse", SetupDomainUse);
2645
2646   // values use to cross communicate with processNextTick
2647   Local<Object> tick_info_obj = Object::New();
2648   tick_info_obj->SetIndexedPropertiesToExternalArrayData(
2649       env->tick_info()->fields(),
2650       kExternalUnsignedIntArray,
2651       env->tick_info()->fields_count());
2652   process->Set(FIXED_ONE_BYTE_STRING(node_isolate, "_tickInfo"), tick_info_obj);
2653
2654   // pre-set _events object for faster emit checks
2655   process->Set(FIXED_ONE_BYTE_STRING(node_isolate, "_events"), Object::New());
2656 }
2657
2658
2659 #undef READONLY_PROPERTY
2660
2661
2662 static void AtExit() {
2663   uv_tty_reset_mode();
2664 }
2665
2666
2667 static void SignalExit(int signal) {
2668   uv_tty_reset_mode();
2669   _exit(128 + signal);
2670 }
2671
2672
2673 // Most of the time, it's best to use `console.error` to write
2674 // to the process.stderr stream.  However, in some cases, such as
2675 // when debugging the stream.Writable class or the process.nextTick
2676 // function, it is useful to bypass JavaScript entirely.
2677 static void RawDebug(const FunctionCallbackInfo<Value>& args) {
2678   HandleScope scope(node_isolate);
2679
2680   assert(args.Length() == 1 && args[0]->IsString() &&
2681          "must be called with a single string");
2682
2683   String::Utf8Value message(args[0]);
2684   fprintf(stderr, "%s\n", *message);
2685   fflush(stderr);
2686 }
2687
2688
2689 void Load(Environment* env) {
2690   HandleScope handle_scope(node_isolate);
2691
2692   // Compile, execute the src/node.js file. (Which was included as static C
2693   // string in node_natives.h. 'natve_node' is the string containing that
2694   // source code.)
2695
2696   // The node.js file returns a function 'f'
2697   atexit(AtExit);
2698
2699   TryCatch try_catch;
2700
2701   // Disable verbose mode to stop FatalException() handler from trying
2702   // to handle the exception. Errors this early in the start-up phase
2703   // are not safe to ignore.
2704   try_catch.SetVerbose(false);
2705
2706   Local<String> script_name = FIXED_ONE_BYTE_STRING(node_isolate, "node.js");
2707   Local<Value> f_value = ExecuteString(MainSource(), script_name);
2708   if (try_catch.HasCaught())  {
2709     ReportException(try_catch);
2710     exit(10);
2711   }
2712   assert(f_value->IsFunction());
2713   Local<Function> f = Local<Function>::Cast(f_value);
2714
2715   // Now we call 'f' with the 'process' variable that we've built up with
2716   // all our bindings. Inside node.js we'll take care of assigning things to
2717   // their places.
2718
2719   // We start the process this way in order to be more modular. Developers
2720   // who do not like how 'src/node.js' setups the module system but do like
2721   // Node's I/O bindings may want to replace 'f' with their own function.
2722
2723   // Add a reference to the global object
2724   Local<Object> global = env->context()->Global();
2725
2726 #if defined HAVE_DTRACE || defined HAVE_ETW
2727   InitDTrace(global);
2728 #endif
2729
2730 #if defined HAVE_PERFCTR
2731   InitPerfCounters(global);
2732 #endif
2733
2734   // Enable handling of uncaught exceptions
2735   // (FatalException(), break on uncaught exception in debugger)
2736   //
2737   // This is not strictly necessary since it's almost impossible
2738   // to attach the debugger fast enought to break on exception
2739   // thrown during process startup.
2740   try_catch.SetVerbose(true);
2741
2742   NODE_SET_METHOD(env->process_object(), "_rawDebug", RawDebug);
2743
2744   Local<Value> arg = env->process_object();
2745   f->Call(global, 1, &arg);
2746 }
2747
2748 static void PrintHelp();
2749
2750 static bool ParseDebugOpt(const char* arg) {
2751   const char* port = NULL;
2752
2753   if (!strcmp(arg, "--debug")) {
2754     use_debug_agent = true;
2755   } else if (!strncmp(arg, "--debug=", sizeof("--debug=") - 1)) {
2756     use_debug_agent = true;
2757     port = arg + sizeof("--debug=") - 1;
2758   } else if (!strcmp(arg, "--debug-brk")) {
2759     use_debug_agent = true;
2760     debug_wait_connect = true;
2761   } else if (!strncmp(arg, "--debug-brk=", sizeof("--debug-brk=") - 1)) {
2762     use_debug_agent = true;
2763     debug_wait_connect = true;
2764     port = arg + sizeof("--debug-brk=") - 1;
2765   } else if (!strncmp(arg, "--debug-port=", sizeof("--debug-port=") - 1)) {
2766     port = arg + sizeof("--debug-port=") - 1;
2767   } else {
2768     return false;
2769   }
2770
2771   if (port != NULL) {
2772     debug_port = atoi(port);
2773     if (debug_port < 1024 || debug_port > 65535) {
2774       fprintf(stderr, "Debug port must be in range 1024 to 65535.\n");
2775       PrintHelp();
2776       exit(12);
2777     }
2778   }
2779
2780   return true;
2781 }
2782
2783 static void PrintHelp() {
2784   printf("Usage: node [options] [ -e script | script.js ] [arguments] \n"
2785          "       node debug script.js [arguments] \n"
2786          "\n"
2787          "Options:\n"
2788          "  -v, --version        print node's version\n"
2789          "  -e, --eval script    evaluate script\n"
2790          "  -p, --print          evaluate script and print result\n"
2791          "  -i, --interactive    always enter the REPL even if stdin\n"
2792          "                       does not appear to be a terminal\n"
2793          "  --no-deprecation     silence deprecation warnings\n"
2794          "  --trace-deprecation  show stack traces on deprecations\n"
2795          "  --v8-options         print v8 command line options\n"
2796          "  --max-stack-size=val set max v8 stack size (bytes)\n"
2797          "\n"
2798          "Environment variables:\n"
2799 #ifdef _WIN32
2800          "NODE_PATH              ';'-separated list of directories\n"
2801 #else
2802          "NODE_PATH              ':'-separated list of directories\n"
2803 #endif
2804          "                       prefixed to the module search path.\n"
2805          "NODE_MODULE_CONTEXTS   Set to 1 to load modules in their own\n"
2806          "                       global contexts.\n"
2807          "NODE_DISABLE_COLORS    Set to 1 to disable colors in the REPL\n"
2808          "\n"
2809          "Documentation can be found at http://nodejs.org/\n");
2810 }
2811
2812
2813 // Parse command line arguments.
2814 //
2815 // argv is modified in place. exec_argv and v8_argv are out arguments that
2816 // ParseArgs() allocates memory for and stores a pointer to the output
2817 // vector in.  The caller should free them with delete[].
2818 //
2819 // On exit:
2820 //
2821 //  * argv contains the arguments with node and V8 options filtered out.
2822 //  * exec_argv contains both node and V8 options and nothing else.
2823 //  * v8_argv contains argv[0] plus any V8 options
2824 static void ParseArgs(int* argc,
2825                       const char** argv,
2826                       int* exec_argc,
2827                       const char*** exec_argv,
2828                       int* v8_argc,
2829                       const char*** v8_argv) {
2830   const unsigned int nargs = static_cast<unsigned int>(*argc);
2831   const char** new_exec_argv = new const char*[nargs];
2832   const char** new_v8_argv = new const char*[nargs];
2833   const char** new_argv = new const char*[nargs];
2834
2835   for (unsigned int i = 0; i < nargs; ++i) {
2836     new_exec_argv[i] = NULL;
2837     new_v8_argv[i] = NULL;
2838     new_argv[i] = NULL;
2839   }
2840
2841   // exec_argv starts with the first option, the other two start with argv[0].
2842   unsigned int new_exec_argc = 0;
2843   unsigned int new_v8_argc = 1;
2844   unsigned int new_argc = 1;
2845   new_v8_argv[0] = argv[0];
2846   new_argv[0] = argv[0];
2847
2848   unsigned int index = 1;
2849   while (index < nargs && argv[index][0] == '-') {
2850     const char* const arg = argv[index];
2851     unsigned int args_consumed = 1;
2852
2853     if (ParseDebugOpt(arg)) {
2854       // Done, consumed by ParseDebugOpt().
2855     } else if (strcmp(arg, "--version") == 0 || strcmp(arg, "-v") == 0) {
2856       printf("%s\n", NODE_VERSION);
2857       exit(0);
2858     } else if (strcmp(arg, "--help") == 0 || strcmp(arg, "-h") == 0) {
2859       PrintHelp();
2860       exit(0);
2861     } else if (strcmp(arg, "--eval") == 0 ||
2862                strcmp(arg, "-e") == 0 ||
2863                strcmp(arg, "--print") == 0 ||
2864                strcmp(arg, "-pe") == 0 ||
2865                strcmp(arg, "-p") == 0) {
2866       bool is_eval = strchr(arg, 'e') != NULL;
2867       bool is_print = strchr(arg, 'p') != NULL;
2868       print_eval = print_eval || is_print;
2869       // --eval, -e and -pe always require an argument.
2870       if (is_eval == true) {
2871         args_consumed += 1;
2872         eval_string = argv[index + 1];
2873         if (eval_string == NULL) {
2874           fprintf(stderr, "%s: %s requires an argument\n", argv[0], arg);
2875           exit(9);
2876         }
2877       } else if (argv[index + 1] != NULL && argv[index + 1][0] != '-') {
2878         args_consumed += 1;
2879         eval_string = argv[index + 1];
2880         if (strncmp(eval_string, "\\-", 2) == 0) {
2881           // Starts with "\\-": escaped expression, drop the backslash.
2882           eval_string += 1;
2883         }
2884       }
2885     } else if (strcmp(arg, "--interactive") == 0 || strcmp(arg, "-i") == 0) {
2886       force_repl = true;
2887     } else if (strcmp(arg, "--no-deprecation") == 0) {
2888       no_deprecation = true;
2889     } else if (strcmp(arg, "--trace-deprecation") == 0) {
2890       trace_deprecation = true;
2891     } else if (strcmp(arg, "--throw-deprecation") == 0) {
2892       throw_deprecation = true;
2893     } else if (strcmp(arg, "--v8-options") == 0) {
2894       new_v8_argv[new_v8_argc] = "--help";
2895       new_v8_argc += 1;
2896     } else {
2897       // V8 option.  Pass through as-is.
2898       new_v8_argv[new_v8_argc] = arg;
2899       new_v8_argc += 1;
2900     }
2901
2902     memcpy(new_exec_argv + new_exec_argc,
2903            argv + index,
2904            args_consumed * sizeof(*argv));
2905
2906     new_exec_argc += args_consumed;
2907     index += args_consumed;
2908   }
2909
2910   // Copy remaining arguments.
2911   const unsigned int args_left = nargs - index;
2912   memcpy(new_argv + new_argc, argv + index, args_left * sizeof(*argv));
2913   new_argc += args_left;
2914
2915   *exec_argc = new_exec_argc;
2916   *exec_argv = new_exec_argv;
2917   *v8_argc = new_v8_argc;
2918   *v8_argv = new_v8_argv;
2919
2920   // Copy new_argv over argv and update argc.
2921   memcpy(argv, new_argv, new_argc * sizeof(*argv));
2922   delete[] new_argv;
2923   *argc = static_cast<int>(new_argc);
2924 }
2925
2926
2927 // Called from V8 Debug Agent TCP thread.
2928 static void DispatchMessagesDebugAgentCallback() {
2929   uv_async_send(&dispatch_debug_messages_async);
2930 }
2931
2932
2933 // Called from the main thread.
2934 static void EnableDebug(bool wait_connect) {
2935   assert(debugger_running == false);
2936   Isolate* isolate = node_isolate;  // TODO(bnoordhuis) Multi-isolate support.
2937   Isolate::Scope isolate_scope(isolate);
2938   HandleScope handle_scope(isolate);
2939   v8::Debug::SetDebugMessageDispatchHandler(DispatchMessagesDebugAgentCallback,
2940                                             false);
2941   debugger_running = v8::Debug::EnableAgent("node " NODE_VERSION,
2942                                             debug_port,
2943                                             wait_connect);
2944   if (debugger_running == false) {
2945     fprintf(stderr, "Starting debugger on port %d failed\n", debug_port);
2946     fflush(stderr);
2947     return;
2948   }
2949   fprintf(stderr, "Debugger listening on port %d\n", debug_port);
2950   fflush(stderr);
2951
2952   Environment* env = Environment::GetCurrentChecked(isolate);
2953   if (env == NULL)
2954     return;  // Still starting up.
2955
2956   Context::Scope context_scope(env->context());
2957   Local<Object> message = Object::New();
2958   message->Set(FIXED_ONE_BYTE_STRING(env->isolate(), "cmd"),
2959                FIXED_ONE_BYTE_STRING(env->isolate(), "NODE_DEBUG_ENABLED"));
2960   Local<Value> argv[] = {
2961     FIXED_ONE_BYTE_STRING(env->isolate(), "internalMessage"),
2962     message
2963   };
2964   MakeCallback(env, env->process_object(), "emit", ARRAY_SIZE(argv), argv);
2965 }
2966
2967
2968 // Called from the main thread.
2969 static void DispatchDebugMessagesAsyncCallback(uv_async_t* handle, int status) {
2970   if (debugger_running == false) {
2971     fprintf(stderr, "Starting debugger agent.\n");
2972     EnableDebug(false);
2973   }
2974   Isolate::Scope isolate_scope(node_isolate);
2975   v8::Debug::ProcessDebugMessages();
2976 }
2977
2978
2979 #ifdef __POSIX__
2980 static volatile sig_atomic_t caught_early_debug_signal;
2981
2982
2983 static void EarlyDebugSignalHandler(int signo) {
2984   caught_early_debug_signal = 1;
2985 }
2986
2987
2988 static void InstallEarlyDebugSignalHandler() {
2989   struct sigaction sa;
2990   memset(&sa, 0, sizeof(sa));
2991   sa.sa_handler = EarlyDebugSignalHandler;
2992   sigaction(SIGUSR1, &sa, NULL);
2993 }
2994
2995
2996 static void EnableDebugSignalHandler(int signo) {
2997   // Call only async signal-safe functions here!
2998   v8::Debug::DebugBreak(*static_cast<Isolate* volatile*>(&node_isolate));
2999   uv_async_send(&dispatch_debug_messages_async);
3000 }
3001
3002
3003 static void RegisterSignalHandler(int signal, void (*handler)(int signal)) {
3004   struct sigaction sa;
3005   memset(&sa, 0, sizeof(sa));
3006   sa.sa_handler = handler;
3007   sigfillset(&sa.sa_mask);
3008   sigaction(signal, &sa, NULL);
3009 }
3010
3011
3012 void DebugProcess(const FunctionCallbackInfo<Value>& args) {
3013   HandleScope scope(node_isolate);
3014
3015   if (args.Length() != 1) {
3016     return ThrowError("Invalid number of arguments.");
3017   }
3018
3019   pid_t pid;
3020   int r;
3021
3022   pid = args[0]->IntegerValue();
3023   r = kill(pid, SIGUSR1);
3024   if (r != 0) {
3025     return ThrowErrnoException(errno, "kill");
3026   }
3027 }
3028
3029
3030 static int RegisterDebugSignalHandler() {
3031   // FIXME(bnoordhuis) Should be per-isolate or per-context, not global.
3032   RegisterSignalHandler(SIGUSR1, EnableDebugSignalHandler);
3033   // If we caught a SIGUSR1 during the bootstrap process, re-raise it
3034   // now that the debugger infrastructure is in place.
3035   if (caught_early_debug_signal)
3036     raise(SIGUSR1);
3037   return 0;
3038 }
3039 #endif  // __POSIX__
3040
3041
3042 #ifdef _WIN32
3043 DWORD WINAPI EnableDebugThreadProc(void* arg) {
3044   v8::Debug::DebugBreak(*static_cast<Isolate* volatile*>(&node_isolate));
3045   uv_async_send(&dispatch_debug_messages_async);
3046   return 0;
3047 }
3048
3049
3050 static int GetDebugSignalHandlerMappingName(DWORD pid, wchar_t* buf,
3051     size_t buf_len) {
3052   return _snwprintf(buf, buf_len, L"node-debug-handler-%u", pid);
3053 }
3054
3055
3056 static int RegisterDebugSignalHandler() {
3057   wchar_t mapping_name[32];
3058   HANDLE mapping_handle;
3059   DWORD pid;
3060   LPTHREAD_START_ROUTINE* handler;
3061
3062   pid = GetCurrentProcessId();
3063
3064   if (GetDebugSignalHandlerMappingName(pid,
3065                                        mapping_name,
3066                                        ARRAY_SIZE(mapping_name)) < 0) {
3067     return -1;
3068   }
3069
3070   mapping_handle = CreateFileMappingW(INVALID_HANDLE_VALUE,
3071                                       NULL,
3072                                       PAGE_READWRITE,
3073                                       0,
3074                                       sizeof *handler,
3075                                       mapping_name);
3076   if (mapping_handle == NULL) {
3077     return -1;
3078   }
3079
3080   handler = reinterpret_cast<LPTHREAD_START_ROUTINE*>(
3081       MapViewOfFile(mapping_handle,
3082                     FILE_MAP_ALL_ACCESS,
3083                     0,
3084                     0,
3085                     sizeof *handler));
3086   if (handler == NULL) {
3087     CloseHandle(mapping_handle);
3088     return -1;
3089   }
3090
3091   *handler = EnableDebugThreadProc;
3092
3093   UnmapViewOfFile(static_cast<void*>(handler));
3094
3095   return 0;
3096 }
3097
3098
3099 static void DebugProcess(const FunctionCallbackInfo<Value>& args) {
3100   HandleScope scope(node_isolate);
3101   DWORD pid;
3102   HANDLE process = NULL;
3103   HANDLE thread = NULL;
3104   HANDLE mapping = NULL;
3105   wchar_t mapping_name[32];
3106   LPTHREAD_START_ROUTINE* handler = NULL;
3107
3108   if (args.Length() != 1) {
3109     ThrowError("Invalid number of arguments.");
3110     goto out;
3111   }
3112
3113   pid = (DWORD) args[0]->IntegerValue();
3114
3115   process = OpenProcess(PROCESS_CREATE_THREAD | PROCESS_QUERY_INFORMATION |
3116                             PROCESS_VM_OPERATION | PROCESS_VM_WRITE |
3117                             PROCESS_VM_READ,
3118                         FALSE,
3119                         pid);
3120   if (process == NULL) {
3121     ThrowException(WinapiErrnoException(GetLastError(), "OpenProcess"));
3122     goto out;
3123   }
3124
3125   if (GetDebugSignalHandlerMappingName(pid,
3126                                        mapping_name,
3127                                        ARRAY_SIZE(mapping_name)) < 0) {
3128     ThrowErrnoException(errno, "sprintf");
3129     goto out;
3130   }
3131
3132   mapping = OpenFileMappingW(FILE_MAP_READ, FALSE, mapping_name);
3133   if (mapping == NULL) {
3134     ThrowException(WinapiErrnoException(GetLastError(), "OpenFileMappingW"));
3135     goto out;
3136   }
3137
3138   handler = reinterpret_cast<LPTHREAD_START_ROUTINE*>(
3139       MapViewOfFile(mapping,
3140                     FILE_MAP_READ,
3141                     0,
3142                     0,
3143                     sizeof *handler));
3144   if (handler == NULL || *handler == NULL) {
3145     ThrowException(WinapiErrnoException(GetLastError(), "MapViewOfFile"));
3146     goto out;
3147   }
3148
3149   thread = CreateRemoteThread(process,
3150                               NULL,
3151                               0,
3152                               *handler,
3153                               NULL,
3154                               0,
3155                               NULL);
3156   if (thread == NULL) {
3157     ThrowException(WinapiErrnoException(GetLastError(), "CreateRemoteThread"));
3158     goto out;
3159   }
3160
3161   // Wait for the thread to terminate
3162   if (WaitForSingleObject(thread, INFINITE) != WAIT_OBJECT_0) {
3163     ThrowException(WinapiErrnoException(GetLastError(), "WaitForSingleObject"));
3164     goto out;
3165   }
3166
3167  out:
3168   if (process != NULL)
3169     CloseHandle(process);
3170   if (thread != NULL)
3171     CloseHandle(thread);
3172   if (handler != NULL)
3173     UnmapViewOfFile(handler);
3174   if (mapping != NULL)
3175     CloseHandle(mapping);
3176 }
3177 #endif  // _WIN32
3178
3179
3180 static void DebugPause(const FunctionCallbackInfo<Value>& args) {
3181   v8::Debug::DebugBreak(node_isolate);
3182 }
3183
3184
3185 static void DebugEnd(const FunctionCallbackInfo<Value>& args) {
3186   if (debugger_running) {
3187     v8::Debug::DisableAgent();
3188     debugger_running = false;
3189   }
3190 }
3191
3192
3193 void Init(int* argc,
3194           const char** argv,
3195           int* exec_argc,
3196           const char*** exec_argv) {
3197   // Initialize prog_start_time to get relative uptime.
3198   uv_uptime(&prog_start_time);
3199
3200   // Make inherited handles noninheritable.
3201   uv_disable_stdio_inheritance();
3202
3203   // init async debug messages dispatching
3204   // FIXME(bnoordhuis) Should be per-isolate or per-context, not global.
3205   uv_async_init(uv_default_loop(),
3206                 &dispatch_debug_messages_async,
3207                 DispatchDebugMessagesAsyncCallback);
3208   uv_unref(reinterpret_cast<uv_handle_t*>(&dispatch_debug_messages_async));
3209
3210   // Parse a few arguments which are specific to Node.
3211   int v8_argc;
3212   const char** v8_argv;
3213   ParseArgs(argc, argv, exec_argc, exec_argv, &v8_argc, &v8_argv);
3214
3215   // TODO(bnoordhuis) Intercept --prof arguments and start the CPU profiler
3216   // manually?  That would give us a little more control over its runtime
3217   // behavior but it could also interfere with the user's intentions in ways
3218   // we fail to anticipate.  Dillema.
3219   for (int i = 1; i < v8_argc; ++i) {
3220     if (strncmp(v8_argv[i], "--prof", sizeof("--prof") - 1) == 0) {
3221       v8_is_profiling = true;
3222       break;
3223     }
3224   }
3225
3226   // The const_cast doesn't violate conceptual const-ness.  V8 doesn't modify
3227   // the argv array or the elements it points to.
3228   V8::SetFlagsFromCommandLine(&v8_argc, const_cast<char**>(v8_argv), true);
3229
3230   // Anything that's still in v8_argv is not a V8 or a node option.
3231   for (int i = 1; i < v8_argc; i++) {
3232     fprintf(stderr, "%s: bad option: %s\n", argv[0], v8_argv[i]);
3233   }
3234   delete[] v8_argv;
3235   v8_argv = NULL;
3236
3237   if (v8_argc > 1) {
3238     exit(9);
3239   }
3240
3241   if (debug_wait_connect) {
3242     const char expose_debug_as[] = "--expose_debug_as=v8debug";
3243     V8::SetFlagsFromString(expose_debug_as, sizeof(expose_debug_as) - 1);
3244   }
3245
3246   V8::SetArrayBufferAllocator(&ArrayBufferAllocator::the_singleton);
3247
3248   // Fetch a reference to the main isolate, so we have a reference to it
3249   // even when we need it to access it from another (debugger) thread.
3250   node_isolate = Isolate::GetCurrent();
3251
3252 #ifdef __POSIX__
3253   // Raise the open file descriptor limit.
3254   {  // NOLINT (whitespace/braces)
3255     struct rlimit lim;
3256     if (getrlimit(RLIMIT_NOFILE, &lim) == 0 && lim.rlim_cur != lim.rlim_max) {
3257       // Do a binary search for the limit.
3258       rlim_t min = lim.rlim_cur;
3259       rlim_t max = 1 << 20;
3260       // But if there's a defined upper bound, don't search, just set it.
3261       if (lim.rlim_max != RLIM_INFINITY) {
3262         min = lim.rlim_max;
3263         max = lim.rlim_max;
3264       }
3265       do {
3266         lim.rlim_cur = min + (max - min) / 2;
3267         if (setrlimit(RLIMIT_NOFILE, &lim)) {
3268           max = lim.rlim_cur;
3269         } else {
3270           min = lim.rlim_cur;
3271         }
3272       } while (min + 1 < max);
3273     }
3274   }
3275   // Ignore SIGPIPE
3276   RegisterSignalHandler(SIGPIPE, SIG_IGN);
3277   RegisterSignalHandler(SIGINT, SignalExit);
3278   RegisterSignalHandler(SIGTERM, SignalExit);
3279 #endif  // __POSIX__
3280
3281   V8::SetFatalErrorHandler(node::OnFatalError);
3282   V8::AddMessageListener(OnMessage);
3283
3284   // If the --debug flag was specified then initialize the debug thread.
3285   if (use_debug_agent) {
3286     EnableDebug(debug_wait_connect);
3287   } else {
3288     RegisterDebugSignalHandler();
3289   }
3290 }
3291
3292
3293 struct AtExitCallback {
3294   AtExitCallback* next_;
3295   void (*cb_)(void* arg);
3296   void* arg_;
3297 };
3298
3299 static AtExitCallback* at_exit_functions_;
3300
3301
3302 // TODO(bnoordhuis) Turn into per-context event.
3303 void RunAtExit(Environment* env) {
3304   AtExitCallback* p = at_exit_functions_;
3305   at_exit_functions_ = NULL;
3306
3307   while (p) {
3308     AtExitCallback* q = p->next_;
3309     p->cb_(p->arg_);
3310     delete p;
3311     p = q;
3312   }
3313 }
3314
3315
3316 void AtExit(void (*cb)(void* arg), void* arg) {
3317   AtExitCallback* p = new AtExitCallback;
3318   p->cb_ = cb;
3319   p->arg_ = arg;
3320   p->next_ = at_exit_functions_;
3321   at_exit_functions_ = p;
3322 }
3323
3324
3325 void EmitExit(Environment* env) {
3326   // process.emit('exit')
3327   HandleScope handle_scope(env->isolate());
3328   Context::Scope context_scope(env->context());
3329   Local<Object> process_object = env->process_object();
3330   process_object->Set(FIXED_ONE_BYTE_STRING(node_isolate, "_exiting"),
3331                       True(node_isolate));
3332
3333   Handle<String> exitCode = FIXED_ONE_BYTE_STRING(node_isolate, "exitCode");
3334   int code = process_object->Get(exitCode)->IntegerValue();
3335
3336   Local<Value> args[] = {
3337     FIXED_ONE_BYTE_STRING(node_isolate, "exit"),
3338     Integer::New(code, node_isolate)
3339   };
3340
3341   MakeCallback(env, process_object, "emit", ARRAY_SIZE(args), args);
3342   exit(code);
3343 }
3344
3345
3346 Environment* CreateEnvironment(Isolate* isolate,
3347                                int argc,
3348                                const char* const* argv,
3349                                int exec_argc,
3350                                const char* const* exec_argv) {
3351   HandleScope handle_scope(isolate);
3352
3353   Local<Context> context = Context::New(isolate);
3354   Context::Scope context_scope(context);
3355   Environment* env = Environment::New(context);
3356
3357   uv_check_init(env->event_loop(), env->immediate_check_handle());
3358   uv_unref(
3359       reinterpret_cast<uv_handle_t*>(env->immediate_check_handle()));
3360   uv_idle_init(env->event_loop(), env->immediate_idle_handle());
3361
3362   // Inform V8's CPU profiler when we're idle.  The profiler is sampling-based
3363   // but not all samples are created equal; mark the wall clock time spent in
3364   // epoll_wait() and friends so profiling tools can filter it out.  The samples
3365   // still end up in v8.log but with state=IDLE rather than state=EXTERNAL.
3366   // TODO(bnoordhuis) Depends on a libuv implementation detail that we should
3367   // probably fortify in the API contract, namely that the last started prepare
3368   // or check watcher runs first.  It's not 100% foolproof; if an add-on starts
3369   // a prepare or check watcher after us, any samples attributed to its callback
3370   // will be recorded with state=IDLE.
3371   uv_prepare_init(env->event_loop(), env->idle_prepare_handle());
3372   uv_check_init(env->event_loop(), env->idle_check_handle());
3373   uv_unref(reinterpret_cast<uv_handle_t*>(env->idle_prepare_handle()));
3374   uv_unref(reinterpret_cast<uv_handle_t*>(env->idle_check_handle()));
3375
3376   if (v8_is_profiling) {
3377     StartProfilerIdleNotifier(env);
3378   }
3379
3380   Local<FunctionTemplate> process_template = FunctionTemplate::New();
3381   process_template->SetClassName(FIXED_ONE_BYTE_STRING(isolate, "process"));
3382
3383   Local<Object> process_object = process_template->GetFunction()->NewInstance();
3384   env->set_process_object(process_object);
3385
3386   SetupProcessObject(env, argc, argv, exec_argc, exec_argv);
3387   Load(env);
3388
3389   return env;
3390 }
3391
3392
3393 int Start(int argc, char** argv) {
3394 #if !defined(_WIN32)
3395   // Try hard not to lose SIGUSR1 signals during the bootstrap process.
3396   InstallEarlyDebugSignalHandler();
3397 #endif
3398
3399   assert(argc > 0);
3400
3401   // Hack around with the argv pointer. Used for process.title = "blah".
3402   argv = uv_setup_args(argc, argv);
3403
3404   // This needs to run *before* V8::Initialize().  The const_cast is not
3405   // optional, in case you're wondering.
3406   int exec_argc;
3407   const char** exec_argv;
3408   Init(&argc, const_cast<const char**>(argv), &exec_argc, &exec_argv);
3409
3410 #if HAVE_OPENSSL
3411   // V8 on Windows doesn't have a good source of entropy. Seed it from
3412   // OpenSSL's pool.
3413   V8::SetEntropySource(crypto::EntropySource);
3414 #endif
3415
3416   V8::Initialize();
3417   {
3418     Locker locker(node_isolate);
3419     Environment* env =
3420         CreateEnvironment(node_isolate, argc, argv, exec_argc, exec_argv);
3421     // This Context::Scope is here so EnableDebug() can look up the current
3422     // environment with Environment::GetCurrentChecked().
3423     // TODO(bnoordhuis) Reorder the debugger initialization logic so it can
3424     // be removed.
3425     Context::Scope context_scope(env->context());
3426     uv_run(env->event_loop(), UV_RUN_DEFAULT);
3427     EmitExit(env);
3428     RunAtExit(env);
3429     env->Dispose();
3430     env = NULL;
3431   }
3432
3433 #ifndef NDEBUG
3434   // Clean up. Not strictly necessary.
3435   V8::Dispose();
3436 #endif  // NDEBUG
3437
3438   delete[] exec_argv;
3439   exec_argv = NULL;
3440
3441   return 0;
3442 }
3443
3444
3445 }  // namespace node