valitydev/dmt-client
14
0
Fork 0
mirror of https://github.com/valitydev/dmt-client.git synced 2024-11-06 01:15:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: PoC of fixing the stale-head issue

Browse Source
This commit is contained in:
Yaroslav Rogov 2021-06-21 19:25:45 +03:00
parent cd8eef5d46
commit 357c772284
No known key found for this signature in database
GPG Key ID: 5159F2A85653816B
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/dmt_client_cache.erl
View File

@ -422,15 +422,21 @@ do_fetch({head, #'Head'{}}, Opts) ->
case latest_snapshot() of
{ok, OldHead} ->
Limit = genlib_app:env(dmt_client, cache_update_pull_limit, ?DEFAULT_LIMIT),
FreshHistory = dmt_client_backend:pull_range(OldHead#'Snapshot'.version, Limit, Opts),
{ok, Head} = dmt_history:head(FreshHistory, OldHead),
Head;
update_head(OldHead, Limit, Opts);
{error, version_not_found} ->
dmt_client_backend:checkout({head, #'Head'{}}, Opts)
end;
do_fetch(Reference, Opts) ->
dmt_client_backend:checkout(Reference, Opts).
update_head(Head, PullLimit, Opts) ->
FreshHistory = dmt_client_backend:pull_range(Head#'Snapshot'.version, PullLimit, Opts),
{ok, NewHead} = dmt_history:head(FreshHistory, Head),
case NewHead == Head of
true -> NewHead;
false -> update_head(NewHead, PullLimit, Opts)
end.
-spec dispatch_reply(from() | undefined, fetch_result()) -> _.
dispatch_reply(undefined, _Result) ->
ok;