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

WIP -- most tests running, a few commented out, sometimes a segv on exit

Browse source
This commit is contained in:
Gregory Burd 2013-04-08 17:21:48 -04:00
parent 07061ed6e8
commit 5c0295624d
3 changed files with 158 additions and 105 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

66
c_src/wterl.c
View file

@ -93,6 +93,20 @@ __session_for(WterlConnHandle *conn_handle, unsigned int worker_id, WT_SESSION *
return 0; return 0;
} }
void
__close_all_sessions(WterlConnHandle *conn_handle)
{
int i;
for (i = 0; i < conn_handle->num_contexts; i++) {
WterlCtx *ctx = &conn_handle->contexts[i];
kh_destroy(cursors, ctx->cursors);
ctx->session->close(ctx->session, NULL);
ctx->session = NULL;
ctx->cursors = NULL;
}
}
/** /**
* Close cursors open on 'uri' object. * Close cursors open on 'uri' object.
* *
@ -151,7 +165,7 @@ __release_cursor(WterlConnHandle *conn_handle, unsigned int worker_id, const cha
} }
/** /**
* Convenience function to generate {error, Reason} or 'not_found' * Convenience function to generate {error, {errno, Reason}} or 'not_found'
* Erlang terms to return to callers. * Erlang terms to return to callers.
* *
* env NIF environment * env NIF environment
@ -163,8 +177,13 @@ __strerror_term(ErlNifEnv* env, int rc)
if (rc == WT_NOTFOUND) { if (rc == WT_NOTFOUND) {
return ATOM_NOT_FOUND; return ATOM_NOT_FOUND;
} else { } else {
/* TODO: The string for the error message provided by strerror() for
any given errno value may be different across platforms, return
{atom, string} and may have been localized too. */
return enif_make_tuple2(env, ATOM_ERROR, return enif_make_tuple2(env, ATOM_ERROR,
enif_make_string(env, wiredtiger_strerror(rc), ERL_NIF_LATIN1)); enif_make_tuple2(env,
enif_make_atom(env, erl_errno_id(rc)),
enif_make_string(env, wiredtiger_strerror(rc), ERL_NIF_LATIN1)));
} }
} }
@ -312,8 +331,8 @@ ASYNC_NIF_DECL(
} }
rc = session->create(session, args->uri, (const char*)config.data); rc = session->create(session, args->uri, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
(void)session->close(session, NULL); (void)session->close(session, NULL);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -377,9 +396,9 @@ ASYNC_NIF_DECL(
// variable (read: punt for now, expect a lot of EBUSYs) // variable (read: punt for now, expect a lot of EBUSYs)
rc = session->drop(session, args->uri, (const char*)config.data); rc = session->drop(session, args->uri, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
(void)session->close(session, NULL); (void)session->close(session, NULL);
enif_mutex_unlock(args->conn_handle->context_mutex); enif_mutex_unlock(args->conn_handle->context_mutex);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -442,9 +461,9 @@ ASYNC_NIF_DECL(
operation will fail with EBUSY(16) "Device or resource busy". */ operation will fail with EBUSY(16) "Device or resource busy". */
// TODO: see drop's note, same goes here. // TODO: see drop's note, same goes here.
rc = session->rename(session, args->oldname, args->newname, (const char*)config.data); rc = session->rename(session, args->oldname, args->newname, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
(void)session->close(session, NULL); (void)session->close(session, NULL);
enif_mutex_unlock(args->conn_handle->context_mutex); enif_mutex_unlock(args->conn_handle->context_mutex);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -504,9 +523,9 @@ ASYNC_NIF_DECL(
} }
rc = session->salvage(session, args->uri, (const char*)config.data); rc = session->salvage(session, args->uri, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
(void)session->close(session, NULL); (void)session->close(session, NULL);
enif_mutex_unlock(args->conn_handle->context_mutex); enif_mutex_unlock(args->conn_handle->context_mutex);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -620,12 +639,12 @@ ASYNC_NIF_DECL(
} }
ErlNifBinary start_key; ErlNifBinary start_key;
if (!enif_inspect_binary(env, args->start, &start_key)) {
ASYNC_NIF_REPLY(enif_make_badarg(env));
return;
}
WT_CURSOR *start = NULL; WT_CURSOR *start = NULL;
if (!enif_is_atom(env, args->start)) { if (!enif_is_atom(env, args->start)) {
if (!enif_inspect_binary(env, args->start, &start_key)) {
ASYNC_NIF_REPLY(enif_make_badarg(env));
return;
}
rc = session->open_cursor(session, args->uri, NULL, "raw", &start); rc = session->open_cursor(session, args->uri, NULL, "raw", &start);
if (rc != 0) { if (rc != 0) {
ASYNC_NIF_REPLY(__strerror_term(env, rc)); ASYNC_NIF_REPLY(__strerror_term(env, rc));
@ -639,12 +658,12 @@ ASYNC_NIF_DECL(
} }
ErlNifBinary stop_key; ErlNifBinary stop_key;
if (!enif_inspect_binary(env, args->stop, &stop_key)) {
ASYNC_NIF_REPLY(enif_make_badarg(env));
return;
}
WT_CURSOR *stop = NULL; WT_CURSOR *stop = NULL;
if (!enif_is_atom(env, args->stop)) { if (!enif_is_atom(env, args->stop)) {
if (!enif_inspect_binary(env, args->stop, &stop_key)) {
ASYNC_NIF_REPLY(enif_make_badarg(env));
return;
}
rc = session->open_cursor(session, args->uri, NULL, "raw", &stop); rc = session->open_cursor(session, args->uri, NULL, "raw", &stop);
if (rc != 0) { if (rc != 0) {
ASYNC_NIF_REPLY(__strerror_term(env, rc)); ASYNC_NIF_REPLY(__strerror_term(env, rc));
@ -658,8 +677,9 @@ ASYNC_NIF_DECL(
} }
rc = session->truncate(session, args->uri, start, stop, (const char*)config.data); rc = session->truncate(session, args->uri, start, stop, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc)); (void)session->close(session, NULL);
enif_mutex_unlock(args->conn_handle->context_mutex); enif_mutex_unlock(args->conn_handle->context_mutex);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -716,9 +736,9 @@ ASYNC_NIF_DECL(
} }
rc = session->upgrade(session, args->uri, (const char*)config.data); rc = session->upgrade(session, args->uri, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
(void)session->close(session, NULL); (void)session->close(session, NULL);
enif_mutex_unlock(args->conn_handle->context_mutex); enif_mutex_unlock(args->conn_handle->context_mutex);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -756,7 +776,7 @@ ASYNC_NIF_DECL(
/* This call requires that there be no open cursors referencing the object. */ /* This call requires that there be no open cursors referencing the object. */
enif_mutex_lock(args->conn_handle->context_mutex); enif_mutex_lock(args->conn_handle->context_mutex);
__close_cursors_on(args->conn_handle, args->uri); __close_all_sessions(args->conn_handle);
ErlNifBinary config; ErlNifBinary config;
if (!enif_inspect_binary(env, args->config, &config)) { if (!enif_inspect_binary(env, args->config, &config)) {
@ -776,9 +796,9 @@ ASYNC_NIF_DECL(
} }
rc = session->verify(session, args->uri, (const char*)config.data); rc = session->verify(session, args->uri, (const char*)config.data);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
(void)session->close(session, NULL); (void)session->close(session, NULL);
enif_mutex_unlock(args->conn_handle->context_mutex); enif_mutex_unlock(args->conn_handle->context_mutex);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -1046,8 +1066,7 @@ ASYNC_NIF_DECL(
return; return;
} }
WterlCursorHandle* cursor_handle = WterlCursorHandle* cursor_handle = enif_alloc_resource(wterl_cursor_RESOURCE, sizeof(WterlCursorHandle));
enif_alloc_resource(wterl_cursor_RESOURCE, sizeof(WterlCursorHandle));
cursor_handle->session = session; cursor_handle->session = session;
cursor_handle->cursor = cursor; cursor_handle->cursor = cursor;
ERL_NIF_TERM result = enif_make_resource(env, cursor_handle); ERL_NIF_TERM result = enif_make_resource(env, cursor_handle);
@ -1080,10 +1099,12 @@ ASYNC_NIF_DECL(
}, },
{ // work { // work
WT_SESSION* session = args->cursor_handle->session; WT_CURSOR *cursor = args->cursor_handle->cursor;
WT_SESSION *session = args->cursor_handle->session;
/* Note: session->close() will cause all open cursors in the session to be /* Note: session->close() will cause all open cursors in the session to be
closed first, so we don't have explicitly to do that here. */ closed first, so we don't have explicitly to do that here. */
int rc = session->close(session, NULL); int rc = cursor->close(cursor);
(void)session->close(session, NULL);
ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc)); ASYNC_NIF_REPLY(rc == 0 ? ATOM_OK : __strerror_term(env, rc));
}, },
{ // post { // post
@ -1618,7 +1639,6 @@ __resource_conn_dtor(ErlNifEnv *env, void *obj)
kh_destroy(cursors, ctx->cursors); kh_destroy(cursors, ctx->cursors);
ctx->session->close(ctx->session, NULL); ctx->session->close(ctx->session, NULL);
} }
bzero(conn_handle->contexts, sizeof(WterlCtx) * ASYNC_NIF_MAX_WORKERS);
enif_mutex_unlock(conn_handle->context_mutex); enif_mutex_unlock(conn_handle->context_mutex);
enif_mutex_destroy(conn_handle->context_mutex); enif_mutex_destroy(conn_handle->context_mutex);
if (conn_handle->session_config) if (conn_handle->session_config)

61
src/riak_kv_wterl_backend.erl
View file

@ -93,15 +93,23 @@ start(Partition, Config) ->
end, end,
case AppStart of case AppStart of
ok -> ok ->
Table = "lsm:wt" ++ integer_to_list(Partition),
%% TODO: open, create, or open/verify
%% on failure to open a table try to verify, and then salvage it
%% if the cluster size > the n value
{ok, Connection} = establish_connection(Config), {ok, Connection} = establish_connection(Config),
case wterl:cursor_open(Connection, Table) of Table = "lsm:wt" ++ integer_to_list(Partition),
{ok, IsEmptyCursor} -> TableOpts =
case wterl:cursor_open(Connection, Table) of [{block_compressor, "snappy"},
{ok, StatusCursor} -> {internal_page_max, "128K"},
{leaf_page_max, "128K"},
{lsm_chunk_size, "25MB"},
{lsm_bloom_newest, true},
{lsm_bloom_oldest, true} ,
{lsm_bloom_bit_count, 128},
{lsm_bloom_hash_count, 64},
{lsm_bloom_config, [{leaf_page_max, "8MB"}]}
],
case wterl:create(Connection, Table, TableOpts) of
ok ->
case establish_utility_cursors(Connection, Table) of
{ok, IsEmptyCursor, StatusCursor} ->
{ok, #state{table=Table, connection=Connection, {ok, #state{table=Table, connection=Connection,
is_empty_cursor=IsEmptyCursor, is_empty_cursor=IsEmptyCursor,
status_cursor=StatusCursor}}; status_cursor=StatusCursor}};
@ -110,9 +118,7 @@ start(Partition, Config) ->
end; end;
{error, Reason3} -> {error, Reason3} ->
{error, Reason3} {error, Reason3}
end; end
{error, Reason4} ->
{error, Reason4}
end. end.
%% @doc Stop the wterl backend %% @doc Stop the wterl backend
@ -177,7 +183,7 @@ fold_buckets(FoldBucketsFun, Acc, Opts, #state{connection=Connection, table=Tabl
BucketFolder = BucketFolder =
fun() -> fun() ->
case wterl:cursor_open(Connection, Table) of case wterl:cursor_open(Connection, Table) of
{error, "No such file or directory"} -> {error, {enoent, _Message}} ->
Acc; Acc;
{ok, Cursor} -> {ok, Cursor} ->
try try
@ -222,7 +228,7 @@ fold_keys(FoldKeysFun, Acc, Opts, #state{connection=Connection, table=Table}) ->
KeyFolder = KeyFolder =
fun() -> fun() ->
case wterl:cursor_open(Connection, Table) of case wterl:cursor_open(Connection, Table) of
{error, "No such file or directory"} -> {error, {enoent, _Message}} ->
Acc; Acc;
{ok, Cursor} -> {ok, Cursor} ->
try try
@ -253,7 +259,7 @@ fold_objects(FoldObjectsFun, Acc, Opts, #state{connection=Connection, table=Tabl
ObjectFolder = ObjectFolder =
fun() -> fun() ->
case wterl:cursor_open(Connection, Table) of case wterl:cursor_open(Connection, Table) of
{error, "No such file or directory"} -> {error, {enoent, _Message}} ->
Acc; Acc;
{ok, Cursor} -> {ok, Cursor} ->
try try
@ -315,6 +321,7 @@ callback(_Ref, _Msg, State) ->
%% Internal functions %% Internal functions
%% =================================================================== %% ===================================================================
%% @private
max_sessions(Config) -> max_sessions(Config) ->
RingSize = RingSize =
case app_helper:get_prop_or_env(ring_creation_size, Config, riak_core) of case app_helper:get_prop_or_env(ring_creation_size, Config, riak_core) of
@ -323,6 +330,20 @@ max_sessions(Config) ->
end, end,
2 * (RingSize * erlang:system_info(schedulers)). 2 * (RingSize * erlang:system_info(schedulers)).
%% @private
establish_utility_cursors(Connection, Table) ->
case wterl:cursor_open(Connection, Table) of
{ok, IsEmptyCursor} ->
case wterl:cursor_open(Connection, Table) of
{ok, StatusCursor} ->
{ok, IsEmptyCursor, StatusCursor};
{error, Reason1} ->
{error, Reason1}
end;
{error, Reason2} ->
{error, Reason2}
end.
%% @private %% @private
establish_connection(Config) -> establish_connection(Config) ->
%% Get the data root directory %% Get the data root directory
@ -353,17 +374,7 @@ establish_connection(Config) ->
]) ] ++ proplists:get_value(wterl, Config, [])), % sec ]) ] ++ proplists:get_value(wterl, Config, [])), % sec
%% WT Session Options: %% WT Session Options:
SessionOpts = SessionOpts = [{isolation, "snapshot"}],
[{block_compressor, "snappy"},
{internal_page_max, "128K"},
{leaf_page_max, "128K"},
{lsm_chunk_size, "25MB"},
{lsm_bloom_newest, true},
{lsm_bloom_oldest, true} ,
{lsm_bloom_bit_count, 128},
{lsm_bloom_hash_count, 64},
{lsm_bloom_config, [{leaf_page_max, "8MB"}]}
],
case wterl_conn:open(DataRoot, ConnectionOpts, SessionOpts) of case wterl_conn:open(DataRoot, ConnectionOpts, SessionOpts) of
{ok, Connection} -> {ok, Connection} ->

