fs/bcachefs/journal.c

921 static int __bch2_set_nr_journal_buckets(struct bch_dev *ca, unsigned nr,
924 	struct bch_fs *c = ca->fs;
925 	struct journal_device *ja = &ca->journal;
945 			bu[nr_got] = bch2_bucket_alloc_new_fs(ca);
951 			ob[nr_got] = bch2_bucket_alloc(c, ca, BCH_WATERMARK_normal, cl);
957 				bch2_trans_mark_metadata_bucket(trans, ca,
959 						ca->mi.bucket_size));
1003 	ret = bch2_journal_buckets_to_sb(c, ca, new_buckets, nr);
1038 				bch2_trans_mark_metadata_bucket(trans, ca,
1056 int bch2_set_nr_journal_buckets(struct bch_fs *c, struct bch_dev *ca,
1059 	struct journal_device *ja = &ca->journal;
1086 						bucket_to_sector(ca, nr - ja->nr), 1, 0);
1090 		ret = __bch2_set_nr_journal_buckets(ca, nr, false, &cl);
1106 int bch2_dev_journal_alloc(struct bch_dev *ca)
1117 	nr = ca->mi.nbuckets >> 7;
1126 			 (1 << 24) / ca->mi.bucket_size));
1128 	ret = __bch2_set_nr_journal_buckets(ca, nr, true, NULL);
1130 	bch_err_fn(ca, ret);
1136 	for_each_online_member(c, ca) {
1137 		if (ca->journal.nr)
1140 		int ret = bch2_dev_journal_alloc(ca);
1142 			percpu_ref_put(&ca->io_ref);
1171 void bch2_dev_journal_stop(struct journal *j, struct bch_dev *ca)
1173 	wait_event(j->wait, !bch2_journal_writing_to_device(j, ca->dev_idx));
1285 void bch2_dev_journal_exit(struct bch_dev *ca)
1287 	struct journal_device *ja = &ca->journal;
1300 int bch2_dev_journal_init(struct bch_dev *ca, struct bch_sb *sb)
1302 	struct journal_device *ja = &ca->journal;
1331 		ja->bio[i]->ca = ca;
1482 	for_each_member_device_rcu(c, ca, &c->rw_devs[BCH_DATA_journal]) {
1483 		struct journal_device *ja = &ca->journal;
1485 		if (!test_bit(ca->dev_idx, c->rw_devs[BCH_DATA_journal].d))
1491 		prt_printf(out, "dev %u:\n",		ca->dev_idx);
1493 		prt_printf(out, "\tbucket size\t%u\n",	ca->mi.bucket_size);