mirror of
https://github.com/linux-apfs/linux-apfs-rw.git
synced 2026-08-18 02:19:59 -07:00
Compare commits
No files matched your search
@@ -9,3 +9,4 @@
|
||||
*.a
|
||||
*.mod
|
||||
tags
|
||||
version.h
|
||||
@@ -14,8 +14,10 @@ apfs-y := btree.o compress.o dir.o extents.o file.o inode.o key.o libzbitmap.o \
|
||||
spaceman.o super.o symlink.o transaction.o unicode.o xattr.o xfield.o
|
||||
|
||||
default:
|
||||
./genver.sh
|
||||
make -C $(KERNEL_DIR) M=$(PWD)
|
||||
install:
|
||||
make -C $(KERNEL_DIR) M=$(PWD) modules_install
|
||||
clean:
|
||||
rm -f version.h
|
||||
make -C $(KERNEL_DIR) M=$(PWD) clean
|
||||
@@ -13,8 +13,6 @@
|
||||
#include <linux/version.h>
|
||||
#include "apfs_raw.h"
|
||||
|
||||
#define APFS_MODULE_ID_STRING "linux-apfs by EA Fernández"
|
||||
|
||||
#define EFSBADCRC EBADMSG /* Bad CRC detected */
|
||||
#define EFSCORRUPTED EUCLEAN /* Filesystem is corrupted */
|
||||
|
||||
@@ -124,7 +122,7 @@ static inline bool apfs_node_has_fixed_kv_size(struct apfs_node *node)
|
||||
struct apfs_spaceman {
|
||||
struct apfs_spaceman_phys *sm_raw; /* On-disk spaceman structure */
|
||||
struct buffer_head *sm_bh; /* Buffer head for @sm_raw */
|
||||
struct buffer_head *sm_ip; /* Current internal pool */
|
||||
struct apfs_nxsb_info *sm_nxi; /* Container superblock */
|
||||
|
||||
u32 sm_blocks_per_chunk; /* Blocks covered by a bitmap block */
|
||||
u32 sm_chunks_per_cib; /* Chunk count in a chunk-info block */
|
||||
@@ -140,6 +138,15 @@ struct apfs_spaceman {
|
||||
*/
|
||||
u64 sm_free_cache_base;
|
||||
u64 sm_free_cache_blkcnt;
|
||||
|
||||
/* Shift to match an ip block with its bitmap in the array */
|
||||
int sm_ip_bmaps_shift;
|
||||
/* Mask to find an ip block's offset inside its ip bitmap */
|
||||
u32 sm_ip_bmaps_mask;
|
||||
/* Number of ip bitmaps */
|
||||
u32 sm_ip_bmaps_count;
|
||||
/* List of ip bitmaps, in order */
|
||||
struct buffer_head *sm_ip_bmaps[];
|
||||
};
|
||||
|
||||
#define TRANSACTION_MAIN_QUEUE_MAX 4096
|
||||
@@ -219,7 +226,7 @@ struct apfs_nxsb_info {
|
||||
unsigned long nx_blocksize;
|
||||
unsigned char nx_blocksize_bits;
|
||||
|
||||
struct apfs_spaceman nx_spaceman;
|
||||
struct apfs_spaceman *nx_spaceman;
|
||||
struct apfs_nx_transaction nx_transaction;
|
||||
|
||||
/* For now, a single semaphore for every operation */
|
||||
@@ -283,6 +290,8 @@ struct apfs_sb_info {
|
||||
struct list_head list; /* List of mounted volumes in container */
|
||||
struct apfs_superblock *s_vsb_raw; /* On-disk volume sb */
|
||||
|
||||
dev_t s_anon_dev; /* Anonymous device for this volume-snapshot */
|
||||
|
||||
char *s_snap_name; /* Label for the mounted snapshot */
|
||||
u64 s_snap_xid; /* Transaction id for mounted snapshot */
|
||||
|
||||
@@ -299,6 +308,7 @@ struct apfs_sb_info {
|
||||
struct apfs_crypto_state_val *s_dflt_pfk; /* default per-file key */
|
||||
|
||||
struct apfs_vol_transaction s_transaction;
|
||||
int s_trans_buffers_max;
|
||||
|
||||
struct inode *s_private_dir; /* Inode for the private directory */
|
||||
};
|
||||
@@ -319,8 +329,10 @@ static inline bool apfs_is_sealed(struct super_block *sb)
|
||||
* apfs_vol_is_encrypted - Check if a volume is encrypting files
|
||||
* @sb: superblock
|
||||
*/
|
||||
static inline bool apfs_vol_is_encrypted(struct super_block *sb) {
|
||||
static inline bool apfs_vol_is_encrypted(struct super_block *sb)
|
||||
{
|
||||
struct apfs_superblock *vsb_raw = APFS_SB(sb)->s_vsb_raw;
|
||||
|
||||
return (vsb_raw->apfs_fs_flags & cpu_to_le64(APFS_FS_UNENCRYPTED)) == 0;
|
||||
}
|
||||
|
||||
@@ -339,7 +351,7 @@ static inline struct apfs_nxsb_info *APFS_NXI(struct super_block *sb)
|
||||
*/
|
||||
static inline struct apfs_spaceman *APFS_SM(struct super_block *sb)
|
||||
{
|
||||
return &APFS_NXI(sb)->nx_spaceman;
|
||||
return APFS_NXI(sb)->nx_spaceman;
|
||||
}
|
||||
|
||||
static inline bool apfs_is_case_insensitive(struct super_block *sb)
|
||||
@@ -611,7 +623,7 @@ static inline u64 apfs_cat_cnid(struct apfs_key_header *key)
|
||||
*/
|
||||
struct apfs_query {
|
||||
struct apfs_node *node; /* Node being searched */
|
||||
struct apfs_key *key; /* What the query is looking for */
|
||||
struct apfs_key key; /* What the query is looking for */
|
||||
|
||||
struct apfs_query *parent; /* Query for parent node */
|
||||
unsigned int flags;
|
||||
@@ -646,7 +658,9 @@ static inline u32 apfs_query_storage(struct apfs_query *query)
|
||||
return APFS_OBJ_PHYSICAL;
|
||||
if (query->flags & APFS_QUERY_OMAP_SNAP)
|
||||
return APFS_OBJ_PHYSICAL;
|
||||
BUG();
|
||||
|
||||
/* Absurd, but don't panic: let the callers fail and report it */
|
||||
return -1;
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -774,6 +788,15 @@ struct apfs_xattr {
|
||||
bool has_dstream;
|
||||
};
|
||||
|
||||
struct apfs_compressed_data {
|
||||
bool has_dstream;
|
||||
u64 size;
|
||||
union {
|
||||
struct apfs_dstream_info *dstream;
|
||||
void *data;
|
||||
};
|
||||
};
|
||||
|
||||
/*
|
||||
* Report function name and line number for the message types that are likely
|
||||
* to signal a bug, to make things easier for reporters. Don't do this for the
|
||||
@@ -788,7 +811,7 @@ struct apfs_xattr {
|
||||
#define apfs_info(sb, fmt, ...) apfs_msg(sb, KERN_INFO, NULL, 0, fmt, ##__VA_ARGS__)
|
||||
|
||||
#ifdef CONFIG_APFS_DEBUG
|
||||
#define ASSERT(expr) BUG_ON(!(expr))
|
||||
#define ASSERT(expr) WARN_ON(!(expr))
|
||||
#define apfs_debug(sb, fmt, ...) apfs_msg(sb, KERN_DEBUG, __func__, __LINE__, fmt, ##__VA_ARGS__)
|
||||
#else
|
||||
#define ASSERT(expr) ((void)0)
|
||||
@@ -808,15 +831,17 @@ do { \
|
||||
} while (0)
|
||||
|
||||
/* btree.c */
|
||||
extern struct apfs_node *apfs_query_root(const struct apfs_query *query);
|
||||
extern struct apfs_query *apfs_alloc_query(struct apfs_node *node,
|
||||
struct apfs_query *parent);
|
||||
extern void apfs_free_query(struct apfs_query *query);
|
||||
extern int apfs_btree_query(struct super_block *sb, struct apfs_query **query);
|
||||
extern int apfs_omap_lookup_block(struct super_block *sb, struct apfs_omap *omap,
|
||||
u64 id, u64 *block, bool write);
|
||||
extern int apfs_omap_lookup_block(struct super_block *sb, struct apfs_omap *omap, u64 id, u64 *block, bool write);
|
||||
extern int apfs_omap_lookup_newest_block(struct super_block *sb, struct apfs_omap *omap, u64 id, u64 *block, bool write);
|
||||
extern int apfs_create_omap_rec(struct super_block *sb, u64 oid, u64 bno);
|
||||
extern int apfs_delete_omap_rec(struct super_block *sb, u64 oid);
|
||||
extern int apfs_query_join_transaction(struct apfs_query *query);
|
||||
extern int __apfs_btree_insert(struct apfs_query *query, void *key, int key_len, void *val, int val_len);
|
||||
extern int apfs_btree_insert(struct apfs_query *query, void *key, int key_len,
|
||||
void *val, int val_len);
|
||||
extern int apfs_btree_remove(struct apfs_query *query);
|
||||
@@ -891,8 +916,11 @@ extern loff_t apfs_remap_file_range(struct file *src_file, loff_t off, struct fi
|
||||
extern int apfs_clone_file_range(struct file *src_file, loff_t off, struct file *dst_file, loff_t destoff, u64 len);
|
||||
#endif
|
||||
extern int apfs_clone_extents(struct apfs_dstream_info *dstream, u64 new_id);
|
||||
extern int apfs_nonsparse_dstream_read(struct apfs_dstream_info *dstream, void *buf, size_t count, u64 offset);
|
||||
extern void apfs_nonsparse_dstream_preread(struct apfs_dstream_info *dstream);
|
||||
|
||||
/* file.c */
|
||||
extern int apfs_file_mmap(struct file *file, struct vm_area_struct *vma);
|
||||
extern int apfs_fsync(struct file *file, loff_t start, loff_t end, int datasync);
|
||||
|
||||
/* inode.c */
|
||||
@@ -920,7 +948,11 @@ extern int apfs_setattr(struct mnt_idmap *idmap,
|
||||
struct dentry *dentry, struct iattr *iattr);
|
||||
#endif
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
extern int apfs_update_time(struct inode *inode, struct timespec64 *time, int flags);
|
||||
#else
|
||||
extern int apfs_update_time(struct inode *inode, int flags);
|
||||
#endif
|
||||
long apfs_dir_ioctl(struct file *file, unsigned int cmd, unsigned long arg);
|
||||
long apfs_file_ioctl(struct file *file, unsigned int cmd, unsigned long arg);
|
||||
|
||||
@@ -969,7 +1001,7 @@ extern __printf(5, 6) void apfs_msg(struct super_block *sb, const char *prefix,
|
||||
extern struct apfs_node *apfs_read_node(struct super_block *sb, u64 oid,
|
||||
u32 storage, bool write);
|
||||
extern void apfs_update_node(struct apfs_node *node);
|
||||
extern int apfs_delete_node(struct apfs_query *query);
|
||||
extern int apfs_delete_node(struct apfs_node *node, int type);
|
||||
extern int apfs_node_query(struct super_block *sb, struct apfs_query *query);
|
||||
extern void apfs_node_query_first(struct apfs_query *query);
|
||||
extern int apfs_omap_map_from_query(struct apfs_query *query, struct apfs_omap_map *map);
|
||||
@@ -977,6 +1009,7 @@ extern int apfs_node_split(struct apfs_query *query);
|
||||
extern int apfs_node_locate_key(struct apfs_node *node, int index, int *off);
|
||||
extern void apfs_node_free(struct apfs_node *node);
|
||||
extern void apfs_node_free_range(struct apfs_node *node, u16 off, u16 len);
|
||||
extern bool apfs_node_has_room(struct apfs_node *node, int length, bool replace);
|
||||
extern int apfs_node_replace(struct apfs_query *query, void *key, int key_len, void *val, int val_len);
|
||||
extern int apfs_node_insert(struct apfs_query *query, void *key, int key_len, void *val, int val_len);
|
||||
extern int apfs_create_single_rec_node(struct apfs_query *query, void *key, int key_len, void *val, int val_len);
|
||||
@@ -1033,6 +1066,9 @@ extern int apfs_xattr_set(struct inode *inode, const char *name, const void *val
|
||||
size_t size, int flags);
|
||||
extern int APFS_XATTR_SET_MAXOPS(void);
|
||||
extern ssize_t apfs_listxattr(struct dentry *dentry, char *buffer, size_t size);
|
||||
extern int apfs_xattr_get_compressed_data(struct inode *inode, const char *name, struct apfs_compressed_data *cdata);
|
||||
extern void apfs_release_compressed_data(struct apfs_compressed_data *cdata);
|
||||
extern int apfs_compressed_data_read(struct apfs_compressed_data *cdata, void *buf, size_t count, u64 offset);
|
||||
|
||||
/* xfield.c */
|
||||
extern int apfs_find_xfield(u8 *xfields, int len, u8 xtype, char **xval);
|
||||
@@ -1046,6 +1082,7 @@ extern int apfs_insert_xfield(u8 *buffer, int buflen,
|
||||
*/
|
||||
|
||||
/* compress.c */
|
||||
extern const struct address_space_operations apfs_compress_aops;
|
||||
extern const struct file_operations apfs_compress_file_operations;
|
||||
|
||||
/* dir.c */
|
||||
@@ -1066,6 +1103,18 @@ extern const struct inode_operations apfs_symlink_inode_operations;
|
||||
/* xattr.c */
|
||||
extern const struct xattr_handler *apfs_xattr_handlers[];
|
||||
|
||||
/**
|
||||
* apfs_assert_query_is_valid - Assert that all of a query's ancestors are set
|
||||
* @query: the query to check
|
||||
*
|
||||
* A query may lose some of its ancestors during a node split, but nothing
|
||||
* should be done to such a query until it gets refreshed.
|
||||
*/
|
||||
static inline void apfs_assert_query_is_valid(const struct apfs_query *query)
|
||||
{
|
||||
ASSERT(apfs_node_is_root(apfs_query_root(query)));
|
||||
}
|
||||
|
||||
/*
|
||||
* TODO: the following are modified variants of buffer head functions that will
|
||||
* work with the shared block device for the container. The correct approach
|
||||
@@ -1093,7 +1142,11 @@ apfs_getblk(struct super_block *sb, sector_t block)
|
||||
{
|
||||
struct buffer_head *bh;
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
bh = __getblk_gfp(APFS_NXI(sb)->nx_bdev, block, sb->s_blocksize, __GFP_MOVABLE);
|
||||
#else
|
||||
bh = bdev_getblk(APFS_NXI(sb)->nx_bdev, block, sb->s_blocksize, __GFP_MOVABLE);
|
||||
#endif
|
||||
if (bh)
|
||||
set_buffer_uptodate(bh);
|
||||
return bh;
|
||||
|
||||
+14
-14
@@ -306,7 +306,7 @@ struct apfs_wrapped_crypto_state {
|
||||
__le32 key_os_version;
|
||||
__le16 key_revision;
|
||||
__le16 key_len;
|
||||
u8 persistent_key[0];
|
||||
u8 persistent_key[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -503,7 +503,7 @@ struct apfs_dir_stats_val {
|
||||
struct apfs_sibling_val {
|
||||
__le64 parent_id;
|
||||
__le16 name_len;
|
||||
u8 name[0];
|
||||
u8 name[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -622,7 +622,7 @@ enum {
|
||||
struct apfs_drec_key {
|
||||
struct apfs_key_header hdr;
|
||||
__le16 name_len;
|
||||
u8 name[0];
|
||||
u8 name[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -632,7 +632,7 @@ struct apfs_drec_key {
|
||||
struct apfs_drec_hashed_key {
|
||||
struct apfs_key_header hdr;
|
||||
__le32 name_len_and_hash;
|
||||
u8 name[0];
|
||||
u8 name[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -641,7 +641,7 @@ struct apfs_drec_hashed_key {
|
||||
struct apfs_xattr_key {
|
||||
struct apfs_key_header hdr;
|
||||
__le16 name_len;
|
||||
u8 name[0];
|
||||
u8 name[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -660,7 +660,7 @@ struct apfs_snap_metadata_key {
|
||||
struct apfs_snap_name_key {
|
||||
struct apfs_key_header hdr;
|
||||
__le16 name_len;
|
||||
u8 name[0];
|
||||
u8 name[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -1278,7 +1278,7 @@ enum {
|
||||
struct apfs_xattr_val {
|
||||
__le16 flags;
|
||||
__le16 xdata_len;
|
||||
u8 xdata[0];
|
||||
u8 xdata[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -1372,7 +1372,7 @@ struct apfs_file_info_key {
|
||||
struct apfs_file_data_hash_val {
|
||||
__le16 hashed_len;
|
||||
u8 hash_size;
|
||||
u8 hash[0];
|
||||
u8 hash[];
|
||||
} __packed;
|
||||
|
||||
#define APFS_FILE_INFO_DATA_HASH 1
|
||||
@@ -1435,7 +1435,7 @@ struct apfs_compress_rsrc_data {
|
||||
struct apfs_compress_rsrc_block {
|
||||
__le32 offs;
|
||||
__le32 size;
|
||||
} __packed block[0];
|
||||
} __packed block[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -1456,7 +1456,7 @@ struct apfs_snap_metadata_val {
|
||||
__le32 extentref_tree_type;
|
||||
__le32 flags;
|
||||
__le16 name_len;
|
||||
u8 name[0];
|
||||
u8 name[];
|
||||
} __packed;
|
||||
|
||||
/*
|
||||
@@ -1475,7 +1475,7 @@ struct apfs_snap_meta_ext {
|
||||
__le32 sme_version;
|
||||
__le32 sme_flags;
|
||||
__le64 sme_snap_xid;
|
||||
char sme_uuid[UUID_SIZE];
|
||||
char sme_uuid[UUID_SIZE];
|
||||
__le64 sme_token;
|
||||
} __packed;
|
||||
|
||||
@@ -1503,11 +1503,11 @@ enum {
|
||||
* Structure of a single entry in the keybag
|
||||
*/
|
||||
struct apfs_keybag_entry {
|
||||
char ke_uuid[UUID_SIZE];
|
||||
char ke_uuid[UUID_SIZE];
|
||||
__le16 ke_tag;
|
||||
__le16 ke_keylen;
|
||||
__le32 padding;
|
||||
u8 ke_keydata[0];
|
||||
u8 ke_keydata[];
|
||||
} __packed;
|
||||
|
||||
#define APFS_KEYBAG_VERSION 2
|
||||
@@ -1520,7 +1520,7 @@ struct apfs_kb_locker {
|
||||
__le16 kl_nkeys;
|
||||
__le32 kl_nbytes;
|
||||
__le64 padding;
|
||||
struct apfs_keybag_entry kl_entries[0];
|
||||
struct apfs_keybag_entry kl_entries[];
|
||||
} __packed;
|
||||
|
||||
#endif /* _APFS_RAW_H */
|
||||
+318
-358
File diff suppressed because it is too large.
Load diff
@@ -99,24 +99,25 @@ static struct apfs_query *apfs_dentry_lookup(struct inode *dir,
|
||||
{
|
||||
struct super_block *sb = dir->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
u64 cnid = apfs_ino(dir);
|
||||
bool hashed = apfs_is_normalization_insensitive(sb);
|
||||
int err;
|
||||
|
||||
apfs_init_drec_key(sb, cnid, child->name, child->len, &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return ERR_PTR(-ENOMEM);
|
||||
query->key = &key;
|
||||
apfs_init_drec_key(sb, cnid, child->name, child->len, &query->key);
|
||||
|
||||
/*
|
||||
* Distinct filenames in the same directory may (rarely) share the same
|
||||
* hash. The query code cannot handle that because their order in the
|
||||
* b-tree would depend on their unnormalized original names. Just get
|
||||
* hash. The query code cannot handle that because their order in the
|
||||
* b-tree would depend on their unnormalized original names. Just get
|
||||
* all the candidates and check them one by one.
|
||||
*
|
||||
* This is very wasteful for normalization-sensitive filesystems: there
|
||||
* are no hashes so we just check every single file in the directory for
|
||||
* no reason. This would be easy to avoid but does it matter? (TODO)
|
||||
*/
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_ANY_NAME | APFS_QUERY_EXACT;
|
||||
do {
|
||||
@@ -128,6 +129,14 @@ static struct apfs_query *apfs_dentry_lookup(struct inode *dir,
|
||||
goto fail;
|
||||
} while (unlikely(apfs_filename_cmp(sb, child->name, child->len, drec->name, drec->name_len)));
|
||||
|
||||
/*
|
||||
* We may need to refresh the query later, but the refresh code doesn't
|
||||
* know how to deal with hash collisions. Instead set the key to the
|
||||
* unnormalized name and pretend that this was never a multiple query
|
||||
* in the first place.
|
||||
*/
|
||||
query->key.name = drec->name;
|
||||
query->flags &= ~(APFS_QUERY_MULTIPLE | APFS_QUERY_DONE | APFS_QUERY_NEXT);
|
||||
return query;
|
||||
|
||||
fail:
|
||||
@@ -173,7 +182,6 @@ static int apfs_readdir(struct file *file, struct dir_context *ctx)
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
u64 cnid = apfs_ino(inode);
|
||||
loff_t pos;
|
||||
@@ -193,8 +201,7 @@ static int apfs_readdir(struct file *file, struct dir_context *ctx)
|
||||
}
|
||||
|
||||
/* We want all the children for the cnid, regardless of the name */
|
||||
apfs_init_drec_key(sb, cnid, NULL /* name */, 0 /* name_len */, &key);
|
||||
query->key = &key;
|
||||
apfs_init_drec_key(sb, cnid, NULL /* name */, 0 /* name_len */, &query->key);
|
||||
query->flags = APFS_QUERY_CAT | APFS_QUERY_MULTIPLE | APFS_QUERY_EXACT;
|
||||
|
||||
pos = ctx->pos - 2;
|
||||
@@ -361,7 +368,6 @@ static int apfs_create_dentry_rec(struct inode *inode, struct qstr *qname,
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
void *raw_key = NULL;
|
||||
struct apfs_drec_val *raw_val = NULL;
|
||||
@@ -369,21 +375,20 @@ static int apfs_create_dentry_rec(struct inode *inode, struct qstr *qname,
|
||||
bool hashed = apfs_is_normalization_insensitive(sb);
|
||||
int ret;
|
||||
|
||||
apfs_init_drec_key(sb, parent_id, qname->name, qname->len, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_drec_key(sb, parent_id, qname->name, qname->len, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
if (ret && ret != -ENODATA) {
|
||||
apfs_err(sb, "query failed in dir 0x%llx (hash 0x%llx)", parent_id, key.number);
|
||||
apfs_err(sb, "query failed in dir 0x%llx (hash 0x%llx)", parent_id, query->key.number);
|
||||
goto fail;
|
||||
}
|
||||
|
||||
if (hashed)
|
||||
key_len = apfs_build_dentry_hashed_key(qname, key.number, parent_id,
|
||||
key_len = apfs_build_dentry_hashed_key(qname, query->key.number, parent_id,
|
||||
(struct apfs_drec_hashed_key **)&raw_key);
|
||||
else
|
||||
key_len = apfs_build_dentry_unhashed_key(qname, parent_id,
|
||||
@@ -401,7 +406,7 @@ static int apfs_create_dentry_rec(struct inode *inode, struct qstr *qname,
|
||||
/* TODO: deal with hash collisions */
|
||||
ret = apfs_btree_insert(query, raw_key, key_len, raw_val, val_len);
|
||||
if (ret)
|
||||
apfs_err(sb, "insertion failed in dir 0x%llx (hash 0x%llx)", parent_id, key.number);
|
||||
apfs_err(sb, "insertion failed in dir 0x%llx (hash 0x%llx)", parent_id, query->key.number);
|
||||
|
||||
fail:
|
||||
kfree(raw_val);
|
||||
@@ -453,18 +458,16 @@ static int apfs_create_sibling_link_rec(struct dentry *dentry,
|
||||
{
|
||||
struct super_block *sb = dentry->d_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_sibling_link_key raw_key;
|
||||
struct apfs_sibling_val *raw_val;
|
||||
int val_len;
|
||||
int ret;
|
||||
|
||||
apfs_init_sibling_link_key(apfs_ino(inode), sibling_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_sibling_link_key(apfs_ino(inode), sibling_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -503,17 +506,15 @@ static int apfs_create_sibling_map_rec(struct dentry *dentry,
|
||||
{
|
||||
struct super_block *sb = dentry->d_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_sibling_map_key raw_key;
|
||||
struct apfs_sibling_map_val raw_val;
|
||||
int ret;
|
||||
|
||||
apfs_init_sibling_map_key(sibling_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_sibling_map_key(sibling_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -601,7 +602,13 @@ static int apfs_create_dentry(struct dentry *dentry, struct inode *inode)
|
||||
}
|
||||
|
||||
/* Now update the parent inode */
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
parent->i_mtime = parent->i_ctime = current_time(inode);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
parent->i_mtime = inode_set_ctime_current(parent);
|
||||
#else
|
||||
inode_set_mtime_to_ts(parent, inode_set_ctime_current(parent));
|
||||
#endif
|
||||
++APFS_I(parent)->i_nchildren;
|
||||
apfs_inode_join_transaction(parent->i_sb, parent);
|
||||
return 0;
|
||||
@@ -841,7 +848,11 @@ static int __apfs_link(struct dentry *old_dentry, struct dentry *dentry)
|
||||
|
||||
/* First update the inode's link count */
|
||||
inc_nlink(inode);
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode->i_ctime = current_time(inode);
|
||||
#else
|
||||
inode_set_ctime_current(inode);
|
||||
#endif
|
||||
apfs_inode_join_transaction(inode->i_sb, inode);
|
||||
|
||||
if (inode->i_nlink == 2) {
|
||||
@@ -915,17 +926,15 @@ static int apfs_delete_sibling_link_rec(struct dentry *dentry, u64 sibling_id)
|
||||
struct super_block *sb = dentry->d_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct inode *inode = d_inode(dentry);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
int ret;
|
||||
|
||||
ASSERT(sibling_id);
|
||||
|
||||
apfs_init_sibling_link_key(apfs_ino(inode), sibling_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_sibling_link_key(apfs_ino(inode), sibling_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -958,17 +967,15 @@ static int apfs_delete_sibling_map_rec(struct dentry *dentry, u64 sibling_id)
|
||||
{
|
||||
struct super_block *sb = dentry->d_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
int ret;
|
||||
|
||||
ASSERT(sibling_id);
|
||||
|
||||
apfs_init_sibling_map_key(sibling_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_sibling_map_key(sibling_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1030,7 +1037,13 @@ static int apfs_delete_dentry(struct dentry *dentry)
|
||||
}
|
||||
|
||||
/* Now update the parent inode */
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
parent->i_mtime = parent->i_ctime = current_time(parent);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
parent->i_mtime = inode_set_ctime_current(parent);
|
||||
#else
|
||||
inode_set_mtime_to_ts(parent, inode_set_ctime_current(parent));
|
||||
#endif
|
||||
--APFS_I(parent)->i_nchildren;
|
||||
apfs_inode_join_transaction(sb, parent);
|
||||
return err;
|
||||
@@ -1107,18 +1120,14 @@ static int apfs_find_primary_link(struct inode *inode, char **name, u64 *parent)
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
int err;
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
|
||||
apfs_init_sibling_link_key(apfs_ino(inode), 0 /* sibling_id */, &key);
|
||||
query->key = &key;
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_ANY_NUMBER |
|
||||
APFS_QUERY_EXACT;
|
||||
apfs_init_sibling_link_key(apfs_ino(inode), 0 /* sibling_id */, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_ANY_NUMBER | APFS_QUERY_EXACT;
|
||||
|
||||
/* The primary link is the one with the lowest sibling id */
|
||||
*name = NULL;
|
||||
@@ -1194,7 +1203,13 @@ static int apfs_create_orphan_link(struct inode *inode)
|
||||
}
|
||||
|
||||
/* Now update the child count for private-dir */
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
priv_dir->i_mtime = priv_dir->i_ctime = current_time(priv_dir);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
priv_dir->i_mtime = inode_set_ctime_current(priv_dir);
|
||||
#else
|
||||
inode_set_mtime_to_ts(priv_dir, inode_set_ctime_current(priv_dir));
|
||||
#endif
|
||||
++APFS_I(priv_dir)->i_nchildren;
|
||||
apfs_inode_join_transaction(sb, priv_dir);
|
||||
|
||||
@@ -1239,7 +1254,13 @@ int apfs_delete_orphan_link(struct inode *inode)
|
||||
}
|
||||
|
||||
/* Now update the child count for private-dir */
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
priv_dir->i_mtime = priv_dir->i_ctime = current_time(priv_dir);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
priv_dir->i_mtime = inode_set_ctime_current(priv_dir);
|
||||
#else
|
||||
inode_set_mtime_to_ts(priv_dir, inode_set_ctime_current(priv_dir));
|
||||
#endif
|
||||
--APFS_I(priv_dir)->i_nchildren;
|
||||
apfs_inode_join_transaction(sb, priv_dir);
|
||||
|
||||
@@ -1330,7 +1351,11 @@ static int __apfs_unlink(struct inode *dir, struct dentry *dentry)
|
||||
if (err)
|
||||
goto fail;
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode->i_ctime = dir->i_ctime;
|
||||
#else
|
||||
inode_set_ctime_to_ts(inode, inode_get_ctime(dir));
|
||||
#endif
|
||||
/* TODO: defer write of the primary name? */
|
||||
err = apfs_update_inode(inode, primary_name);
|
||||
if (err)
|
||||
|
||||
@@ -1,7 +1,8 @@
|
||||
PACKAGE_NAME="linux-apfs-rw"
|
||||
PACKAGE_VERSION="0.3.4"
|
||||
PACKAGE_VERSION="0.3.7"
|
||||
|
||||
BUILT_MODULE_NAME[0]="apfs"
|
||||
DEST_MODULE_LOCATION[0]="/extra"
|
||||
|
||||
AUTOINSTALL="yes"
|
||||
PRE_BUILD="genver.sh"
|
||||
@@ -5,6 +5,7 @@
|
||||
|
||||
#include <linux/buffer_head.h>
|
||||
#include <linux/slab.h>
|
||||
#include <linux/blk_types.h>
|
||||
#include "apfs.h"
|
||||
|
||||
#define MAX(X, Y) ((X) <= (Y) ? (Y) : (X))
|
||||
@@ -46,7 +47,7 @@ int apfs_extent_from_query(struct apfs_query *query,
|
||||
char *raw = query->node->object.data;
|
||||
u64 ext_len;
|
||||
|
||||
if(!apfs_is_sealed(sb)) {
|
||||
if (!apfs_is_sealed(sb)) {
|
||||
struct apfs_file_extent_val *ext = NULL;
|
||||
struct apfs_file_extent_key *ext_key = NULL;
|
||||
|
||||
@@ -138,7 +139,7 @@ static int apfs_extent_read(struct apfs_dstream_info *dstream, sector_t dsblock,
|
||||
ret = -ENOMEM;
|
||||
goto done;
|
||||
}
|
||||
query->key = &key;
|
||||
query->key = key;
|
||||
query->flags = apfs_is_sealed(sb) ? APFS_QUERY_FEXT : APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -412,7 +413,6 @@ static int apfs_update_tail_extent(struct apfs_dstream_info *dstream, const stru
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_file_extent_key raw_key;
|
||||
struct apfs_file_extent_val raw_val;
|
||||
@@ -430,13 +430,11 @@ static int apfs_update_tail_extent(struct apfs_dstream_info *dstream, const stru
|
||||
new_crypto = 0;
|
||||
raw_val.crypto_id = cpu_to_le64(new_crypto);
|
||||
|
||||
/* We want the last extent record */
|
||||
apfs_init_file_extent_key(extent_id, -1, &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
/* We want the last extent record */
|
||||
apfs_init_file_extent_key(extent_id, -1, &query->key);
|
||||
query->flags = APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -601,7 +599,7 @@ static int apfs_update_mid_extent(struct apfs_dstream_info *dstream, const struc
|
||||
raw_key.logical_addr = cpu_to_le64(extent->logical_addr);
|
||||
raw_val.len_and_flags = cpu_to_le64(extent->len);
|
||||
raw_val.phys_block_num = cpu_to_le64(extent->phys_block_num);
|
||||
if(apfs_vol_is_encrypted(sb))
|
||||
if (apfs_vol_is_encrypted(sb))
|
||||
new_crypto = extent_id;
|
||||
else
|
||||
new_crypto = 0;
|
||||
@@ -613,7 +611,7 @@ search_and_insert:
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
query->key = key;
|
||||
query->flags = APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -800,7 +798,6 @@ static int apfs_insert_phys_extent(struct apfs_dstream_info *dstream, const stru
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
struct apfs_superblock *vsb_raw = APFS_SB(sb)->s_vsb_raw;
|
||||
struct apfs_node *extref_root;
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_phys_extent pext;
|
||||
u64 blkcnt = extent->len >> sb->s_blocksize_bits;
|
||||
@@ -829,8 +826,7 @@ static int apfs_insert_phys_extent(struct apfs_dstream_info *dstream, const stru
|
||||
* one.
|
||||
*/
|
||||
last_bno = extent->phys_block_num + blkcnt - 1;
|
||||
apfs_init_extent_key(last_bno, &key);
|
||||
query->key = &key;
|
||||
apfs_init_extent_key(last_bno, &query->key);
|
||||
query->flags = APFS_QUERY_EXTENTREF;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1152,7 +1148,6 @@ static int apfs_create_hole(struct apfs_dstream_info *dstream, u64 start, u64 en
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_file_extent_key raw_key;
|
||||
struct apfs_file_extent_val raw_val;
|
||||
@@ -1172,11 +1167,10 @@ static int apfs_create_hole(struct apfs_dstream_info *dstream, u64 start, u64 en
|
||||
raw_val.phys_block_num = cpu_to_le64(0); /* It's a hole... */
|
||||
raw_val.crypto_id = cpu_to_le64(apfs_vol_is_encrypted(sb) ? extent_id : 0);
|
||||
|
||||
apfs_init_file_extent_key(extent_id, start, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_file_extent_key(extent_id, start, &query->key);
|
||||
query->flags = APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1259,7 +1253,6 @@ static int apfs_range_in_snap(struct super_block *sb, u64 bno, u64 blkcnt, bool
|
||||
{
|
||||
struct apfs_superblock *vsb_raw = APFS_SB(sb)->s_vsb_raw;
|
||||
struct apfs_node *extref_root = NULL;
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_phys_extent pext = {0};
|
||||
int ret;
|
||||
@@ -1286,8 +1279,7 @@ static int apfs_range_in_snap(struct super_block *sb, u64 bno, u64 blkcnt, bool
|
||||
goto out;
|
||||
}
|
||||
|
||||
apfs_init_extent_key(bno, &key);
|
||||
query->key = &key;
|
||||
apfs_init_extent_key(bno, &query->key);
|
||||
query->flags = APFS_QUERY_EXTENTREF;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1499,18 +1491,15 @@ static int apfs_shrink_dstream_last_extent(struct apfs_dstream_info *dstream, lo
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_file_extent tail;
|
||||
u64 extent_id = dstream->ds_id;
|
||||
int ret = 0;
|
||||
|
||||
apfs_init_file_extent_key(extent_id, -1, &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_file_extent_key(extent_id, -1, &query->key);
|
||||
query->flags = APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1703,7 +1692,13 @@ int apfs_clone_file_range(struct file *src_file, loff_t off, struct file *dst_fi
|
||||
}
|
||||
src_ds->ds_shared = true;
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
dst_inode->i_mtime = dst_inode->i_ctime = current_time(dst_inode);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
dst_inode->i_mtime = inode_set_ctime_current(dst_inode);
|
||||
#else
|
||||
inode_set_mtime_to_ts(dst_inode, inode_set_ctime_current(dst_inode));
|
||||
#endif
|
||||
dst_inode->i_size = src_inode->i_size;
|
||||
dst_ai->i_key_class = src_ai->i_key_class;
|
||||
dst_ai->i_int_flags = src_ai->i_int_flags;
|
||||
@@ -1755,18 +1750,15 @@ fail:
|
||||
static int apfs_extent_create_record(struct super_block *sb, u64 dstream_id, struct apfs_file_extent *extent)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_file_extent_val raw_val;
|
||||
struct apfs_file_extent_key raw_key;
|
||||
int ret = 0;
|
||||
|
||||
apfs_init_file_extent_key(dstream_id, extent->logical_addr, &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_file_extent_key(dstream_id, extent->logical_addr, &query->key);
|
||||
query->flags = APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1830,7 +1822,7 @@ restart:
|
||||
ret = -ENOMEM;
|
||||
goto out;
|
||||
}
|
||||
query->key = &key;
|
||||
query->key = key;
|
||||
query->flags = APFS_QUERY_EXTENTREF;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1970,7 +1962,7 @@ restart:
|
||||
ret = -ENOMEM;
|
||||
goto out;
|
||||
}
|
||||
query->key = &key;
|
||||
query->key = key;
|
||||
query->flags = APFS_QUERY_EXTENTREF;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -2130,3 +2122,147 @@ int apfs_clone_extents(struct apfs_dstream_info *dstream, u64 new_id)
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_nonsparse_dstream_read - Read from a dstream without holes
|
||||
* @dstream: dstream to read
|
||||
* @buf: destination buffer
|
||||
* @count: exact number of bytes to read
|
||||
* @offset: dstream offset to read from
|
||||
*
|
||||
* Returns 0 on success or a negative error code in case of failure.
|
||||
*/
|
||||
int apfs_nonsparse_dstream_read(struct apfs_dstream_info *dstream, void *buf, size_t count, u64 offset)
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
u64 logical_start_block, logical_end_block, log_bno, blkcnt, idx;
|
||||
struct buffer_head **bhs = NULL;
|
||||
int ret = 0;
|
||||
|
||||
/* Save myself from thinking about overflow here */
|
||||
if (count >= APFS_MAX_FILE_SIZE || offset >= APFS_MAX_FILE_SIZE) {
|
||||
apfs_err(sb, "dstream read overflow (0x%llx-0x%llx)", offset, (unsigned long long)count);
|
||||
return -EFBIG;
|
||||
}
|
||||
|
||||
if (offset + count > dstream->ds_size) {
|
||||
apfs_err(sb, "reading past the end (0x%llx-0x%llx)", offset, (unsigned long long)count);
|
||||
/* No caller is expected to legitimately read out-of-bounds */
|
||||
return -EFSCORRUPTED;
|
||||
}
|
||||
|
||||
logical_start_block = offset >> sb->s_blocksize_bits;
|
||||
logical_end_block = (offset + count + sb->s_blocksize - 1) >> sb->s_blocksize_bits;
|
||||
blkcnt = logical_end_block - logical_start_block;
|
||||
bhs = kcalloc(blkcnt, sizeof(*bhs), GFP_KERNEL);
|
||||
if (!bhs)
|
||||
return -ENOMEM;
|
||||
|
||||
for (log_bno = logical_start_block; log_bno < logical_end_block; log_bno++) {
|
||||
struct buffer_head *bh = NULL;
|
||||
u64 bno = 0;
|
||||
|
||||
idx = log_bno - logical_start_block;
|
||||
|
||||
ret = apfs_logic_to_phys_bno(dstream, log_bno, &bno);
|
||||
if (ret)
|
||||
goto out;
|
||||
if (bno == 0) {
|
||||
apfs_err(sb, "nonsparse dstream has a hole");
|
||||
ret = -EFSCORRUPTED;
|
||||
goto out;
|
||||
}
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
bhs[idx] = __getblk_gfp(APFS_NXI(sb)->nx_bdev, bno, sb->s_blocksize, __GFP_MOVABLE);
|
||||
#else
|
||||
bhs[idx] = bdev_getblk(APFS_NXI(sb)->nx_bdev, bno, sb->s_blocksize, __GFP_MOVABLE);
|
||||
#endif
|
||||
if (!bhs[idx]) {
|
||||
apfs_err(sb, "failed to map block 0x%llx", bno);
|
||||
ret = -EIO;
|
||||
goto out;
|
||||
}
|
||||
|
||||
bh = bhs[idx];
|
||||
if (!buffer_uptodate(bh)) {
|
||||
get_bh(bh);
|
||||
lock_buffer(bh);
|
||||
bh->b_end_io = end_buffer_read_sync;
|
||||
apfs_submit_bh(REQ_OP_READ, 0, bh);
|
||||
}
|
||||
}
|
||||
|
||||
for (log_bno = logical_start_block; log_bno < logical_end_block; log_bno++) {
|
||||
int off_in_block, left_in_block;
|
||||
|
||||
idx = log_bno - logical_start_block;
|
||||
wait_on_buffer(bhs[idx]);
|
||||
if (!buffer_uptodate(bhs[idx])) {
|
||||
apfs_err(sb, "failed to read a block");
|
||||
ret = -EIO;
|
||||
goto out;
|
||||
}
|
||||
|
||||
if (log_bno == logical_start_block)
|
||||
off_in_block = offset & (sb->s_blocksize - 1);
|
||||
else
|
||||
off_in_block = 0;
|
||||
|
||||
if (log_bno == logical_end_block - 1)
|
||||
left_in_block = count + offset - (log_bno << sb->s_blocksize_bits) - off_in_block;
|
||||
else
|
||||
left_in_block = sb->s_blocksize - off_in_block;
|
||||
|
||||
memcpy(buf, bhs[idx]->b_data + off_in_block, left_in_block);
|
||||
buf += left_in_block;
|
||||
}
|
||||
|
||||
out:
|
||||
if (bhs) {
|
||||
for (idx = 0; idx < blkcnt; idx++)
|
||||
brelse(bhs[idx]);
|
||||
kfree(bhs);
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_nonsparse_dstream_preread - Attempt to preread a dstream without holes
|
||||
* @dstream: dstream to preread
|
||||
*
|
||||
* Requests reads for all blocks of a dstream, but doesn't wait for the result.
|
||||
*/
|
||||
void apfs_nonsparse_dstream_preread(struct apfs_dstream_info *dstream)
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
u64 logical_end_block, log_bno;
|
||||
|
||||
logical_end_block = (dstream->ds_size + sb->s_blocksize - 1) >> sb->s_blocksize_bits;
|
||||
|
||||
for (log_bno = 0; log_bno < logical_end_block; log_bno++) {
|
||||
struct buffer_head *bh = NULL;
|
||||
u64 bno = 0;
|
||||
int ret;
|
||||
|
||||
ret = apfs_logic_to_phys_bno(dstream, log_bno, &bno);
|
||||
if (ret || bno == 0)
|
||||
return;
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
bh = __getblk_gfp(APFS_NXI(sb)->nx_bdev, bno, sb->s_blocksize, __GFP_MOVABLE);
|
||||
#else
|
||||
bh = bdev_getblk(APFS_NXI(sb)->nx_bdev, bno, sb->s_blocksize, __GFP_MOVABLE);
|
||||
#endif
|
||||
if (!bh)
|
||||
return;
|
||||
if (!buffer_uptodate(bh)) {
|
||||
get_bh(bh);
|
||||
lock_buffer(bh);
|
||||
bh->b_end_io = end_buffer_read_sync;
|
||||
apfs_submit_bh(REQ_OP_READ, 0, bh);
|
||||
}
|
||||
brelse(bh);
|
||||
bh = NULL;
|
||||
}
|
||||
}
|
||||
@@ -18,6 +18,9 @@ static vm_fault_t apfs_page_mkwrite(struct vm_fault *vmf)
|
||||
struct vm_area_struct *vma = vmf->vma;
|
||||
#endif
|
||||
struct page *page = vmf->page;
|
||||
#if LINUX_VERSION_CODE >= KERNEL_VERSION(6, 7, 0)
|
||||
struct folio *folio;
|
||||
#endif
|
||||
struct inode *inode = file_inode(vma->vm_file);
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct buffer_head *bh, *head;
|
||||
@@ -54,8 +57,16 @@ static vm_fault_t apfs_page_mkwrite(struct vm_fault *vmf)
|
||||
goto out_unlock;
|
||||
}
|
||||
|
||||
if (!page_has_buffers(page))
|
||||
if (!page_has_buffers(page)) {
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
create_empty_buffers(page, sb->s_blocksize, 0);
|
||||
#else
|
||||
folio = page_folio(page);
|
||||
bh = folio_buffers(folio);
|
||||
if (!bh)
|
||||
bh = create_empty_buffers(folio, sb->s_blocksize, 0);
|
||||
#endif
|
||||
}
|
||||
|
||||
size = i_size_read(inode);
|
||||
if (page->index == size >> PAGE_SHIFT)
|
||||
@@ -99,7 +110,11 @@ out_abort:
|
||||
apfs_transaction_abort(sb);
|
||||
out:
|
||||
if (err)
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
ret = block_page_mkwrite_return(err);
|
||||
#else
|
||||
ret = vmf_fs_error(err);
|
||||
#endif
|
||||
sb_end_pagefault(inode->i_sb);
|
||||
return ret;
|
||||
}
|
||||
@@ -110,7 +125,7 @@ static const struct vm_operations_struct apfs_file_vm_ops = {
|
||||
.page_mkwrite = apfs_page_mkwrite,
|
||||
};
|
||||
|
||||
static int apfs_file_mmap(struct file * file, struct vm_area_struct * vma)
|
||||
int apfs_file_mmap(struct file *file, struct vm_area_struct *vma)
|
||||
{
|
||||
struct address_space *mapping = file->f_mapping;
|
||||
|
||||
@@ -155,6 +170,13 @@ const struct file_operations apfs_file_operations = {
|
||||
#else
|
||||
.clone_file_range = apfs_clone_file_range,
|
||||
#endif
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 5, 0)
|
||||
.splice_read = generic_file_splice_read,
|
||||
#else
|
||||
.splice_read = filemap_splice_read,
|
||||
#endif
|
||||
.splice_write = iter_file_splice_write,
|
||||
};
|
||||
|
||||
#if LINUX_VERSION_CODE == KERNEL_VERSION(5, 3, 0)
|
||||
|
||||
@@ -0,0 +1,13 @@
|
||||
#!/bin/sh
|
||||
# SPDX-License-Identifier: GPL-2.0-only
|
||||
#
|
||||
# Script to generate the module version header
|
||||
#
|
||||
|
||||
if command -v git >/dev/null 2>&1 && [ -d .git ]; then
|
||||
GIT_COMMIT=$(git describe HEAD | tail -c 9)
|
||||
else
|
||||
GIT_COMMIT="$(grep PACKAGE_VERSION dkms.conf | cut -d '"' -f2)?"
|
||||
fi
|
||||
|
||||
printf '#define GIT_COMMIT\t"%s"\n' "$GIT_COMMIT" > version.h
|
||||
@@ -64,17 +64,15 @@ static int apfs_create_dstream_rec(struct apfs_dstream_info *dstream)
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_dstream_id_key raw_key;
|
||||
struct apfs_dstream_id_val raw_val;
|
||||
int ret;
|
||||
|
||||
apfs_init_dstream_id_key(dstream->ds_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_dstream_id_key(dstream->ds_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -190,7 +188,6 @@ int apfs_dstream_adj_refcnt(struct apfs_dstream_info *dstream, u32 delta)
|
||||
{
|
||||
struct super_block *sb = dstream->ds_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_dstream_id_val raw_val;
|
||||
void *raw = NULL;
|
||||
@@ -199,11 +196,10 @@ int apfs_dstream_adj_refcnt(struct apfs_dstream_info *dstream, u32 delta)
|
||||
|
||||
ASSERT(APFS_I(dstream->ds_inode)->i_has_dstream);
|
||||
|
||||
apfs_init_dstream_id_key(dstream->ds_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_dstream_id_key(dstream->ds_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -268,7 +264,6 @@ static int apfs_create_crypto_rec(struct inode *inode)
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_dstream_info *dstream = &APFS_I(inode)->i_dstream;
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_crypto_state_key raw_key;
|
||||
int ret;
|
||||
@@ -276,11 +271,10 @@ static int apfs_create_crypto_rec(struct inode *inode)
|
||||
if (inode->i_size || inode->i_blocks) /* Already has a dstream */
|
||||
return 0;
|
||||
|
||||
apfs_init_crypto_state_key(dstream->ds_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_crypto_state_key(dstream->ds_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -288,14 +282,16 @@ static int apfs_create_crypto_rec(struct inode *inode)
|
||||
goto out;
|
||||
|
||||
apfs_key_set_hdr(APFS_TYPE_CRYPTO_STATE, dstream->ds_id, &raw_key);
|
||||
if(sbi->s_dflt_pfk) {
|
||||
if (sbi->s_dflt_pfk) {
|
||||
struct apfs_crypto_state_val *raw_val = sbi->s_dflt_pfk;
|
||||
unsigned key_len = le16_to_cpu(raw_val->state.key_len);
|
||||
unsigned int key_len = le16_to_cpu(raw_val->state.key_len);
|
||||
|
||||
ret = apfs_btree_insert(query, &raw_key, sizeof(raw_key), raw_val, sizeof(*raw_val) + key_len);
|
||||
if (ret)
|
||||
apfs_err(sb, "insertion failed for id 0x%llx", dstream->ds_id);
|
||||
} else {
|
||||
struct apfs_crypto_state_val raw_val;
|
||||
|
||||
raw_val.refcnt = cpu_to_le32(1);
|
||||
raw_val.state.major_version = cpu_to_le16(APFS_WMCS_MAJOR_VERSION);
|
||||
raw_val.state.minor_version = cpu_to_le16(APFS_WMCS_MINOR_VERSION);
|
||||
@@ -318,7 +314,7 @@ out:
|
||||
* apfs_dflt_key_class - Returns default key class for files in volume
|
||||
* @sb: volume superblock
|
||||
*/
|
||||
static unsigned apfs_dflt_key_class(struct super_block *sb)
|
||||
static unsigned int apfs_dflt_key_class(struct super_block *sb)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
|
||||
@@ -341,7 +337,6 @@ static unsigned apfs_dflt_key_class(struct super_block *sb)
|
||||
int apfs_crypto_adj_refcnt(struct super_block *sb, u64 crypto_id, int delta)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_crypto_state_val *raw_val;
|
||||
char *raw;
|
||||
@@ -350,11 +345,10 @@ int apfs_crypto_adj_refcnt(struct super_block *sb, u64 crypto_id, int delta)
|
||||
if (!crypto_id)
|
||||
return 0;
|
||||
|
||||
apfs_init_crypto_state_key(crypto_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_crypto_state_key(crypto_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -394,23 +388,21 @@ int APFS_CRYPTO_ADJ_REFCNT_MAXOPS(void)
|
||||
static int apfs_crypto_set_key(struct super_block *sb, u64 crypto_id, struct apfs_crypto_state_val *new_val)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_crypto_state_val *raw_val;
|
||||
char *raw;
|
||||
int ret;
|
||||
unsigned pfk_len;
|
||||
unsigned int pfk_len;
|
||||
|
||||
if (!crypto_id)
|
||||
return 0;
|
||||
|
||||
pfk_len = le16_to_cpu(new_val->state.key_len);
|
||||
|
||||
apfs_init_crypto_state_key(crypto_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_crypto_state_key(crypto_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -441,24 +433,22 @@ out:
|
||||
* @max_len: maximum allowed value of val->state.key_len
|
||||
*/
|
||||
static int apfs_crypto_get_key(struct super_block *sb, u64 crypto_id, struct apfs_crypto_state_val *val,
|
||||
unsigned max_len)
|
||||
unsigned int max_len)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_crypto_state_val *raw_val;
|
||||
char *raw;
|
||||
int ret;
|
||||
unsigned pfk_len;
|
||||
unsigned int pfk_len;
|
||||
|
||||
if (!crypto_id)
|
||||
return -ENOENT;
|
||||
|
||||
apfs_init_crypto_state_key(crypto_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_crypto_state_key(crypto_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -468,7 +458,7 @@ static int apfs_crypto_get_key(struct super_block *sb, u64 crypto_id, struct apf
|
||||
raw_val = (void *)raw + query->off;
|
||||
|
||||
pfk_len = le16_to_cpu(raw_val->state.key_len);
|
||||
if(pfk_len > max_len) {
|
||||
if (pfk_len > max_len) {
|
||||
ret = -ENOSPC;
|
||||
goto out;
|
||||
}
|
||||
@@ -486,6 +476,9 @@ int __apfs_write_begin(struct file *file, struct address_space *mapping, loff_t
|
||||
struct apfs_dstream_info *dstream = &APFS_I(inode)->i_dstream;
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct page *page;
|
||||
#if LINUX_VERSION_CODE >= KERNEL_VERSION(6, 7, 0)
|
||||
struct folio *folio;
|
||||
#endif
|
||||
struct buffer_head *bh, *head;
|
||||
unsigned int blocksize, block_start, block_end, from, to;
|
||||
pgoff_t index = pos >> PAGE_SHIFT;
|
||||
@@ -501,7 +494,7 @@ int __apfs_write_begin(struct file *file, struct address_space *mapping, loff_t
|
||||
return err;
|
||||
}
|
||||
|
||||
if(apfs_vol_is_encrypted(sb)) {
|
||||
if (apfs_vol_is_encrypted(sb)) {
|
||||
err = apfs_create_crypto_rec(inode);
|
||||
if (err) {
|
||||
apfs_err(sb, "crypto creation failed for ino 0x%llx", apfs_ino(inode));
|
||||
@@ -518,8 +511,16 @@ int __apfs_write_begin(struct file *file, struct address_space *mapping, loff_t
|
||||
#endif
|
||||
if (!page)
|
||||
return -ENOMEM;
|
||||
if (!page_has_buffers(page))
|
||||
if (!page_has_buffers(page)) {
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
create_empty_buffers(page, sb->s_blocksize, 0);
|
||||
#else
|
||||
folio = page_folio(page);
|
||||
bh = folio_buffers(folio);
|
||||
if (!bh)
|
||||
bh = create_empty_buffers(folio, sb->s_blocksize, 0);
|
||||
#endif
|
||||
}
|
||||
|
||||
/* CoW moves existing blocks, so read them but mark them as unmapped */
|
||||
head = page_buffers(page);
|
||||
@@ -722,11 +723,13 @@ static void apfs_inode_set_ops(struct inode *inode, dev_t rdev, bool compressed)
|
||||
switch (inode->i_mode & S_IFMT) {
|
||||
case S_IFREG:
|
||||
inode->i_op = &apfs_file_inode_operations;
|
||||
if (compressed)
|
||||
if (compressed) {
|
||||
inode->i_fop = &apfs_compress_file_operations;
|
||||
else
|
||||
inode->i_mapping->a_ops = &apfs_compress_aops;
|
||||
} else {
|
||||
inode->i_fop = &apfs_file_operations;
|
||||
inode->i_mapping->a_ops = &apfs_aops;
|
||||
inode->i_mapping->a_ops = &apfs_aops;
|
||||
}
|
||||
break;
|
||||
case S_IFDIR:
|
||||
inode->i_op = &apfs_dir_inode_operations;
|
||||
@@ -795,9 +798,19 @@ static int apfs_inode_from_query(struct apfs_query *query, struct inode *inode)
|
||||
ai->i_nchildren = le32_to_cpu(inode_val->nchildren);
|
||||
}
|
||||
|
||||
inode->i_atime = ns_to_timespec64(le64_to_cpu(inode_val->access_time));
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode->i_ctime = ns_to_timespec64(le64_to_cpu(inode_val->change_time));
|
||||
#else
|
||||
inode_set_ctime_to_ts(inode, ns_to_timespec64(le64_to_cpu(inode_val->change_time)));
|
||||
#endif
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
inode->i_atime = ns_to_timespec64(le64_to_cpu(inode_val->access_time));
|
||||
inode->i_mtime = ns_to_timespec64(le64_to_cpu(inode_val->mod_time));
|
||||
#else
|
||||
inode_set_atime_to_ts(inode, ns_to_timespec64(le64_to_cpu(inode_val->access_time)));
|
||||
inode_set_mtime_to_ts(inode, ns_to_timespec64(le64_to_cpu(inode_val->mod_time)));
|
||||
#endif
|
||||
ai->i_crtime = ns_to_timespec64(le64_to_cpu(inode_val->create_time));
|
||||
|
||||
dstream->ds_size = inode->i_size = inode->i_blocks = 0;
|
||||
@@ -860,16 +873,13 @@ static struct apfs_query *apfs_inode_lookup(const struct inode *inode)
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
int ret;
|
||||
|
||||
apfs_init_inode_key(apfs_ino(inode), &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return ERR_PTR(-ENOMEM);
|
||||
query->key = &key;
|
||||
apfs_init_inode_key(apfs_ino(inode), &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -930,7 +940,6 @@ static int apfs_check_dstream_refcnt(struct inode *inode)
|
||||
struct apfs_dstream_info *dstream = &ai->i_dstream;
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_dstream_id_val raw_val;
|
||||
void *raw = NULL;
|
||||
@@ -942,11 +951,10 @@ static int apfs_check_dstream_refcnt(struct inode *inode)
|
||||
return 0;
|
||||
}
|
||||
|
||||
apfs_init_dstream_id_key(dstream->ds_id, &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_dstream_id_key(dstream->ds_id, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1036,6 +1044,7 @@ int apfs_getattr(struct vfsmount *mnt, struct dentry *dentry,
|
||||
struct inode *inode = d_inode(dentry);
|
||||
|
||||
generic_fillattr(inode, stat);
|
||||
stat->dev = APFS_SB(inode->i_sb)->s_anon_dev;
|
||||
stat->ino = apfs_ino(inode);
|
||||
return 0;
|
||||
}
|
||||
@@ -1079,10 +1088,13 @@ int apfs_getattr(struct mnt_idmap *idmap,
|
||||
generic_fillattr(inode, stat);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 3, 0)
|
||||
generic_fillattr(mnt_userns, inode, stat);
|
||||
#else
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
generic_fillattr(idmap, inode, stat);
|
||||
#else
|
||||
generic_fillattr(idmap, request_mask, inode, stat);
|
||||
#endif
|
||||
|
||||
stat->dev = APFS_SB(inode->i_sb)->s_anon_dev;
|
||||
stat->ino = apfs_ino(inode);
|
||||
return 0;
|
||||
}
|
||||
@@ -1102,6 +1114,9 @@ static int apfs_build_inode_val(struct inode *inode, struct qstr *qname,
|
||||
{
|
||||
struct apfs_inode_val *val;
|
||||
struct apfs_x_field xkey;
|
||||
#if LINUX_VERSION_CODE >= KERNEL_VERSION(6, 7, 0)
|
||||
struct timespec64 ts;
|
||||
#endif
|
||||
int total_xlen, val_len;
|
||||
bool is_device = S_ISCHR(inode->i_mode) || S_ISBLK(inode->i_mode);
|
||||
__le32 rdev;
|
||||
@@ -1120,7 +1135,12 @@ static int apfs_build_inode_val(struct inode *inode, struct qstr *qname,
|
||||
val->parent_id = cpu_to_le64(APFS_I(inode)->i_parent_id);
|
||||
val->private_id = cpu_to_le64(apfs_ino(inode));
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
val->mod_time = cpu_to_le64(timespec64_to_ns(&inode->i_mtime));
|
||||
#else
|
||||
ts = inode_get_mtime(inode);
|
||||
val->mod_time = cpu_to_le64(timespec64_to_ns(&ts));
|
||||
#endif
|
||||
val->create_time = val->change_time = val->access_time = val->mod_time;
|
||||
|
||||
if (S_ISDIR(inode->i_mode))
|
||||
@@ -1231,7 +1251,7 @@ static int apfs_create_dstream_xfield(struct inode *inode,
|
||||
|
||||
dstream_raw.size = cpu_to_le64(inode->i_size);
|
||||
dstream_raw.alloced_size = cpu_to_le64(apfs_alloced_size(dstream));
|
||||
if(apfs_vol_is_encrypted(inode->i_sb))
|
||||
if (apfs_vol_is_encrypted(inode->i_sb))
|
||||
dstream_raw.default_crypto_id = cpu_to_le64(dstream->ds_id);
|
||||
|
||||
/* TODO: can we assume that all inode records have an xfield blob? */
|
||||
@@ -1482,9 +1502,22 @@ int apfs_update_inode(struct inode *inode, char *new_name)
|
||||
if (gid_valid(sbi->s_gid))
|
||||
inode_raw->group = cpu_to_le32(ai->i_saved_gid);
|
||||
|
||||
inode_raw->access_time = cpu_to_le64(timespec64_to_ns(&inode->i_atime));
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode_raw->change_time = cpu_to_le64(timespec64_to_ns(&inode->i_ctime));
|
||||
#else
|
||||
struct timespec64 ictime = inode_get_ctime(inode);
|
||||
inode_raw->change_time = cpu_to_le64(timespec64_to_ns(&ictime));
|
||||
#endif
|
||||
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
inode_raw->access_time = cpu_to_le64(timespec64_to_ns(&inode->i_atime));
|
||||
inode_raw->mod_time = cpu_to_le64(timespec64_to_ns(&inode->i_mtime));
|
||||
#else
|
||||
struct timespec64 ts = inode_get_mtime(inode);
|
||||
inode_raw->mod_time = cpu_to_le64(timespec64_to_ns(&ts));
|
||||
ts = inode_get_atime(inode);
|
||||
inode_raw->access_time = cpu_to_le64(timespec64_to_ns(&ts));
|
||||
#endif
|
||||
inode_raw->create_time = cpu_to_le64(timespec64_to_ns(&ai->i_crtime));
|
||||
|
||||
if (S_ISDIR(inode->i_mode)) {
|
||||
@@ -1663,7 +1696,14 @@ struct inode *apfs_new_inode(struct inode *dir, umode_t mode, dev_t rdev)
|
||||
dstream->ds_shared = false;
|
||||
|
||||
now = current_time(inode);
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode->i_atime = inode->i_mtime = inode->i_ctime = ai->i_crtime = now;
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
inode_set_ctime_to_ts(inode, now);
|
||||
inode->i_atime = inode->i_mtime = ai->i_crtime = now;
|
||||
#else
|
||||
ai->i_crtime = simple_inode_init_ts(inode);
|
||||
#endif
|
||||
vsb_raw->apfs_last_mod_time = cpu_to_le64(timespec64_to_ns(&now));
|
||||
|
||||
if (S_ISREG(mode))
|
||||
@@ -1700,18 +1740,16 @@ int apfs_create_inode_rec(struct super_block *sb, struct inode *inode,
|
||||
struct dentry *dentry)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_inode_key raw_key;
|
||||
struct apfs_inode_val *raw_val;
|
||||
int val_len;
|
||||
int ret;
|
||||
|
||||
apfs_init_inode_key(apfs_ino(inode), &key);
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_inode_key(apfs_ino(inode), &query->key);
|
||||
query->flags |= APFS_QUERY_CAT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -1757,7 +1795,13 @@ static int apfs_setsize(struct inode *inode, loff_t new_size)
|
||||
|
||||
if (new_size == inode->i_size)
|
||||
return 0;
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode->i_mtime = inode->i_ctime = current_time(inode);
|
||||
#elif LINUX_VERSION_CODE < KERNEL_VERSION(6, 7, 0)
|
||||
inode->i_mtime = inode_set_ctime_current(inode);
|
||||
#else
|
||||
inode_set_mtime_to_ts(inode, inode_set_ctime_current(inode));
|
||||
#endif
|
||||
|
||||
err = apfs_inode_create_dstream_rec(inode);
|
||||
if (err) {
|
||||
@@ -1843,7 +1887,11 @@ fail:
|
||||
}
|
||||
|
||||
/* TODO: this only seems to be necessary because ->write_inode() isn't firing */
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
int apfs_update_time(struct inode *inode, struct timespec64 *time, int flags)
|
||||
#else
|
||||
int apfs_update_time(struct inode *inode, int flags)
|
||||
#endif
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_max_ops maxops;
|
||||
@@ -1857,9 +1905,11 @@ int apfs_update_time(struct inode *inode, struct timespec64 *time, int flags)
|
||||
return err;
|
||||
apfs_inode_join_transaction(sb, inode);
|
||||
|
||||
err = generic_update_time(inode, time, flags);
|
||||
if (err)
|
||||
goto fail;
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
generic_update_time(inode, time, flags);
|
||||
#else
|
||||
generic_update_time(inode, flags);
|
||||
#endif
|
||||
|
||||
err = apfs_transaction_commit(sb);
|
||||
if (err)
|
||||
@@ -1879,7 +1929,7 @@ static int apfs_ioc_set_dflt_pfk(struct file *file, void __user *user_pfk)
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_wrapped_crypto_state pfk_hdr;
|
||||
struct apfs_crypto_state_val *pfk;
|
||||
unsigned key_len;
|
||||
unsigned int key_len;
|
||||
|
||||
if (__copy_from_user(&pfk_hdr, user_pfk, sizeof(pfk_hdr)))
|
||||
return -EFAULT;
|
||||
@@ -1946,7 +1996,7 @@ static int apfs_ioc_set_pfk(struct file *file, void __user *user_pfk)
|
||||
struct apfs_inode_info *ai = APFS_I(inode);
|
||||
struct apfs_dstream_info *dstream = &ai->i_dstream;
|
||||
struct apfs_max_ops maxops;
|
||||
unsigned key_len, key_class;
|
||||
unsigned int key_len, key_class;
|
||||
int err;
|
||||
|
||||
if (__copy_from_user(&pfk_hdr, user_pfk, sizeof(pfk_hdr)))
|
||||
@@ -2013,7 +2063,7 @@ static int apfs_ioc_get_pfk(struct file *file, void __user *user_pfk)
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_wrapped_crypto_state pfk_hdr;
|
||||
struct apfs_crypto_state_val *pfk;
|
||||
unsigned max_len, key_len;
|
||||
unsigned int max_len, key_len;
|
||||
struct apfs_dstream_info *dstream = &APFS_I(inode)->i_dstream;
|
||||
int err;
|
||||
|
||||
@@ -2280,7 +2330,11 @@ int apfs_fileattr_set(struct mnt_idmap *idmap, struct dentry *dentry, struct fil
|
||||
|
||||
apfs_inode_join_transaction(sb, inode);
|
||||
apfs_setflags(inode, fa->flags);
|
||||
#if LINUX_VERSION_CODE < KERNEL_VERSION(6, 6, 0)
|
||||
inode->i_ctime = current_time(inode);
|
||||
#else
|
||||
inode_set_ctime_current(inode);
|
||||
#endif
|
||||
|
||||
err = apfs_transaction_commit(sb);
|
||||
if (err)
|
||||
|
||||
+5
-20
@@ -71,7 +71,6 @@ static int apfs_create_snap_metadata_rec(struct inode *mntpoint, struct apfs_nod
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_superblock *vsb_raw = sbi->s_vsb_raw;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_key key = {0};
|
||||
struct apfs_snap_metadata_key raw_key;
|
||||
struct apfs_snap_metadata_val *raw_val = NULL;
|
||||
int val_len;
|
||||
@@ -79,14 +78,12 @@ static int apfs_create_snap_metadata_rec(struct inode *mntpoint, struct apfs_nod
|
||||
u64 xid = APFS_NXI(sb)->nx_xid;
|
||||
int err;
|
||||
|
||||
apfs_init_snap_metadata_key(xid, &key);
|
||||
|
||||
query = apfs_alloc_query(snap_root, NULL /* parent */);
|
||||
if (!query) {
|
||||
err = -ENOMEM;
|
||||
goto fail;
|
||||
}
|
||||
query->key = &key;
|
||||
apfs_init_snap_metadata_key(xid, &query->key);
|
||||
query->flags |= APFS_QUERY_SNAP_META | APFS_QUERY_EXACT;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
@@ -137,20 +134,17 @@ static int apfs_create_snap_name_rec(struct apfs_node *snap_root, const char *na
|
||||
{
|
||||
struct super_block *sb = snap_root->object.sb;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_key key = {0};
|
||||
struct apfs_snap_name_key *raw_key = NULL;
|
||||
struct apfs_snap_name_val raw_val;
|
||||
int key_len;
|
||||
int err;
|
||||
|
||||
apfs_init_snap_name_key(name, &key);
|
||||
|
||||
query = apfs_alloc_query(snap_root, NULL /* parent */);
|
||||
if (!query) {
|
||||
err = -ENOMEM;
|
||||
goto fail;
|
||||
}
|
||||
query->key = &key;
|
||||
apfs_init_snap_name_key(name, &query->key);
|
||||
query->flags |= APFS_QUERY_SNAP_META | APFS_QUERY_EXACT;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
@@ -246,7 +240,6 @@ static int apfs_update_omap_snap_tree(struct super_block *sb, __le64 *oid_p)
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_node *root = NULL;
|
||||
u64 oid = le64_to_cpup(oid_p);
|
||||
struct apfs_key key = {0};
|
||||
struct apfs_query *query = NULL;
|
||||
__le64 raw_key;
|
||||
struct apfs_omap_snapshot raw_val = {0};
|
||||
@@ -268,14 +261,12 @@ static int apfs_update_omap_snap_tree(struct super_block *sb, __le64 *oid_p)
|
||||
}
|
||||
oid = 0;
|
||||
|
||||
apfs_init_omap_snap_key(nxi->nx_xid, &key);
|
||||
|
||||
query = apfs_alloc_query(root, NULL /* parent */);
|
||||
if (!query) {
|
||||
err = -ENOMEM;
|
||||
goto fail;
|
||||
}
|
||||
query->key = &key;
|
||||
apfs_init_omap_snap_key(nxi->nx_xid, &query->key);
|
||||
query->flags = APFS_QUERY_OMAP_SNAP | APFS_QUERY_EXACT;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
@@ -499,15 +490,12 @@ static int apfs_snapshot_name_to_xid(struct apfs_node *snap_root, const char *na
|
||||
{
|
||||
struct super_block *sb = snap_root->object.sb;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_key key = {0};
|
||||
int err;
|
||||
|
||||
apfs_init_snap_name_key(name, &key);
|
||||
|
||||
query = apfs_alloc_query(snap_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_snap_name_key(name, &query->key);
|
||||
query->flags |= APFS_QUERY_SNAP_META | APFS_QUERY_EXACT;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
@@ -545,15 +533,12 @@ static int apfs_snapshot_xid_to_sblock(struct apfs_node *snap_root, u64 xid, u64
|
||||
{
|
||||
struct super_block *sb = snap_root->object.sb;
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_key key = {0};
|
||||
int err;
|
||||
|
||||
apfs_init_snap_metadata_key(xid, &key);
|
||||
|
||||
query = apfs_alloc_query(snap_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_snap_metadata_key(xid, &query->key);
|
||||
query->flags |= APFS_QUERY_SNAP_META | APFS_QUERY_EXACT;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
|
||||
+195
-75
@@ -5,6 +5,7 @@
|
||||
|
||||
#include <linux/buffer_head.h>
|
||||
#include <linux/fs.h>
|
||||
#include <linux/slab.h>
|
||||
#include "apfs.h"
|
||||
|
||||
/**
|
||||
@@ -95,6 +96,25 @@ static int apfs_read_spaceman_dev(struct super_block *sb,
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_spaceman_get_16 - Get a 16-bit value from an offset in the spaceman
|
||||
* @sb: superblock structure
|
||||
* @off: offset for the value
|
||||
*
|
||||
* Returns a pointer to the value, or NULL if it doesn't fit.
|
||||
*/
|
||||
static __le16 *apfs_spaceman_get_16(struct super_block *sb, size_t off)
|
||||
{
|
||||
struct apfs_spaceman *spaceman = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *sm_raw = spaceman->sm_raw;
|
||||
|
||||
if (off > sb->s_blocksize)
|
||||
return NULL;
|
||||
if (off + sizeof(__le16) > sb->s_blocksize)
|
||||
return NULL;
|
||||
return (void *)sm_raw + off;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_spaceman_get_64 - Get a 64-bit value from an offset in the spaceman
|
||||
* @sb: superblock structure
|
||||
@@ -124,7 +144,7 @@ static bool apfs_ip_bm_is_free(struct apfs_spaceman_phys *sm, u16 index)
|
||||
u16 free_head = le16_to_cpu(sm->sm_ip_bm_free_head);
|
||||
u16 free_tail = le16_to_cpu(sm->sm_ip_bm_free_tail);
|
||||
u16 free_len, index_in_free;
|
||||
u16 bmap_count = 16;
|
||||
u16 bmap_count = le32_to_cpu(sm->sm_ip_bm_block_count);
|
||||
|
||||
free_len = (bmap_count + free_tail - free_head) % bmap_count;
|
||||
index_in_free = (bmap_count + index - free_head) % bmap_count;
|
||||
@@ -144,7 +164,7 @@ static int apfs_update_ip_bm_free_next(struct super_block *sb)
|
||||
struct apfs_spaceman *spaceman = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *raw = spaceman->sm_raw;
|
||||
u32 free_next_off = le32_to_cpu(raw->sm_ip_bm_free_next_offset);
|
||||
int bmap_count = 16;
|
||||
int bmap_count = le32_to_cpu(raw->sm_ip_bm_block_count);
|
||||
__le16 *free_next;
|
||||
int i;
|
||||
|
||||
@@ -168,65 +188,61 @@ static int apfs_update_ip_bm_free_next(struct super_block *sb)
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_rotate_ip_bitmaps - Allocate a new ip bitmap from the circular buffer
|
||||
* @sb: superblock structure
|
||||
* apfs_rotate_single_ip_bitmap - Reallocate an ip bmap in the circular buffer
|
||||
* @sb: filesystem superblock
|
||||
* @idx: index of the ip bitmap to reallocate
|
||||
*
|
||||
* Returns 0 on success or a negative error code in case of failure.
|
||||
*/
|
||||
static int apfs_rotate_ip_bitmaps(struct super_block *sb)
|
||||
static int apfs_rotate_single_ip_bitmap(struct super_block *sb, u32 idx)
|
||||
{
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_spaceman *spaceman = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *sm_raw = spaceman->sm_raw;
|
||||
u64 bmap_base = le64_to_cpu(sm_raw->sm_ip_bm_base);
|
||||
u32 bmap_length = le32_to_cpu(sm_raw->sm_ip_bm_block_count);
|
||||
u16 free_head, free_tail;
|
||||
__le64 *curr_bmap_off, *xid;
|
||||
struct buffer_head *old_bh = NULL, *new_bh = NULL;
|
||||
int err = 0;
|
||||
|
||||
apfs_assert_in_transaction(sb, &sm_raw->sm_o);
|
||||
|
||||
if (le32_to_cpu(sm_raw->sm_ip_bm_size_in_blocks) != 1) {
|
||||
apfs_warn(sb, "Multiblock ip bitmaps not supported");
|
||||
return -EOPNOTSUPP;
|
||||
}
|
||||
|
||||
xid = apfs_spaceman_get_64(sb, le32_to_cpu(sm_raw->sm_ip_bm_xid_offset));
|
||||
if (!xid) {
|
||||
apfs_err(sb, "xid out of bounds (%u)", le32_to_cpu(sm_raw->sm_ip_bm_xid_offset));
|
||||
return -EFSCORRUPTED;
|
||||
}
|
||||
*xid = cpu_to_le64(nxi->nx_xid);
|
||||
u64 ring_base;
|
||||
u32 ring_length;
|
||||
u32 xid_off, ip_bitmap_off;
|
||||
u64 ip_bitmap_bno;
|
||||
u16 free_head;
|
||||
__le64 *xid_p = NULL;
|
||||
__le16 *ip_bitmap_p = NULL;
|
||||
int err;
|
||||
|
||||
ring_base = le64_to_cpu(sm_raw->sm_ip_bm_base);
|
||||
ring_length = le32_to_cpu(sm_raw->sm_ip_bm_block_count);
|
||||
free_head = le16_to_cpu(sm_raw->sm_ip_bm_free_head);
|
||||
free_tail = le16_to_cpu(sm_raw->sm_ip_bm_free_tail);
|
||||
|
||||
curr_bmap_off = apfs_spaceman_get_64(sb, le32_to_cpu(sm_raw->sm_ip_bitmap_offset));
|
||||
if (!curr_bmap_off) {
|
||||
apfs_err(sb, "bmap offset out of bounds (%u)", le32_to_cpu(sm_raw->sm_ip_bitmap_offset));
|
||||
xid_off = le32_to_cpu(sm_raw->sm_ip_bm_xid_offset) + idx * sizeof(*xid_p);
|
||||
xid_p = apfs_spaceman_get_64(sb, xid_off);
|
||||
if (!xid_p) {
|
||||
apfs_err(sb, "xid out of bounds (%u)", xid_off);
|
||||
return -EFSCORRUPTED;
|
||||
}
|
||||
old_bh = apfs_sb_bread(sb, bmap_base + le64_to_cpup(curr_bmap_off));
|
||||
*xid_p = cpu_to_le64(nxi->nx_xid);
|
||||
|
||||
ip_bitmap_off = le32_to_cpu(sm_raw->sm_ip_bitmap_offset) + idx * sizeof(*ip_bitmap_p);
|
||||
ip_bitmap_p = apfs_spaceman_get_16(sb, ip_bitmap_off);
|
||||
if (!ip_bitmap_p) {
|
||||
apfs_err(sb, "bmap offset out of bounds (%u)", ip_bitmap_off);
|
||||
return -EFSCORRUPTED;
|
||||
}
|
||||
|
||||
ip_bitmap_bno = ring_base + le16_to_cpup(ip_bitmap_p);
|
||||
old_bh = apfs_sb_bread(sb, ip_bitmap_bno);
|
||||
if (!old_bh) {
|
||||
apfs_err(sb, "failed to read current ip bitmap (0x%llx)", bmap_base + le64_to_cpup(curr_bmap_off));
|
||||
apfs_err(sb, "failed to read current ip bitmap (0x%llx)", ip_bitmap_bno);
|
||||
return -EIO;
|
||||
}
|
||||
|
||||
*curr_bmap_off = cpu_to_le64(free_head);
|
||||
free_head = (free_head + 1) % bmap_length;
|
||||
free_tail = (free_tail + 1) % bmap_length;
|
||||
*ip_bitmap_p = cpu_to_le16(free_head);
|
||||
free_head = (free_head + 1) % ring_length;
|
||||
sm_raw->sm_ip_bm_free_head = cpu_to_le16(free_head);
|
||||
sm_raw->sm_ip_bm_free_tail = cpu_to_le16(free_tail);
|
||||
err = apfs_update_ip_bm_free_next(sb);
|
||||
if (err) {
|
||||
apfs_err(sb, "failed to update bitmap ring");
|
||||
goto out;
|
||||
}
|
||||
|
||||
new_bh = apfs_getblk(sb, bmap_base + le64_to_cpup(curr_bmap_off));
|
||||
ip_bitmap_bno = ring_base + le16_to_cpup(ip_bitmap_p);
|
||||
new_bh = apfs_getblk(sb, ip_bitmap_bno);
|
||||
if (!new_bh) {
|
||||
apfs_err(sb, "failed to map block for CoW (0x%llx)", bmap_base + le64_to_cpup(curr_bmap_off));
|
||||
apfs_err(sb, "failed to map block for CoW (0x%llx)", ip_bitmap_bno);
|
||||
err = -EIO;
|
||||
goto out;
|
||||
}
|
||||
@@ -234,7 +250,7 @@ static int apfs_rotate_ip_bitmaps(struct super_block *sb)
|
||||
err = apfs_transaction_join(sb, new_bh);
|
||||
if (err)
|
||||
goto out;
|
||||
spaceman->sm_ip = new_bh;
|
||||
spaceman->sm_ip_bmaps[idx] = new_bh;
|
||||
|
||||
out:
|
||||
brelse(old_bh);
|
||||
@@ -243,6 +259,64 @@ out:
|
||||
return err;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_rotate_ip_bitmaps - Allocate new ip bitmaps from the circular buffer
|
||||
* @sb: superblock structure
|
||||
*
|
||||
* Allocates bitmaps for the whole internal pool at once, meaning that each
|
||||
* transaction is forced to allocate one bitmap for every ~1.32 TiB of container
|
||||
* size, even if they won't be needed. This seems very reasonable to me, but the
|
||||
* official implementation avoids it and they may have a good reason.
|
||||
*
|
||||
* Returns 0 on success or a negative error code in case of failure.
|
||||
*/
|
||||
static int apfs_rotate_ip_bitmaps(struct super_block *sb)
|
||||
{
|
||||
struct apfs_spaceman *spaceman = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *sm_raw = spaceman->sm_raw;
|
||||
u32 ring_length = le32_to_cpu(sm_raw->sm_ip_bm_block_count);
|
||||
u32 bmaps_count = spaceman->sm_ip_bmaps_count;
|
||||
u16 free_head, free_tail, free_len;
|
||||
int err;
|
||||
u32 i;
|
||||
|
||||
apfs_assert_in_transaction(sb, &sm_raw->sm_o);
|
||||
|
||||
free_head = le16_to_cpu(sm_raw->sm_ip_bm_free_head);
|
||||
free_tail = le16_to_cpu(sm_raw->sm_ip_bm_free_tail);
|
||||
|
||||
/*
|
||||
* Check that we have enough room before doing anything. If we run out
|
||||
* I may need to compact the ring using the blocks marked as 0xFFFF in
|
||||
* ip_bm_free_next (TODO).
|
||||
*/
|
||||
free_len = (ring_length + free_tail - free_head) % ring_length;
|
||||
if (free_len < bmaps_count) {
|
||||
apfs_alert(sb, "full ip bitmap ring (%u < %u)", free_len, bmaps_count);
|
||||
return -ENOSPC;
|
||||
}
|
||||
|
||||
for (i = 0; i < bmaps_count; ++i) {
|
||||
err = apfs_rotate_single_ip_bitmap(sb, i);
|
||||
if (err) {
|
||||
apfs_err(sb, "failed to rotate ip bitmap %u", i);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
|
||||
/* All bitmaps have been reallocated, so just free the same number */
|
||||
free_tail = (free_tail + bmaps_count) % ring_length;
|
||||
sm_raw->sm_ip_bm_free_tail = cpu_to_le16(free_tail);
|
||||
|
||||
err = apfs_update_ip_bm_free_next(sb);
|
||||
if (err) {
|
||||
apfs_err(sb, "failed to update bitmap ring");
|
||||
return err;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
/*
|
||||
* Free queue record data
|
||||
*/
|
||||
@@ -309,10 +383,11 @@ static int apfs_ip_mark_free(struct super_block *sb, u64 bno)
|
||||
{
|
||||
struct apfs_spaceman *sm = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *sm_raw = sm->sm_raw;
|
||||
char *bitmap = sm->sm_ip->b_data;
|
||||
struct buffer_head *bmap_bh = NULL;
|
||||
|
||||
bno -= le64_to_cpu(sm_raw->sm_ip_base);
|
||||
__clear_bit_le(bno, bitmap);
|
||||
bmap_bh = sm->sm_ip_bmaps[bno >> sm->sm_ip_bmaps_shift];
|
||||
__clear_bit_le(bno & sm->sm_ip_bmaps_mask, bmap_bh->b_data);
|
||||
|
||||
return 0;
|
||||
}
|
||||
@@ -337,15 +412,13 @@ static int apfs_flush_fq_rec(struct apfs_node *root, u64 xid, u64 *len)
|
||||
struct apfs_spaceman *sm = APFS_SM(sb);
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_fq_rec fqrec = {0};
|
||||
struct apfs_key key;
|
||||
u64 bno;
|
||||
int err;
|
||||
|
||||
query = apfs_alloc_query(root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
apfs_init_free_queue_key(xid, 0 /* paddr */, &key);
|
||||
query->key = &key;
|
||||
apfs_init_free_queue_key(xid, 0 /* paddr */, &query->key);
|
||||
query->flags |= APFS_QUERY_FREE_QUEUE | APFS_QUERY_ANY_NUMBER | APFS_QUERY_EXACT;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
@@ -361,7 +434,7 @@ static int apfs_flush_fq_rec(struct apfs_node *root, u64 xid, u64 *len)
|
||||
}
|
||||
|
||||
for (bno = fqrec.bno; bno < fqrec.bno + fqrec.len; ++bno) {
|
||||
if(apfs_block_in_ip(sm, bno))
|
||||
if (apfs_block_in_ip(sm, bno))
|
||||
err = apfs_ip_mark_free(sb, bno);
|
||||
else
|
||||
err = apfs_main_free(sb, bno);
|
||||
@@ -406,7 +479,7 @@ static u64 apfs_free_queue_oldest_xid(struct apfs_node *root)
|
||||
*
|
||||
* Returns 0 on success or a negative error code in case of failure.
|
||||
*/
|
||||
static int apfs_flush_free_queue(struct super_block *sb, unsigned qid)
|
||||
static int apfs_flush_free_queue(struct super_block *sb, unsigned int qid)
|
||||
{
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_spaceman *sm = APFS_SM(sb);
|
||||
@@ -466,6 +539,42 @@ fail:
|
||||
return err;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_allocate_spaceman - Allocate an in-memory spaceman struct, if needed
|
||||
* @sb: superblock structure
|
||||
* @bmap_cnt: internal pool bitmap count
|
||||
*
|
||||
* Returns the spaceman and sets it in the superblock info. Also sets the fixed
|
||||
* information about the ip bitmap count. On failure, returns an error pointer.
|
||||
*/
|
||||
static struct apfs_spaceman *apfs_allocate_spaceman(struct super_block *sb, u32 bmap_cnt)
|
||||
{
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_spaceman *spaceman = NULL;
|
||||
int blk_bitcnt = sb->s_blocksize * 8;
|
||||
size_t sm_size;
|
||||
|
||||
if (nxi->nx_spaceman)
|
||||
return nxi->nx_spaceman;
|
||||
|
||||
/* We don't expect filesystems this big, it would be like 260 TiB */
|
||||
if (bmap_cnt > 200) {
|
||||
apfs_err(sb, "too many ip bitmap blocks (%u)", bmap_cnt);
|
||||
return ERR_PTR(-EFSCORRUPTED);
|
||||
}
|
||||
sm_size = sizeof(*spaceman) + bmap_cnt * sizeof(spaceman->sm_ip_bmaps[0]);
|
||||
|
||||
spaceman = nxi->nx_spaceman = kzalloc(sm_size, GFP_KERNEL);
|
||||
if (!spaceman)
|
||||
return ERR_PTR(-ENOMEM);
|
||||
spaceman->sm_nxi = nxi;
|
||||
|
||||
spaceman->sm_ip_bmaps_count = bmap_cnt;
|
||||
spaceman->sm_ip_bmaps_mask = blk_bitcnt - 1;
|
||||
spaceman->sm_ip_bmaps_shift = order_base_2(blk_bitcnt);
|
||||
return spaceman;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_read_spaceman - Find and read the space manager
|
||||
* @sb: superblock structure
|
||||
@@ -478,7 +587,7 @@ int apfs_read_spaceman(struct super_block *sb)
|
||||
{
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_nx_superblock *raw_sb = nxi->nx_raw;
|
||||
struct apfs_spaceman *spaceman = APFS_SM(sb);
|
||||
struct apfs_spaceman *spaceman = NULL;
|
||||
struct buffer_head *sm_bh;
|
||||
struct apfs_spaceman_phys *sm_raw;
|
||||
u32 sm_flags;
|
||||
@@ -488,8 +597,6 @@ int apfs_read_spaceman(struct super_block *sb)
|
||||
if (sb->s_flags & SB_RDONLY) /* The space manager won't be needed */
|
||||
return 0;
|
||||
|
||||
spaceman->sm_free_cache_base = spaceman->sm_free_cache_blkcnt = 0;
|
||||
|
||||
sm_bh = apfs_read_ephemeral_object(sb, oid);
|
||||
if (IS_ERR(sm_bh)) {
|
||||
apfs_err(sb, "ephemeral read failed for oid 0x%llx", oid);
|
||||
@@ -497,6 +604,15 @@ int apfs_read_spaceman(struct super_block *sb)
|
||||
}
|
||||
sm_raw = (struct apfs_spaceman_phys *)sm_bh->b_data;
|
||||
|
||||
spaceman = apfs_allocate_spaceman(sb, le32_to_cpu(sm_raw->sm_ip_bm_size_in_blocks));
|
||||
if (IS_ERR(spaceman)) {
|
||||
apfs_err(sb, "failed to allocate spaceman");
|
||||
err = PTR_ERR(spaceman);
|
||||
goto fail;
|
||||
}
|
||||
|
||||
spaceman->sm_free_cache_base = spaceman->sm_free_cache_blkcnt = 0;
|
||||
|
||||
sm_flags = le32_to_cpu(sm_raw->sm_flags);
|
||||
/* Undocumented feature, but it's too common to refuse to mount */
|
||||
if (sm_flags & APFS_SM_FLAG_VERSIONED)
|
||||
@@ -557,7 +673,7 @@ static void apfs_write_spaceman(struct apfs_spaceman *sm)
|
||||
struct apfs_spaceman_device *dev_raw = &sm_raw->sm_dev[APFS_SD_MAIN];
|
||||
struct apfs_nxsb_info *nxi;
|
||||
|
||||
nxi = container_of(sm, struct apfs_nxsb_info, nx_spaceman);
|
||||
nxi = sm->sm_nxi;
|
||||
ASSERT(le64_to_cpu(sm_raw->sm_o.o_xid) == nxi->nx_xid);
|
||||
|
||||
dev_raw->sm_free_count = cpu_to_le64(sm->sm_free_count);
|
||||
@@ -573,18 +689,26 @@ static u64 apfs_ip_find_free(struct super_block *sb)
|
||||
{
|
||||
struct apfs_spaceman *sm = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *sm_raw = sm->sm_raw;
|
||||
u64 bitcount = le64_to_cpu(sm_raw->sm_ip_block_count);
|
||||
char *bitmap = sm->sm_ip->b_data;
|
||||
u64 offset;
|
||||
int blk_bitcnt = sb->s_blocksize * 8;
|
||||
u64 full_bitcnt = le64_to_cpu(sm_raw->sm_ip_block_count);
|
||||
u32 i;
|
||||
|
||||
if (bitcount > sb->s_blocksize * 8)
|
||||
return 0;
|
||||
offset = find_next_zero_bit_le(bitmap, bitcount, 0 /* offset */);
|
||||
if (offset >= bitcount) {
|
||||
apfs_warn(sb, "internal pool seems full");
|
||||
return 0;
|
||||
for (i = 0; i < sm->sm_ip_bmaps_count; ++i) {
|
||||
char *bitmap = sm->sm_ip_bmaps[i]->b_data;
|
||||
u64 off_in_bmap_blk, off_in_ip;
|
||||
|
||||
off_in_bmap_blk = find_next_zero_bit_le(bitmap, blk_bitcnt, 0 /* offset */);
|
||||
if (off_in_bmap_blk >= blk_bitcnt) /* No space in this chunk */
|
||||
continue;
|
||||
|
||||
/* We found something, confirm that it's not outside the ip */
|
||||
off_in_ip = (i << sm->sm_ip_bmaps_shift) + off_in_bmap_blk;
|
||||
if (off_in_ip >= full_bitcnt)
|
||||
break;
|
||||
return le64_to_cpu(sm_raw->sm_ip_base) + off_in_ip;
|
||||
}
|
||||
return le64_to_cpu(sm_raw->sm_ip_base) + offset;
|
||||
apfs_err(sb, "internal pool seems full");
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -615,10 +739,11 @@ static void apfs_ip_mark_used(struct super_block *sb, u64 bno)
|
||||
{
|
||||
struct apfs_spaceman *sm = APFS_SM(sb);
|
||||
struct apfs_spaceman_phys *sm_raw = sm->sm_raw;
|
||||
char *bitmap = sm->sm_ip->b_data;
|
||||
struct buffer_head *bmap_bh = NULL;
|
||||
|
||||
bno -= le64_to_cpu(sm_raw->sm_ip_base);
|
||||
__set_bit_le(bno, bitmap);
|
||||
bmap_bh = sm->sm_ip_bmaps[bno >> sm->sm_ip_bmaps_shift];
|
||||
__set_bit_le(bno & sm->sm_ip_bmaps_mask, bmap_bh->b_data);
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -671,7 +796,6 @@ int apfs_free_queue_insert_nocache(struct super_block *sb, u64 bno, u64 count)
|
||||
struct apfs_query *query = NULL;
|
||||
struct apfs_spaceman_free_queue_key raw_key;
|
||||
__le64 raw_val;
|
||||
struct apfs_key key;
|
||||
u64 node_count;
|
||||
u16 node_limit;
|
||||
int err;
|
||||
@@ -693,9 +817,7 @@ int apfs_free_queue_insert_nocache(struct super_block *sb, u64 bno, u64 count)
|
||||
err = -ENOMEM;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
apfs_init_free_queue_key(nxi->nx_xid, bno, &key);
|
||||
query->key = &key;
|
||||
apfs_init_free_queue_key(nxi->nx_xid, bno, &query->key);
|
||||
query->flags |= APFS_QUERY_FREE_QUEUE;
|
||||
|
||||
err = apfs_btree_query(sb, &query);
|
||||
@@ -829,7 +951,7 @@ static int apfs_chunk_alloc_free(struct super_block *sb,
|
||||
if (!ci->ci_bitmap_addr) {
|
||||
u64 bmap_bno;
|
||||
|
||||
if(!is_alloc) {
|
||||
if (!is_alloc) {
|
||||
apfs_err(sb, "attempt to free block in all-free chunk");
|
||||
return -EFSCORRUPTED;
|
||||
}
|
||||
@@ -930,10 +1052,9 @@ static int apfs_chunk_alloc_free(struct super_block *sb,
|
||||
ci->ci_bitmap_addr = cpu_to_le64(bmap_bh->b_blocknr);
|
||||
ASSERT(buffer_trans(*cib_bh));
|
||||
set_buffer_csum(*cib_bh);
|
||||
mark_buffer_dirty(*cib_bh);
|
||||
|
||||
/* Finally, allocate / free the actual block that was requested */
|
||||
if(is_alloc) {
|
||||
if (is_alloc) {
|
||||
*bno = apfs_chunk_find_free(sb, bmap, le64_to_cpu(ci->ci_addr));
|
||||
if (!*bno) {
|
||||
apfs_err(sb, "no free blocks in chunk");
|
||||
@@ -943,11 +1064,10 @@ static int apfs_chunk_alloc_free(struct super_block *sb,
|
||||
apfs_chunk_mark_used(sb, bmap, *bno);
|
||||
sm->sm_free_count -= 1;
|
||||
} else {
|
||||
if(!apfs_chunk_mark_free(sb, bmap, *bno)) {
|
||||
if (!apfs_chunk_mark_free(sb, bmap, *bno)) {
|
||||
apfs_err(sb, "block already marked as free (0x%llx)", *bno);
|
||||
le32_add_cpu(&ci->ci_free_count, -1);
|
||||
set_buffer_csum(*cib_bh);
|
||||
mark_buffer_dirty(*cib_bh);
|
||||
err = -EFSCORRUPTED;
|
||||
} else
|
||||
sm->sm_free_count += 1;
|
||||
@@ -1102,7 +1222,7 @@ static int apfs_main_free(struct super_block *sb, u64 bno)
|
||||
u64 cib_bno;
|
||||
int err;
|
||||
|
||||
if(!sm_raw->sm_blocks_per_chunk || !sm_raw->sm_chunks_per_cib) {
|
||||
if (!sm_raw->sm_blocks_per_chunk || !sm_raw->sm_chunks_per_cib) {
|
||||
apfs_err(sb, "block or chunk count not set");
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
@@ -14,6 +14,9 @@
|
||||
#include <linux/statfs.h>
|
||||
#include <linux/seq_file.h>
|
||||
#include "apfs.h"
|
||||
#include "version.h"
|
||||
|
||||
#define APFS_MODULE_ID_STRING "linux-apfs by eafer (" GIT_COMMIT ")"
|
||||
|
||||
#if LINUX_VERSION_CODE >= KERNEL_VERSION(4, 16, 0) /* iversion came in 4.16 */
|
||||
#include <linux/iversion.h>
|
||||
@@ -110,11 +113,8 @@ static struct buffer_head *apfs_read_super_copy(struct super_block *sb)
|
||||
apfs_err(sb, "not an apfs filesystem");
|
||||
goto fail;
|
||||
}
|
||||
if (!apfs_obj_verify_csum(sb, bh)) {
|
||||
apfs_err(sb, "inconsistent container superblock");
|
||||
err = -EFSBADCRC;
|
||||
goto fail;
|
||||
}
|
||||
if (!apfs_obj_verify_csum(sb, bh))
|
||||
apfs_notice(sb, "backup superblock seems corrupted");
|
||||
return bh;
|
||||
|
||||
fail:
|
||||
@@ -317,6 +317,8 @@ static inline void apfs_unmap_main_super(struct apfs_sb_info *sbi)
|
||||
#endif
|
||||
|
||||
list_del(&nxi->nx_list);
|
||||
kfree(nxi->nx_spaceman);
|
||||
nxi->nx_spaceman = NULL;
|
||||
kfree(nxi);
|
||||
out:
|
||||
sbi->s_nxi = NULL;
|
||||
@@ -879,10 +881,11 @@ static int apfs_count_used_blocks(struct super_block *sb, u64 *count)
|
||||
vol_id = le64_to_cpu(msb_raw->nx_fs_oid[i]);
|
||||
if (vol_id == 0) /* All volumes have been checked */
|
||||
break;
|
||||
err = apfs_omap_lookup_block(sb, omap, vol_id, &vol_bno,
|
||||
false /* write */);
|
||||
if (err)
|
||||
err = apfs_omap_lookup_newest_block(sb, omap, vol_id, &vol_bno, false /* write */);
|
||||
if (err) {
|
||||
apfs_err(sb, "omap lookup failed for vol id 0x%llx", vol_id);
|
||||
break;
|
||||
}
|
||||
|
||||
bh = apfs_sb_bread(sb, vol_bno);
|
||||
if (!bh) {
|
||||
@@ -958,6 +961,8 @@ static int apfs_show_options(struct seq_file *seq, struct dentry *root)
|
||||
|
||||
if (sbi->s_vol_nr != 0)
|
||||
seq_printf(seq, ",vol=%u", sbi->s_vol_nr);
|
||||
if (sbi->s_snap_name)
|
||||
seq_printf(seq, ",snap=%s", sbi->s_snap_name);
|
||||
if (uid_valid(sbi->s_uid))
|
||||
seq_printf(seq, ",uid=%u", from_kuid(&init_user_ns,
|
||||
sbi->s_uid));
|
||||
@@ -970,12 +975,15 @@ static int apfs_show_options(struct seq_file *seq, struct dentry *root)
|
||||
return 0;
|
||||
}
|
||||
|
||||
/* TODO: don't ignore @wait */
|
||||
int apfs_sync_fs(struct super_block *sb, int wait)
|
||||
{
|
||||
struct apfs_max_ops maxops = {0};
|
||||
int err;
|
||||
|
||||
/* TODO: actually start the commit and return without waiting? */
|
||||
if (wait == 0)
|
||||
return 0;
|
||||
|
||||
err = apfs_transaction_start(sb, maxops);
|
||||
if (err)
|
||||
return err;
|
||||
@@ -1331,6 +1339,27 @@ static int apfs_setup_bdi(struct super_block *sb)
|
||||
|
||||
#endif
|
||||
|
||||
static void apfs_set_trans_buffer_limit(struct super_block *sb)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
unsigned long memsize_in_blocks;
|
||||
struct sysinfo info = {0};
|
||||
|
||||
si_meminfo(&info);
|
||||
memsize_in_blocks = info.totalram << (PAGE_SHIFT - sb->s_blocksize_bits);
|
||||
|
||||
/*
|
||||
* Buffer heads are not reclaimed while they are part of the current
|
||||
* transaction, so systems with little memory will crash if we don't
|
||||
* commit often enough. This hack should make that happen in general,
|
||||
* but I still need to get the reclaim to work eventually (TODO).
|
||||
*/
|
||||
if (memsize_in_blocks >= 16 * TRANSACTION_BUFFERS_MAX)
|
||||
sbi->s_trans_buffers_max = TRANSACTION_BUFFERS_MAX;
|
||||
else
|
||||
sbi->s_trans_buffers_max = memsize_in_blocks / 16;
|
||||
}
|
||||
|
||||
static int apfs_fill_super(struct super_block *sb, void *data, int silent)
|
||||
{
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
@@ -1344,6 +1373,8 @@ static int apfs_fill_super(struct super_block *sb, void *data, int silent)
|
||||
if (err)
|
||||
return err;
|
||||
|
||||
apfs_set_trans_buffer_limit(sb);
|
||||
|
||||
sbi->s_uid = INVALID_UID;
|
||||
sbi->s_gid = INVALID_GID;
|
||||
err = parse_options(sb, data);
|
||||
@@ -1449,16 +1480,34 @@ static int apfs_test_super(struct super_block *sb, void *data)
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_set_super - Assign a fake bdev and an info struct to a superblock
|
||||
* apfs_set_super - Assign the device and an info struct to a superblock
|
||||
* @sb: superblock structure to set
|
||||
* @data: superblock info for the volume being mounted
|
||||
*/
|
||||
static int apfs_set_super(struct super_block *sb, void *data)
|
||||
{
|
||||
int err = set_anon_super(sb, data);
|
||||
if (!err)
|
||||
sb->s_fs_info = data;
|
||||
return err;
|
||||
struct apfs_sb_info *sbi = data;
|
||||
struct apfs_nxsb_info *nxi = sbi->s_nxi;
|
||||
int err;
|
||||
|
||||
/*
|
||||
* This fake device number will be unique to this volume-snapshot
|
||||
* combination. It gets reported by stat(), so that userland tools can
|
||||
* use it to tell different mountpoints apart.
|
||||
*/
|
||||
err = get_anon_bdev(&sbi->s_anon_dev);
|
||||
if (err)
|
||||
return err;
|
||||
|
||||
/*
|
||||
* This is the actual device number, shared by all volumes and
|
||||
* snapshots. It gets reported by the mountinfo file, and it seems that
|
||||
* udisks uses it to decide if a device is mounted, so it must be set.
|
||||
*/
|
||||
sb->s_dev = nxi->nx_bdev->bd_dev;
|
||||
|
||||
sb->s_fs_info = sbi;
|
||||
return 0;
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -1620,11 +1669,19 @@ out_unlock:
|
||||
return ERR_PTR(error);
|
||||
}
|
||||
|
||||
static void apfs_kill_sb(struct super_block *sb)
|
||||
{
|
||||
dev_t anon_dev = APFS_SB(sb)->s_anon_dev;
|
||||
|
||||
generic_shutdown_super(sb);
|
||||
free_anon_bdev(anon_dev);
|
||||
}
|
||||
|
||||
static struct file_system_type apfs_fs_type = {
|
||||
.owner = THIS_MODULE,
|
||||
.name = "apfs",
|
||||
.mount = apfs_mount,
|
||||
.kill_sb = kill_anon_super,
|
||||
.kill_sb = apfs_kill_sb,
|
||||
.fs_flags = FS_REQUIRES_DEV,
|
||||
};
|
||||
MODULE_ALIAS_FS("apfs");
|
||||
@@ -1650,6 +1707,7 @@ static void __exit exit_apfs_fs(void)
|
||||
|
||||
MODULE_AUTHOR("Ernesto A. Fernández");
|
||||
MODULE_DESCRIPTION("Apple File System");
|
||||
MODULE_VERSION(GIT_COMMIT);
|
||||
MODULE_LICENSE("GPL");
|
||||
module_init(init_apfs_fs)
|
||||
module_exit(exit_apfs_fs)
|
||||
+64
-52
@@ -523,42 +523,6 @@ fail:
|
||||
return err;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_end_buffer_write_sync - Clean up a buffer head just synced to disk
|
||||
* @bh: the buffer head to clean
|
||||
* @uptodate: has the write succeeded?
|
||||
*/
|
||||
static void apfs_end_buffer_write_sync(struct buffer_head *bh, int uptodate)
|
||||
{
|
||||
struct page *page = NULL;
|
||||
bool must_unlock, is_metadata;
|
||||
|
||||
page = bh->b_page;
|
||||
get_page(page);
|
||||
|
||||
is_metadata = buffer_csum(bh);
|
||||
clear_buffer_csum(bh);
|
||||
end_buffer_write_sync(bh, uptodate);
|
||||
bh = NULL;
|
||||
|
||||
/* Future writes to mmapped areas should fault for CoW */
|
||||
must_unlock = trylock_page(page);
|
||||
page_mkclean(page);
|
||||
|
||||
/* XXX: otherwise, the page cache fills up and crashes the machine */
|
||||
if (!is_metadata) {
|
||||
#if LINUX_VERSION_CODE >= KERNEL_VERSION(5, 19, 0)
|
||||
try_to_free_buffers(page_folio(page));
|
||||
#else
|
||||
try_to_free_buffers(page);
|
||||
#endif
|
||||
}
|
||||
|
||||
if (must_unlock)
|
||||
unlock_page(page);
|
||||
put_page(page);
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_transaction_flush_all_inodes - Flush inode metadata to the buffer heads
|
||||
* @sb: superblock structure
|
||||
@@ -628,6 +592,7 @@ static int apfs_transaction_commit_nx(struct super_block *sb)
|
||||
struct apfs_nx_transaction *nx_trans = &nxi->nx_transaction;
|
||||
struct apfs_bh_info *bhi, *tmp;
|
||||
int err = 0;
|
||||
u32 bmap_idx;
|
||||
|
||||
ASSERT(!(sb->s_flags & SB_RDONLY));
|
||||
ASSERT(nx_trans->t_old_msb);
|
||||
@@ -652,7 +617,7 @@ static int apfs_transaction_commit_nx(struct super_block *sb)
|
||||
sm->sm_free_cache_base = sm->sm_free_cache_blkcnt = 0;
|
||||
}
|
||||
|
||||
list_for_each_entry_safe(bhi, tmp, &nx_trans->t_buffers, list) {
|
||||
list_for_each_entry(bhi, &nx_trans->t_buffers, list) {
|
||||
struct buffer_head *bh = bhi->bh;
|
||||
|
||||
ASSERT(buffer_trans(bh));
|
||||
@@ -660,6 +625,25 @@ static int apfs_transaction_commit_nx(struct super_block *sb)
|
||||
if (buffer_csum(bh))
|
||||
apfs_obj_set_csum(sb, (void *)bh->b_data);
|
||||
|
||||
clear_buffer_dirty(bh);
|
||||
get_bh(bh);
|
||||
lock_buffer(bh);
|
||||
bh->b_end_io = end_buffer_write_sync;
|
||||
apfs_submit_bh(REQ_OP_WRITE, REQ_SYNC, bh);
|
||||
}
|
||||
list_for_each_entry_safe(bhi, tmp, &nx_trans->t_buffers, list) {
|
||||
struct buffer_head *bh = bhi->bh;
|
||||
struct page *page = NULL;
|
||||
bool is_metadata;
|
||||
|
||||
ASSERT(buffer_trans(bh));
|
||||
|
||||
wait_on_buffer(bh);
|
||||
if (!buffer_uptodate(bh)) {
|
||||
apfs_err(sb, "failed to write some blocks");
|
||||
return -EIO;
|
||||
}
|
||||
|
||||
list_del(&bhi->list);
|
||||
clear_buffer_trans(bh);
|
||||
nx_trans->t_buffers_count--;
|
||||
@@ -669,10 +653,27 @@ static int apfs_transaction_commit_nx(struct super_block *sb)
|
||||
kfree(bhi);
|
||||
bhi = NULL;
|
||||
|
||||
clear_buffer_dirty(bh);
|
||||
lock_buffer(bh);
|
||||
bh->b_end_io = apfs_end_buffer_write_sync;
|
||||
apfs_submit_bh(REQ_OP_WRITE, REQ_SYNC, bh);
|
||||
page = bh->b_page;
|
||||
get_page(page);
|
||||
|
||||
is_metadata = buffer_csum(bh);
|
||||
clear_buffer_csum(bh);
|
||||
put_bh(bh);
|
||||
bh = NULL;
|
||||
|
||||
/* Future writes to mmapped areas should fault for CoW */
|
||||
lock_page(page);
|
||||
page_mkclean(page);
|
||||
/* XXX: otherwise, the page cache fills up and crashes the machine */
|
||||
if (!is_metadata) {
|
||||
#if LINUX_VERSION_CODE >= KERNEL_VERSION(5, 19, 0)
|
||||
try_to_free_buffers(page_folio(page));
|
||||
#else
|
||||
try_to_free_buffers(page);
|
||||
#endif
|
||||
}
|
||||
unlock_page(page);
|
||||
put_page(page);
|
||||
}
|
||||
err = apfs_checkpoint_end(sb);
|
||||
if (err) {
|
||||
@@ -686,6 +687,7 @@ static int apfs_transaction_commit_nx(struct super_block *sb)
|
||||
|
||||
list_for_each_entry(sbi, &nxi->vol_list, list) {
|
||||
struct apfs_vol_transaction *vol_trans = &sbi->s_transaction;
|
||||
|
||||
if (!vol_trans->t_old_vsb)
|
||||
continue;
|
||||
|
||||
@@ -701,8 +703,10 @@ static int apfs_transaction_commit_nx(struct super_block *sb)
|
||||
vol_trans->t_old_cat_root.object.o_bh = NULL;
|
||||
}
|
||||
|
||||
brelse(APFS_SM(sb)->sm_ip);
|
||||
APFS_SM(sb)->sm_ip = NULL;
|
||||
for (bmap_idx = 0; bmap_idx < APFS_SM(sb)->sm_ip_bmaps_count; ++bmap_idx) {
|
||||
brelse(APFS_SM(sb)->sm_ip_bmaps[bmap_idx]);
|
||||
APFS_SM(sb)->sm_ip_bmaps[bmap_idx] = NULL;
|
||||
}
|
||||
brelse(APFS_SM(sb)->sm_bh);
|
||||
APFS_SM(sb)->sm_bh = NULL;
|
||||
return 0;
|
||||
@@ -736,7 +740,7 @@ static bool apfs_transaction_need_commit(struct super_block *sb)
|
||||
struct apfs_spaceman_phys *sm_raw = sm->sm_raw;
|
||||
struct apfs_spaceman_free_queue *fq_ip = &sm_raw->sm_fq[APFS_SFQ_IP];
|
||||
struct apfs_spaceman_free_queue *fq_main = &sm_raw->sm_fq[APFS_SFQ_MAIN];
|
||||
int buffers_max = TRANSACTION_BUFFERS_MAX;
|
||||
int buffers_max = APFS_SB(sb)->s_trans_buffers_max;
|
||||
int starts_max = TRANSACTION_STARTS_MAX;
|
||||
int mq_max = TRANSACTION_MAIN_QUEUE_MAX;
|
||||
|
||||
@@ -751,7 +755,7 @@ static bool apfs_transaction_need_commit(struct super_block *sb)
|
||||
mq_max += 20;
|
||||
}
|
||||
|
||||
if(nx_trans->t_buffers_count > buffers_max)
|
||||
if (nx_trans->t_buffers_count > buffers_max)
|
||||
return true;
|
||||
if (nx_trans->t_starts_count > starts_max)
|
||||
return true;
|
||||
@@ -761,11 +765,11 @@ static bool apfs_transaction_need_commit(struct super_block *sb)
|
||||
* exactly 3 times. Don't allow large transactions if we can't
|
||||
* be sure the bitmap changes will all fit.
|
||||
*/
|
||||
if(le64_to_cpu(fq_ip->sfq_count) * 3 > le64_to_cpu(sm_raw->sm_ip_block_count))
|
||||
if (le64_to_cpu(fq_ip->sfq_count) * 3 > le64_to_cpu(sm_raw->sm_ip_block_count))
|
||||
return true;
|
||||
|
||||
/* Don't let the main queue get too full either */
|
||||
if(le64_to_cpu(fq_main->sfq_count) > mq_max)
|
||||
if (le64_to_cpu(fq_main->sfq_count) > mq_max)
|
||||
return true;
|
||||
}
|
||||
|
||||
@@ -845,7 +849,7 @@ int apfs_transaction_join(struct super_block *sb, struct buffer_head *bh)
|
||||
get_bh(bh);
|
||||
bhi->bh = bh;
|
||||
list_add(&bhi->list, &nx_trans->t_buffers);
|
||||
nx_trans->t_buffers_count ++;
|
||||
nx_trans->t_buffers_count++;
|
||||
|
||||
set_buffer_trans(bh);
|
||||
bh->b_private = bhi;
|
||||
@@ -883,6 +887,8 @@ void apfs_transaction_abort(struct super_block *sb)
|
||||
struct apfs_nx_transaction *nx_trans = &nxi->nx_transaction;
|
||||
struct apfs_bh_info *bhi, *tmp;
|
||||
struct apfs_inode_info *ai, *ai_tmp;
|
||||
struct apfs_spaceman *sm = NULL;
|
||||
u32 bmap_idx;
|
||||
|
||||
if (sb->s_flags & SB_RDONLY) {
|
||||
/* Transaction already aborted, do nothing */
|
||||
@@ -923,6 +929,7 @@ void apfs_transaction_abort(struct super_block *sb)
|
||||
|
||||
list_for_each_entry(sbi, &nxi->vol_list, list) {
|
||||
struct apfs_vol_transaction *vol_trans = &sbi->s_transaction;
|
||||
|
||||
if (!vol_trans->t_old_vsb)
|
||||
continue;
|
||||
|
||||
@@ -945,10 +952,15 @@ void apfs_transaction_abort(struct super_block *sb)
|
||||
vol_trans->t_old_cat_root.object.data = NULL;
|
||||
}
|
||||
|
||||
brelse(APFS_SM(sb)->sm_ip);
|
||||
APFS_SM(sb)->sm_ip = NULL;
|
||||
brelse(APFS_SM(sb)->sm_bh);
|
||||
APFS_SM(sb)->sm_bh = NULL;
|
||||
sm = APFS_SM(sb);
|
||||
if (sm) {
|
||||
for (bmap_idx = 0; bmap_idx < sm->sm_ip_bmaps_count; ++bmap_idx) {
|
||||
brelse(sm->sm_ip_bmaps[bmap_idx]);
|
||||
sm->sm_ip_bmaps[bmap_idx] = NULL;
|
||||
}
|
||||
brelse(sm->sm_bh);
|
||||
sm->sm_bh = NULL;
|
||||
}
|
||||
|
||||
/*
|
||||
* It's not possible to undo in-memory changes from old operations in
|
||||
|
||||
@@ -112,9 +112,7 @@ static int apfs_xattr_extents_read(struct inode *parent,
|
||||
{
|
||||
struct super_block *sb = parent->i_sb;
|
||||
struct apfs_dstream_info *dstream;
|
||||
int length, blkcnt, i;
|
||||
struct buffer_head **bhs = NULL;
|
||||
int ret;
|
||||
int length, ret;
|
||||
|
||||
dstream = kzalloc(sizeof(*dstream), GFP_KERNEL);
|
||||
if (!dstream)
|
||||
@@ -146,59 +144,11 @@ static int apfs_xattr_extents_read(struct inode *parent,
|
||||
length = size;
|
||||
}
|
||||
|
||||
blkcnt = (length + sb->s_blocksize - 1) >> sb->s_blocksize_bits;
|
||||
bhs = kcalloc(blkcnt, sizeof(*bhs), GFP_KERNEL);
|
||||
for (i = 0; i < blkcnt; i++) {
|
||||
struct buffer_head *bh = NULL;
|
||||
u64 bno = 0;
|
||||
|
||||
ret = apfs_logic_to_phys_bno(dstream, i, &bno);
|
||||
if (ret)
|
||||
goto out;
|
||||
if (bno == 0) {
|
||||
/* No holes in xattr dstreams, I believe */
|
||||
apfs_err(sb, "xattr dstream has a hole");
|
||||
ret = -EFSCORRUPTED;
|
||||
goto out;
|
||||
}
|
||||
|
||||
bhs[i] = __getblk_gfp(APFS_NXI(sb)->nx_bdev, bno, sb->s_blocksize, __GFP_MOVABLE);
|
||||
if (!bhs[i]) {
|
||||
apfs_err(sb, "failed to map block 0x%llx", bno);
|
||||
ret = -EIO;
|
||||
goto out;
|
||||
}
|
||||
|
||||
bh = bhs[i];
|
||||
if (!buffer_uptodate(bh)) {
|
||||
get_bh(bh);
|
||||
lock_buffer(bh);
|
||||
bh->b_end_io = end_buffer_read_sync;
|
||||
apfs_submit_bh(REQ_OP_READ, 0, bh);
|
||||
}
|
||||
}
|
||||
for (i = 0; i < blkcnt; i++) {
|
||||
int off, tocopy;
|
||||
|
||||
wait_on_buffer(bhs[i]);
|
||||
if (!buffer_uptodate(bhs[i])) {
|
||||
apfs_err(sb, "failed to read a block");
|
||||
ret = -EIO;
|
||||
goto out;
|
||||
}
|
||||
|
||||
off = i << sb->s_blocksize_bits;
|
||||
tocopy = min(sb->s_blocksize, (unsigned long)(length - off));
|
||||
memcpy(buffer + off, bhs[i]->b_data, tocopy);
|
||||
}
|
||||
ret = length;
|
||||
ret = apfs_nonsparse_dstream_read(dstream, buffer, length, 0 /* offset */);
|
||||
if (ret == 0)
|
||||
ret = length;
|
||||
|
||||
out:
|
||||
if (bhs) {
|
||||
for (i = 0; i < blkcnt; i++)
|
||||
brelse(bhs[i]);
|
||||
kfree(bhs);
|
||||
}
|
||||
kfree(dstream);
|
||||
return ret;
|
||||
}
|
||||
@@ -233,6 +183,123 @@ static int apfs_xattr_inline_read(struct apfs_xattr *xattr, void *buffer, size_t
|
||||
return length;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_xattr_get_compressed_data - Get the compressed data in a named attribute
|
||||
* @inode: inode the attribute belongs to
|
||||
* @name: name of the attribute
|
||||
* @cdata: compressed data struct to set on return
|
||||
*
|
||||
* Returns 0 on success or a negative error code in case of failure.
|
||||
*/
|
||||
int apfs_xattr_get_compressed_data(struct inode *inode, const char *name, struct apfs_compressed_data *cdata)
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_query *query;
|
||||
struct apfs_xattr xattr;
|
||||
u64 cnid = apfs_ino(inode);
|
||||
int ret;
|
||||
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
apfs_init_xattr_key(cnid, name, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
if (ret) {
|
||||
apfs_err(sb, "query failed for id 0x%llx (%s)", cnid, name);
|
||||
goto done;
|
||||
}
|
||||
|
||||
ret = apfs_xattr_from_query(query, &xattr);
|
||||
if (ret) {
|
||||
apfs_err(sb, "bad xattr record in inode 0x%llx", cnid);
|
||||
goto done;
|
||||
}
|
||||
|
||||
cdata->has_dstream = xattr.has_dstream;
|
||||
if (cdata->has_dstream) {
|
||||
struct apfs_dstream_info *dstream = NULL;
|
||||
|
||||
dstream = kzalloc(sizeof(*dstream), GFP_KERNEL);
|
||||
if (!dstream) {
|
||||
ret = -ENOMEM;
|
||||
goto done;
|
||||
}
|
||||
apfs_dstream_from_xattr(sb, &xattr, dstream);
|
||||
|
||||
cdata->dstream = dstream;
|
||||
cdata->size = dstream->ds_size;
|
||||
} else {
|
||||
void *data = NULL;
|
||||
int len;
|
||||
|
||||
len = xattr.xdata_len;
|
||||
if (len > APFS_XATTR_MAX_EMBEDDED_SIZE) {
|
||||
apfs_err(sb, "inline xattr too big");
|
||||
ret = -EFSCORRUPTED;
|
||||
goto done;
|
||||
}
|
||||
data = kzalloc(len, GFP_KERNEL);
|
||||
if (!data) {
|
||||
ret = -ENOMEM;
|
||||
goto done;
|
||||
}
|
||||
memcpy(data, xattr.xdata, len);
|
||||
|
||||
cdata->data = data;
|
||||
cdata->size = len;
|
||||
}
|
||||
ret = 0;
|
||||
|
||||
done:
|
||||
apfs_free_query(query);
|
||||
return ret;
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_release_compressed_data - Clean up a compressed data struct
|
||||
* @cdata: struct to clean up (but not free)
|
||||
*/
|
||||
void apfs_release_compressed_data(struct apfs_compressed_data *cdata)
|
||||
{
|
||||
if (!cdata)
|
||||
return;
|
||||
|
||||
if (cdata->has_dstream) {
|
||||
kfree(cdata->dstream);
|
||||
cdata->dstream = NULL;
|
||||
} else {
|
||||
kfree(cdata->data);
|
||||
cdata->data = NULL;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* apfs_compressed_data_read - Read from a compressed data struct
|
||||
* @cdata: compressed data struct
|
||||
* @buf: destination buffer
|
||||
* @count: exact number of bytes to read
|
||||
* @offset: dstream offset to read from
|
||||
*
|
||||
* Returns 0 on success or a negative error code in case of failure.
|
||||
*/
|
||||
int apfs_compressed_data_read(struct apfs_compressed_data *cdata, void *buf, size_t count, u64 offset)
|
||||
{
|
||||
if (cdata->has_dstream)
|
||||
return apfs_nonsparse_dstream_read(cdata->dstream, buf, count, offset);
|
||||
|
||||
if (offset > cdata->size || count > cdata->size - offset) {
|
||||
apfs_err(NULL, "reading past the end (0x%llx-0x%llx)", offset, (unsigned long long)count);
|
||||
/* No caller is expected to legitimately read out-of-bounds */
|
||||
return -EFSCORRUPTED;
|
||||
}
|
||||
memcpy(buf, cdata->data + offset, count);
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* __apfs_xattr_get - Find and read a named attribute
|
||||
* @inode: inode the attribute belongs to
|
||||
@@ -261,18 +328,15 @@ int ____apfs_xattr_get(struct inode *inode, const char *name, void *buffer,
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
struct apfs_xattr xattr;
|
||||
u64 cnid = apfs_ino(inode);
|
||||
int ret;
|
||||
|
||||
apfs_init_xattr_key(cnid, name, &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
query->key = &key;
|
||||
apfs_init_xattr_key(cnid, name, &query->key);
|
||||
query->flags |= APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -392,16 +456,13 @@ static int apfs_delete_any_xattr(struct inode *inode)
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
int ret;
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query)
|
||||
return -ENOMEM;
|
||||
|
||||
apfs_init_xattr_key(apfs_ino(inode), NULL /* name */, &key);
|
||||
query->key = &key;
|
||||
apfs_init_xattr_key(apfs_ino(inode), NULL /* name */, &query->key);
|
||||
query->flags = APFS_QUERY_CAT | APFS_QUERY_ANY_NAME | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -646,7 +707,6 @@ int apfs_xattr_set(struct inode *inode, const char *name, const void *value,
|
||||
{
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query = NULL;
|
||||
u64 cnid = apfs_ino(inode);
|
||||
int key_len, val_len;
|
||||
@@ -664,14 +724,12 @@ int apfs_xattr_set(struct inode *inode, const char *name, const void *value,
|
||||
}
|
||||
}
|
||||
|
||||
apfs_init_xattr_key(cnid, name, &key);
|
||||
|
||||
query = apfs_alloc_query(sbi->s_cat_root, NULL /* parent */);
|
||||
if (!query) {
|
||||
ret = -ENOMEM;
|
||||
goto done;
|
||||
}
|
||||
query->key = &key;
|
||||
apfs_init_xattr_key(cnid, name, &query->key);
|
||||
query->flags = APFS_QUERY_CAT | APFS_QUERY_EXACT;
|
||||
|
||||
ret = apfs_btree_query(sb, &query);
|
||||
@@ -805,7 +863,6 @@ ssize_t apfs_listxattr(struct dentry *dentry, char *buffer, size_t size)
|
||||
struct super_block *sb = inode->i_sb;
|
||||
struct apfs_sb_info *sbi = APFS_SB(sb);
|
||||
struct apfs_nxsb_info *nxi = APFS_NXI(sb);
|
||||
struct apfs_key key;
|
||||
struct apfs_query *query;
|
||||
u64 cnid = apfs_ino(inode);
|
||||
size_t free = size;
|
||||
@@ -820,8 +877,7 @@ ssize_t apfs_listxattr(struct dentry *dentry, char *buffer, size_t size)
|
||||
}
|
||||
|
||||
/* We want all the xattrs for the cnid, regardless of the name */
|
||||
apfs_init_xattr_key(cnid, NULL /* name */, &key);
|
||||
query->key = &key;
|
||||
apfs_init_xattr_key(cnid, NULL /* name */, &query->key);
|
||||
query->flags = APFS_QUERY_CAT | APFS_QUERY_MULTIPLE | APFS_QUERY_EXACT;
|
||||
|
||||
while (1) {
|
||||
|
||||
Reference in new issue
Block a user