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

WIP: chain mgmt prototype scaffolding 2

Browse source
This commit is contained in:
Scott Lystig Fritchie 2014-10-27 19:51:54 +09:00
parent add6f421aa
commit 63d23330b2
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
prototype/poc-machi/src/machi_chain_manager1.erl
View file

@ -27,7 +27,7 @@
-define(D(X), io:format(user, "~s ~p\n", [??X, X])). -define(D(X), io:format(user, "~s ~p\n", [??X, X])).
%% API %% API
-export([start_link/6, stop/1, -export([start_link/6, stop/1, ping/1,
calculate_projection_internal_old/1, calculate_projection_internal_old/1,
cl_write_current_projection/1]). cl_write_current_projection/1]).
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
@ -58,6 +58,9 @@ start_link(MyName, All_list, Seed,
stop(Pid) -> stop(Pid) ->
gen_server:call(Pid, {stop}, infinity). gen_server:call(Pid, {stop}, infinity).
ping(Pid) ->
gen_server:call(Pid, {ping}, infinity).
calculate_projection_internal_old(Pid) -> calculate_projection_internal_old(Pid) ->
gen_server:call(Pid, {calculate_projection_internal_old}, infinity). gen_server:call(Pid, {calculate_projection_internal_old}, infinity).
@ -87,6 +90,8 @@ handle_call({calculate_projection_internal_old}, _From,
handle_call({cl_write_current_projection}, _From, S) -> handle_call({cl_write_current_projection}, _From, S) ->
{Res, S2} = do_cl_write_current_proj(S), {Res, S2} = do_cl_write_current_proj(S),
{reply, Res, S2}; {reply, Res, S2};
handle_call({ping}, _From, S) ->
{reply, pong, S};
handle_call({stop}, _From, S) -> handle_call({stop}, _From, S) ->
{stop, normal, ok, S}; {stop, normal, ok, S};
handle_call(_Call, _From, S) -> handle_call(_Call, _From, S) ->
@ -120,6 +125,7 @@ do_cl_write_current_proj(#ch_mgr{proj=Proj, myflu=MyFLU} = S) ->
MyP = make_projection_summary(element(2, MyP = make_projection_summary(element(2,
machi_flu0:proj_read_latest(MyFLU, private))), machi_flu0:proj_read_latest(MyFLU, private))),
?D(MyP), ?D(MyP),
?D(S3#ch_mgr.runenv),
{ok, S3#ch_mgr{proj=Proj2}}; {ok, S3#ch_mgr{proj=Proj2}};
{_Other3, _S3}=Else3 -> {_Other3, _S3}=Else3 ->
Else3 Else3