anchor.diff:          ets:new(job_events, [named_table, duplicate_bag]),
   
           % node_laod records how many disco_workers there are
  -        % running on a node (could be found in active_workers)
  -        % as well. This table exists mainly for convenience and
  +        % running on a node (could be found in active_workers
  +        % as well). This table exists mainly for convenience and
           % possibly for performance reasons.
           ets:new(node_load, [named_table]),
   
  
positive.code: % clean_worker() gets called whenever a disco_worker process dies, either
  % normally or abnormally. Its main job is to remove the exiting worker
  % from the active_workers table and to notify the corresponding job 
  % coordinator about the worker status.
  clean_worker(Pid, ReplyType, Msg, WaitQueue) ->
          {V, Nfo} = case ets:lookup(active_workers, Pid) of
                          [] -> event("[master]",
  
negative.code:                 length(AllowedNodes) == 0 -> 
                          {all_bad, length(TaskBlackNodes), length(AllNodes)};
                  true -> 
                          % Pick the node with the lowest load.
                          [{Node, _}|_] = lists:keysort(2, AllowedNodes),
                          Node
                  end;
          true ->
                  % If yes, return the preferred node.
                  PrefNode
          end.
  
  