Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

gen_fsm replaced by gen_statem in vnode #80

Closed
wants to merge 17 commits into from
Closed

gen_fsm replaced by gen_statem in vnode #80

Changes from 1 commit
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
58a1993
Merge pull request #5 from WoelkiM/19_2_reconstruct_format
WoelkiM Sep 9, 2020
b5c27b5
replace gen_fsm_compat into gen_statem
Sep 14, 2020
6c5547f
fix lint
Sep 14, 2020
06c9da3
test
Sep 15, 2020
020090d
Merge riak_core_lite master into local branch
Oct 12, 2020
abee551
Merge branch 'master' into 19_3_gen_statem
WoelkiM Oct 13, 2020
72e191c
Merge remote-tracking branch 'upstream/master' into 19_3_gen_statem
Nov 24, 2020
9385b01
Moved get_modstate to test scope
Nov 24, 2020
6714fad
Removed gen_fsm_compat, removed PULSE tests as they depend on gen_fsm…
Nov 24, 2020
e0c581d
change handle_overload / add gen_statem events
Jan 26, 2021
406e862
Merge branch '19_3_gen_statem' of https://github.com/WoelkiM/riak_cor…
Jan 26, 2021
c140e80
Update riak_core_vnode.erl
Jan 26, 2021
97fe136
execute format in erlang version 21/22/23
Feb 1, 2021
5e6e831
Merge pull request #10 from riak-core-lite/master
WoelkiM Mar 1, 2021
cc19eb6
Merge remote-tracking branch 'origin/master' into 19_3_gen_statem
Mar 1, 2021
bbff7d8
#80 execute format
Mar 2, 2021
8ed838b
Up to date master
Jul 15, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix lint
  • Loading branch information
woelki committed Sep 14, 2020
commit 6c5547f337a7dc0f642c99f7d1b65b0cc5328bbc
19 changes: 10 additions & 9 deletions src/riak_core_vnode.erl
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -599,13 +599,6 @@ active(cast, cancel_handoff,
handoff_type = undefined,
modstate = NewModState})
end;
%% 13
active(cast,
#riak_coverage_req_v1{keyspaces = KeySpaces,
request = Request, sender = Sender},
State) ->
%% Coverage request handled in handoff and non-handoff. Will be forwarded if set.
vnode_coverage(Sender, Request, KeySpaces, State);
%% #16
active(cast, handoff_complete, State) ->
State2 = start_manager_event_timer(handoff_complete,
Expand Down Expand Up @@ -677,6 +670,14 @@ active(cast, {send_manager_event, Event}, State) ->
State2 = start_manager_event_timer(Event, State),
continue(State2);

%% 13
active(_C,
#riak_coverage_req_v1{keyspaces = KeySpaces,
request = Request, sender = Sender},
State) ->
%% Coverage request handled in handoff and non-handoff. Will be forwarded if set.
vnode_coverage(Sender, Request, KeySpaces, State);

%% forward_request
active(_C,
#riak_vnode_req_v1{sender = Sender,
Expand Down Expand Up @@ -721,8 +722,8 @@ active(_C,
_Other -> vnode_command(Sender, Request, State)
end
end;
%%
active(_C,
%%
active(cast,
#riak_vnode_req_v1{sender = Sender, request = Request},
State) ->
vnode_handoff_command(Sender,
Expand Down