subversion/libsvn_fs_base/lock.c

101   struct lock_args *args = baton;
106   *args->lock_p = NULL;
108   SVN_ERR(svn_fs_base__get_path_kind(&kind, args->path, trail, trail->pool));
113     return SVN_FS__ERR_NOT_FILE(trail->fs, args->path);
119       if (SVN_IS_VALID_REVNUM(args->current_rev))
123           args->path);
128           args->path);
136   if (SVN_IS_VALID_REVNUM(args->current_rev))
139       SVN_ERR(svn_fs_base__get_path_created_rev(&created_rev, args->path,
149                                  args->path);
151       if (args->current_rev < created_rev)
154                                  args->path);
161   if (args->token)
165                                               args->token, trail,
175           if (strcmp(lock_from_token->path, args->path) != 0)
191   SVN_ERR(svn_fs_base__get_lock_helper(&existing_lock, args->path,
195       if (! args->steal_lock)
211   lock = svn_lock_create(args->result_pool);
212   if (args->token)
213     lock->token = apr_pstrdup(args->result_pool, args->token);
216                                              args->result_pool));
217   lock->path = args->path; /* Already in result_pool. */
218   lock->owner = apr_pstrdup(args->result_pool, trail->fs->access_ctx->username);
219   lock->comment = apr_pstrdup(args->result_pool, args->comment);
220   lock->is_dav_comment = args->is_dav_comment;
222   lock->expiration_date = args->expiration_date;
223   SVN_ERR(add_lock_and_token(lock, lock->token, args->path, trail));
224   *(args->lock_p) = lock;
253       struct lock_args args;
260       args.lock_p = &lock;
261       args.path = svn_fs__canonicalize_abspath(path, result_pool);
262       args.token = target->token;
263       args.comment = comment;
264       args.is_dav_comment = is_dav_comment;
265       args.steal_lock = steal_lock;
266       args.expiration_date = expiration_date;
267       args.current_rev = target->current_rev;
268       args.result_pool = result_pool;
279         err = svn_fs_base__retry_txn(fs, txn_body_lock, &args, TRUE,
282         cb_err = lock_callback(lock_baton, args.path, lock, err, iterpool);
326   struct unlock_args *args = baton;
331   SVN_ERR(svn_fs_bdb__lock_token_get(&lock_token, trail->fs, args->path,
335   if (!args->break_lock)
338       if (args->token == NULL)
339         return svn_fs_base__err_no_lock_token(trail->fs, args->path);
340       else if (strcmp(lock_token, args->token) != 0)
341         return SVN_FS__ERR_NO_SUCH_LOCK(trail->fs, args->path);
359   return delete_lock_and_token(lock_token, args->path, trail);
380       struct unlock_args args;
386       args.path = svn_fs__canonicalize_abspath(path, result_pool);
387       args.token = token;
388       args.break_lock = break_lock;
390       err = svn_fs_base__retry_txn(fs, txn_body_unlock, &args, TRUE,
453   struct lock_token_get_args *args = baton;
454   return svn_fs_base__get_lock_helper(args->lock_p, args->path,
465   struct lock_token_get_args args;
469   args.path = svn_fs__canonicalize_abspath(path, pool);
470   args.lock_p = lock;
471   return svn_fs_base__retry_txn(fs, txn_body_get_lock, &args, FALSE, pool);
517   struct locks_get_args *args = baton;
518   return svn_fs_bdb__locks_get(trail->fs, args->path, args->depth,
519                                spool_locks_info, args->stream,
532   struct locks_get_args args;
540   args.path = svn_fs__canonicalize_abspath(path, pool);
541   args.depth = depth;
543   args.stream = svn_stream__from_spillbuf(svn_spillbuf__create(4 * 1024  /* blocksize */,
547   SVN_ERR(svn_fs_base__retry_txn(fs, txn_body_get_locks, &args, FALSE, pool));
550   stream = args.stream;