anchor.diff:      RexiMon = fabric_util:create_monitors(Workers),
       BufferSize = couch_config:get("fabric", "reduce_buffer_size", "20"),
       #view_query_args{limit = Limit, skip = Skip} = Args,
  +    OsProc = case os_proc_needed(RedSrc) of
  +        true -> couch_query_servers:get_os_process(Lang);
  +        _ -> nil
  +    end,
       State = #collector{
           db_name = DbName,
           query_args = Args,
  
positive.code:     after
          rexi_monitor:stop(RexiMon),
          fabric_util:cleanup(Workers),
          catch couch_query_servers:ret_os_process(State#collector.os_proc)
      end.
  
  handle_message({rexi_DOWN, _, {_, NodeRef}, _}, _, State) ->
  
negative.code:         skip = Skip,
          limit = Limit,
          lang = Group#group.def_lang,
          os_proc = OsProc,
          reducer = RedSrc,
          rows = dict:new(),
          user_acc = Acc0
  