vitalif
/
sophia-perl
mirror of https://github.com/vitalif/sophia-perl
1
0
Fork 0
Code Issues Releases Wiki Activity

it works

master
Vitaliy Filippov 2015-03-20 20:41:17 +03:00
parent 95cba3e7c7
commit 539473c434
2 changed files with 214 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
Makefile.PL
View File

@ -7,9 +7,6 @@ use Archive::Extract;
use FindBin; use FindBin;
use ExtUtils::MakeMaker; use ExtUtils::MakeMaker;
my $sophia = $FindBin::Bin ."/Sophia-src";
my $sophia_src = "$sophia/db";
my $rc = eval my $rc = eval
{ {
require 5.010; require 5.010;
@ -30,8 +27,8 @@ if($rc && !-e "sophia-master")
}; };
} }
$sophia = $FindBin::Bin ."/sophia-master"; my $sophia = $FindBin::Bin ."/sophia-master";
$sophia_src = -e "$sophia/db" ? "$sophia/db" : $sophia; my $sophia_src = -e "$sophia/db" ? "$sophia/db" : $sophia;
`make -C $sophia_src libsophia.a`; `make -C $sophia_src libsophia.a`;

225
Sophia.xs
View File

@ -5,11 +5,13 @@
#include "XSUB.h" #include "XSUB.h"
#include <stdarg.h> #include <stdarg.h>
#include <sophia.h> #include "sophia.h"
typedef struct typedef struct
{ {
void *ptr; void *ptr;
void *cmp;
void *arg;
} }
sophia_env_t; sophia_env_t;
@ -132,6 +134,15 @@ begin(env)
OUTPUT: OUTPUT:
RETVAL RETVAL
void
DESTROY(ptr)
Database::Sophia ptr;
CODE:
if(ptr)
free(ptr);
MODULE = Database::Sophia PACKAGE = Database::Sophia::Ctl MODULE = Database::Sophia PACKAGE = Database::Sophia::Ctl
PROTOTYPES: DISABLE PROTOTYPES: DISABLE
@ -172,17 +183,21 @@ get(ctl, key)
{ {
croak("Object of empty type returned from ctl sp_get"); croak("Object of empty type returned from ctl sp_get");
} }
elseif (!strcmp(t, "database")) else if (!strcmp(t, "database"))
{ {
sophia_db_t *db = malloc(sizeof(sophia_db_t)); sophia_db_t *db = malloc(sizeof(sophia_db_t));
db->ptr = obj; db->ptr = obj;
RETVAL = sv_newmortal();
sv_setref_pv(RETVAL, "Database::Sophia::DB", (void *)db); sv_setref_pv(RETVAL, "Database::Sophia::DB", (void *)db);
SvREFCNT_inc(RETVAL);
} }
else if (!strcmp(t, "snapshot")) else if (!strcmp(t, "snapshot"))
{ {
sophia_snapshot_t *snapshot = malloc(sizeof(sophia_snapshot_t)); sophia_snapshot_t *snapshot = malloc(sizeof(sophia_snapshot_t));
snapshot->ptr = obj; snapshot->ptr = obj;
RETVAL = sv_newmortal();
sv_setref_pv(RETVAL, "Database::Sophia::Snapshot", (void *)snapshot); sv_setref_pv(RETVAL, "Database::Sophia::Snapshot", (void *)snapshot);
SvREFCNT_inc(RETVAL);
} }
else if (!strcmp(t, "object")) else if (!strcmp(t, "object"))
{ {
@ -210,9 +225,28 @@ cursor(ctl)
OUTPUT: OUTPUT:
RETVAL RETVAL
void
DESTROY(ptr)
Database::Sophia::Ctl ptr;
CODE:
if(ptr)
free(ptr);
MODULE = Database::Sophia PACKAGE = Database::Sophia::DB MODULE = Database::Sophia PACKAGE = Database::Sophia::DB
Database::Sophia::Ctl
ctl(db)
Database::Sophia::DB db;
CODE:
sophia_ctl_t *ctl = malloc(sizeof(sophia_ctl_t));
ctl->ptr = sp_ctl(db->ptr);
RETVAL = ctl;
OUTPUT:
RETVAL
SV* SV*
open(db) open(db)
Database::Sophia::DB db; Database::Sophia::DB db;
@ -313,10 +347,10 @@ cursor(db, key, order)
STRLEN len_k = 0; STRLEN len_k = 0;
char *key_c = SvPV(key, len_k); char *key_c = SvPV(key, len_k);
STRLEN len_o = 0; STRLEN len_o = 0;
char *order_c = SvPV(order, len_v); char *order_c = SvPV(order, len_o);
void *obj = sp_object(db->ptr); void *obj = sp_object(db->ptr);
RETVAL = &PL_sv_undef; RETVAL = (void*)&PL_sv_undef;
if (obj) if (obj)
{ {
sp_set(obj, "key", key_c, len_k); sp_set(obj, "key", key_c, len_k);
@ -333,6 +367,16 @@ cursor(db, key, order)
OUTPUT: OUTPUT:
RETVAL RETVAL
void
DESTROY(ptr)
Database::Sophia::DB ptr;
CODE:
if(ptr->ptr)
sp_destroy(ptr->ptr);
if(ptr)
free(ptr);
MODULE = Database::Sophia PACKAGE = Database::Sophia::Txn MODULE = Database::Sophia PACKAGE = Database::Sophia::Txn
@ -344,24 +388,102 @@ commit(txn)
CODE: CODE:
RETVAL = newSViv( sp_commit(txn->ptr) ); RETVAL = newSViv( sp_commit(txn->ptr) );
// FIXME destroy
OUTPUT: OUTPUT:
RETVAL RETVAL
SV* SV*
get(txn, key) get(txn, db, key)
Database::Sophia::Txn txn; Database::Sophia::Txn txn;
Database::Sophia::DB db;
SV *key; SV *key;
CODE:
int err;
STRLEN len_k = 0;
char *key_c = SvPV(key, len_k);
void *value;
size_t size;
RETVAL = &PL_sv_undef;
void *obj = sp_object(db->ptr);
void *ret;
if (obj)
{
sp_set(obj, "key", key_c, len_k);
ret = sp_get(txn->ptr, obj);
if (!err)
{
value = sp_get(ret, "value", &size);
RETVAL = newSVpv(value, size);
sp_destroy(ret);
}
sp_destroy(obj);
}
OUTPUT:
RETVAL
SV* SV*
delete(txn, key) delete(txn, db, key)
Database::Sophia::Txn txn; Database::Sophia::Txn txn;
Database::Sophia::DB db;
SV *key; SV *key;
CODE:
int err;
STRLEN len_k = 0;
char *key_c = SvPV(key, len_k);
RETVAL = &PL_sv_undef;
void *obj = sp_object(db->ptr);
void *ret;
if (obj)
{
sp_set(obj, "key", key_c, len_k);
err = sp_delete(txn->ptr, obj);
sp_destroy(obj);
}
RETVAL = newSViv(err);
OUTPUT:
RETVAL
SV* SV*
set(txn, key, value) set(txn, db, key, value)
Database::Sophia::Txn txn; Database::Sophia::Txn txn;
Database::Sophia::DB db;
SV *key; SV *key;
SV *value; SV *value;
CODE:
int err;
STRLEN len_k = 0;
char *key_c = SvPV(key, len_k);
STRLEN len_v = 0;
char *value_c = SvPV(value, len_v);
RETVAL = &PL_sv_undef;
void *obj = sp_object(db->ptr);
void *ret;
if (obj)
{
sp_set(obj, "key", key_c, len_k);
sp_set(obj, "value", value_c, len_v);
err = sp_set(txn->ptr, obj);
sp_destroy(obj);
}
RETVAL = newSViv(err);
OUTPUT:
RETVAL
void
DESTROY(ptr)
Database::Sophia::Txn ptr;
CODE:
if(ptr->ptr)
sp_destroy(ptr->ptr);
if(ptr)
free(ptr);
MODULE = Database::Sophia PACKAGE = Database::Sophia::Snapshot MODULE = Database::Sophia PACKAGE = Database::Sophia::Snapshot
@ -379,15 +501,77 @@ drop(snapshot)
RETVAL RETVAL
SV* SV*
get(txn, key) get(snapshot, db, key)
Database::Sophia::Snapshot snapshot; Database::Sophia::Snapshot snapshot;
Database::Sophia::DB db;
SV *key; SV *key;
CODE:
int err;
STRLEN len_k = 0;
char *key_c = SvPV(key, len_k);
void *value;
size_t size;
RETVAL = &PL_sv_undef;
void *obj = sp_object(db->ptr);
void *ret;
if (obj)
{
sp_set(obj, "key", key_c, len_k);
ret = sp_get(snapshot->ptr, obj);
if (!err)
{
value = sp_get(ret, "value", &size);
RETVAL = newSVpv(value, size);
sp_destroy(ret);
}
sp_destroy(obj);
}
OUTPUT:
RETVAL
Database::Sophia::Cursor Database::Sophia::Cursor
cursor(db, key, order) cursor(snapshot, db, key, order)
Database::Sophia::Snapshot snapshot; Database::Sophia::Snapshot snapshot;
Database::Sophia::DB db;
SV *key; SV *key;
SV *order; SV *order;
CODE:
void *c;
STRLEN len_k = 0;
char *key_c = SvPV(key, len_k);
STRLEN len_o = 0;
char *order_c = SvPV(order, len_o);
void *obj = sp_object(db->ptr);
RETVAL = (void*)&PL_sv_undef;
if (obj)
{
sp_set(obj, "key", key_c, len_k);
sp_set(obj, "order", order_c, len_o);
c = sp_cursor(snapshot->ptr, obj);
sp_destroy(obj);
if (c)
{
sophia_cursor_t *cur = malloc(sizeof(sophia_cursor_t));
cur->ptr = c;
RETVAL = cur;
}
}
OUTPUT:
RETVAL
void
DESTROY(ptr)
Database::Sophia::Snapshot ptr;
CODE:
if(ptr->ptr)
sp_destroy(ptr->ptr);
if(ptr)
free(ptr);
MODULE = Database::Sophia PACKAGE = Database::Sophia::Cursor MODULE = Database::Sophia PACKAGE = Database::Sophia::Cursor
@ -395,9 +579,24 @@ MODULE = Database::Sophia PACKAGE = Database::Sophia::Cursor
PROTOTYPES: DISABLE PROTOTYPES: DISABLE
SV* SV*
get(cursor, key) next_key(cursor)
Database::Sophia::Cursor cursor; Database::Sophia::Cursor cursor;
SV *key;
CODE:
void *obj = sp_get(cursor->ptr);
uint32_t size;
char *value;
if (obj)
{
value = sp_get(obj, "key", &size);
RETVAL = newSVpv(value, size);
}
else
{
RETVAL = &PL_sv_undef;
}
OUTPUT:
RETVAL
SV* SV*
cur_key(cursor) cur_key(cursor)
@ -441,10 +640,10 @@ cur_value(cursor)
void void
DESTROY(ptr) DESTROY(ptr)
Database::Sophia ptr; Database::Sophia::Snapshot ptr;
CODE: CODE:
if(ptr->ptr) if(ptr->ptr)
sp_destroy(ptr); sp_destroy(ptr->ptr);
if(ptr) if(ptr)
free(ptr); free(ptr);