void *(* fs_brw_start)(int objcount, struct fsfilt_objinfo *fso,
int niocount, struct niobuf_local *nb,
void *desc_private, int logs);
- int (* fs_commit)(struct inode *inode, void *handle,int force_sync);
+ int (* fs_commit)(struct super_block *sb, struct inode *inode,
+ void *handle,int force_sync);
int (* fs_commit_async)(struct inode *inode, void *handle,
void **wait_handle);
int (* fs_commit_wait)(struct inode *inode, void *handle);
void *cb_data);
int (* fs_statfs)(struct super_block *sb, struct obd_statfs *osfs);
int (* fs_sync)(struct super_block *sb);
- int (* fs_map_inode_page)(struct inode *inode, struct page *page,
- unsigned long *blocks, int *created,
- int create);
+ int (* fs_map_inode_pages)(struct inode *inode, struct page **page,
+ int pages, unsigned long *blocks,
+ int *created, int create,
+ struct semaphore *sem);
int (* fs_prep_san_write)(struct inode *inode, long *blocks,
int nblocks, loff_t newsize);
int (* fs_write_record)(struct file *, void *, int size, loff_t *,
int force_sync);
int (* fs_read_record)(struct file *, void *, int size, loff_t *);
- int (* fs_setup)(struct super_block *sb);
-
+ int (* fs_setup)(struct obd_device *, struct super_block *);
+
+ int (* fs_post_setup)(struct obd_device *obd, struct vfsmount *mnt);
+ int (* fs_post_cleanup)(struct obd_device *obd, struct vfsmount *mnt);
+ int (* fs_get_reint_log_ctxt)(struct super_block *sb,
+ struct llog_ctxt **ctxt);
+ int (* fs_set_kml_flags)(struct inode *inode);
+ int (* fs_clear_kml_flags)(struct inode *inode);
+ int (* fs_set_ost_flags)(struct super_block *sb);
+ int (* fs_set_mds_flags)(struct super_block *sb);
+ int (* fs_precreate_rec)(struct dentry *dentry, int *num,
+ struct obdo *oa);
int (* fs_set_xattr)(struct inode *inode, void *handle, char *name,
- void *buffer, int buffer_size);
+ void *buffer, int buffer_size);
int (* fs_get_xattr)(struct inode *inode, char *name,
void *buffer, int buffer_size);
+
+ int (* fs_init_extents_ea)(struct inode *inode);
+ int (* fs_insert_extents_ea)(struct inode *inode, unsigned long from,
+ unsigned long num);
+ int (* fs_write_extents)(struct dentry *dentry,
+ unsigned long offset, unsigned long blks);
+ int (* fs_remove_extents_ea)(struct inode *inode, unsigned long from,
+ unsigned long num);
+ int (* fs_get_ino_write_extents)(struct super_block *sb, ino_t ino,
+ char **pbuf, int *size);
+ int (* fs_free_write_extents)(struct super_block *sb, ino_t ino,
+ char *pbuf, int size);
+ int (* fs_get_inode_write_extents)(struct inode *inode, char **pbuf,
+ int *size);
+ int (* fs_get_write_extents_num)(struct inode *inode, int* size);
int (* fs_get_op_len)(int, struct fsfilt_objinfo *, int);
+ int (* fs_add_dir_entry)(struct obd_device *, struct dentry *,
+ char *, int, unsigned long, unsigned long,
+ unsigned);
+ int (* fs_del_dir_entry)(struct obd_device *, struct dentry *);
};
extern int fsfilt_register_ops(struct fsfilt_operations *fs_ops);
}
static inline int
-fsfilt_commit_ops(struct fsfilt_operations *ops, struct inode *inode,
- void *handle, int force_sync)
+fsfilt_commit_ops(struct fsfilt_operations *ops, struct super_block *sb,
+ struct inode *inode, void *handle, int force_sync)
{
unsigned long now = jiffies;
- int rc = ops->fs_commit(inode, handle, force_sync);
+ int rc = ops->fs_commit(sb, inode, handle, force_sync);
CDEBUG(D_HA, "committing handle %p\n", handle);
if (time_after(jiffies, now + 15 * HZ))
}
static inline int
-fsfilt_commit(struct obd_device *obd, struct inode *inode,
- void *handle, int force_sync)
+fsfilt_commit(struct obd_device *obd, struct super_block *sb,
+ struct inode *inode, void *handle, int force_sync)
{
- return fsfilt_commit_ops(obd->obd_fsops, inode, handle, force_sync);
+ return fsfilt_commit_ops(obd->obd_fsops, sb, inode, handle, force_sync);
}
-static inline int
+static inline int
llog_fsfilt_commit(struct llog_ctxt *ctxt, struct inode *inode,
void *handle, int force_sync)
{
- return fsfilt_commit_ops(ctxt->loc_fsops, inode, handle, force_sync);
+ return fsfilt_commit_ops(ctxt->loc_fsops, inode->i_sb, inode, handle,
+ force_sync);
}
static inline void *
struct super_block *fs)
{
if (obd->obd_fsops->fs_setup)
- return obd->obd_fsops->fs_setup(fs);
-
+ return obd->obd_fsops->fs_setup(obd, fs);
return 0;
}
LASSERT(page != NULL);
filter = &obd->u.filter;
-
+
if (!obd->obd_fsops->fs_putpage)
return -ENOSYS;
CDEBUG(D_INFO, "putpage %lx\n", page->index);
-
+
rc = obd->obd_fsops->fs_putpage(inode, page);
if (time_after(jiffies, now + 15 * HZ))
return ERR_PTR(-ENOSYS);
CDEBUG(D_INFO, "getpage %lx\n", index);
-
+
page = obd->obd_fsops->fs_getpage(inode, index);
-
+
if (time_after(jiffies, now + 15 * HZ))
CERROR("long getpage time %lus\n", (jiffies - now) / HZ);
return obd->obd_fsops->fs_sync(sb);
}
-static inline int
-fsfilt_map_inode_page(struct obd_device *obd, struct inode *inode,
- struct page *page, unsigned long *blocks,
- int *created, int create)
+static inline int fsfilt_map_inode_pages(struct obd_device *obd,
+ struct inode *inode,
+ struct page **page, int pages,
+ unsigned long *blocks, int *created,
+ int create, struct semaphore *sem)
{
- return obd->obd_fsops->fs_map_inode_page(inode, page, blocks,
- created, create);
+ return obd->obd_fsops->fs_map_inode_pages(inode, page, pages, blocks,
+ created, create, sem);
+}
+
+static inline int
+fsfilt_write_extents(struct obd_device *obd, struct dentry *dentry,
+ unsigned long offset, unsigned long blks)
+{
+ if (obd->obd_fsops->fs_write_extents)
+ return obd->obd_fsops->fs_write_extents(dentry,
+ offset, blks);
+ return 0;
}
static inline int
return obd->obd_fsops->fs_read_record(file, buf, size, offs);
}
+static inline int
+llog_fsfilt_read_record(struct llog_ctxt *ctxt, struct file *file,
+ void *buf, loff_t size, loff_t *offs)
+{
+ return ctxt->loc_fsops->fs_read_record(file, buf, size, offs);
+}
+
static inline int
fsfilt_write_record(struct obd_device *obd, struct file *file,
void *buf, loff_t size, loff_t *offs, int force_sync)
{
- return obd->obd_fsops->fs_write_record(file, buf, size, offs,
+ return obd->obd_fsops->fs_write_record(file, buf, size, offs,
force_sync);
}
force_sync);
}
-static inline int
-llog_fsfilt_read_record(struct llog_ctxt *ctxt, struct file *file,
- void *buf, loff_t size, loff_t *offs)
+static inline int
+fsfilt_set_kml_flags(struct obd_device *obd, struct inode *inode)
{
- return ctxt->loc_fsops->fs_read_record(file, buf, size, offs);
+ if (obd->obd_fsops->fs_set_kml_flags)
+ return obd->obd_fsops->fs_set_kml_flags(inode);
+ return 0;
+}
+
+static inline int
+fsfilt_clear_kml_flags(struct obd_device *obd, struct inode *inode)
+{
+ if (obd->obd_fsops->fs_clear_kml_flags)
+ return obd->obd_fsops->fs_clear_kml_flags(inode);
+ return 0;
+}
+static inline int
+fsfilt_precreate_rec(struct obd_device *obd, struct dentry *dentry,
+ int *num, struct obdo *oa)
+{
+ if (obd->obd_fsops->fs_precreate_rec)
+ return obd->obd_fsops->fs_precreate_rec(dentry, num, oa);
+ return 0;
+}
+
+static inline int
+fsfilt_post_setup(struct obd_device *obd)
+{
+ if (obd->obd_fsops->fs_post_setup)
+ return obd->obd_fsops->fs_post_setup(obd,
+ obd->obd_lvfs_ctxt.pwdmnt);
+ return 0;
+}
+
+static inline int
+fsfilt_post_cleanup(struct obd_device *obd)
+{
+ if (obd->obd_fsops->fs_post_cleanup)
+ return obd->obd_fsops->fs_post_cleanup(obd,
+ obd->obd_lvfs_ctxt.pwdmnt);
+ return 0;
+}
+
+static inline int
+fsfilt_get_ino_write_extents(struct obd_device *obd,
+ struct super_block *sb,
+ int ino, char **buf, int *size)
+{
+ if (obd->obd_fsops->fs_get_ino_write_extents)
+ return obd->obd_fsops->fs_get_ino_write_extents(sb, ino,
+ buf, size);
+ return 0;
+}
+
+static inline int
+fsfilt_free_write_extents(struct obd_device *obd,
+ struct super_block *sb,
+ int ino, char *buf, int size)
+{
+ if (obd->obd_fsops->fs_free_write_extents)
+ return obd->obd_fsops->fs_free_write_extents(sb, ino,
+ buf, size);
+ return 0;
+}
+
+static inline int
+fsfilt_get_reint_log_ctxt(struct obd_device *obd,
+ struct super_block *sb,
+ struct llog_ctxt **ctxt)
+{
+ if (obd->obd_fsops->fs_get_reint_log_ctxt)
+ return obd->obd_fsops->fs_get_reint_log_ctxt(sb, ctxt);
+ return 0;
+}
+
+static inline int
+fsfilt_set_ost_flags(struct obd_device *obd, struct super_block *sb)
+{
+ if (obd->obd_fsops->fs_set_ost_flags)
+ return obd->obd_fsops->fs_set_ost_flags(sb);
+ return 0;
+}
+
+static inline int
+fsfilt_set_mds_flags(struct obd_device *obd, struct super_block *sb)
+{
+ if (obd->obd_fsops->fs_set_mds_flags)
+ return obd->obd_fsops->fs_set_mds_flags(sb);
+ return 0;
+}
+
+static inline int
+fsfilt_add_dir_entry(struct obd_device *obd, struct dentry *dir,
+ char *name, int namelen, unsigned long ino,
+ unsigned long generation, unsigned mds)
+{
+ LASSERT(obd->obd_fsops->fs_add_dir_entry);
+ return obd->obd_fsops->fs_add_dir_entry(obd, dir, name,
+ namelen, ino, generation, mds);
+}
+
+static inline int
+fsfilt_del_dir_entry(struct obd_device *obd, struct dentry *dentry)
+{
+ LASSERT(obd->obd_fsops->fs_del_dir_entry);
+ return obd->obd_fsops->fs_del_dir_entry(obd, dentry);
}
#endif /* __KERNEL__ */
git://git.whamcloud.com / fs / lustre-release.git / blobdiff