greg/machi
1
0
Fork 0
Code Issues 11 Pull requests 1 Projects Releases Packages Wiki Activity Actions

Ss/flu1 factorization2 #55

Merged
shino merged 5 commits from ss/flu1-factorization2 into master 2015-12-18 08:19:17 +00:00
Conversation 6 Commits 5 Files changed 10 +12 -7
2 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 7d262fd3ec - Show all commits

10
src/machi_flu1.erl
View file

@ -87,13 +87,11 @@ stop(Pid) when is_pid(Pid) ->
error error
end. end.
update_wedge_state(PidSpec, Boolean, EpochId) update_wedge_state(PidSpec, Boolean, EpochId) ->
when is_boolean(Boolean), is_tuple(EpochId) -> machi_flu1_append_server:int_update_wedge_state(PidSpec, Boolean, EpochId).
gen_server:cast(PidSpec, {wedge_state_change, Boolean, EpochId}).
wedge_myself(PidSpec, EpochId) wedge_myself(PidSpec, EpochId) ->
when is_tuple(EpochId) -> machi_flu1_append_server:int_wedge_myself(PidSpec, EpochId).
gen_server:cast(PidSpec, {wedge_myself, EpochId}).
%%%%%%%%%%%%%%%%%%%%%%%%%%%% %%%%%%%%%%%%%%%%%%%%%%%%%%%%

9
src/machi_flu1_append_server.erl
View file

@ -36,7 +36,7 @@
-export([init/1]). -export([init/1]).
-export([handle_call/3, handle_cast/2, handle_info/2, -export([handle_call/3, handle_cast/2, handle_info/2,
terminate/2, code_change/3]). terminate/2, code_change/3]).
-export([int_update_wedge_state/3, int_wedge_myself/2]).
-export([current_state/1, format_state/1]). -export([current_state/1, format_state/1]).
-record(state, { -record(state, {
@ -67,6 +67,13 @@ format_state(State) ->
[_Name | Values] = tuple_to_list(State), [_Name | Values] = tuple_to_list(State),
lists:zip(Fields, Values). lists:zip(Fields, Values).
int_update_wedge_state(PidSpec, Boolean, EpochId)
when is_boolean(Boolean), is_tuple(EpochId) ->
gen_server:cast(PidSpec, {wedge_state_change, Boolean, EpochId}).
int_wedge_myself(PidSpec, EpochId)
when is_tuple(EpochId) ->
gen_server:cast(PidSpec, {wedge_myself, EpochId}).
init([Fluname, Witness_p, Wedged_p, EpochId]) -> init([Fluname, Witness_p, Wedged_p, EpochId]) ->
TID = ets:new(machi_flu1:ets_table_name(Fluname), TID = ets:new(machi_flu1:ets_table_name(Fluname),