fs/bcachefs/btree_trans_commit.c

214 	v = READ_ONCE(b->flags);
227 	} while ((v = cmpxchg(&b->flags, old, new)) != old);
286 		EBUG_ON(test_bit(BCH_FS_clean_shutdown, &c->flags));
318 		!(i->flags & BTREE_UPDATE_INTERNAL_SNAPSHOT_NODE) &&
319 		test_bit(JOURNAL_REPLAY_DONE, &trans->c->journal.flags) &&
325 						      unsigned flags)
328 				    trans->journal_u64s, flags);
357 btree_key_can_insert_cached_slowpath(struct btree_trans *trans, unsigned flags,
393 static int btree_key_can_insert_cached(struct btree_trans *trans, unsigned flags,
400 	unsigned watermark = flags & BCH_WATERMARK_MASK;
405 	    !test_bit(BKEY_CACHED_DIRTY, &ck->flags) &&
421 		return btree_key_can_insert_cached_slowpath(trans, flags, path, new_u64s);
436 			       unsigned flags)
446 	if (unlikely(flags & BTREE_TRIGGER_NORUN))
452 				BTREE_TRIGGER_INSERT|BTREE_TRIGGER_OVERWRITE|flags);
455 				bkey_i_to_s(new), flags) ?:
457 				old, flags);
475 	unsigned flags = i->flags|BTREE_TRIGGER_TRANSACTIONAL;
479 	if ((i->flags & BTREE_TRIGGER_NORUN) ||
490 					BTREE_TRIGGER_OVERWRITE|flags) ?: 1;
493 		return bch2_key_trigger_old(trans, i->btree_id, i->level, old, flags) ?: 1;
496 		return bch2_key_trigger_new(trans, i->btree_id, i->level, bkey_i_to_s(i->k), flags) ?: 1;
575 		BUG_ON(!(i->flags & BTREE_TRIGGER_NORUN) &&
593 			int ret = run_one_mem_trigger(trans, i, i->flags|BTREE_TRIGGER_GC);
603 bch2_trans_commit_write_locked(struct btree_trans *trans, unsigned flags,
623 	prefetch(&trans->c->journal.flags);
633 			: btree_key_can_insert_cached(trans, flags, trans->paths + i->path, u64s);
646 	if (likely(!(flags & BCH_TRANS_COMMIT_no_journal_res))) {
648 				(flags & BCH_WATERMARK_MASK)|
663 	    !(flags & BCH_TRANS_COMMIT_no_journal_res)) {
689 			ret = run_one_mem_trigger(trans, i, BTREE_TRIGGER_ATOMIC|i->flags);
700 	if (likely(!(flags & BCH_TRANS_COMMIT_no_journal_res))) {
708 			if (i->flags & BTREE_UPDATE_NOJOURNAL)
746 			bch2_btree_insert_key_cached(trans, flags, i);
769 						   enum bkey_invalid_flags flags,
784 	bch2_bkey_invalid(c, bkey_i_to_s_c(i->k), i->bkey_type, flags, err);
823 static inline int do_bch2_trans_commit(struct btree_trans *trans, unsigned flags,
841 							i->level, flags);
854 	ret = bch2_trans_commit_write_locked(trans, flags, stopped_at, trace_ip);
870 	if (likely(!(flags & BCH_TRANS_COMMIT_no_journal_res)))
887 int bch2_trans_commit_error(struct btree_trans *trans, unsigned flags,
892 	enum bch_watermark watermark = flags & BCH_WATERMARK_MASK;
896 		ret = bch2_btree_split_leaf(trans, i->path, flags);
910 		if ((flags & BCH_TRANS_COMMIT_journal_reclaim) &&
918 					(flags & BCH_WATERMARK_MASK)|
941 				(flags & BCH_TRANS_COMMIT_no_enospc), c,
948 bch2_trans_commit_get_rw_cold(struct btree_trans *trans, unsigned flags)
953 	if (likely(!(flags & BCH_TRANS_COMMIT_lazy_rw)) ||
954 	    test_bit(BCH_FS_started, &c->flags))
985 int __bch2_trans_commit(struct btree_trans *trans, unsigned flags)
1005 		if (!(flags & BCH_TRANS_COMMIT_no_journal_res))
1023 		if (!(flags & BCH_TRANS_COMMIT_no_journal_res))
1035 	if (unlikely(!test_bit(BCH_FS_may_go_rw, &c->flags))) {
1040 	if (!(flags & BCH_TRANS_COMMIT_no_check_rw) &&
1042 		ret = bch2_trans_commit_get_rw_cold(trans, flags);
1047 	EBUG_ON(test_bit(BCH_FS_clean_shutdown, &c->flags));
1068 		if (i->flags & BTREE_UPDATE_NOJOURNAL)
1082 				(flags & BCH_TRANS_COMMIT_no_enospc)
1090 	if (likely(!(flags & BCH_TRANS_COMMIT_no_journal_res)))
1093 	ret = do_bch2_trans_commit(trans, flags, &errored_at, _RET_IP_);
1103 	if (likely(!(flags & BCH_TRANS_COMMIT_no_check_rw)))
1112 	ret = bch2_trans_commit_error(trans, flags, errored_at, ret, _RET_IP_);
1123 	if (flags & BCH_TRANS_COMMIT_no_journal_res) {