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

Merge pull request #32 from aeternity/uw-push-pop-error

Browse Source 
Tx push at retry before mutex instead of after
This commit is contained in:
Ulf Wiger 2022-10-26 13:16:28 +02:00 committed by GitHub
commit ee9e7eac67
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/mrdb.erl
View File

@ -290,16 +290,13 @@ do_activity(F, Alias, Ctxt, WithLock) ->
abort_and_pop(Cat, Err) abort_and_pop(Cat, Err)
end. end.
-spec run_f(_, #{'activity':=#{'handle':=_, 'type':='batch' | 'tx', 'attempt'=>1, 'no_snapshot'=>boolean(), 'retries'=>non_neg_integer(), _=>_}, 'alias':=_, 'db_ref':=_, 'no_snapshot'=>boolean(), 'retries'=>non_neg_integer(), _=>_}, boolean(), _) -> any().
run_f(F, Ctxt, false, _) -> run_f(F, Ctxt, false, _) ->
push_ctxt(Ctxt), push_ctxt(Ctxt),
F(); F();
run_f(F, Ctxt, true, Alias) -> run_f(F, Ctxt, true, Alias) ->
mrdb_mutex:do(
Alias,
fun() ->
push_ctxt(incr_attempt(Ctxt)), push_ctxt(incr_attempt(Ctxt)),
F() mrdb_mutex:do(Alias, F).
end).
incr_attempt(#{ activity := #{type := tx, attempt := A} = Act, db_ref := DbRef } = C) -> incr_attempt(#{ activity := #{type := tx, attempt := A} = Act, db_ref := DbRef } = C) ->
{ok, TxH} = rdb_transaction(DbRef, []), {ok, TxH} = rdb_transaction(DbRef, []),