// Copyright Joyent, Inc. and other Node contributors.

//

// Permission is hereby granted, free of charge, to any person obtaining a

// copy of this software and associated documentation files (the

// "Software"), to deal in the Software without restriction, including

// without limitation the rights to use, copy, modify, merge, publish,

// distribute, sublicense, and/or sell copies of the Software, and to permit

// persons to whom the Software is furnished to do so, subject to the

// following conditions:

//

// The above copyright notice and this permission notice shall be included

// in all copies or substantial portions of the Software.

//

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN

// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,

// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR

// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE

// USE OR OTHER DEALINGS IN THE SOFTWARE.

#include "node_buffer.h"

#include "node_constants.h"

#include "node_javascript.h"

#include "node_platform.h"

#include "node_version.h"

#include "node_internals.h"

#include "node_revert.h"

#include "node_debug_options.h"

#include "node_perf.h"

#include "node_context_data.h"

#if defined HAVE_PERFCTR

#include "node_counters.h"

#endif

#if HAVE_OPENSSL

#include "node_crypto.h"

#endif

#if defined(NODE_HAVE_I18N_SUPPORT)

#include "node_i18n.h"

#endif

#if HAVE_INSPECTOR

#include "inspector_io.h"

#endif

#if defined HAVE_DTRACE || defined HAVE_ETW

#include "node_dtrace.h"

#endif

#include "ares.h"

#include "async_wrap-inl.h"

#include "env-inl.h"

#include "handle_wrap.h"

#include "http_parser.h"

#include "nghttp2/nghttp2ver.h"

#include "req_wrap-inl.h"

#include "string_bytes.h"

#include "tracing/agent.h"

#include "util.h"

#include "uv.h"

#if NODE_USE_V8_PLATFORM

#include "libplatform/libplatform.h"

#endif // NODE_USE_V8_PLATFORM

#include "v8-profiler.h"

#include "zlib.h"

#ifdef NODE_ENABLE_VTUNE_PROFILING

#include "../deps/v8/src/third_party/vtune/v8-vtune.h"

#endif

#include <errno.h>

#include <fcntl.h> // _O_RDWR

#include <limits.h> // PATH_MAX

#include <locale.h>

#include <signal.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <string>

#include <vector>

#if defined(NODE_HAVE_I18N_SUPPORT)

#include <unicode/uvernum.h>

#endif

#if defined(LEAK_SANITIZER)

#include <sanitizer/lsan_interface.h>

#endif

#if defined(_MSC_VER)

#include <direct.h>

#include <io.h>

#define umask _umask

typedef int mode_t;

#else

#include <pthread.h>

#include <sys/resource.h> // getrlimit, setrlimit

#include <termios.h> // tcgetattr, tcsetattr

#include <unistd.h> // setuid, getuid

#endif

#if defined(__POSIX__) && !defined(__ANDROID__) && !defined(__CloudABI__)

#include <pwd.h> // getpwnam()

#include <grp.h> // getgrnam()

#endif

#if defined(__POSIX__)

#include <dlfcn.h>

#endif

#ifdef __APPLE__

#include <crt_externs.h>

#define environ (*_NSGetEnviron())

#elif !defined(_MSC_VER)

extern char **environ;

#endif

// This is used to load built-in modules. Instead of using

// __attribute__((constructor)), we call the _register_<modname>

// function for each built-in modules explicitly in

// node::RegisterBuiltinModules(). This is only forward declaration.

// The definitions are in each module's implementation when calling

// the NODE_BUILTIN_MODULE_CONTEXT_AWARE.

#define V(modname) void _register_##modname();

NODE_BUILTIN_MODULES(V)

#undef V

