anchor.diff:                                                    _ ->
                                                         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})
  +                                          {timeout, ErrorMsg} ->
  +                                              ?xdcr_trace("Warning! timeout when fetching metadata from remote for key: ~p, "
  +                                                          "just send the doc (msg: ~p)", [Key, ErrorMsg]),
  +                                              true;
  +                                          {error, ErrorMsg} ->
  +                                              ?xdcr_error("Error! memcached error when fetching metadata for key: ~p, "
  +                                                          "just send the doc (msg: ~p)", [Key, ErrorMsg]),
  +                                              true
                                         end,
                               case Missing of
                                   true ->
  
positive.code:                     {ok, RemoteFullMeta, RemoteCAS};
                  {ok, key_enoent, RemoteCAS} ->
                      {key_enoent, "key does not exist at remote", RemoteCAS};
                  {memcached_error, ErrorMsg} ->
                      {error, ErrorMsg}
              end,
  
negative.code:                                "(vb: ~p, status code: ~p, error: ~p)",
                                 [VBucket, OtherResponse, mc_client_binary:map_status(OtherResponse)])};
  
                %% if timeout when fetching remote metadata, treat it as local wins and just send the doc
                {error, timeout} ->
                    {timeout, ?format_msg("remote memcached timeout when retrieving metadata at sock: ~p, vb: ~p",
                                                  [Sock, VBucket])}
            end,
  
  