Exception: MiniRacer::EvalError

Inherits:

Error

• Object
• StandardError
• Error
• MiniRacer::EvalError

Defined in:

lib/mini_racer.rb,
ext/mini_racer_extension/mini_racer_extension.c

Direct Known Subclasses

InternalError, ParseError, RuntimeError, ScriptError, ScriptTerminatedError, V8OutOfMemoryError

Class Method Summary

• .load(blob) ⇒ Object

Instance Method Summary

• #attach(name, proc) ⇒ Object
• #cache_rejected? ⇒ Boolean
• #cached_data ⇒ Object
• #call(*args) ⇒ Object
• #compile(*args) ⇒ Object
• #compile_module(*args) ⇒ Object
• #dispose ⇒ Object
• #disposed? ⇒ Boolean
• #dump ⇒ Object
• #dynamic_import_resolver ⇒ Object
• #dynamic_import_resolver=(blk) ⇒ Object
• #eval(*args) ⇒ Object
• #evaluate ⇒ Object
• #heap_snapshot ⇒ Object
• #heap_stats ⇒ Object
• #initialize(*args) ⇒ Object constructor
• #instantiate ⇒ Object
• #load_module_graph(*args) ⇒ Object

  same Module instance instead of being recompiled.

• #low_memory_notification ⇒ Object

  takes ownership of |b|.

• #namespace ⇒ Object
• #perform_microtask_checkpoint ⇒ Object
• #pump_message_loop ⇒ Object
• #reset_realm ⇒ Object

  and are invalidated by the reset.

• #run ⇒ Object
• #size ⇒ Object
• #status ⇒ Object
• #stop ⇒ Object
• #warmup!(arg) ⇒ Object

Constructor Details

#initialize(*args) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2036

static VALUE context_initialize(int argc, VALUE *argv, VALUE self)
{
    VALUE kwargs, a, k, v;
    pthread_attr_t attr;
    const char *cause;
    pthread_t thr;
    Snapshot *ss;
    Context *c;
    char *s;
    int r;

    TypedData_Get_Struct(self, Context, &context_type, c);
    rb_scan_args(argc, argv, ":", &kwargs);
    if (NIL_P(kwargs))
        goto init;
    a = rb_ary_new();
    rb_hash_foreach(kwargs, collect, a);
    while (RARRAY_LENINT(a)) {
        v = rb_ary_pop(a);
        k = rb_ary_pop(a);
        k = rb_sym2str(k);
        s = RSTRING_PTR(k);
        if (!strcmp(s, "ensure_gc_after_idle")) {
            Check_Type(v, T_FIXNUM);
            c->idle_gc = FIX2LONG(v);
            if (c->idle_gc < 0 || c->idle_gc > INT32_MAX)
                rb_raise(rb_eArgError, "bad ensure_gc_after_idle");
        } else if (!strcmp(s, "max_memory")) {
            Check_Type(v, T_FIXNUM);
            c->max_memory = FIX2LONG(v);
            if (c->max_memory < 0 || c->max_memory >= UINT32_MAX)
                rb_raise(rb_eArgError, "bad max_memory");
        } else if (!strcmp(s, "marshal_stack_depth")) { // backcompat, ignored
            Check_Type(v, T_FIXNUM);
        } else if (!strcmp(s, "timeout")) {
            Check_Type(v, T_FIXNUM);
            c->timeout = FIX2LONG(v);
            if (c->timeout < 0 || c->timeout > INT32_MAX)
                rb_raise(rb_eArgError, "bad timeout");
        } else if (!strcmp(s, "snapshot")) {
            if (NIL_P(v))
                continue;
            TypedData_Get_Struct(v, Snapshot, &snapshot_type, ss);
            if (buf_put(&c->snapshot, RSTRING_PTR(ss->blob), RSTRING_LENINT(ss->blob)))
                rb_raise(runtime_error, "out of memory");
        } else if (!strcmp(s, "verbose_exceptions")) {
            c->verbose_exceptions = !(v == Qfalse || v == Qnil);
        } else if (!strcmp(s, "host_namespace")) {
            const char *ns = NULL;
            if (v == Qtrue) {
                ns = "MiniRacer"; // default brand, like Deno's `Deno`
            } else if (v != Qnil && v != Qfalse) {
                Check_Type(v, T_STRING);
                ns = StringValueCStr(v); // raises on embedded NUL
            }
            if (ns && *ns) {
                // The name becomes a global, so require a valid (ASCII) JS
                // identifier; otherwise it would only be reachable through
                // globalThis["..."] rather than as `<name>.method()`.
                for (const char *q = ns; *q; q++) {
                    int ch = (unsigned char)*q;
                    int ident_start = ch == '_' || ch == '$' ||
                        (ch >= 'A' && ch <= 'Z') || (ch >= 'a' && ch <= 'z');
                    int ident_char = ident_start || (ch >= '0' && ch <= '9');
                    if (!(q == ns ? ident_start : ident_char))
                        rb_raise(rb_eArgError,
                                 "host_namespace must be a valid identifier: %s", ns);
                }
                // store the name plus its NUL terminator
                buf_reset(&c->host_namespace);
                if (buf_put(&c->host_namespace, ns, strlen(ns) + 1))
                    rb_raise(runtime_error, "out of memory");
            }
        } else {
            rb_raise(runtime_error, "bad keyword: %s", s);
        }
    }
init:
    if (single_threaded) {
        v8_once_init();
        c->pst = v8_thread_init(c, c->snapshot.buf, c->snapshot.len, c->max_memory, c->verbose_exceptions,
                                c->host_namespace.len ? (const char *)c->host_namespace.buf : NULL);
    } else {
        cause = "pthread_attr_init";
        if ((r = pthread_attr_init(&attr)))
            goto fail;
        pthread_attr_setstacksize(&attr, 2<<20); // 2 MiB
        pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
        // v8 thread takes ownership of |c|
        cause = "pthread_create";
        r = pthread_create(&thr, &attr, v8_thread_start, c);
        pthread_attr_destroy(&attr);
        if (r)
            goto fail;
        rb_thread_call_without_gvl(context_boot_wait, c, NULL, NULL);
    }
    // Deferred to first Context.new so Platform.set_flags! still has effect
    // on the tag (which depends on V8 flags applied during v8_global_init).
    {
        static int version_tag_defined;
        if (!version_tag_defined) {
            VALUE m = rb_const_get(rb_cObject, rb_intern("MiniRacer"));
            rb_define_const(m, "V8_CACHED_DATA_VERSION_TAG",
                            UINT2NUM(v8_cached_data_version_tag()));
            version_tag_defined = 1;
        }
    }
    return Qnil;
fail:
    rb_raise(runtime_error, "Context.initialize: %s: %s", cause, strerror(r));
    return Qnil; // pacify compiler
}