namespace node {

using v8::Array;

using v8::ArrayBuffer;

using v8::Boolean;

using v8::Context;

using v8::EscapableHandleScope;

using v8::Exception;

using v8::Float64Array;

using v8::Function;

using v8::FunctionCallbackInfo;

using v8::HandleScope;

using v8::HeapStatistics;

using v8::Integer;

using v8::Isolate;

using v8::Just;

using v8::Local;

using v8::Locker;

using v8::Maybe;

using v8::MaybeLocal;

using v8::Message;

using v8::Name;

using v8::NamedPropertyHandlerConfiguration;

using v8::Nothing;

using v8::Null;

using v8::Number;

using v8::Object;

using v8::ObjectTemplate;

using v8::Promise;

using v8::PropertyCallbackInfo;

using v8::ScriptOrigin;

using v8::SealHandleScope;

using v8::String;

using v8::TryCatch;

using v8::Uint32;

using v8::Uint32Array;

using v8::Undefined;

using v8::V8;

using v8::Value;

static Mutex process_mutex;

static Mutex environ_mutex;

// Safe to call more than once and from signal handlers.

inline void PlatformExit();

static bool print_eval = false;

static bool force_repl = false;

static bool syntax_check_only = false;

static bool trace_deprecation = false;

static bool throw_deprecation = false;

static bool trace_sync_io = false;

static bool no_force_async_hooks_checks = false;

static bool track_heap_objects = false;

static const char* eval_string = nullptr;

static std::vector<std::string> preload_modules;

static const int v8_default_thread_pool_size = 4;

static int v8_thread_pool_size = v8_default_thread_pool_size;

static bool prof_process = false;

static bool v8_is_profiling = false;

static bool node_is_initialized = false;

static node_module* modpending;

static node_module* modlist_builtin;

static node_module* modlist_internal;

static node_module* modlist_linked;

static node_module* modlist_addon;

static std::string trace_enabled_categories; // NOLINT(runtime/string)

static std::string trace_file_pattern = // NOLINT(runtime/string)

"node_trace.${rotation}.log";

static bool abort_on_uncaught_exception = false;

// Bit flag used to track security reverts (see node_revert.h)

unsigned int reverted = 0;

#if defined(NODE_HAVE_I18N_SUPPORT)

// Path to ICU data (for i18n / Intl)

std::string icu_data_dir; // NOLINT(runtime/string)

#endif

// used by C++ modules as well

bool no_deprecation = false;

#if HAVE_OPENSSL

// use OpenSSL's cert store instead of bundled certs

bool ssl_openssl_cert_store =

#if defined(NODE_OPENSSL_CERT_STORE)

true;

#else

false;

#endif

# if NODE_FIPS_MODE

// used by crypto module

bool enable_fips_crypto = false;

bool force_fips_crypto = false;

# endif // NODE_FIPS_MODE

std::string openssl_config; // NOLINT(runtime/string)

#endif // HAVE_OPENSSL

// true if process warnings should be suppressed

bool no_process_warnings = false;

bool trace_warnings = false;

// Set in node.cc by ParseArgs when --preserve-symlinks is used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/module.js

bool config_preserve_symlinks = false;

// Set in node.cc by ParseArgs when --preserve-symlinks-main is used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/module.js

bool config_preserve_symlinks_main = false;

// Set in node.cc by ParseArgs when --experimental-modules is used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/module.js

bool config_experimental_modules = false;

// Set in node.cc by ParseArgs when --experimental-vm-modules is used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/vm.js

bool config_experimental_vm_modules = false;

// Set in node.cc by ParseArgs when --experimental-repl-await is used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/repl.js.

bool config_experimental_repl_await = false;

// Set in node.cc by ParseArgs when --loader is used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/internal/bootstrap/node.js

std::string config_userland_loader; // NOLINT(runtime/string)

// Set by ParseArgs when --pending-deprecation or NODE_PENDING_DEPRECATION

// is used.

bool config_pending_deprecation = false;

// Set in node.cc by ParseArgs when --redirect-warnings= is used.

std::string config_warning_file; // NOLINT(runtime/string)

// Set in node.cc by ParseArgs when --expose-internals or --expose_internals is

// used.

// Used in node_config.cc to set a constant on process.binding('config')

// that is used by lib/internal/bootstrap/node.js

bool config_expose_internals = false;

bool v8_initialized = false;

bool linux_at_secure = false;

// process-relative uptime base, initialized at start-up

static double prog_start_time;

static Mutex node_isolate_mutex;

static v8::Isolate* node_isolate;

DebugOptions debug_options;

static struct {

#if NODE_USE_V8_PLATFORM

void Initialize(int thread_pool_size) {

tracing_agent_.reset(new tracing::Agent(trace_file_pattern));

auto controller = tracing_agent_->GetTracingController();

tracing::TraceEventHelper::SetTracingController(controller);

StartTracingAgent();

platform_ = new NodePlatform(thread_pool_size, controller);

V8::InitializePlatform(platform_);

}

void Dispose() {

platform_->Shutdown();

delete platform_;

platform_ = nullptr;

tracing_agent_.reset(nullptr);

}

void DrainVMTasks(Isolate* isolate) {

platform_->DrainBackgroundTasks(isolate);

}

void CancelVMTasks(Isolate* isolate) {

platform_->CancelPendingDelayedTasks(isolate);

}

#if HAVE_INSPECTOR

bool StartInspector(Environment *env, const char* script_path,

const DebugOptions& options) {

// Inspector agent can't fail to start, but if it was configured to listen

// right away on the websocket port and fails to bind/etc, this will return

// false.

return env->inspector_agent()->Start(platform_, script_path, options);

}

bool InspectorStarted(Environment *env) {

return env->inspector_agent()->IsStarted();

}

#endif // HAVE_INSPECTOR

void StartTracingAgent() {

tracing_agent_->Enable(trace_enabled_categories);

}

void StopTracingAgent() {

if (tracing_agent_)

tracing_agent_->Stop();

}

tracing::Agent* GetTracingAgent() const {

return tracing_agent_.get();

}

NodePlatform* Platform() {

return platform_;

}

std::unique_ptr<tracing::Agent> tracing_agent_;

NodePlatform* platform_;

#else // !NODE_USE_V8_PLATFORM

void Initialize(int thread_pool_size) {}

void Dispose() {}

void DrainVMTasks(Isolate* isolate) {}

void CancelVMTasks(Isolate* isolate) {}

bool StartInspector(Environment *env, const char* script_path,

const DebugOptions& options) {

env->ThrowError("Node compiled with NODE_USE_V8_PLATFORM=0");

return true;

}

void StartTracingAgent() {

if (!trace_enabled_categories.empty()) {

fprintf(stderr, "Node compiled with NODE_USE_V8_PLATFORM=0, "

"so event tracing is not available.\n");

}

}

void StopTracingAgent() {}

tracing::Agent* GetTracingAgent() const { return nullptr; }

NodePlatform* Platform() {

return nullptr;

}

#endif // !NODE_USE_V8_PLATFORM

#if !NODE_USE_V8_PLATFORM || !HAVE_INSPECTOR

bool InspectorStarted(Environment *env) {

return false;

}

#endif // !NODE_USE_V8_PLATFORM || !HAVE_INSPECTOR

} v8_platform;

#ifdef __POSIX__

static const unsigned kMaxSignal = 32;

#endif

static void PrintErrorString(const char* format, ...) {

va_list ap;

va_start(ap, format);

#ifdef _WIN32

HANDLE stderr_handle = GetStdHandle(STD_ERROR_HANDLE);

// Check if stderr is something other than a tty/console

if (stderr_handle == INVALID_HANDLE_VALUE ||

stderr_handle == nullptr ||

uv_guess_handle(_fileno(stderr)) != UV_TTY) {

vfprintf(stderr, format, ap);

va_end(ap);

return;

}

// Fill in any placeholders

int n = _vscprintf(format, ap);

std::vector<char> out(n + 1);

vsprintf(out.data(), format, ap);

// Get required wide buffer size

n = MultiByteToWideChar(CP_UTF8, 0, out.data(), -1, nullptr, 0);

std::vector<wchar_t> wbuf(n);

MultiByteToWideChar(CP_UTF8, 0, out.data(), -1, wbuf.data(), n);

// Don't include the null character in the output

CHECK_GT(n, 0);

WriteConsoleW(stderr_handle, wbuf.data(), n - 1, nullptr, nullptr);

#else

vfprintf(stderr, format, ap);

#endif

va_end(ap);

}

const char *signo_string(int signo) {

#define SIGNO_CASE(e) case e: return #e;

switch (signo) {

#ifdef SIGHUP

SIGNO_CASE(SIGHUP);

#endif

#ifdef SIGINT

SIGNO_CASE(SIGINT);

#endif

#ifdef SIGQUIT

SIGNO_CASE(SIGQUIT);

#endif

#ifdef SIGILL

SIGNO_CASE(SIGILL);

#endif

#ifdef SIGTRAP

SIGNO_CASE(SIGTRAP);

#endif

#ifdef SIGABRT

SIGNO_CASE(SIGABRT);

#endif

#ifdef SIGIOT

# if SIGABRT != SIGIOT

SIGNO_CASE(SIGIOT);

# endif

#endif

#ifdef SIGBUS

SIGNO_CASE(SIGBUS);

#endif

#ifdef SIGFPE

SIGNO_CASE(SIGFPE);

#endif

#ifdef SIGKILL

SIGNO_CASE(SIGKILL);

#endif

#ifdef SIGUSR1

SIGNO_CASE(SIGUSR1);

#endif

#ifdef SIGSEGV

SIGNO_CASE(SIGSEGV);

#endif

#ifdef SIGUSR2

SIGNO_CASE(SIGUSR2);

#endif

#ifdef SIGPIPE

SIGNO_CASE(SIGPIPE);

#endif

#ifdef SIGALRM

SIGNO_CASE(SIGALRM);

#endif

SIGNO_CASE(SIGTERM);

#ifdef SIGCHLD

SIGNO_CASE(SIGCHLD);

#endif

#ifdef SIGSTKFLT

SIGNO_CASE(SIGSTKFLT);

#endif

#ifdef SIGCONT

SIGNO_CASE(SIGCONT);

#endif

#ifdef SIGSTOP

SIGNO_CASE(SIGSTOP);

#endif

#ifdef SIGTSTP

SIGNO_CASE(SIGTSTP);

#endif

#ifdef SIGBREAK

SIGNO_CASE(SIGBREAK);

#endif

#ifdef SIGTTIN

SIGNO_CASE(SIGTTIN);

#endif

#ifdef SIGTTOU

SIGNO_CASE(SIGTTOU);

#endif

#ifdef SIGURG

SIGNO_CASE(SIGURG);

#endif

#ifdef SIGXCPU

SIGNO_CASE(SIGXCPU);

#endif

#ifdef SIGXFSZ

SIGNO_CASE(SIGXFSZ);

#endif

#ifdef SIGVTALRM

SIGNO_CASE(SIGVTALRM);

#endif

#ifdef SIGPROF

SIGNO_CASE(SIGPROF);

#endif

#ifdef SIGWINCH

SIGNO_CASE(SIGWINCH);

#endif

#ifdef SIGIO

SIGNO_CASE(SIGIO);

#endif

#ifdef SIGPOLL

# if SIGPOLL != SIGIO

SIGNO_CASE(SIGPOLL);

# endif

#endif

#ifdef SIGLOST

# if SIGLOST != SIGABRT

SIGNO_CASE(SIGLOST);

# endif

#endif

#ifdef SIGPWR

# if SIGPWR != SIGLOST

SIGNO_CASE(SIGPWR);

# endif

#endif

#ifdef SIGINFO

# if !defined(SIGPWR) || SIGINFO != SIGPWR

SIGNO_CASE(SIGINFO);

# endif

#endif

#ifdef SIGSYS

SIGNO_CASE(SIGSYS);

#endif

default: return "";

}

}

// Look up environment variable unless running as setuid root.

bool SafeGetenv(const char* key, std::string* text) {

#if !defined(__CloudABI__) && !defined(_WIN32)

if (linux_at_secure || getuid() != geteuid() || getgid() != getegid())

goto fail;

#endif

{

Mutex::ScopedLock lock(environ_mutex);

if (const char* value = getenv(key)) {

*text = value;

return true;

}

}

fail:

text->clear();

return false;

}

void* ArrayBufferAllocator::Allocate(size_t size) {

if (zero_fill_field_ || zero_fill_all_buffers)

return UncheckedCalloc(size);

else

return UncheckedMalloc(size);

}

namespace {

bool ShouldAbortOnUncaughtException(Isolate* isolate) {

HandleScope scope(isolate);

Environment* env = Environment::GetCurrent(isolate);

return env->should_abort_on_uncaught_toggle()[0] &&

!env->inside_should_not_abort_on_uncaught_scope();

}

} // anonymous namespace

void AddPromiseHook(v8::Isolate* isolate, promise_hook_func fn, void* arg) {

Environment* env = Environment::GetCurrent(isolate);

env->AddPromiseHook(fn, arg);

}

void AddEnvironmentCleanupHook(v8::Isolate* isolate,

void (*fun)(void* arg),

void* arg) {

Environment* env = Environment::GetCurrent(isolate);

env->AddCleanupHook(fun, arg);

}

void RemoveEnvironmentCleanupHook(v8::Isolate* isolate,

void (*fun)(void* arg),

void* arg) {

Environment* env = Environment::GetCurrent(isolate);

env->RemoveCleanupHook(fun, arg);

}

MaybeLocal<Value> InternalMakeCallback(Environment* env,

Local<Object> recv,

const Local<Function> callback,

int argc,

Local<Value> argv[],

async_context asyncContext) {

CHECK(!recv.IsEmpty());

InternalCallbackScope scope(env, recv, asyncContext);

if (scope.Failed()) {

return Undefined(env->isolate());

}

Local<Function> domain_cb = env->domain_callback();

MaybeLocal<Value> ret;

if (asyncContext.async_id != 0 || domain_cb.IsEmpty() || recv.IsEmpty()) {

ret = callback->Call(env->context(), recv, argc, argv);

} else {

std::vector<Local<Value>> args(1 + argc);

args[0] = callback;

std::copy(&argv[0], &argv[argc], args.begin() + 1);

ret = domain_cb->Call(env->context(), recv, args.size(), &args[0]);

}

if (ret.IsEmpty()) {

// NOTE: For backwards compatibility with public API we return Undefined()

// if the top level call threw.

scope.MarkAsFailed();

return scope.IsInnerMakeCallback() ? ret : Undefined(env->isolate());

}

scope.Close();

if (scope.Failed()) {

return Undefined(env->isolate());

}

return ret;

}

// Public MakeCallback()s

MaybeLocal<Value> MakeCallback(Isolate* isolate,

Local<Object> recv,

const char* method,

int argc,

Local<Value> argv[],

async_context asyncContext) {

Local<String> method_string =

String::NewFromUtf8(isolate, method, v8::NewStringType::kNormal)

.ToLocalChecked();

return MakeCallback(isolate, recv, method_string, argc, argv, asyncContext);

}

MaybeLocal<Value> MakeCallback(Isolate* isolate,

Local<Object> recv,

Local<String> symbol,

int argc,

Local<Value> argv[],

async_context asyncContext) {

Local<Value> callback_v = recv->Get(symbol);

if (callback_v.IsEmpty()) return Local<Value>();

if (!callback_v->IsFunction()) return Local<Value>();

Local<Function> callback = callback_v.As<Function>();

return MakeCallback(isolate, recv, callback, argc, argv, asyncContext);

}

MaybeLocal<Value> MakeCallback(Isolate* isolate,

Local<Object> recv,

Local<Function> callback,

int argc,

Local<Value> argv[],

async_context asyncContext) {

// Observe the following two subtleties:

//

// 1. The environment is retrieved from the callback function's context.

// 2. The context to enter is retrieved from the environment.

//

// Because of the AssignToContext() call in src/node_contextify.cc,

// the two contexts need not be the same.

Environment* env = Environment::GetCurrent(callback->CreationContext());

Context::Scope context_scope(env->context());

return InternalMakeCallback(env, recv, callback,

argc, argv, asyncContext);

}

// Legacy MakeCallback()s

Local<Value> MakeCallback(Isolate* isolate,

Local<Object> recv,

const char* method,

int argc,

Local<Value>* argv) {

EscapableHandleScope handle_scope(isolate);

return handle_scope.Escape(

MakeCallback(isolate, recv, method, argc, argv, {0, 0})

.FromMaybe(Local<Value>()));

}

Local<Value> MakeCallback(Isolate* isolate,

Local<Object> recv,

Local<String> symbol,

int argc,

Local<Value>* argv) {

EscapableHandleScope handle_scope(isolate);

return handle_scope.Escape(

MakeCallback(isolate, recv, symbol, argc, argv, {0, 0})

.FromMaybe(Local<Value>()));

}

Local<Value> MakeCallback(Isolate* isolate,

Local<Object> recv,

Local<Function> callback,

int argc,

Local<Value>* argv) {

EscapableHandleScope handle_scope(isolate);

return handle_scope.Escape(

MakeCallback(isolate, recv, callback, argc, argv, {0, 0})

.FromMaybe(Local<Value>()));

}

bool IsExceptionDecorated(Environment* env, Local<Value> er) {

if (!er.IsEmpty() && er->IsObject()) {

Local<Object> err_obj = er.As<Object>();

auto maybe_value =

err_obj->GetPrivate(env->context(), env->decorated_private_symbol());

Local<Value> decorated;

return maybe_value.ToLocal(&decorated) && decorated->IsTrue();

}

return false;

}

void AppendExceptionLine(Environment* env,

Local<Value> er,

Local<Message> message,

enum ErrorHandlingMode mode) {

if (message.IsEmpty())

return;

HandleScope scope(env->isolate());

Local<Object> err_obj;

if (!er.IsEmpty() && er->IsObject()) {

err_obj = er.As<Object>();

}

// Print (filename):(line number): (message).

ScriptOrigin origin = message->GetScriptOrigin();

node::Utf8Value filename(env->isolate(), message->GetScriptResourceName());

const char* filename_string = *filename;

int linenum = message->GetLineNumber(env->context()).FromJust();

// Print line of source code.

MaybeLocal<String> source_line_maybe = message->GetSourceLine(env->context());

node::Utf8Value sourceline(env->isolate(),

source_line_maybe.ToLocalChecked());

const char* sourceline_string = *sourceline;

if (strstr(sourceline_string, "node-do-not-add-exception-line") != nullptr)

return;

// Because of how node modules work, all scripts are wrapped with a

// "function (module, exports, __filename, ...) {"

// to provide script local variables.

//

// When reporting errors on the first line of a script, this wrapper

// function is leaked to the user. There used to be a hack here to

// truncate off the first 62 characters, but it caused numerous other

// problems when vm.runIn*Context() methods were used for non-module

// code.

//

// If we ever decide to re-instate such a hack, the following steps

// must be taken:

//

// 1. Pass a flag around to say "this code was wrapped"

// 2. Update the stack frame output so that it is also correct.

//

// It would probably be simpler to add a line rather than add some

// number of characters to the first line, since V8 truncates the

// sourceline to 78 characters, and we end up not providing very much

// useful debugging info to the user if we remove 62 characters.

int script_start =

(linenum - origin.ResourceLineOffset()->Value()) == 1 ?

origin.ResourceColumnOffset()->Value() : 0;

int start = message->GetStartColumn(env->context()).FromMaybe(0);

int end = message->GetEndColumn(env->context()).FromMaybe(0);

if (start >= script_start) {

CHECK_GE(end, start);

start -= script_start;

end -= script_start;

}

char arrow[1024];

int max_off = sizeof(arrow) - 2;

int off = snprintf(arrow,

sizeof(arrow),

"%s:%i\n%s\n",

filename_string,

linenum,

sourceline_string);

CHECK_GE(off, 0);

if (off > max_off) {

off = max_off;

}

// Print wavy underline (GetUnderline is deprecated).

for (int i = 0; i < start; i++) {

if (sourceline_string[i] == '\0' || off >= max_off) {

break;

}

CHECK_LT(off, max_off);

arrow[off++] = (sourceline_string[i] == '\t') ? '\t' : ' ';

}

for (int i = start; i < end; i++) {

if (sourceline_string[i] == '\0' || off >= max_off) {

break;

}

CHECK_LT(off, max_off);

arrow[off++] = '^';

}

CHECK_LE(off, max_off);

arrow[off] = '\n';

arrow[off + 1] = '\0';

Local<String> arrow_str = String::NewFromUtf8(env->isolate(), arrow);

const bool can_set_arrow = !arrow_str.IsEmpty() && !err_obj.IsEmpty();

// If allocating arrow_str failed, print it out. There's not much else to do.

// If it's not an error, but something needs to be printed out because

// it's a fatal exception, also print it out from here.

// Otherwise, the arrow property will be attached to the object and handled

// by the caller.

if (!can_set_arrow || (mode == FATAL_ERROR && !err_obj->IsNativeError())) {

if (env->printed_error())

return;

Mutex::ScopedLock lock(process_mutex);

env->set_printed_error(true);

PlatformExit();

PrintErrorString("\n%s", arrow);

return;

}

CHECK(err_obj->SetPrivate(

env->context(),

env->arrow_message_private_symbol(),

arrow_str).FromMaybe(false));

}

static void ReportException(Environment* env,

Local<Value> er,

Local<Message> message) {

CHECK(!er.IsEmpty());

HandleScope scope(env->isolate());

if (message.IsEmpty())

message = Exception::CreateMessage(env->isolate(), er);

AppendExceptionLine(env, er, message, FATAL_ERROR);

Local<Value> trace_value;

Local<Value> arrow;

const bool decorated = IsExceptionDecorated(env, er);

if (er->IsUndefined() || er->IsNull()) {

trace_value = Undefined(env->isolate());

} else {

Local<Object> err_obj = er->ToObject(env->context()).ToLocalChecked();

trace_value = err_obj->Get(env->stack_string());

arrow =

err_obj->GetPrivate(

env->context(),

env->arrow_message_private_symbol()).ToLocalChecked();

}

node::Utf8Value trace(env->isolate(), trace_value);

// range errors have a trace member set to undefined

if (trace.length() > 0 && !trace_value->IsUndefined()) {

if (arrow.IsEmpty() || !arrow->IsString() || decorated) {

PrintErrorString("%s\n", *trace);

} else {

node::Utf8Value arrow_string(env->isolate(), arrow);

PrintErrorString("%s\n%s\n", *arrow_string, *trace);

}

} else {

// this really only happens for RangeErrors, since they're the only

// kind that won't have all this info in the trace, or when non-Error

// objects are thrown manually.

Local<Value> message;

Local<Value> name;

if (er->IsObject()) {

Local<Object> err_obj = er.As<Object>();

message = err_obj->Get(env->message_string());

name = err_obj->Get(FIXED_ONE_BYTE_STRING(env->isolate(), "name"));

}

if (message.IsEmpty() ||

message->IsUndefined() ||

name.IsEmpty() ||

name->IsUndefined()) {

// Not an error object. Just print as-is.

String::Utf8Value message(env->isolate(), er);

PrintErrorString("%s\n", *message ? *message :

"<toString() threw exception>");

} else {

node::Utf8Value name_string(env->isolate(), name);

node::Utf8Value message_string(env->isolate(), message);

if (arrow.IsEmpty() || !arrow->IsString() || decorated) {

PrintErrorString("%s: %s\n", *name_string, *message_string);

} else {

node::Utf8Value arrow_string(env->isolate(), arrow);

PrintErrorString("%s\n%s: %s\n",

*arrow_string,

*name_string,

*message_string);

}

}

}

fflush(stderr);

#if HAVE_INSPECTOR

env->inspector_agent()->FatalException(er, message);

#endif

}

static void ReportException(Environment* env, const TryCatch& try_catch) {

ReportException(env, try_catch.Exception(), try_catch.Message());

}

// Executes a str within the current v8 context.

static Local<Value> ExecuteString(Environment* env,

Local<String> source,

Local<String> filename) {

EscapableHandleScope scope(env->isolate());

TryCatch try_catch(env->isolate());

// try_catch must be nonverbose to disable FatalException() handler,

// we will handle exceptions ourself.

try_catch.SetVerbose(false);

ScriptOrigin origin(filename);

MaybeLocal<v8::Script> script =

v8::Script::Compile(env->context(), source, &origin);

if (script.IsEmpty()) {

ReportException(env, try_catch);

exit(3);