Module: CBson

Defined in:
ext/cbson/cbson.c

Constant Summary collapse

VERSION = 
ext_version

Class Method Summary collapse

Class Method Details

.deserialize(bson, opts) ⇒ Object 



968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
 
# File 'ext/cbson/cbson.c', line 968

static VALUE method_deserialize(VALUE self, VALUE bson, VALUE opts) {
    const char* buffer = RSTRING_PTR(bson);
    int remaining = RSTRING_LENINT(bson);
    struct deserialize_opts deserialize_opts;
    deserialize_opts.compile_regex = 1;
    if (rb_funcall(opts, rb_intern("has_key?"), 1, ID2SYM(rb_intern("compile_regex"))) == Qtrue && 
        rb_hash_aref(opts, ID2SYM(rb_intern("compile_regex"))) == Qfalse) {
        deserialize_opts.compile_regex = 0;
    }

    // NOTE we just swallow the size and end byte here
    buffer += 4;
    remaining -= 5;

    return elements_to_hash(buffer, remaining, &deserialize_opts);
}

.max_bson_size ⇒ Object 



1115
1116
1117
 
# File 'ext/cbson/cbson.c', line 1115

static VALUE method_max_bson_size(VALUE self) {
    return INT2FIX(max_bson_size);
}

.serialize(doc, check_keys, move_id, max_size) ⇒ Object 



691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
 
# File 'ext/cbson/cbson.c', line 691

static VALUE method_serialize(VALUE self, VALUE doc, VALUE check_keys,
    VALUE move_id, VALUE max_size) {

    VALUE result;
    bson_buffer_t buffer = bson_buffer_new();
    if (buffer == NULL) {
        rb_raise(rb_eNoMemError, "failed to allocate memory in buffer.c");
    }
    bson_buffer_set_max_size(buffer, FIX2INT(max_size));

    write_doc(buffer, doc, check_keys, move_id);

    result = rb_str_new(bson_buffer_get_buffer(buffer), bson_buffer_get_position(buffer));
    if (bson_buffer_free(buffer) != 0) {
        rb_raise(rb_eRuntimeError, "failed to free buffer");
    }
    return result;
}

.update_max_bson_size(connection) ⇒ Object 



1110
1111
1112
1113
 
# File 'ext/cbson/cbson.c', line 1110

static VALUE method_update_max_bson_size(VALUE self, VALUE connection) {
    max_bson_size = FIX2INT(rb_funcall(connection, rb_intern("max_bson_size"), 0));
    return INT2FIX(max_bson_size);
}