Class Method Details

.load(blob) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2249

static VALUE snapshot_load(VALUE klass, VALUE blob)
{
    Snapshot *ss;
    VALUE self;

    Check_Type(blob, T_STRING);
    self = snapshot_alloc(klass);
    TypedData_Get_Struct(self, Snapshot, &snapshot_type, ss);
    ss->blob = rb_str_dup(blob);
    rb_enc_associate(ss->blob, rb_ascii8bit_encoding());
    ENC_CODERANGE_SET(ss->blob, ENC_CODERANGE_VALID);
    return self;
}

Instance Method Details

#attach(name, proc) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1711

static VALUE context_attach(VALUE self, VALUE name, VALUE proc)
{
    Context *c;
    VALUE e;
    Ser s;

    TypedData_Get_Struct(self, Context, &context_type, c);
    // request is (A)ttach, [name, id] array
    ser_init1(&s, 'A');
    ser_array_begin(&s, 2);
    add_string(&s, name);
    ser_int(&s, RARRAY_LENINT(c->procs));
    ser_array_end(&s, 2);
    rb_ary_push(c->procs, proc);
    // response is an exception or undefined
    e = rendezvous(c, &s.b);
    handle_exception(e);
    return Qnil;
}

#cache_rejected? ⇒ Boolean

Returns:

• (Boolean)

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2405

static VALUE script_cache_rejected_p(VALUE self)
{
    Script *script;
    TypedData_Get_Struct(self, Script, &script_type, script);
    return script->cache_rejected ? Qtrue : Qfalse;
}

#cached_data ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2398

static VALUE script_cached_data(VALUE self)
{
    Script *script;
    TypedData_Get_Struct(self, Script, &script_type, script);
    return script->cached_data;
}

#call(*args) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1782

