greg/wterl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Pass configuration along when opening sessions.

Browse source
This commit is contained in:
Gregory Burd 2013-03-07 20:31:42 -05:00
parent f224c61b7a
commit a8bc4bf6c0
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
c_src/wterl.c
View file

@ -112,7 +112,7 @@ static ErlNifFunc nif_funcs[] =
{"session_delete", 3, wterl_session_delete}, {"session_delete", 3, wterl_session_delete},
{"session_drop", 3, wterl_session_drop}, {"session_drop", 3, wterl_session_drop},
{"session_get", 3, wterl_session_get}, {"session_get", 3, wterl_session_get},
{"session_open", 1, wterl_session_open}, {"session_open", 2, wterl_session_open},
{"session_put", 4, wterl_session_put}, {"session_put", 4, wterl_session_put},
{"session_rename", 4, wterl_session_rename}, {"session_rename", 4, wterl_session_rename},
{"session_salvage", 3, wterl_session_salvage}, {"session_salvage", 3, wterl_session_salvage},
@ -218,11 +218,13 @@ static inline ERL_NIF_TERM wterl_session_worker(ErlNifEnv* env, int argc, const
static ERL_NIF_TERM wterl_session_open(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]) static ERL_NIF_TERM wterl_session_open(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[])
{ {
WterlConnHandle* conn_handle; WterlConnHandle* conn_handle;
if (enif_get_resource(env, argv[0], wterl_conn_RESOURCE, (void**)&conn_handle)) ErlNifBinary config;
if (enif_get_resource(env, argv[0], wterl_conn_RESOURCE, (void**)&conn_handle) &&
enif_inspect_binary(env, argv[1], &config))
{ {
WT_CONNECTION* conn = conn_handle->conn; WT_CONNECTION* conn = conn_handle->conn;
WT_SESSION* session; WT_SESSION* session;
int rc = conn->open_session(conn, NULL, NULL, &session); int rc = conn->open_session(conn, NULL, (const char *)config.data, &session);
if (rc == 0) if (rc == 0)
{ {
WterlSessionHandle* session_handle = WterlSessionHandle* session_handle =