1 // SPDX-License-Identifier: GPL-2.0
4 #include "journal_sb.h"
7 #include <linux/sort.h>
9 /* BCH_SB_FIELD_journal: */
11 static int u64_cmp(const void *_l, const void *_r)
16 return cmp_int(*l, *r);
19 static int bch2_sb_journal_validate(struct bch_sb *sb,
20 struct bch_sb_field *f,
23 struct bch_sb_field_journal *journal = field_to_type(f, journal);
24 struct bch_member m = bch2_sb_member_get(sb, sb->dev_idx);
25 int ret = -BCH_ERR_invalid_sb_journal;
30 nr = bch2_nr_journal_buckets(journal);
34 b = kmalloc_array(nr, sizeof(u64), GFP_KERNEL);
36 return -BCH_ERR_ENOMEM_sb_journal_validate;
38 for (i = 0; i < nr; i++)
39 b[i] = le64_to_cpu(journal->buckets[i]);
41 sort(b, nr, sizeof(u64), u64_cmp, NULL);
44 prt_printf(err, "journal bucket at sector 0");
48 if (b[0] < le16_to_cpu(m.first_bucket)) {
49 prt_printf(err, "journal bucket %llu before first bucket %u",
50 b[0], le16_to_cpu(m.first_bucket));
54 if (b[nr - 1] >= le64_to_cpu(m.nbuckets)) {
55 prt_printf(err, "journal bucket %llu past end of device (nbuckets %llu)",
56 b[nr - 1], le64_to_cpu(m.nbuckets));
60 for (i = 0; i + 1 < nr; i++)
61 if (b[i] == b[i + 1]) {
62 prt_printf(err, "duplicate journal buckets %llu", b[i]);
72 static void bch2_sb_journal_to_text(struct printbuf *out, struct bch_sb *sb,
73 struct bch_sb_field *f)
75 struct bch_sb_field_journal *journal = field_to_type(f, journal);
76 unsigned i, nr = bch2_nr_journal_buckets(journal);
78 prt_printf(out, "Buckets: ");
79 for (i = 0; i < nr; i++)
80 prt_printf(out, " %llu", le64_to_cpu(journal->buckets[i]));
84 const struct bch_sb_field_ops bch_sb_field_ops_journal = {
85 .validate = bch2_sb_journal_validate,
86 .to_text = bch2_sb_journal_to_text,
94 static int u64_range_cmp(const void *_l, const void *_r)
96 const struct u64_range *l = _l;
97 const struct u64_range *r = _r;
99 return cmp_int(l->start, r->start);
102 static int bch2_sb_journal_v2_validate(struct bch_sb *sb,
103 struct bch_sb_field *f,
104 struct printbuf *err)
106 struct bch_sb_field_journal_v2 *journal = field_to_type(f, journal_v2);
107 struct bch_member m = bch2_sb_member_get(sb, sb->dev_idx);
108 int ret = -BCH_ERR_invalid_sb_journal;
113 nr = bch2_sb_field_journal_v2_nr_entries(journal);
117 b = kmalloc_array(nr, sizeof(*b), GFP_KERNEL);
119 return -BCH_ERR_ENOMEM_sb_journal_v2_validate;
121 for (i = 0; i < nr; i++) {
122 b[i].start = le64_to_cpu(journal->d[i].start);
123 b[i].end = b[i].start + le64_to_cpu(journal->d[i].nr);
126 sort(b, nr, sizeof(*b), u64_range_cmp, NULL);
129 prt_printf(err, "journal bucket at sector 0");
133 if (b[0].start < le16_to_cpu(m.first_bucket)) {
134 prt_printf(err, "journal bucket %llu before first bucket %u",
135 b[0].start, le16_to_cpu(m.first_bucket));
139 if (b[nr - 1].end > le64_to_cpu(m.nbuckets)) {
140 prt_printf(err, "journal bucket %llu past end of device (nbuckets %llu)",
141 b[nr - 1].end - 1, le64_to_cpu(m.nbuckets));
145 for (i = 0; i + 1 < nr; i++) {
146 if (b[i].end > b[i + 1].start) {
147 prt_printf(err, "duplicate journal buckets in ranges %llu-%llu, %llu-%llu",
148 b[i].start, b[i].end, b[i + 1].start, b[i + 1].end);
159 static void bch2_sb_journal_v2_to_text(struct printbuf *out, struct bch_sb *sb,
160 struct bch_sb_field *f)
162 struct bch_sb_field_journal_v2 *journal = field_to_type(f, journal_v2);
163 unsigned i, nr = bch2_sb_field_journal_v2_nr_entries(journal);
165 prt_printf(out, "Buckets: ");
166 for (i = 0; i < nr; i++)
167 prt_printf(out, " %llu-%llu",
168 le64_to_cpu(journal->d[i].start),
169 le64_to_cpu(journal->d[i].start) + le64_to_cpu(journal->d[i].nr));
173 const struct bch_sb_field_ops bch_sb_field_ops_journal_v2 = {
174 .validate = bch2_sb_journal_v2_validate,
175 .to_text = bch2_sb_journal_v2_to_text,
178 int bch2_journal_buckets_to_sb(struct bch_fs *c, struct bch_dev *ca,
179 u64 *buckets, unsigned nr)
181 struct bch_sb_field_journal_v2 *j;
182 unsigned i, dst = 0, nr_compacted = 1;
185 lockdep_assert_held(&c->sb_lock);
188 bch2_sb_field_delete(&ca->disk_sb, BCH_SB_FIELD_journal);
189 bch2_sb_field_delete(&ca->disk_sb, BCH_SB_FIELD_journal_v2);
193 for (i = 0; i + 1 < nr; i++)
194 if (buckets[i] + 1 != buckets[i + 1])
197 j = bch2_sb_field_resize(&ca->disk_sb, journal_v2,
198 (sizeof(*j) + sizeof(j->d[0]) * nr_compacted) / sizeof(u64));
200 return -BCH_ERR_ENOSPC_sb_journal;
202 bch2_sb_field_delete(&ca->disk_sb, BCH_SB_FIELD_journal);
204 j->d[dst].start = cpu_to_le64(buckets[0]);
205 j->d[dst].nr = cpu_to_le64(1);
207 for (i = 1; i < nr; i++) {
208 if (buckets[i] == buckets[i - 1] + 1) {
209 le64_add_cpu(&j->d[dst].nr, 1);
212 j->d[dst].start = cpu_to_le64(buckets[i]);
213 j->d[dst].nr = cpu_to_le64(1);
217 BUG_ON(dst + 1 != nr_compacted);