github-migration/mongo-ruby-driver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

handle longs in c extension

Browse Source
This commit is contained in:
Mike Dirolf 2009-08-04 10:39:25 -04:00
parent 0a60ad0d7b
commit fb48299975
1 changed files with 23 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
ext/cbson/cbson.c
View File

@ -194,30 +194,24 @@ static int write_element_allow_id(VALUE key, VALUE value, VALUE extra, int allow
switch(TYPE(value)) { switch(TYPE(value)) {
case T_BIGNUM: case T_BIGNUM:
{
VALUE as_f;
int int_value;
if (rb_funcall(value, rb_intern(">"), 1, INT2NUM(2147483647)) == Qtrue ||
rb_funcall(value, rb_intern("<"), 1, INT2NUM(-2147483648)) == Qtrue) {
rb_raise(rb_eRangeError, "MongoDB can only handle 4-byte ints"
" - try converting to a double before saving");
}
write_name_and_type(buffer, key, 0x10);
as_f = rb_funcall(value, rb_intern("to_f"), 0);
int_value = NUM2LL(as_f);
buffer_write_bytes(buffer, (char*)&int_value, 4);
break;
}
case T_FIXNUM: case T_FIXNUM:
{ {
int int_value = FIX2INT(value); if (rb_funcall(value, rb_intern(">"), 1, LL2NUM(9223372036854775807LL)) == Qtrue ||
if (rb_funcall(value, rb_intern(">"), 1, INT2NUM(2147483647)) == Qtrue || rb_funcall(value, rb_intern("<"), 1, LL2NUM(-9223372036854775808LL)) == Qtrue) {
rb_funcall(value, rb_intern("<"), 1, INT2NUM(-2147483648)) == Qtrue) { rb_raise(rb_eRangeError, "MongoDB can only handle 8-byte ints");
rb_raise(rb_eRangeError, "MongoDB can only handle 4-byte ints" }
" - try converting to a double before saving"); if (rb_funcall(value, rb_intern(">"), 1, INT2NUM(2147483647L)) == Qtrue ||
rb_funcall(value, rb_intern("<"), 1, INT2NUM(-2147483648L)) == Qtrue) {
long long ll_value;
write_name_and_type(buffer, key, 0x12);
ll_value = NUM2LL(value);
buffer_write_bytes(buffer, (char*)&ll_value, 8);
} else {
int int_value;
write_name_and_type(buffer, key, 0x10);
int_value = NUM2LL(value);
buffer_write_bytes(buffer, (char*)&int_value, 4);
} }
write_name_and_type(buffer, key, 0x10);
buffer_write_bytes(buffer, (char*)&int_value, 4);
break; break;
} }
case T_TRUE: case T_TRUE:
@ -698,6 +692,14 @@ static VALUE get_value(const char* buffer, int* position, int type) {
*position += 8; *position += 8;
break; break;
} }
case 18:
{
long long ll;
memcpy(&ll, buffer + *position, 8);
value = LL2NUM(ll);
*position += 8;
break;
}
default: default:
{ {
rb_raise(rb_eTypeError, "no c decoder for this type yet (%d)", type); rb_raise(rb_eTypeError, "no c decoder for this type yet (%d)", type);