anchor.diff:          skip = Skip,
           limit = Limit,
           lang = Group#group.def_lang,
  -        os_proc = couch_query_servers:get_os_process(Lang),
  +        os_proc = OsProc,
           reducer = RedSrc,
           rows = dict:new(),
           user_acc = Acc0
  
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:     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,
  