static VALUE context_call(int argc, VALUE *argv, VALUE self)
{
    VALUE name, args;
    VALUE a, e;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Context, &context_type, c);
    rb_scan_args(argc, argv, "1*", &name, &args);
    Check_Type(name, T_STRING);
    rb_ary_unshift(args, name);
    // request is (C)all, [name, args...] array
    ser_init1(&s, 'C');
    if (serialize(&s, args)) {
        ser_reset(&s);
        rb_raise(runtime_error, "Context.call: %s", s.err);
    }
    // response is [result, err] array
    a = rendezvous(c, &s.b); // takes ownership of |s.b|
    e = rb_ary_pop(a);
    handle_exception(e);
    return rb_ary_pop(a);
}

#compile(*args) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2276

static VALUE context_compile(int argc, VALUE *argv, VALUE self)
{
    VALUE a, e, source, filename, cached_data, produce_cache, kwargs;
    VALUE script_v, result;
    Script *script;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Context, &context_type, c);
    rb_scan_args(argc, argv, "1:", &source, &kwargs);
    Check_Type(source, T_STRING);
    filename = Qnil;
    cached_data = Qnil;
    produce_cache = Qfalse;
    if (!NIL_P(kwargs)) {
        filename = rb_hash_aref(kwargs, ID2SYM(id_filename));
        cached_data = rb_hash_aref(kwargs, ID2SYM(id_cached_data));
        produce_cache = rb_hash_aref(kwargs, ID2SYM(id_produce_cache));
    }
    if (NIL_P(filename))
        filename = rb_str_new_cstr("<compile>");
    Check_Type(filename, T_STRING);
    if (!NIL_P(cached_data)) {
        Check_Type(cached_data, T_STRING);
        // Refuse non-binary encodings so a user reading a cache file without
        // 'rb' mode gets a clear error instead of mangled bytes flowing to V8.
        if (rb_enc_get(cached_data) != rb_ascii8bit_encoding())
            rb_raise(rb_eEncodingError,
                     "cached_data must be ASCII-8BIT (binary), got %s",
                     rb_enc_name(rb_enc_get(cached_data)));
    }
    ser_init1(&s, 'K');
    ser_array_begin(&s, 4);
    add_string(&s, filename);
    add_string(&s, source);
    if (NIL_P(cached_data)) {
        ser_null(&s);
    } else {
        ser_uint8array(&s, (const uint8_t *)RSTRING_PTR(cached_data),
                       RSTRING_LENINT(cached_data));
    }
    ser_bool(&s, RTEST(produce_cache));
    ser_array_end(&s, 4);
    a = rendezvous(c, &s.b);
    e = rb_ary_pop(a);
    handle_exception(e);
    result = rb_ary_pop(a);
    Check_Type(result, T_ARRAY);

    script_v = rb_obj_alloc(script_class); // skip the raising initialize
    TypedData_Get_Struct(script_v, Script, &script_type, script);
    script->context = self;
    script->handle_id = NUM2INT(rb_ary_entry(result, 0));
    script->cached_data = rb_ary_entry(result, 1);
    script->cache_rejected = RTEST(rb_ary_entry(result, 2));
    return script_v;
}

#compile_module(*args) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2440

static VALUE context_compile_module(int argc, VALUE *argv, VALUE self)
{
    VALUE a, e, source, filename, cached_data, produce_cache, kwargs;
    VALUE module_v, result;
    Module *m;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    rb_scan_args(argc, argv, "1:", &source, &kwargs);
    Check_Type(source, T_STRING);
    filename = Qnil;
    cached_data = Qnil;
    produce_cache = Qfalse;
    if (!NIL_P(kwargs)) {
        filename = rb_hash_aref(kwargs, ID2SYM(id_filename));
        cached_data = rb_hash_aref(kwargs, ID2SYM(id_cached_data));
        produce_cache = rb_hash_aref(kwargs, ID2SYM(id_produce_cache));
    }
    if (NIL_P(filename))
        filename = rb_str_new_cstr("<compile_module>");
    Check_Type(filename, T_STRING);
    if (!NIL_P(cached_data)) {
        Check_Type(cached_data, T_STRING);
        // Refuse non-binary encodings so a user reading a cache file without
        // 'rb' mode gets a clear error instead of mangled bytes flowing to V8.
        if (rb_enc_get(cached_data) != rb_ascii8bit_encoding())
            rb_raise(rb_eEncodingError,
                     "cached_data must be ASCII-8BIT (binary), got %s",
                     rb_enc_name(rb_enc_get(cached_data)));
    }
    ser_init1(&s, 'O');
    ser_array_begin(&s, 4);
    add_string(&s, filename);
    add_string(&s, source);
    if (NIL_P(cached_data)) {
        ser_null(&s);
    } else {
        ser_uint8array(&s, (const uint8_t *)RSTRING_PTR(cached_data),
                       RSTRING_LENINT(cached_data));
    }
    ser_bool(&s, RTEST(produce_cache));
    ser_array_end(&s, 4);
    a = rendezvous(c, &s.b);
    e = rb_ary_pop(a);
    handle_exception(e);
    result = rb_ary_pop(a);
    Check_Type(result, T_ARRAY);

    module_v = rb_obj_alloc(module_class); // skip the raising initialize
    TypedData_Get_Struct(module_v, Module, &module_type, m);
    m->context = self;
    m->handle_id = NUM2INT(rb_ary_entry(result, 0));
    m->cached_data = rb_ary_entry(result, 1);
    m->cache_rejected = RTEST(rb_ary_entry(result, 2));
    return module_v;
}

