#include <linux/init.h>
#include <linux/fs.h>
#include <linux/slab.h>
+#include <linux/dcache.h>
#include <linux/obd_class.h>
#include <linux/obd_support.h>
#include <linux/lustre_lib.h>
#include <linux/lustre_smfs.h>
#include "smfs_internal.h"
+/* get lustre_id from "sid" attribute. */
+static int mds_rec_get_id(struct inode *inode, struct lustre_id *id)
+{
+ struct fsfilt_operations *fsfilt = S2SMI(inode->i_sb)->sm_fsfilt;
+ int rc = 0;
+ ENTRY;
+
+ LASSERT(id != NULL);
+ LASSERT(inode != NULL);
+
+ rc = fsfilt->fs_get_xattr(inode, XATTR_LUSTRE_MDS_SID_EA,
+ &id->li_fid, sizeof(id->li_fid));
+
+ if (rc > 0) {
+ LASSERT(id_fid(id) != 0);
+ rc = 0;
+ } else if (rc == 0) {
+ rc = -ENODATA;
+ }
+
+ RETURN(rc);
+}
+
static int mds_rec_link_pack(char *buffer, struct dentry *dentry,
struct inode *dir, void *data1, void *data2)
{
struct dentry *tgt = (struct dentry *)data2;
struct mds_kml_pack_info *mkpi;
struct lustre_msg *msg = NULL;
- struct mdc_op_data op_data;
+ struct mdc_op_data *op_data;
void *tmp = NULL;
int rc = 0;
+ ENTRY;
+
+ OBD_ALLOC(op_data, sizeof(*op_data));
+ if (op_data == NULL)
+ return -ENOMEM;
+
+ smfs_prepare_mdc_data(op_data, src->d_inode, dir,
+ (char *)tgt->d_name.name,
+ tgt->d_name.len, 0);
- mdc_prepare_mdc_data(&op_data, src->d_inode, dir,
- tgt->d_name.name, tgt->d_name.len, 0);
+ mds_rec_get_id(src->d_inode, &op_data->id1);
+ mds_rec_get_id(dir, &op_data->id2);
PACK_KML_REC_INIT(buffer, MDS_REINT);
mkpi = (struct mds_kml_pack_info *)buffer;
mkpi->mpi_bufcount = 2;
mkpi->mpi_size[0] = sizeof(struct mds_rec_link);
- mkpi->mpi_size[1] = op_data.namelen + 1;
+ mkpi->mpi_size[1] = op_data->namelen + 1;
/* the mds reint log format is: opcode + mkpi + request */
msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
- tmp = mdc_link_pack(msg, 0, &op_data);
+ tmp = mdc_link_pack(msg, 0, op_data);
+ OBD_FREE(op_data, sizeof(*op_data));
+ mkpi->mpi_total_size = tmp - (void *)msg;
+ rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
+
+ RETURN(rc);
+}
+
+static int mds_rec_setxattr_pack(char *buffer, struct dentry *dentry,
+ struct inode *dir, void *data1, void *data2)
+{
+ struct kml_buffer *kbuf = (struct kml_buffer *)data2;
+ struct mds_rec_setattr *rec = NULL;
+ struct mds_kml_pack_info *mkpi;
+ struct lustre_msg *msg = NULL;
+ struct mdc_op_data *op_data;
+ char *name = (char *)data1;
+ void *tmp = NULL;
+ int rc = 0;
+ ENTRY;
+
+ OBD_ALLOC(op_data, sizeof(*op_data));
+ if (op_data == NULL)
+ return -ENOMEM;
+
+ smfs_prepare_mdc_data(op_data, dir, NULL, NULL, 0, 0);
+ mds_rec_get_id(dir, &op_data->id1);
+
+ PACK_KML_REC_INIT(buffer, MDS_REINT);
+ mkpi = (struct mds_kml_pack_info *)buffer;
+
+ mkpi->mpi_bufcount = 3;
+ mkpi->mpi_size[0] = sizeof(struct mds_rec_setattr);
+ mkpi->mpi_size[1] = strlen(name);
+ mkpi->mpi_size[2] = kbuf->buf_size;
+
+ msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
+ lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
+
+ LASSERT(kbuf && name);
+
+ tmp = mdc_setattr_pack(msg, 0, op_data, NULL, name, strlen(name),
+ kbuf->buf, kbuf->buf_size, NULL, 0);
+ OBD_FREE(op_data, sizeof(*op_data));
+
+ rec = (struct mds_rec_setattr *)lustre_msg_buf(msg, 0, 0);
+ rec->sa_valid = ATTR_EA_CMOBD;
+
mkpi->mpi_total_size = tmp - (void *)msg;
rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
- return rc;
+
+ RETURN(rc);
}
/* FIXME-WANGDI: did not think about EA situation. */
struct mds_rec_setattr *rec = NULL;
struct mds_kml_pack_info *mkpi;
struct lustre_msg *msg = NULL;
- struct mdc_op_data op_data;
+ struct mdc_op_data *op_data;
int rc = 0, ealen = 0;
char *ea = NULL;
void *tmp = NULL;
+ ENTRY;
- mdc_prepare_mdc_data(&op_data, dir, NULL, NULL, 0, 0);
+ OBD_ALLOC(op_data, sizeof(*op_data));
+ if (op_data == NULL)
+ return -ENOMEM;
+
+ smfs_prepare_mdc_data(op_data, dir, NULL, NULL, 0, 0);
+ mds_rec_get_id(dir, &op_data->id1);
PACK_KML_REC_INIT(buffer, MDS_REINT);
- mkpi = (struct mds_kml_pack_info*)buffer;
+ mkpi = (struct mds_kml_pack_info *)buffer;
mkpi->mpi_bufcount = 1;
mkpi->mpi_size[0] = sizeof(struct mds_rec_setattr);
msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
- tmp = mdc_setattr_pack(msg, 0, &op_data, iattr, ea, ealen, NULL, 0);
+ tmp = mdc_setattr_pack(msg, 0, op_data, iattr, ea, ealen,
+ NULL, 0, NULL, 0);
+ OBD_FREE(op_data, sizeof(*op_data));
/* FIXME-WANGDI: there are maybe some better ways to set the time
* attr. */
mkpi->mpi_total_size = tmp - (void *)msg;
rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
-
- return rc;
+ RETURN(rc);
}
static int mds_rec_create_pack(char *buffer, struct dentry *dentry,
{
struct mds_kml_pack_info *mkpi;
struct lustre_msg *msg = NULL;
- struct mdc_op_data op_data;
+ struct dentry_params *param;
+ struct mdc_op_data *op_data;
struct mds_rec_create *rec;
int rc = 0, tgt_len = 0;
void *tmp = NULL;
+ ENTRY;
+
+ param = (struct dentry_params *)dentry->d_fsdata;
+ OBD_ALLOC(op_data, sizeof(*op_data));
+ if (op_data == NULL)
+ return -ENOMEM;
+
+ smfs_prepare_mdc_data(op_data, dir, dentry->d_inode,
+ (char *)dentry->d_name.name,
+ dentry->d_name.len, 0);
- mdc_prepare_mdc_data(&op_data, dir, dentry->d_inode,
- dentry->d_name.name, dentry->d_name.len, 0);
+ mds_rec_get_id(dir, &op_data->id1);
+ id_fid(&op_data->id2) = param->p_fid;
+ id_group(&op_data->id2) = param->p_group;
+
PACK_KML_REC_INIT(buffer, MDS_REINT);
mkpi = (struct mds_kml_pack_info *)buffer;
mkpi->mpi_bufcount = 2;
mkpi->mpi_size[0] = sizeof(struct mds_rec_create);
- mkpi->mpi_size[1] = op_data.namelen + 1;
+ mkpi->mpi_size[1] = op_data->namelen + 1;
if (data1 && data2) {
mkpi->mpi_size[2] = *(int *)data2;
mkpi->mpi_bufcount++;
}
- if (data1) {
- /* for symlink, data1 will be the tgt name. */
+ /* for symlink, data1 will be the tgt name. */
+ if (data1)
tgt_len = *(int *)data2;
- }
+
msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
- tmp = mdc_create_pack(msg, 0, &op_data, dentry->d_inode->i_mode,
+ tmp = mdc_create_pack(msg, 0, op_data, dentry->d_inode->i_mode,
dentry->d_inode->i_mode, data1, tgt_len);
rec = (struct mds_rec_create *)lustre_msg_buf(msg, 0, 0);
- rec->cr_replayid = op_data.id2;
+ rec->cr_replayid = op_data->id2;
rec->cr_flags |= REC_REINT_CREATE;
mkpi->mpi_total_size = tmp - (void *)msg;
rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
-
- return rc;
+ OBD_FREE(op_data, sizeof(*op_data));
+ RETURN(rc);
}
static int mds_rec_unlink_pack(char *buffer, struct dentry *dentry,
{
struct lustre_msg *msg = NULL;
struct mds_kml_pack_info *mkpi;
- struct mdc_op_data op_data;
+ struct mdc_op_data *op_data;
int mode = *(int*)data1;
void *tmp = NULL;
int rc = 0;
+ ENTRY;
+
+ OBD_ALLOC(op_data, sizeof(*op_data));
+ if (op_data == NULL)
+ return -ENOMEM;
+
+ smfs_prepare_mdc_data(op_data, dir, NULL,
+ (char *)dentry->d_name.name,
+ dentry->d_name.len, mode);
- mdc_prepare_mdc_data(&op_data, dir, NULL,
- dentry->d_name.name,
- dentry->d_name.len, mode);
+ mds_rec_get_id(dir, &op_data->id1);
PACK_KML_REC_INIT(buffer, MDS_REINT);
- mkpi = (struct mds_kml_pack_info*)buffer;
+ mkpi = (struct mds_kml_pack_info *)buffer;
mkpi->mpi_bufcount = 2;
mkpi->mpi_size[0] = sizeof(struct mds_rec_unlink);
- mkpi->mpi_size[1] = op_data.namelen + 1;
+ mkpi->mpi_size[1] = op_data->namelen + 1;
msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
- tmp = mdc_unlink_pack(msg, 0, &op_data);
+ tmp = mdc_unlink_pack(msg, 0, op_data);
- mkpi->mpi_total_size = tmp - (void*)msg;
+ mkpi->mpi_total_size = tmp - (void *)msg;
rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
-
- return rc;
+ OBD_FREE(op_data, sizeof(*op_data));
+ RETURN(rc);
}
static int mds_rec_rename_pack(char *buffer, struct dentry *dentry,
struct inode *new_dir = (struct inode *)data1;
struct mds_kml_pack_info *mkpi;
struct lustre_msg *msg = NULL;
- struct mdc_op_data op_data;
+ struct mdc_op_data *op_data;
struct mds_rec_rename *rec;
void *tmp = NULL;
int rc = 0;
+ ENTRY;
+
+ OBD_ALLOC(op_data, sizeof(*op_data));
+ if (op_data == NULL)
+ return -ENOMEM;
+ smfs_prepare_mdc_data(op_data, dir, new_dir, NULL, 0, 0);
- mdc_prepare_mdc_data(&op_data, dir, new_dir, NULL, 0, 0);
+ mds_rec_get_id(dir, &op_data->id1);
+ mds_rec_get_id(new_dir, &op_data->id2);
PACK_KML_REC_INIT(buffer, MDS_REINT);
- mkpi = (struct mds_kml_pack_info*)buffer;
+ mkpi = (struct mds_kml_pack_info *)buffer;
mkpi->mpi_bufcount = 3;
mkpi->mpi_size[0] = sizeof(struct mds_rec_rename);
rec = (struct mds_rec_rename *)(buffer + sizeof(*mkpi));
-
msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
- tmp = mdc_rename_pack(msg, 0, &op_data, dentry->d_name.name,
- dentry->d_name.len, new_dentry->d_name.name,
+ tmp = mdc_rename_pack(msg, 0, op_data, (char *)dentry->d_name.name,
+ dentry->d_name.len, (char *)new_dentry->d_name.name,
new_dentry->d_name.len);
- mkpi->mpi_total_size = tmp - (void*)msg;
+ mkpi->mpi_total_size = tmp - (void *)msg;
rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
- return rc;
+ OBD_FREE(op_data, sizeof(*op_data));
+ RETURN(rc);
}
-typedef int (*mds_pack_rec_func)(char *buffer, struct dentry *dentry,
- struct inode *dir, void *data1, void *data2);
+typedef int (*mds_pack_rec_func)(char *, struct dentry *,
+ struct inode *, void *, void *);
static mds_pack_rec_func mds_kml_pack[REINT_MAX + 1] = {
[REINT_LINK] mds_rec_link_pack,
[REINT_CREATE] mds_rec_create_pack,
[REINT_UNLINK] mds_rec_unlink_pack,
[REINT_RENAME] mds_rec_rename_pack,
+ [REINT_SETXATTR] mds_rec_setxattr_pack,
};
-int mds_rec_pack(char *buffer, struct dentry *dentry, struct inode *dir,
- void *data1, void *data2, int op)
+int mds_rec_pack(int op, char *buffer, struct dentry *dentry,
+ struct inode *dir, void *arg, void *arg2)
{
- return mds_kml_pack[op](buffer, dentry, dir, data1, data2);
+ return mds_kml_pack[op](buffer, dentry, dir, arg, arg2);
}
-int mds_rec_pack_init(struct smfs_super_info *smsi)
-{
-
- smsi->smsi_pack_rec[PACK_MDS] = mds_rec_pack;
- return 0;
-}
+
git://git.whamcloud.com / fs / lustre-release.git / blobdiff