subversion/libsvn_client/mtcc.c

100   mtcc_op_t *op;
102   op = apr_pcalloc(result_pool, sizeof(*op));
103   op->name = name ? apr_pstrdup(result_pool, name) : "";
106     op->kind = directory ? OP_ADD_DIR : OP_ADD_FILE;
108     op->kind = directory ? OP_OPEN_DIR : OP_OPEN_FILE;
111     op->children = apr_array_make(result_pool, 4, sizeof(mtcc_op_t *));
113   op->src_rev = SVN_INVALID_REVNUM;
115   return op;
119 mtcc_op_find(mtcc_op_t **op,
140         *op = base_op;
142         *op = NULL;
161           *op = NULL;
181                         mtcc_op_find(op, created, child ? child : "", cop,
189       *op = NULL;
202         *op = cop;
208                 mtcc_op_find(op, created, child, cop, find_existing,
220            mtcc_op_t *op,
229       if (op->kind == OP_ADD_DIR || op->kind == OP_ADD_FILE)
231       *origin_relpath = op->src_relpath
232                                 ? apr_pstrdup(result_pool, op->src_relpath)
234       *rev = op->src_rev;
247   if (op->children && op->children->nelts)
251       for (i = op->children->nelts-1; i >= 0; i--)
255            cop = APR_ARRAY_IDX(op->children, i, mtcc_op_t *);
277   if (op->kind == OP_ADD_DIR || op->kind == OP_ADD_FILE)
280       if (op->src_relpath)
282           *origin_relpath = svn_relpath_join(op->src_relpath, relpath,
284           *rev = op->src_rev;
366 update_copy_src(mtcc_op_t *op,
372   if (op->src_relpath)
373     op->src_relpath = svn_relpath_join(add_relpath, op->src_relpath,
376   if (!op->children)
379   for (i = 0; i < op->children->nelts; i++)
383       cop = APR_ARRAY_IDX(op->children, i, mtcc_op_t *);
449       mtcc_op_t *op;
451       SVN_ERR(mtcc_op_find(&op, NULL, new_relpath, mtcc->root_op, TRUE, FALSE,
454       if (op)
460       SVN_ERR(mtcc_op_find(&op, NULL, new_relpath, mtcc->root_op, TRUE, TRUE,
463       if (op)
488   mtcc_op_t *op;
497       op = mtcc->root_op;
501       SVN_ERR(mtcc_op_find(&op, &created, relpath, mtcc->root_op, FALSE, FALSE,
504       if (!op || !created)
512   op->kind = OP_ADD_FILE;
513   op->src_stream = src_stream;
514   op->src_checksum = src_checksum ? svn_checksum_dup(src_checksum, mtcc->pool)
527   mtcc_op_t *op;
555   SVN_ERR(mtcc_op_find(&op, &created, dst_relpath, mtcc->root_op, FALSE, FALSE,
558   if (!op || !created)
565   op->kind = (kind == svn_node_file) ? OP_ADD_FILE : OP_ADD_DIR;
566   op->src_relpath = apr_pstrdup(mtcc->pool, src_relpath);
567   op->src_rev = revision;
575 mtcc_op_contains_non_delete(const mtcc_op_t *op)
577   if (op->kind != OP_OPEN_DIR && op->kind != OP_OPEN_FILE
578       && op->kind != OP_DELETE)
583   if (op->prop_mods && op->prop_mods->nelts)
586   if (op->src_stream)
589   if (op->children)
593       for (i = 0; i < op->children->nelts; i++)
595           const mtcc_op_t *c_op = APR_ARRAY_IDX(op->children, i,
611   mtcc_op_t *op;
629       op = mtcc->root_op;
633       SVN_ERR(mtcc_op_find(&op, &created, relpath, mtcc->root_op, FALSE, TRUE,
636       if (!for_move && !op && !created)
641           SVN_ERR(mtcc_op_find(&op, &created, relpath, mtcc->root_op, TRUE,
644           if (op && mtcc_op_contains_non_delete(op))
645             op = NULL;
650       if (!op || !created)
658   op->kind = OP_DELETE;
659   op->children = NULL;
660   op->prop_mods = NULL;
678   mtcc_op_t *op;
692   SVN_ERR(mtcc_op_find(&op, &created, relpath, mtcc->root_op, FALSE, FALSE,
695   if (!op || !created)
702   op->kind = OP_ADD_DIR;
748   mtcc_op_t *op;
754   SVN_ERR(mtcc_op_find(&op, NULL, mpgb->relpath, mpgb->mtcc->root_op, TRUE,
757   if (op)
763           for (i = 0; op->prop_mods && i < op->prop_mods->nelts; i++)
765               const svn_prop_t *mod = &APR_ARRAY_IDX(op->prop_mods, i,
777       if (stream && op->src_stream)
783           err = svn_stream_mark(op->src_stream, &mark, pool);
791               err = svn_stream_copy3(svn_stream_disown(op->src_stream, pool),
798                             svn_stream_seek(op->src_stream, mark)));
832   mtcc_op_t *op;
894       op = mtcc->root_op;
898       SVN_ERR(mtcc_op_find(&op, NULL, relpath, mtcc->root_op, TRUE, FALSE,
901       if (!op)
917           SVN_ERR(mtcc_op_find(&op, &created, relpath, mtcc->root_op, TRUE, FALSE,
921           SVN_ERR_ASSERT(op != NULL);
925   if (!op->prop_mods)
926       op->prop_mods = apr_array_make(mtcc->pool, 4, sizeof(svn_prop_t));
937     APR_ARRAY_PUSH(op->prop_mods, svn_prop_t) = propchange;
952   mtcc_op_t *op;
965   SVN_ERR(mtcc_op_find(&op, &created, relpath, mtcc->root_op, TRUE, FALSE,
968   if (!op
969       || (op->kind != OP_OPEN_FILE && op->kind != OP_ADD_FILE)
970       || (op->src_stream != NULL))
976   op->src_stream = src_stream;
977   op->src_checksum = src_checksum ? svn_checksum_dup(src_checksum, mtcc->pool)
980   op->base_stream = base_stream;
981   op->base_checksum = base_checksum ? svn_checksum_dup(base_checksum,
997   mtcc_op_t *op;
1017   SVN_ERR(mtcc_op_find(&op, NULL, relpath, mtcc->root_op, TRUE, FALSE,
1020   if (!op || (check_repository && !op->performed_stat))
1032       if (op && *kind == svn_node_dir)
1034           if (op->kind == OP_OPEN_DIR || op->kind == OP_ADD_DIR)
1035             op->performed_stat = TRUE;
1036           else if (op->kind == OP_OPEN_FILE || op->kind == OP_ADD_FILE)
1042       else if (op && *kind == svn_node_file)
1044           if (op->kind == OP_OPEN_FILE || op->kind == OP_ADD_FILE)
1045             op->performed_stat = TRUE;
1046           else if (op->kind == OP_OPEN_DIR || op->kind == OP_ADD_DIR)
1052       else if (op && (op->kind == OP_OPEN_DIR || op->kind == OP_OPEN_FILE))
1062   /* op != NULL */
1063   if (op->kind == OP_OPEN_DIR || op->kind == OP_ADD_DIR)
1068   else if (op->kind == OP_OPEN_FILE || op->kind == OP_ADD_FILE)
1078                   const mtcc_op_t *op,
1085   if (!op->prop_mods || op->prop_mods->nelts == 0)
1089   for (i = 0; i < op->prop_mods->nelts; i++)
1091       const svn_prop_t *mod = &APR_ARRAY_IDX(op->prop_mods, i, svn_prop_t);
1095       if (op->kind == OP_ADD_DIR || op->kind == OP_OPEN_DIR)
1098       else if (op->kind == OP_ADD_FILE || op->kind == OP_OPEN_FILE)
1110             mtcc_op_t *op,
1118   svn_checksum_t *src_checksum = op->src_checksum;
1119   SVN_ERR(commit_properties(editor, op, file_baton, scratch_pool));
1121   if (op->src_stream)
1127       svn_stream_t *src_stream = op->src_stream;
1129       if (op->base_checksum && op->base_checksum->kind == svn_checksum_md5)
1130         base_checksum = svn_checksum_to_cstring(op->base_checksum, scratch_pool);
1160           if (!op->base_stream)
1165             SVN_ERR(svn_txdelta_run(op->base_stream, src_stream,
1173       if (op->base_stream)
1174         SVN_ERR(svn_stream_close(op->base_stream));
1187                  mtcc_op_t *op,
1195   SVN_ERR(commit_properties(editor, op, dir_baton, scratch_pool));
1197   if (op->children && op->children->nelts > 0)
1202       for (i = 0; i < op->children->nelts; i++)
1208           cop = APR_ARRAY_IDX(op->children, i, mtcc_op_t *);
1279 add_commit_items(mtcc_op_t *op,
1286   if ((op->kind != OP_OPEN_DIR && op->kind != OP_OPEN_FILE)
1287       || (op->prop_mods && op->prop_mods->nelts)
1288       || (op->src_stream))
1295       if (op->kind == OP_OPEN_DIR || op->kind == OP_ADD_DIR)
1297       else if (op->kind == OP_OPEN_FILE || op->kind == OP_ADD_FILE)
1306       if (op->src_relpath)
1309                                                            op->src_relpath,
1311           item->copyfrom_rev = op->src_rev;
1317       if (op->kind == OP_ADD_DIR || op->kind == OP_ADD_FILE)
1319       else if (op->kind == OP_DELETE)
1323       if (op->prop_mods && op->prop_mods->nelts)
1326       if (op->src_stream)
1332   if (op->children && op->children->nelts)
1337       for (i = 0; i < op->children->nelts; i++)
1342           cop = APR_ARRAY_IDX(op->children, i, mtcc_op_t *);