136
src/wterl.erl
View file

@ -93,8 +93,8 @@ nif_stub_error(Line) ->
-spec init() -> ok | {error, any()}. -spec init() -> ok | {error, any()}.
init() -> init() ->
erlang:load_nif(filename:join([priv_dir(), atom_to_list(?MODULE)]), erlang:load_nif(filename:join([priv_dir(), atom_to_list(?MODULE)]),
[{wterl, "163a5073cb85db2a270ebe904e788bd8d478ea1c"}, [{wterl, "07061ed6e8252543c2f06b81a646eca6945cc558"},
{wiredtiger, "e9a607b1b78ffa528631519b5cb6ac944468991e"}]). {wiredtiger, "6f7a4b961c744bfb21f0c21d4c28c2d162400f1b"}]).
-spec connection_open(string(), config_list()) -> {ok, connection()} | {error, term()}. -spec connection_open(string(), config_list()) -> {ok, connection()} | {error, term()}.
-spec connection_open(string(), config_list(), config_list()) -> {ok, connection()} | {error, term()}. -spec connection_open(string(), config_list(), config_list()) -> {ok, connection()} | {error, term()}.
@ -454,6 +454,7 @@ config_to_bin([{Key, Value} | Rest], Acc) ->
{eviction_trigger, integer}, {eviction_trigger, integer},
{extensions, {list, quoted}}, {extensions, {list, quoted}},
{force, bool}, {force, bool},
{from, string},
{hazard_max, integer}, {hazard_max, integer},
{home_environment, bool}, {home_environment, bool},
{home_environment_priv, bool}, {home_environment_priv, bool},
@ -474,7 +475,8 @@ config_to_bin([{Key, Value} | Rest], Acc) ->
{session_max, integer}, {session_max, integer},
{statistics_log, config}, {statistics_log, config},
{sync, bool}, {sync, bool},
{target, list}, {target, {list, quoted}},
{to, string},
{transactional, bool}, {transactional, bool},
{verbose, list}, {verbose, list},
{wait, integer}], {wait, integer}],
@ -510,14 +512,18 @@ remove_dir_tree(Dir) ->
remove_all_files(Dir, Files) -> remove_all_files(Dir, Files) ->
lists:foreach(fun(File) -> lists:foreach(fun(File) ->
FilePath = filename:join([Dir, File]), FilePath = filename:join([Dir, File]),
{ok, FileInfo} = file:read_file_info(FilePath), case file:read_file_info(FilePath) of
case FileInfo#file_info.type of {ok, FileInfo} ->
directory -> case FileInfo#file_info.type of
{ok, DirFiles} = file:list_dir(FilePath), directory ->
remove_all_files(FilePath, DirFiles), {ok, DirFiles} = file:list_dir(FilePath),
file:del_dir(FilePath); remove_all_files(FilePath, DirFiles),
_ -> file:del_dir(FilePath);
file:delete(FilePath) _ ->
file:delete(FilePath)
end;
{error, Reason} ->
ok
end end
end, Files). end, Files).
@ -528,7 +534,7 @@ open_test_conn(DataDir) ->
open_test_conn(DataDir, OpenConfig) -> open_test_conn(DataDir, OpenConfig) ->
{ok, CWD} = file:get_cwd(), {ok, CWD} = file:get_cwd(),
?assertMatch(true, lists:suffix("wterl/.eunit", CWD)), ?assertMatch(true, lists:suffix("wterl/.eunit", CWD)),
?cmd("rm -rf " ++ filename:join([CWD, DataDir])), remove_dir_tree(filename:join([CWD, DataDir])), %?cmd("rm -rf " ++ filename:join([CWD, DataDir])),
?assertMatch(ok, filelib:ensure_dir(filename:join([DataDir, "x"]))), ?assertMatch(ok, filelib:ensure_dir(filename:join([DataDir, "x"]))),
{ok, ConnRef} = connection_open(filename:join([CWD, DataDir]), OpenConfig), {ok, ConnRef} = connection_open(filename:join([CWD, DataDir]), OpenConfig),
ConnRef. ConnRef.
@ -555,11 +561,11 @@ conn_test_() ->
{inorder, {inorder,
[{"open and close a connection", [{"open and close a connection",
fun() -> fun() ->
?assertMatch(ok, ok) ConnRef = open_test_table(ConnRef)
end}, end},
{"create, verify, drop a table(btree)", {"create, verify, drop a table(btree)",
fun() -> fun() ->
ConnRef = open_test_table(ConnRef), wterl:create(ConnRef, "table:test", []),
?assertMatch(ok, verify(ConnRef, "table:test")), ?assertMatch(ok, verify(ConnRef, "table:test")),
?assertMatch(ok, drop(ConnRef, "table:test")) ?assertMatch(ok, drop(ConnRef, "table:test"))
end}, end},
@ -601,7 +607,7 @@ init_test_table() ->
stop_test_table(ConnRef) -> stop_test_table(ConnRef) ->
?assertMatch(ok, connection_close(ConnRef)). ?assertMatch(ok, connection_close(ConnRef)).
various_test_() -> various_online_test_() ->
{setup, {setup,
fun init_test_table/0, fun init_test_table/0,
fun stop_test_table/1, fun stop_test_table/1,
@ -610,60 +616,76 @@ various_test_() ->
[ [
{"checkpoint", {"checkpoint",
fun() -> fun() ->
?assertMatch(ok, checkpoint(ConnRef, [{target, ["\"table:test\""]}])), ?assertMatch(ok, checkpoint(ConnRef, [{target, ["table:test"]}])),
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>)) ?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>))
end}, end}
{"verify", %% ,
%% {"truncate",
%% fun() ->
%% ?assertMatch(ok, truncate(ConnRef, "table:test")),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"a">>))
%% end},
%% {"truncate range, found",
%% fun() ->
%% ?assertMatch(ok, truncate(ConnRef, "table:test", <<"b">>, last)),
%% ?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>))
%% end},
%% {"truncate range, not_found",
%% fun() ->
%% ?assertMatch(ok, truncate(ConnRef, "table:test", first, <<"b">>)),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"a">>))
%% end},
%% {"truncate range, middle",
%% fun() ->
%% ?assertMatch(ok, truncate(ConnRef, "table:test", <<"b">>, <<"f">>)),
%% ?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>)),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"b">>)),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"c">>)),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"d">>)),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"e">>)),
%% ?assertMatch(not_found, get(ConnRef, "table:test", <<"f">>)),
%% ?assertMatch({ok, <<"gooseberry">>}, get(ConnRef, "table:test", <<"g">>))
%% end},
%% {"drop table",
%% fun() ->
%% ?assertMatch(ok, drop(ConnRef, "table:test"))
%% end}
]}
end}.
various_maintenance_test_() ->
{setup,
fun () ->
{ok, CWD} = file:get_cwd(),
?assertMatch(true, lists:suffix("wterl/.eunit", CWD)),
?assertMatch(ok, filelib:ensure_dir(filename:join([?TEST_DATA_DIR, "x"]))),
{ok, ConnRef} = connection_open(filename:join([CWD, ?TEST_DATA_DIR]), []),
ConnRef
end,
fun (ConnRef) ->
?assertMatch(ok, connection_close(ConnRef))
end,
fun(ConnRef) ->
{inorder,
[
{"drop table",
fun() -> fun() ->
?assertMatch(ok, verify(ConnRef, "table:test")), ?assertMatch(ok, create(ConnRef, "table:test")),
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>)) ?assertMatch(ok, drop(ConnRef, "table:test")),
?assertMatch(ok, create(ConnRef, "table:test"))
end}, end},
{"salvage", {"salvage",
fun() -> fun() ->
ok = salvage(ConnRef, "table:test"), ?assertMatch(ok, salvage(ConnRef, "table:test"))
{ok, <<"apple">>} = get(ConnRef, "table:test", <<"a">>)
end}, end},
{"upgrade", {"upgrade",
fun() -> fun() ->
?assertMatch(ok, upgrade(ConnRef, "table:test")), ?assertMatch(ok, upgrade(ConnRef, "table:test"))
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>))
end}, end},
{"rename", {"rename",
fun() -> fun() ->
?assertMatch(ok, rename(ConnRef, "table:test", "table:new")), ?assertMatch(ok, rename(ConnRef, "table:test", "table:new")),
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:new", <<"a">>)), ?assertMatch(ok, rename(ConnRef, "table:new", "table:test"))
?assertMatch(ok, rename(ConnRef, "table:new", "table:test")),
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>))
end},
{"truncate",
fun() ->
?assertMatch(ok, truncate(ConnRef, "table:test")),
?assertMatch(not_found, get(ConnRef, "table:test", <<"a">>))
end},
{"truncate range, found",
fun() ->
?assertMatch(ok, truncate(ConnRef, "table:test", <<"b">>, last)),
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>))
end},
{"truncate range, not_found",
fun() ->
?assertMatch(ok, truncate(ConnRef, "table:test", first, <<"b">>)),
?assertMatch(not_found, get(ConnRef, "table:test", <<"a">>))
end},
{"truncate range, middle",
fun() ->
?assertMatch(ok, truncate(ConnRef, "table:test", <<"b">>, <<"f">>)),
?assertMatch({ok, <<"apple">>}, get(ConnRef, "table:test", <<"a">>)),
?assertMatch(not_found, get(ConnRef, "table:test", <<"b">>)),
?assertMatch(not_found, get(ConnRef, "table:test", <<"c">>)),
?assertMatch(not_found, get(ConnRef, "table:test", <<"d">>)),
?assertMatch(not_found, get(ConnRef, "table:test", <<"e">>)),
?assertMatch(not_found, get(ConnRef, "table:test", <<"f">>)),
?assertMatch({ok, <<"gooseberry">>}, get(ConnRef, "table:test", <<"g">>))
end},
{"drop table",
fun() ->
?assertMatch(ok, drop(ConnRef, "table:test"))
end} end}
]} ]}
end}. end}.