X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=001%2Fsrc%2Flife_cell.erl;h=a77e279edbf2b454956c02c6cf4af598ca2455ec;hb=263bc3ae8952564b65bab30d02fc0462711e88fb;hp=e7cebcd4cec65d1645a9b711b7bc3847bce24073;hpb=1d121bcf9312f8c869537e5d28f2c2964fe35169;p=cellular-automata.git

diff --git a/001/src/life_cell.erl b/001/src/life_cell.erl
index e7cebcd..a77e279 100644
--- a/001/src/life_cell.erl
+++ b/001/src/life_cell.erl
@@ -23,6 +23,7 @@
                ,num_neighbors   :: integer()
                ,replies_pending :: integer()
                ,gen_id          :: integer()
+               ,early_msgs      :: list()
                }).
 
 
@@ -49,6 +50,7 @@ init([{CellID, Name, NeighborNames}]) ->
                   ,num_neighbors   = length(NeighborNames)
                   ,live_neighbors  = 0
                   ,replies_pending = 0
+                  ,early_msgs      = []
                   },
     {ok, State}.
 
@@ -66,22 +68,39 @@ handle_call(_Msg, _From, State) ->
 
 
 handle_cast({next_gen, GenID},
-    #state{cell_state=CellState
+    #state{name=Name
+          ,cell_state=CellState
           ,neighbors=Neighbors
           ,num_neighbors=NumNeighbors
+          ,early_msgs=EarlyMsgs
           }=State) ->
 
-    ok = cast_all(Neighbors, {state_broadcast, GenID, CellState}),
-    {noreply, State#state{replies_pending=NumNeighbors, gen_id=GenID}};
+    ok = cast_one2all(Neighbors, {state_broadcast, GenID, CellState}),
+
+    % Put stashed messages back in the mailbox,
+    % now that we're ready to handle them
+    ok = cast_all2one(Name, EarlyMsgs),
+
+    NewState = State#state{replies_pending=NumNeighbors
+                          ,gen_id=GenID
+                          ,early_msgs=[]
+                          },
+
+    {noreply, NewState};
 
 
-%% If we receive 'state_broadcast' before we receive 'next_gen', throw it back
-%% in the queue. (Took me a while to realize this, but sometimes it is
-%% possible. The more there're cells, the more likely this is to happen.)
+%% If we receive 'state_broadcast' before we receive 'next_gen',
+%% stash it until we do.
+%%
+%% Took me a while to realize this, but sometimes it is possible. The more
+%% there're cells, the more likely this is to happen.
+%%
 handle_cast({state_broadcast, ReceivedGenID, _NeighborState}=Msg,
-    #state{gen_id=GenID, name=Name}=State) when GenID =/= ReceivedGenID->
-    ok = gen_server:cast(Name, Msg),
-    {noreply, State};
+    #state{gen_id=GenID
+          ,early_msgs=EarlyMsgs
+          }=State) when GenID =/= ReceivedGenID ->
+
+    {noreply, State#state{early_msgs=[Msg|EarlyMsgs]}};
 
 
 %% Now that we can be sure that this request is for the current generation, we
@@ -128,10 +147,18 @@ handle_info(_Msg, State) ->
 %% Internal
 %% ============================================================================
 
-cast_all([], _) -> ok;
-cast_all([Server | Servers], Msg) ->
+% Cast all messages to one destination
+cast_all2one(_, []) -> ok;
+cast_all2one(Server, [Msg | Msgs]) ->
+    ok = gen_server:cast(Server, Msg),
+    cast_all2one(Server, Msgs).
+
+
+% Cast one message to all destinations
+cast_one2all([], _) -> ok;
+cast_one2all([Server | Servers], Msg) ->
     ok = gen_server:cast(Server, Msg),
-    cast_all(Servers, Msg).
+    cast_one2all(Servers, Msg).
 
 
 new_state(1, LiveNeighbors) when LiveNeighbors  <  2 -> 0;