Upgraded to gen_pnet 0.1.7.

joergen7 · Sep 12, 2017 · 23ddcc4 · 23ddcc4
1 parent 66770aa
commit 23ddcc4
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/rebar.config b/rebar.config
@@ -3,7 +3,7 @@
 {cover_enabled, true}.
 
 {deps, [
-        {gen_pnet, "0.1.6"}
+        {gen_pnet, "0.1.7"}
        ]}.
 
 {eunit_opts, [verbose]}.

diff --git a/src/cre_client.erl b/src/cre_client.erl
@@ -80,7 +80,7 @@ start_link( ClientName, CreName, ClientMod, ClientArg ) ->
                        [] ).
 
 eval( ClientName, T ) ->
-  gen_pnet:call( ClientName, {eval, T} ).
+  gen_pnet:call( ClientName, {eval, T}, infinity ).
 
 demand( ClientName ) ->
   gen_pnet:cast( ClientName, demand ).
@@ -156,7 +156,7 @@ when is_atom( ClientMod ) ->
 
   cre_master:add_client( CreName, self() ),
 
-  {ok, gen_pnet:new( ?MODULE, ClientState )}.
+  ClientState.
 
 
 -spec terminate( Reason :: _, NetState :: _ ) -> ok.

diff --git a/src/cre_master.erl b/src/cre_master.erl
@@ -134,9 +134,9 @@ code_change( _OldVsn, NetState, _Extra )  -> {ok, NetState}.
 handle_call( _Request, _From, _NetState ) -> {reply, {error, bad_msg}}.
 terminate( _Reason, _NetState )           -> ok.
 
-init( [] ) ->
+init( _MasterArg ) ->
   process_flag( trap_exit, true ),
-  {ok, gen_pnet:new( ?MODULE, [] )}.
+  [].
 
 handle_cast( {add_worker, P}, _ ) ->
   io:format( "cre_master:handle_cast received add worker~n  CRE:    ~p~n  Worker: ~p~n", [self(), P] ),

diff --git a/src/cre_worker.erl b/src/cre_worker.erl
@@ -118,7 +118,7 @@ init( {CreName, WrkMod, WrkArg} ) ->
 
   ok = cre_master:add_worker( CreName, self() ),
 
-  {ok, gen_pnet:new( ?MODULE, WrkState )}.
+  WrkState.
 
 terminate( _Reason, _NetState ) -> ok.