anchor.diff:              receive_catalog_query_results(StreamRef, Sender, Conn);
           Msg ->
               riak_search_backend:catalog_query_done(Sender),
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               throw({unexpected_msg, Msg})
       after
           ?CATALOG_QUERY_TIMEOUT ->   
               riak_search_backend:catalog_query_done(Sender),
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               error_logger:warning_msg("Catalog query result Raptor conn timeout\n")
       end,
       ok.
  
positive.code:     receive
          {info, StreamRef, timeout} ->
              riak_search_backend:info_response(Sender, Results),
              raptor_conn:close(Conn),
              error_logger:warning_msg("Info range result Raptor socket timeout\n");
  
          {info, StreamRef, "$end_of_info", 0} ->
  
negative.code:     receive
          {catalog_query, _ReqId, timeout} ->
              riak_search_backend:catalog_query_done(Sender),
              exit(Conn, kill),
              error_logger:warning_msg("Catalog query result Raptor socket timeout\n");
          {catalog_query, _ReqId, "$end_of_results", _, _, _, _} ->
              riak_search_backend:catalog_query_done(Sender);
  