Make sure to export bdberl_get/4; adjust thrash to use RMW flag to reduce deadlocks
This commit is contained in:
parent
b4c6aae90c
commit
3be9b64c30
|
@ -12,7 +12,7 @@
|
||||||
txn_begin/1, txn_begin/2,
|
txn_begin/1, txn_begin/2,
|
||||||
txn_commit/1, txn_commit/2, txn_abort/1,
|
txn_commit/1, txn_commit/2, txn_abort/1,
|
||||||
put/4, put/5,
|
put/4, put/5,
|
||||||
get/3]).
|
get/3, get/4]).
|
||||||
|
|
||||||
-define(CMD_NONE, 0).
|
-define(CMD_NONE, 0).
|
||||||
-define(CMD_OPEN_DB, 1).
|
-define(CMD_OPEN_DB, 1).
|
||||||
|
|
|
@ -11,7 +11,7 @@
|
||||||
all() ->
|
all() ->
|
||||||
[test_thrash].
|
[test_thrash].
|
||||||
|
|
||||||
-define(PROCS, 2).
|
-define(PROCS, 5).
|
||||||
|
|
||||||
test_thrash(_Config) ->
|
test_thrash(_Config) ->
|
||||||
%% Spin up 15 processes (async thread pool is 10)
|
%% Spin up 15 processes (async thread pool is 10)
|
||||||
|
@ -71,7 +71,7 @@ thrash_incr_loop(Port, Owner, Count) ->
|
||||||
|
|
||||||
|
|
||||||
get_or_die(Port, DbRef, Key) ->
|
get_or_die(Port, DbRef, Key) ->
|
||||||
case bdberl_port:get(Port, DbRef, Key) of
|
case bdberl_port:get(Port, DbRef, Key, [rmw]) of
|
||||||
not_found ->
|
not_found ->
|
||||||
not_found;
|
not_found;
|
||||||
{ok, Value} ->
|
{ok, Value} ->
|
||||||
|
|
Loading…
Reference in a new issue