#dispose ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1760

static VALUE context_dispose(VALUE self)
{
    Context *c;

    TypedData_Get_Struct(self, Context, &context_type, c);
    rb_thread_call_without_gvl(context_dispose_do, c, NULL, NULL);
    return Qnil;
}

#disposed? ⇒ Boolean

Returns:

• (Boolean)

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2433

static VALUE script_disposed_p(VALUE self)
{
    Script *script;
    TypedData_Get_Struct(self, Script, &script_type, script);
    return script->disposed ? Qtrue : Qfalse;
}

#dump ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2241

static VALUE snapshot_dump(VALUE self)
{
    Snapshot *ss;

    TypedData_Get_Struct(self, Snapshot, &snapshot_type, ss);
    return ss->blob;
}

#dynamic_import_resolver ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2812

static VALUE context_get_dynamic_import_resolver(VALUE self)
{
    Context *c;
    TypedData_Get_Struct(self, Context, &context_type, c);
    return c->dynamic_import_resolver;
}

#dynamic_import_resolver=(blk) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2801

static VALUE context_set_dynamic_import_resolver(VALUE self, VALUE blk)
{
    Context *c;
    TypedData_Get_Struct(self, Context, &context_type, c);
    if (!NIL_P(blk) && !rb_respond_to(blk, rb_intern("call")))
        rb_raise(rb_eTypeError,
                 "dynamic_import_resolver must respond to #call or be nil");
    c->dynamic_import_resolver = blk;
    return blk;
}

#eval(*args) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1806

static VALUE context_eval(int argc, VALUE *argv, VALUE self)
{
    VALUE a, e, source, filename, kwargs;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Context, &context_type, c);
    filename = Qnil;
    rb_scan_args(argc, argv, "1:", &source, &kwargs);
    Check_Type(source, T_STRING);
    if (!NIL_P(kwargs))
        filename = rb_hash_aref(kwargs, rb_id2sym(rb_intern("filename")));
    if (NIL_P(filename))
        filename = rb_str_new_cstr("<eval>");
    Check_Type(filename, T_STRING);
    // request is (E)val, [filename, source] array
    ser_init1(&s, 'E');
    ser_array_begin(&s, 2);
    add_string(&s, filename);
    add_string(&s, source);
    ser_array_end(&s, 2);
    // response is [result, errname] array
    a = rendezvous(c, &s.b); // takes ownership of |s.b|
    e = rb_ary_pop(a);
    handle_exception(e);
    return rb_ary_pop(a);
}

#evaluate ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2700

static VALUE module_evaluate(VALUE self)
{
    VALUE a, e;
    Module *m;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Module, &module_type, m);
    if (m->disposed)
        rb_raise(runtime_error, "disposed module");
    TypedData_Get_Struct(m->context, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    ser_init1(&s, 'V');
    ser_int(&s, m->handle_id);
    a = rendezvous(c, &s.b);
    e = rb_ary_pop(a);
    handle_exception(e);
    return rb_ary_pop(a);
}

#heap_snapshot ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1856

static VALUE context_heap_snapshot(VALUE self)
{
    Buf req, res;
    Context *c;

    TypedData_Get_Struct(self, Context, &context_type, c);
    buf_init(&req);
    buf_putc(&req, 'H');              // (H)eap snapshot, returns plain bytes
    rendezvous_no_des(c, &req, &res); // takes ownership of |req|
    return rb_utf8_str_new((char *)res.buf, res.len);
}

#heap_stats ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1834

