QPQ-AG/mnesia_rocksdb
9
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix on_write_error options

Browse Source
This commit is contained in:
Ulf Wiger 2019-09-24 16:10:13 +02:00
parent c8da9ce31b
commit f93c1aba93
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/mnesia_rocksdb.erl
View File

@ -182,7 +182,7 @@
, type , type
, size_warnings % integer() , size_warnings % integer()
, maintain_size % boolean() , maintain_size % boolean()
, on_write_error = verbose :: verbose | warning | error | fatal , on_write_error = verbose :: debug | verbose | warning | error | fatal
}). }).
%% ---------------------------------------------------------------------------- %% ----------------------------------------------------------------------------
@ -1592,7 +1592,8 @@ db_delete(Ref, K, Opts, St) ->
write_result(ok, _, _, _) -> write_result(ok, _, _, _) ->
ok; ok;
write_result(Res, Op, Args, #st{on_write_error = Rpt}) -> write_result(Res, Op, Args, #st{on_write_error = Rpt}) ->
mnesia_lib:Rpt("FAILED rocksdb:~p(" ++ rpt_fmt(Args) ++ ") -> ~p~n", RptOp = rpt_op(Rpt),
mnesia_lib:RptOp("FAILED rocksdb:~p(" ++ rpt_fmt(Args) ++ ") -> ~p~n",
[Op | Args] ++ [Res]), [Op | Args] ++ [Res]),
if Rpt == fatal; Rpt == error -> if Rpt == fatal; Rpt == error ->
badarg; badarg;
@ -1603,8 +1604,14 @@ write_result(Res, Op, Args, #st{on_write_error = Rpt}) ->
rpt_fmt([_|T]) -> rpt_fmt([_|T]) ->
lists:append(["~p" | [", ~p" || _ <- T]]). lists:append(["~p" | [", ~p" || _ <- T]]).
rpt_op(debug) ->
dbg_out;
rpt_op(Op) ->
Op.
valid_mnesia_op(Op) -> valid_mnesia_op(Op) ->
if Op==verbose if Op==debug
; Op==verbose
; Op==warning ; Op==warning
; Op==error ; Op==error
; Op==fatal -> ; Op==fatal ->