anchor.diff:          end,
           Parent ! {writer_checkpoint, HighSeq},
           couch_rep_att:cleanup(),
  +        couch_util:should_flush(),
           writer_loop(Parent, Reader, Target)
       end.
   
  
positive.code:             Reason = proplists:get_value(<<"reason">>, Props),
              {{Id, Rev}, {ErrId, Reason}}
          end, ErrorsJson),
      case erase(docs_remaining) of
      undefined ->
          {ok, lists:flatten([ErrorsList|ErrorsAcc])};
      MoreDocs ->
          write_docs(Db, MoreDocs, [ErrorsList|ErrorsAcc])
      end;
  write_docs(Db, Docs, _) ->
  
negative.code:     ErrorsJson = couch_rep_httpc:request(Db#http_db{
          resource = "_bulk_docs",
          method = post,
          body = {fun upload_docs/1, {start, self(), Docs}},
          headers = [{"transfer-encoding", "chunked"} | Db#http_db.headers]
      }),
      ErrorsList =
  