gistfile1.txt

go(DbName, DDoc, IndexName, QueryArgs, Counters, Bookmark,HttpResp) ->
    {Workers, _} = lists:unzip(Counters),
    #index_query_args{limit = Limit, sort = Sort} = QueryArgs,
    Replacements = fabric_view:get_shard_replacements(DbName, Workers),
    State = #state{
        limit = Limit,
        sort = Sort,
        top_docs = #top_docs{total_hits=0,hits=[]},
        counters = Counters,
        start_args = [DDoc, IndexName, QueryArgs],
        replacements = Replacements,
        procs = 0,
        http_resp=HttpResp
     },
    
    % RexiMon = fabric_util:create_monitors(Workers),
    case rexi_utils:recv(Workers, #shard.ref, fun handle_message/3,
        State, infinity, 1000 * 60 * 60) of
    {ok,search_all_complete} ->
        {ok,search_all_complete};
    {error, Reason} ->
        twig:log(error, "Error: ~p", [Reason]),
        {error, Reason}
    end.