1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2 * vim:expandtab:shiftwidth=8:tabstop=8:
4 * Lustre filesystem abstraction routines
6 * Copyright (C) 2004 Cluster File Systems, Inc.
8 * This file is part of Lustre, http://www.lustre.org.
10 * Lustre is free software; you can redistribute it and/or
11 * modify it under the terms of version 2 of the GNU General Public
12 * License as published by the Free Software Foundation.
14 * Lustre is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with Lustre; if not, write to the Free Software
21 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
24 #define DEBUG_SUBSYSTEM S_SM
26 #include <linux/kmod.h>
27 #include <linux/init.h>
29 #include <linux/slab.h>
30 #include <linux/obd_class.h>
31 #include <linux/obd_support.h>
32 #include <linux/lustre_lib.h>
33 #include <linux/lustre_idl.h>
34 #include <linux/lustre_fsfilt.h>
35 #include <linux/lustre_lite.h>
36 #include <linux/lustre_mds.h>
37 #include <linux/lustre_smfs.h>
38 #include "smfs_internal.h"
40 static int mds_rec_link_pack(char *buffer, struct dentry *dentry,
41 struct inode *dir, void *data1, void *data2)
43 struct mdc_op_data op_data;
44 struct mds_kml_pack_info *mkpi;
45 struct dentry *tgt = (struct dentry *)data1;
46 struct dentry *src = (struct dentry *)data2;
48 struct lustre_msg *msg = NULL;
51 ll_prepare_mdc_op_data(&op_data, src->d_inode, dir, tgt->d_name.name,
54 PACK_KML_REC_INIT(buffer, MDS_REINT);
56 mkpi = (struct mds_kml_pack_info*)buffer;
58 mkpi->mpi_bufcount = 2;
59 mkpi->mpi_size[0] = sizeof(struct mds_rec_link);
60 mkpi->mpi_size[1] = op_data.namelen + 1;
62 /*the mds reint log format
63 *opcode + mkpi + request
65 msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
66 lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
68 tmp = mdc_link_pack(msg, 0, &op_data);
69 mkpi->mpi_total_size = tmp - (void*)msg;
70 rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
74 static int mds_rec_setattr_pack(char *buffer, struct dentry *dentry,
75 struct inode *dir, void *data1, void *data2)
77 struct mds_rec_setattr *rec = NULL;
78 struct mdc_op_data op_data;
79 struct mds_kml_pack_info *mkpi;
80 struct iattr *iattr = (struct iattr *)data1;
81 struct lustre_msg *msg = NULL;
84 int rc = 0, ealen = 0;
86 ll_prepare_mdc_op_data(&op_data, dir, NULL, NULL, 0, 0);
88 PACK_KML_REC_INIT(buffer, MDS_REINT);
90 mkpi = (struct mds_kml_pack_info*)buffer;
92 /*FIXME later, did not think about EA situation*/
94 mkpi->mpi_bufcount = 1;
95 mkpi->mpi_size[0] = sizeof(struct mds_rec_setattr);
97 mkpi->mpi_bufcount ++;
98 mkpi->mpi_size[1] = *(int *)data2;
99 ealen = *(int *)data2;
100 ea = data2 + sizeof(ealen);
103 msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
104 lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
106 tmp = mdc_setattr_pack(msg, &op_data, iattr, ea, ealen, NULL, 0);
108 /*There are maybe some better ways
109 *to set the time attr FIXME WANGDI later
111 rec = (struct mds_rec_setattr *)lustre_msg_buf(msg, 0, 0);
112 if (rec->sa_valid & ATTR_CTIME)
113 rec->sa_valid |= ATTR_CTIME_SET;
114 if (rec->sa_valid & ATTR_MTIME)
115 rec->sa_valid |= ATTR_MTIME_SET;
116 if (rec->sa_valid & ATTR_ATIME)
117 rec->sa_valid |= ATTR_ATIME_SET;
119 mkpi->mpi_total_size = tmp - (void*)msg;
120 rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
125 static int mds_rec_create_pack(char *buffer, struct dentry *dentry,
126 struct inode *dir, void *data1, void *data2)
128 struct lustre_msg *msg = NULL;
129 struct mdc_op_data op_data;
130 struct mds_rec_create *rec;
131 struct mds_kml_pack_info *mkpi;
133 int rc = 0, tgt_len = 0;
135 ll_prepare_mdc_op_data(&op_data, dir, dentry->d_inode,
136 dentry->d_name.name, dentry->d_name.len, 0);
137 PACK_KML_REC_INIT(buffer, MDS_REINT);
139 mkpi = (struct mds_kml_pack_info*)buffer;
140 mkpi->mpi_bufcount = 2;
141 mkpi->mpi_size[0] = sizeof(struct mds_rec_create);
142 mkpi->mpi_size[1] = op_data.namelen + 1;
143 if (data1 && data2) {
144 mkpi->mpi_size[2] = *(int *)data2;
145 mkpi->mpi_bufcount++;
149 /*for symlink, data1 will be the tgt name */
150 tgt_len = *(int*)data2;
152 msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
153 lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
155 tmp = mdc_create_pack(msg, 0, &op_data, dentry->d_inode->i_mode,
156 dentry->d_inode->i_mode, data1, tgt_len);
158 rec = (struct mds_rec_create *)lustre_msg_buf(msg, 0, 0);
160 rec->cr_replayfid = op_data.fid2;
161 rec->cr_flags |= REC_REINT_CREATE;
162 mkpi->mpi_total_size = tmp - (void*)msg;
163 rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
168 static int mds_rec_unlink_pack(char *buffer, struct dentry *dentry,
169 struct inode *dir, void *data1, void *data2)
171 struct lustre_msg *msg = NULL;
172 struct mdc_op_data op_data;
173 struct mds_kml_pack_info *mkpi;
174 int mode = *(int*)data1;
178 ll_prepare_mdc_op_data(&op_data, dir, NULL, dentry->d_name.name,
179 dentry->d_name.len, mode);
181 PACK_KML_REC_INIT(buffer, MDS_REINT);
183 mkpi = (struct mds_kml_pack_info*)buffer;
184 mkpi->mpi_bufcount = 2;
185 mkpi->mpi_size[0] = sizeof(struct mds_rec_unlink);
186 mkpi->mpi_size[1] = op_data.namelen + 1;
188 msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
189 lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
191 tmp = mdc_unlink_pack(msg, 0, &op_data);
193 mkpi->mpi_total_size = tmp - (void*)msg;
194 rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
199 static int mds_rec_rename_pack(char *buffer, struct dentry *dentry,
200 struct inode *dir, void *data1, void *data2)
202 struct lustre_msg *msg = NULL;
203 struct dentry *new_dir = (struct dentry *)data1;
204 struct dentry *new_dentry = (struct dentry *)data2;
205 struct mdc_op_data op_data;
206 struct mds_kml_pack_info *mkpi;
207 struct mds_rec_rename *rec;
211 ll_prepare_mdc_op_data(&op_data, dir, new_dir->d_inode, NULL, 0, 0);
213 PACK_KML_REC_INIT(buffer, MDS_REINT);
215 mkpi = (struct mds_kml_pack_info*)buffer;
216 mkpi->mpi_bufcount = 3;
217 mkpi->mpi_size[0] = sizeof(struct mds_rec_rename);
218 mkpi->mpi_size[1] = dentry->d_name.len + 1;
219 mkpi->mpi_size[2] = new_dentry->d_name.len + 1;
221 rec = (struct mds_rec_rename *)(buffer + sizeof(*mkpi));
223 msg = (struct lustre_msg *)(buffer + sizeof(*mkpi));
224 lustre_init_msg(msg, mkpi->mpi_bufcount, mkpi->mpi_size, NULL);
226 tmp = mdc_rename_pack(msg, 0, &op_data, dentry->d_name.name,
227 dentry->d_name.len, new_dentry->d_name.name,
228 new_dentry->d_name.len);
230 mkpi->mpi_total_size = tmp - (void*)msg;
231 rc = mkpi->mpi_total_size + sizeof(*mkpi) + sizeof(int);
235 typedef int (*mds_pack_rec_func)(char *buffer, struct dentry *dentry,
236 struct inode *dir, void *data1, void *data2);
237 static mds_pack_rec_func mds_kml_pack[REINT_MAX + 1] = {
238 [REINT_LINK] mds_rec_link_pack,
239 [REINT_SETATTR] mds_rec_setattr_pack,
240 [REINT_CREATE] mds_rec_create_pack,
241 [REINT_UNLINK] mds_rec_unlink_pack,
242 [REINT_RENAME] mds_rec_rename_pack,
245 int mds_rec_pack(char *buffer, struct dentry *dentry, struct inode *dir,
246 void *data1, void *data2, int op)
248 return mds_kml_pack[op](buffer, dentry, dir, data1, data2);
251 int mds_rec_pack_init(struct super_block *sb)
253 struct smfs_super_info *smsi = S2SMI(sb);
255 smsi->smsi_pack_rec[PACK_MDS] = mds_rec_pack;