anchor.diff:                                 "(vb: ~p, status code: ~p, error: ~p)",
                                  [VBucket, OtherResponse, mc_client_binary:map_status(OtherResponse)])};
   
  -              %% if timeout, treat it as error
  +              %% if timeout when fetching remote metadata, treat it as local wins and just send the doc
                 {error, timeout} ->
  -                  {memcached_error, ?format_msg("remote memcached timeout at sock: ~p, vb: ~p",
  +                  {timeout, ?format_msg("remote memcached timeout when retrieving metadata at sock: ~p, vb: ~p",
                                                   [Sock, VBucket])}
             end,
   
  
positive.code:                                                   _ ->
                                                        false
                                                end;
                                            {error, Msg} ->
                                                ?xdcr_error("Error! (memcached error msg: ~p) found in replication, "
                                                            "abort the worker thread", [Msg]),
                                                throw({bad_request, memcached_error, Msg})
                                        end,
                              case Missing of
                                  true ->
  
negative.code:                     {ok, RemoteFullMeta, RemoteCAS};
                  {ok, key_enoent, RemoteCAS} ->
                      {key_enoent, "key does not exist at remote", RemoteCAS};
                  %% if timeout in retreiving metadata, we just send the doc optimistically
                  {timeout, ErrorMsg} ->
                      {timeout, ErrorMsg};
                  {memcached_error, ErrorMsg} ->
                      {error, ErrorMsg}
              end,
  