summaryrefslogtreecommitdiff
path: root/libbcachefs/sb-errors.c
diff options
context:
space:
mode:
Diffstat (limited to 'libbcachefs/sb-errors.c')
-rw-r--r--libbcachefs/sb-errors.c45
1 files changed, 18 insertions, 27 deletions
diff --git a/libbcachefs/sb-errors.c b/libbcachefs/sb-errors.c
index 48853efd..41a259ea 100644
--- a/libbcachefs/sb-errors.c
+++ b/libbcachefs/sb-errors.c
@@ -110,75 +110,66 @@ void bch2_sb_error_count(struct bch_fs *c, enum bch_sb_error_id err)
};
unsigned i;
- mutex_lock(&c->fsck_error_counts_lock);
+ guard(mutex)(&c->fsck_error_counts_lock);
+
for (i = 0; i < e->nr; i++) {
if (err == e->data[i].id) {
e->data[i].nr++;
e->data[i].last_error_time = n.last_error_time;
- goto out;
+ return;
}
if (err < e->data[i].id)
break;
}
if (darray_make_room(e, 1))
- goto out;
+ return;
darray_insert_item(e, i, n);
-out:
- mutex_unlock(&c->fsck_error_counts_lock);
}
void bch2_sb_errors_from_cpu(struct bch_fs *c)
{
- bch_sb_errors_cpu *src = &c->fsck_error_counts;
- struct bch_sb_field_errors *dst;
- unsigned i;
-
- mutex_lock(&c->fsck_error_counts_lock);
-
- dst = bch2_sb_field_resize(&c->disk_sb, errors,
- bch2_sb_field_errors_u64s(src->nr));
+ guard(mutex)(&c->fsck_error_counts_lock);
+ bch_sb_errors_cpu *src = &c->fsck_error_counts;
+ struct bch_sb_field_errors *dst =
+ bch2_sb_field_resize(&c->disk_sb, errors,
+ bch2_sb_field_errors_u64s(src->nr));
if (!dst)
- goto err;
+ return;
- for (i = 0; i < src->nr; i++) {
+ for (unsigned i = 0; i < src->nr; i++) {
SET_BCH_SB_ERROR_ENTRY_ID(&dst->entries[i], src->data[i].id);
SET_BCH_SB_ERROR_ENTRY_NR(&dst->entries[i], src->data[i].nr);
dst->entries[i].last_error_time = cpu_to_le64(src->data[i].last_error_time);
}
-
-err:
- mutex_unlock(&c->fsck_error_counts_lock);
}
static int bch2_sb_errors_to_cpu(struct bch_fs *c)
{
+ guard(mutex)(&c->fsck_error_counts_lock);
+
struct bch_sb_field_errors *src = bch2_sb_field_get(c->disk_sb.sb, errors);
bch_sb_errors_cpu *dst = &c->fsck_error_counts;
- unsigned i, nr = bch2_sb_field_errors_nr_entries(src);
- int ret;
+ unsigned nr = bch2_sb_field_errors_nr_entries(src);
if (!nr)
return 0;
- mutex_lock(&c->fsck_error_counts_lock);
- ret = darray_make_room(dst, nr);
+ int ret = darray_make_room(dst, nr);
if (ret)
- goto err;
+ return ret;
dst->nr = nr;
- for (i = 0; i < nr; i++) {
+ for (unsigned i = 0; i < nr; i++) {
dst->data[i].id = BCH_SB_ERROR_ENTRY_ID(&src->entries[i]);
dst->data[i].nr = BCH_SB_ERROR_ENTRY_NR(&src->entries[i]);
dst->data[i].last_error_time = le64_to_cpu(src->entries[i].last_error_time);
}
-err:
- mutex_unlock(&c->fsck_error_counts_lock);
- return ret;
+ return 0;
}
void bch2_fs_sb_errors_exit(struct bch_fs *c)