anchor.diff:          false -> nop;
           true -> gen_fsm:send_event(Coord, {acc, {list, Reply}})
       end,
  -    case FSMs of
  -        [] -> 
  -            case Done of
  -                true -> finish(StateData);
  -                _ -> nop
  -            end;
  -        _ -> nop
  -    end,
  -    {next_state, wait, StateData#state{map_fsms=FSMs}};
  +    case FSMs =:= [] andalso Done =:= true of
  +        true ->
  +            finish(StateData);
  +        false ->
  +            {next_state, wait, StateData#state{map_fsms=FSMs}}
  +    end;
  +
   wait({mapexec_error, _ErrFSM, ErrMsg}, StateData=
        #state{next_fsm=NextFSM,coord=Coord}) ->
       riak_eventer:notify(riak_map_phase_fsm, error, ErrMsg),
  
positive.code: -export([init/1, handle_event/3, handle_sync_event/4,
           handle_info/3, terminate/3, code_change/4]).
  
  -export([wait/2]). 
  
  -record(state, {done,qterm,next_fsm,coord,acc,map_fsms,ring}).
  
  
negative.code:   when is_binary(_B) andalso (is_list(_K) orelse is_binary(_K)) -> I;
  convert_input(I={_B,_K})
    when is_binary(_B) andalso (is_list(_K) orelse is_binary(_K)) -> {I,undefined}.
  