fs/bcachefs/btree_write_buffer.c

138 	int ret;
144 	ret = bch2_btree_iter_traverse(iter);
145 	if (ret)
146 		return ret;
158 		ret = bch2_btree_node_lock_write(trans, path, &path->l[0].b->c);
159 		if (ret)
160 			return ret;
191 	int ret;
198 	ret   = bch2_btree_iter_traverse(&iter) ?:
202 	return ret;
262 	int ret = 0;
320 				ret = lockrestart_do(trans,
327 				if (ret)
343 				ret = -BCH_ERR_journal_reclaim_would_deadlock;
347 			ret = wb_flush_one(trans, &iter, k, &write_locked, &fast);
350 		} while (bch2_err_matches(ret, BCH_ERR_transaction_restart));
352 		if (!ret) {
354 		} else if (ret == -BCH_ERR_journal_reclaim_would_deadlock) {
356 			ret = 0;
367 	if (ret)
393 			ret = commit_do(trans, NULL, NULL,
400 			if (ret)
405 	bch2_fs_fatal_err_on(ret, c, "%s", bch2_err_str(ret));
409 	return ret;
416 	int ret = 0;
418 	while (!ret && (buf = bch2_next_write_buffer_flush_journal_buf(j, seq))) {
419 		ret = bch2_journal_keys_to_write_buffer(c, buf);
423 	return ret;
430 	int ret = 0, fetch_from_journal_err;
442 		ret = bch2_btree_write_buffer_flush_locked(trans);
444 	} while (!ret &&
449 	return ret;
473 	int ret = 0;
476 		ret = bch2_btree_write_buffer_flush_locked(trans);
480 	return ret;
490 	int ret = bch2_btree_write_buffer_flush_nocheck_rw(trans);
492 	return ret;
499 	int ret;
503 		ret = bch2_trans_run(c, bch2_btree_write_buffer_flush_locked(trans));
504 	} while (!ret && bch2_btree_write_buffer_should_flush(c));
515 	int ret;
517 	ret = darray_make_room_gfp(&dst->wb->keys, 1, GFP_KERNEL);
518 	if (!ret && dst->wb == &wb->flushing)
519 		ret = darray_resize(&wb->sorted, wb->flushing.keys.size);
521 	if (unlikely(ret)) {
530 		return ret;
601 	int ret = 0;
607 			ret = bch2_journal_key_to_wb(c, &dst, entry->btree_id, k);
608 			if (ret)
620 	return ret;
631 	int ret = darray_resize(&wb->keys, new_size);
633 	return ret;