static VALUE context_heap_stats(VALUE self)
{
    VALUE a, h, k, v;
    Context *c;
    int i, n;
    Buf b;

    TypedData_Get_Struct(self, Context, &context_type, c);
    buf_init(&b);
    buf_putc(&b, 'S');     // (S)tats, returns object
    h = rendezvous(c, &b); // takes ownership of |b|
    a = rb_ary_new();
    rb_hash_foreach(h, collect, a);
    for (i = 0, n = RARRAY_LENINT(a); i < n; i += 2) {
        k = rb_ary_entry(a, i+0);
        v = rb_ary_entry(a, i+1);
        rb_hash_delete(h, k);
        rb_hash_aset(h, rb_str_intern(k), v); // turn "key" into :key
    }
    return h;
}

#instantiate ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2581

static VALUE module_instantiate(VALUE self)
{
    VALUE block;
    Module *m;
    Context *c;
    struct instantiate_args ia;

    if (!rb_block_given_p())
        rb_raise(rb_eArgError, "Module#instantiate requires a resolver block");
    block = rb_block_proc();

    TypedData_Get_Struct(self, Module, &module_type, m);
    if (m->disposed)
        rb_raise(runtime_error, "disposed module");
    TypedData_Get_Struct(m->context, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");

    // Save the previous resolver slot so a re-entrant instantiate from
    // inside this block restores its caller's block on the way out.
    // rb_ensure guarantees restoration even when the resolver block
    // raises (without it, the slot would be left pointing at this call's
    // block and keep it GC-alive until something else overwrites it).
    ia.c = c;
    ia.handle_id = m->handle_id;
    ia.prev_block = c->resolve_block;
    c->resolve_block = block;
    rb_ensure(module_instantiate_body, (VALUE)&ia,
              module_instantiate_restore, (VALUE)&ia);
    return self;
}

#load_module_graph(*args) ⇒ Object

same Module instance instead of being recompiled.

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2669

static VALUE context_load_module_graph(int argc, VALUE *argv, VALUE self)
{
    VALUE entry_url, kwargs, resolve, fetch_batch;
    Context *c;
    struct load_graph_args la;

    TypedData_Get_Struct(self, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    rb_scan_args(argc, argv, "1:", &entry_url, &kwargs);
    Check_Type(entry_url, T_STRING);
    resolve = fetch_batch = Qnil;
    if (!NIL_P(kwargs)) {
        resolve     = rb_hash_aref(kwargs, ID2SYM(rb_intern("resolve")));
        fetch_batch = rb_hash_aref(kwargs, ID2SYM(rb_intern("fetch_batch")));
    }
    if (!rb_respond_to(resolve, rb_intern("call")))
        rb_raise(rb_eArgError, "load_module_graph requires a resolve: callable");
    if (!rb_respond_to(fetch_batch, rb_intern("call")))
        rb_raise(rb_eArgError, "load_module_graph requires a fetch_batch: callable");

    // Persist the callbacks for the Context's lifetime so dynamic import() can
    // reuse them after this call returns (case A). A later load_module_graph
    // overwrites them; dispose frees them.
    c->graph_resolve_block = resolve;
    c->graph_fetch_block   = fetch_batch;
    la.c = c;
    la.entry_url = entry_url;
    return context_load_module_graph_body((VALUE)&la);
}

#low_memory_notification ⇒ Object

takes ownership of |b|

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1910

static VALUE context_low_memory_notification(VALUE self)
{
    Buf req, res;
    Context *c;

    TypedData_Get_Struct(self, Context, &context_type, c);
    buf_init(&req);
    buf_putc(&req, 'L');              // (L)ow memory notification, returns nothing
    rendezvous_no_des(c, &req, &res); // takes ownership of |req|
    return Qnil;
}

#namespace ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2721

static VALUE module_namespace(VALUE self)
{
    VALUE a, e;
    Module *m;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Module, &module_type, m);
    if (m->disposed)
        rb_raise(runtime_error, "disposed module");
    TypedData_Get_Struct(m->context, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    ser_init1(&s, 'N');
    ser_int(&s, m->handle_id);
    a = rendezvous(c, &s.b);
    e = rb_ary_pop(a);
    handle_exception(e);
    return rb_ary_pop(a);
}

#perform_microtask_checkpoint ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1868

static VALUE context_perform_microtask_checkpoint(VALUE self)
{
    Context *c;
    Buf b;

    TypedData_Get_Struct(self, Context, &context_type, c);
    buf_init(&b);
    buf_putc(&b, 'M');        // (M)icrotask checkpoint, returns nil
    return rendezvous(c, &b); // takes ownership of |b|
}

#pump_message_loop ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1899

static VALUE context_pump_message_loop(VALUE self)
{
    Context *c;
    Buf b;

    TypedData_Get_Struct(self, Context, &context_type, c);
    buf_init(&b);
    buf_putc(&b, 'P');        // (P)ump, returns bool
    return rendezvous(c, &b); // takes ownership of |b|
}

#reset_realm ⇒ Object

and are invalidated by the reset. Refused from within a host callback.

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1885

static VALUE context_reset_realm(VALUE self)
{
    Context *c;
    VALUE e;
    Buf b;

    TypedData_Get_Struct(self, Context, &context_type, c);
    buf_init(&b);
    buf_putc(&b, 'F');     // (F)resh realm, returns err or undefined
    e = rendezvous(c, &b); // takes ownership of |b|
    handle_exception(e);
    return Qnil;
}

#run ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2377

static VALUE script_run(VALUE self)
{
    VALUE a, e;
    Script *script;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Script, &script_type, script);
    if (script->disposed)
        rb_raise(runtime_error, "disposed script");
    TypedData_Get_Struct(script->context, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    ser_init1(&s, 'R');
    ser_int(&s, script->handle_id);
    a = rendezvous(c, &s.b);
    e = rb_ary_pop(a);
    handle_exception(e);
    return rb_ary_pop(a);
}

#size ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2263

static VALUE snapshot_size0(VALUE self)
{
    Snapshot *ss;

    TypedData_Get_Struct(self, Snapshot, &snapshot_type, ss);
    return LONG2FIX(RSTRING_LENINT(ss->blob));
}

#status ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2742

static VALUE module_status(VALUE self)
{
    VALUE a, e, result;
    Module *m;
    Context *c;
    Ser s;

    TypedData_Get_Struct(self, Module, &module_type, m);
    if (m->disposed)
        rb_raise(runtime_error, "disposed module");
    TypedData_Get_Struct(m->context, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    ser_init1(&s, 'U');
    ser_int(&s, m->handle_id);
    a = rendezvous(c, &s.b);
    e = rb_ary_pop(a);
    handle_exception(e);
    result = rb_ary_pop(a);
    // v8_module_status always replies with a String on success; a non-string
    // would mean the v8 thread fell through to the Undefined fail path with
    // a missing error (shouldn't happen, but check defensively rather than
    // crash rb_str_intern on Qnil).
    Check_Type(result, T_STRING);
    return rb_str_intern(result);
}

#stop ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 1769

static VALUE context_stop(VALUE self)
{
    Context *c;

    // does not grab |mtx| because Context.stop can be called from another
    // thread and then we deadlock if e.g. the V8 thread busy-loops in JS
    TypedData_Get_Struct(self, Context, &context_type, c);
    if (atomic_load(&c->quit))
        rb_raise(context_disposed_error, "disposed context");
    v8_terminate_execution(c->pst);
    return Qnil;
}

#warmup!(arg) ⇒ Object

# File 'ext/mini_racer_extension/mini_racer_extension.c', line 2210

static VALUE snapshot_warmup(VALUE self, VALUE arg)
{
    VALUE a, e, cv;
    Snapshot *ss;
    Context *c;
    DesCtx d;
    Ser s;

    TypedData_Get_Struct(self, Snapshot, &snapshot_type, ss);
    Check_Type(arg, T_STRING);
    cv = context_alloc(context_class);
    context_initialize(0, NULL, cv);
    TypedData_Get_Struct(cv, Context, &context_type, c);
    // request is (W)armup, [snapshot, "warmup code"]
    ser_init1(&s, 'W');
    ser_array_begin(&s, 2);
    ser_string8(&s, (const uint8_t *)RSTRING_PTR(ss->blob), RSTRING_LENINT(ss->blob));
    add_string(&s, arg);
    ser_array_end(&s, 2);
    // response is [arraybuffer, error]
    DesCtx_init(&d);
    d.transcode_latin1 = 0; // don't mangle snapshot binary data
    a = rendezvous1(c, &s.b, &d);
    e = rb_ary_pop(a);
    context_dispose(cv);
    if (*RSTRING_PTR(e))
        rb_raise(snapshot_error, "%s", RSTRING_PTR(e)+1);
    ss->blob = rb_ary_pop(a);
    return self;
}