subversion/libsvn_ra_serf/update.c

278   report_context_t *ctx;
462                  report_context_t *ctx,
466   dir_baton_t *parent = ctx->cur_dir;
473     dir_pool = svn_pool_create(ctx->pool);
477   dir->ctx = ctx;
489   dir->repos_relpath = svn_hash_gets(ctx->switched_paths, dir->relpath);
496         dir->repos_relpath = svn_uri_skip_ancestor(ctx->sess->repos_root_str,
497                                                    ctx->sess->session_url_str,
506   ctx->cur_dir = dir;
514                   report_context_t *ctx,
518   dir_baton_t *parent = ctx->cur_dir;
533   file->repos_relpath = svn_hash_gets(ctx->switched_paths, file->relpath);
544   ctx->cur_file = file;
592 get_best_connection(report_context_t *ctx)
610   if (ctx->report_received && (ctx->sess->max_connections > 2))
615   if (ctx->sess->num_conns - first_conn == 1)
617       conn = ctx->sess->conns[first_conn];
634       for (i = first_conn; i < ctx->sess->num_conns; i++)
636           serf_connection_t *sc = ctx->sess->conns[i]->conn;
644       conn = ctx->sess->conns[best_conn];
648       conn = ctx->sess->conns[ctx->sess->cur_conn];
649       ctx->sess->cur_conn++;
650       if (ctx->sess->cur_conn >= ctx->sess->num_conns)
651         ctx->sess->cur_conn = first_conn;
664   report_context_t *ctx = dir->ctx;
671       if (ctx->destination
672           && ctx->sess->wc_callbacks->invalidate_wc_props)
674           SVN_ERR(ctx->sess->wc_callbacks->invalidate_wc_props(
675                       ctx->sess->wc_callback_baton,
676                       ctx->update_target,
680       SVN_ERR(ctx->editor->open_root(ctx->editor_baton, dir->base_rev,
690           SVN_ERR(ctx->editor->open_directory(dir->relpath,
698           SVN_ERR(ctx->editor->add_directory(dir->relpath,
717   report_context_t *ctx = dir->ctx;
734           SVN_ERR(ctx->editor->change_file_prop(dir->dir_baton,
741   SVN_ERR(dir->ctx->editor->close_directory(dir->dir_baton, scratch_pool));
755   const svn_delta_editor_t *editor = file->parent_dir->ctx->editor;
861   const svn_delta_editor_t *editor = file->parent_dir->ctx->editor;
886   report_context_t *ctx = parent_dir->ctx;
899           SVN_ERR(ctx->editor->change_file_prop(file->file_baton,
915   if (!ctx->add_props_included
919       SVN_ERR(ctx->editor->change_file_prop(file->file_baton,
927       SVN_ERR(ctx->editor->change_file_prop(file->file_baton,
935   SVN_ERR(ctx->editor->close_file(file->file_baton,
1106   report_context_t *ctx = file->parent_dir->ctx;
1121       /* assert(!ctx->add_props_included); // Or we wouldn't be here */
1141   SVN_ERR(ctx->editor->change_file_prop(file->file_baton,
1164   file->parent_dir->ctx->num_active_propfinds--;
1196   file->parent_dir->ctx->num_active_fetches--;
1218   report_context_t *ctx = file->parent_dir->ctx;
1223   if (ctx->sess->num_conns < ctx->sess->max_connections)
1224     SVN_ERR(open_connection_if_needed(ctx->sess, ctx->num_active_fetches +
1225                                                  ctx->num_active_propfinds));
1228   conn = get_best_connection(ctx);
1237       if (!ctx->text_deltas
1246           && ctx->sess->wc_callbacks->get_wc_contents)
1251           err = ctx->sess->wc_callbacks->get_wc_contents(
1252                                                 ctx->sess->wc_callback_baton,
1284           fetch_ctx->session = ctx->sess;
1287           if (SVN_RA_SERF__HAVE_HTTPV2_SUPPORT(ctx->sess))
1295                                                        ctx->sess->rev_root_stub,
1306                                                        ctx->sess->rev_root_stub,
1313           else if (ctx->sess->wc_callbacks->get_wc_prop)
1320               SVN_ERR(ctx->sess->wc_callbacks->get_wc_prop(
1321                                                 ctx->sess->wc_callback_baton,
1331           handler = svn_ra_serf__create_handler(ctx->sess, file->pool);
1356           ctx->num_active_fetches++;
1364                                                    ctx->sess, file->url,
1365                                                    ctx->target_rev, "0",
1377       ctx->num_active_propfinds++;
1400   report_context_t *ctx = dir->ctx;
1409   SVN_ERR(ctx->editor->change_dir_prop(dir->dir_baton,
1430   dir->ctx->num_active_propfinds--;
1447   report_context_t *ctx = dir->ctx;
1451   if (ctx->sess->num_conns < ctx->sess->max_connections)
1452     SVN_ERR(open_connection_if_needed(ctx->sess, ctx->num_active_fetches +
1453                                                  ctx->num_active_propfinds));
1456   conn = get_best_connection(ctx);
1462                                                    ctx->sess, dir->url,
1463                                                    ctx->target_rev, "0",
1475       ctx->num_active_propfinds++;
1495   report_context_t *ctx = baton;
1508             ctx->add_props_included = TRUE;
1514               ctx->send_all_mode = TRUE;
1517               ctx->add_props_included = TRUE;
1533           SVN_ERR(create_dir_baton(&dir, ctx, name, scratch_pool));
1568               if (! ctx->add_props_included)
1580           SVN_ERR(create_file_baton(&file, ctx, svn_hash_gets(attrs, "name"),
1629               if (! ctx->send_all_mode)
1634               if (! ctx->add_props_included)
1642           file_baton_t *file = ctx->cur_file;
1649           if (! ctx->send_all_mode)
1662           SVN_ERR(open_file_txdelta(ctx->cur_file, scratch_pool));
1664           if (ctx->cur_file->txdelta != svn_delta_noop_window_handler)
1692           if (ctx->cur_file)
1693             ctx->cur_file->fetch_props = TRUE;
1694           else if (ctx->cur_dir)
1695             ctx->cur_dir->fetch_props = TRUE;
1714   report_context_t *ctx = baton;
1719         ctx->done = TRUE;
1728           SVN_ERR(ctx->editor->set_target_revision(ctx->editor_baton,
1735         if (ctx->cur_file)
1736           ctx->cur_file->url = apr_pstrdup(ctx->cur_file->pool, cdata->data);
1738           ctx->cur_dir->url = apr_pstrdup(ctx->cur_dir->pool, cdata->data);
1762           if (ctx->cur_file)
1764               file_baton_t *file = ctx->cur_file;
1767                   || ctx->add_props_included
1772                   SVN_ERR(ctx->editor->change_file_prop(file->file_baton,
1789               dir_baton_t *dir = ctx->cur_dir;
1792                   || ctx->add_props_included
1797                   SVN_ERR(ctx->editor->change_dir_prop(dir->dir_baton,
1818           dir_baton_t *dir = ctx->cur_dir;
1819           ctx->cur_dir = ctx->cur_dir->parent_dir;
1846           file_baton_t *file = ctx->cur_file;
1848           ctx->cur_file = NULL;
1877         SVN_ERR(svn_checksum_parse_hex(&ctx->cur_file->final_md5_checksum,
1880                                        ctx->cur_file->pool));
1885           file_baton_t *file = ctx->cur_file;
1903           if (! ctx->send_all_mode)
1914           SVN_ERR(ensure_dir_opened(ctx->cur_dir, scratch_pool));
1923           SVN_ERR(ctx->editor->delete_entry(
1924                                     svn_relpath_join(ctx->cur_dir->relpath,
1928                                     ctx->cur_dir->dir_baton,
1937           SVN_ERR(ensure_dir_opened(ctx->cur_dir, scratch_pool));
1939           SVN_ERR(ctx->editor->absent_directory(
1940                                     svn_relpath_join(ctx->cur_dir->relpath,
1942                                     ctx->cur_dir->dir_baton,
1950           SVN_ERR(ensure_dir_opened(ctx->cur_dir, scratch_pool));
1952           SVN_ERR(ctx->editor->absent_file(
1953                                     svn_relpath_join(ctx->cur_dir->relpath,
1955                                     ctx->cur_dir->dir_baton,
1962           file_baton_t *file = ctx->cur_file;
1992           if (ctx->cur_file)
1993             SVN_ERR(ensure_file_opened(ctx->cur_file, scratch_pool));
1994           else if (ctx->cur_dir)
1995             SVN_ERR(ensure_dir_opened(ctx->cur_dir, scratch_pool));
2014           if (ctx->cur_file)
2015             SVN_ERR(ctx->editor->change_file_prop(ctx->cur_file->file_baton,
2019             SVN_ERR(ctx->editor->change_dir_prop(ctx->cur_dir->dir_baton,
2039   report_context_t *ctx = baton;
2041   if (current_state == TXDELTA && ctx->cur_file
2042       && ctx->cur_file->txdelta_stream)
2044       SVN_ERR(svn_stream_write(ctx->cur_file->txdelta_stream, data, &len));
2395 process_editor_report(report_context_t *ctx,
2399   svn_ra_serf__session_t *sess = ctx->sess;
2407   ud->report = ctx;
2426          || ctx->num_active_fetches
2427          || ctx->num_active_propfinds
2428          || !ctx->done)
2461   if (ctx->done)
2462     SVN_ERR(ctx->editor->close_edit(ctx->editor_baton, iterpool));