1 files changed, 141 insertions, 0 deletions
diff --git a/libbcache/super-io.h b/libbcache/super-io.h
new file mode 100644
index 00000000..1eda57bc
--- /dev/null
+++ b/libbcache/super-io.h
@@ -0,0 +1,141 @@
+#ifndef _BCACHE_SUPER_IO_H
+#define _BCACHE_SUPER_IO_H
+
+#include "extents.h"
+#include "super_types.h"
+
+#include <asm/byteorder.h>
+
+struct bch_sb_field *bch_sb_field_get(struct bch_sb *, enum bch_sb_field_types);
+
+#define BCH_SB_FIELD_TYPE(_name)				\
+static inline struct bch_sb_field_##_name *			\
+bch_sb_get_##_name(struct bch_sb *sb)				\
+{								\
+	struct bch_sb_field *f =				\
+		bch_sb_field_get(sb, BCH_SB_FIELD_##_name);	\
+								\
+	return container_of_or_null(f, struct bch_sb_field_##_name, field);\
+}
+
+BCH_SB_FIELD_TYPE(journal);
+BCH_SB_FIELD_TYPE(members);
+BCH_SB_FIELD_TYPE(crypt);
+
+static inline bool bch_sb_test_feature(struct bch_sb *sb,
+				       enum bch_sb_features f)
+{
+	unsigned w = f / 64;
+	unsigned b = f % 64;
+
+	return le64_to_cpu(sb->features[w]) & (1ULL << b);
+}
+
+static inline void bch_sb_set_feature(struct bch_sb *sb,
+				      enum bch_sb_features f)
+{
+	if (!bch_sb_test_feature(sb, f)) {
+		unsigned w = f / 64;
+		unsigned b = f % 64;
+
+		le64_add_cpu(&sb->features[w], 1ULL << b);
+	}
+}
+
+static inline __le64 bch_sb_magic(struct cache_set *c)
+{
+	__le64 ret;
+	memcpy(&ret, &c->sb.uuid, sizeof(ret));
+	return ret;
+}
+
+static inline __u64 jset_magic(struct cache_set *c)
+{
+	return __le64_to_cpu(bch_sb_magic(c) ^ JSET_MAGIC);
+}
+
+static inline __u64 pset_magic(struct cache_set *c)
+{
+	return __le64_to_cpu(bch_sb_magic(c) ^ PSET_MAGIC);
+}
+
+static inline __u64 bset_magic(struct cache_set *c)
+{
+	return __le64_to_cpu(bch_sb_magic(c) ^ BSET_MAGIC);
+}
+
+static inline struct cache_member_cpu cache_mi_to_cpu_mi(struct bch_member *mi)
+{
+	return (struct cache_member_cpu) {
+		.nbuckets	= le64_to_cpu(mi->nbuckets),
+		.first_bucket	= le16_to_cpu(mi->first_bucket),
+		.bucket_size	= le16_to_cpu(mi->bucket_size),
+		.state		= BCH_MEMBER_STATE(mi),
+		.tier		= BCH_MEMBER_TIER(mi),
+		.has_metadata	= BCH_MEMBER_HAS_METADATA(mi),
+		.has_data	= BCH_MEMBER_HAS_DATA(mi),
+		.replacement	= BCH_MEMBER_REPLACEMENT(mi),
+		.discard	= BCH_MEMBER_DISCARD(mi),
+		.valid		= !bch_is_zero(mi->uuid.b, sizeof(uuid_le)),
+	};
+}
+
+int bch_cache_set_mi_update(struct cache_set *, struct bch_member *, unsigned);
+
+int bch_sb_to_cache_set(struct cache_set *, struct bch_sb *);
+int bch_sb_from_cache_set(struct cache_set *, struct cache *);
+
+struct bch_sb_field *bch_fs_sb_field_resize(struct cache_set *,
+				struct bch_sb_field *, unsigned);
+struct bch_sb_field *bch_dev_sb_field_resize(struct bcache_superblock *,
+				struct bch_sb_field *, unsigned);
+
+void bch_free_super(struct bcache_superblock *);
+int bch_super_realloc(struct bcache_superblock *, unsigned);
+
+const char *bch_validate_cache_super(struct bcache_superblock *);
+
+const char *bch_read_super(struct bcache_superblock *,
+			   struct cache_set_opts, const char *);
+void bch_write_super(struct cache_set *);
+
+void bch_check_mark_super_slowpath(struct cache_set *,
+				   const struct bkey_i *, bool);
+
+#define cache_member_info_get(_c)					\
+	(rcu_read_lock(), rcu_dereference((_c)->members))
+
+#define cache_member_info_put()	rcu_read_unlock()
+
+static inline bool bch_check_super_marked(struct cache_set *c,
+					  const struct bkey_i *k, bool meta)
+{
+	struct bkey_s_c_extent e = bkey_i_to_s_c_extent(k);
+	const struct bch_extent_ptr *ptr;
+	struct cache_member_cpu *mi = cache_member_info_get(c)->m;
+	bool ret = true;
+
+	extent_for_each_ptr(e, ptr)
+		if (!ptr->cached &&
+		    !(meta
+		      ? mi[ptr->dev].has_metadata
+		      : mi[ptr->dev].has_data)) {
+			ret = false;
+			break;
+		}
+
+	cache_member_info_put();
+
+	return ret;
+}
+
+static inline void bch_check_mark_super(struct cache_set *c,
+					const struct bkey_i *k, bool meta)
+{
+	if (bch_check_super_marked(c, k, meta))
+		return;
+
+	bch_check_mark_super_slowpath(c, k, meta);
+}
+
+#endif /* _BCACHE_SUPER_IO_H */