anchor.diff:  cluster_runmany(Fun, Fuse, TaskList, Nodes, Running, Results) when length(Running) > 0 ->
       receive
   	{Pid, Num, Result} ->
  -	    % throw out the normal exit message
  -	    receive {'DOWN', _, _, Pid, normal} ->
  -		    nil;
  -		    {'DOWN', _, _, Pid, noproc}->
  +	    % throw out the exit message, Reason should be
  +	    % normal, noproc, or noconnection
  +	    receive {'DOWN', _, _, Pid, _Reason} ->
   		    nil
   	    end,
   	    {Running2, FinishedNode, _} = delete_running(Pid, Running, []),
  
positive.code:     Fun2 = fun (L) -> lists:foldl(Fun, InitAcc, L) end,
      runmany(Fun2, Fuse, List, Malt).
  
  % @doc Same semantics as in module
  % <a href="http://www.erlang.org/doc/man/lists.html">lists</a>.
  % @spec (Fun, List) -> void()
  foreach(Fun, List) ->
      foreach(Fun, List, 1).
  
  % @doc Same semantics as in module
  % <a href="http://www.erlang.org/doc/man/lists.html">lists</a>.
  % @spec (Fun, List, Malt) -> void()
  foreach(Fun, List, Malt) ->
      runmany(fun (L) ->
  
negative.code: 			   Reducer ! die,
  			   exit(Reason)
  		   end,
      Reducer ! {mappers, done, SentMessages},
      Results = receive
  		  {Reducer, Results2} ->
  		      Results2;
  