2 * Lustre Light Update Records
4 * This code is issued under the GNU General Public License.
5 * See the file COPYING in this distribution
7 * Copryright (C) 2002 Cluster File Systems, Inc.
11 #include <linux/config.h>
12 #include <linux/module.h>
13 #include <linux/kernel.h>
15 #include <linux/string.h>
16 #include <linux/stat.h>
17 #include <linux/errno.h>
18 #include <linux/locks.h>
19 #include <linux/unistd.h>
21 #include <asm/system.h>
22 #include <asm/uaccess.h>
25 #include <linux/stat.h>
26 #include <asm/uaccess.h>
27 #include <linux/slab.h>
28 #include <asm/segment.h>
30 #define DEBUG_SUBSYSTEM S_MDS
32 #include <linux/obd_support.h>
33 #include <linux/lustre_lib.h>
34 #include <linux/lustre_idl.h>
35 #include <linux/lustre_light.h>
37 /* packing of MDS records */
38 void mds_create_pack(struct mds_rec_create *rec, struct inode *inode, const char *name, int namelen, __u32 mode, __u64 id, __u32 uid, __u32 gid, __u64 time, const char *tgt, int tgtlen)
40 char *tmp = (char *)rec + sizeof(*rec);
41 /* XXX do something about time, uid, gid */
43 HTON__u32(sizeof(*rec) + size_round0(namelen) +
45 rec->cr_opcode = HTON__u32(REINT_CREATE);
47 ll_inode2fid(&rec->cr_fid, inode);
48 rec->cr_mode = HTON__u32(mode);
49 rec->cr_id = HTON__u64(id);
50 rec->cr_uid = HTON__u32(uid);
51 rec->cr_gid = HTON__u32(gid);
52 rec->cr_time = HTON__u64(time);
53 rec->cr_namelen = HTON__u32(namelen + 1); /* for terminating \0 */
54 LOGL0(name, namelen, tmp);
56 rec->cr_tgtlen = HTON__u32(tgtlen + 1);
57 LOGL0(tgt, tgtlen, tmp);
62 void mds_setattr_pack(struct mds_rec_setattr *rec, struct inode *inode, struct iattr *iattr)
64 rec->sa_reclen = HTON__u32(sizeof(*rec));
65 rec->sa_opcode = HTON__u32(REINT_SETATTR);
67 ll_inode2fid(&rec->sa_fid, inode);
68 rec->sa_valid = HTON__u32(iattr->ia_valid);
69 rec->sa_mode = HTON__u32(iattr->ia_mode);
70 rec->sa_uid = HTON__u32(iattr->ia_uid);
71 rec->sa_gid = HTON__u32(iattr->ia_gid);
72 rec->sa_size = HTON__u64(iattr->ia_size);
73 rec->sa_atime = HTON__u64(iattr->ia_atime);
74 rec->sa_mtime = HTON__u64(iattr->ia_mtime);
75 rec->sa_ctime = HTON__u64(iattr->ia_ctime);
76 rec->sa_attr_flags = HTON__u32(iattr->ia_attr_flags);
79 void mds_unlink_pack(struct mds_rec_unlink *rec,
80 struct inode *inode, const char *name, int namelen)
82 char *tmp = (char *)rec + sizeof(*rec);
84 rec->ul_reclen = HTON__u32(sizeof(*rec)) + size_round0(namelen);
85 rec->ul_opcode = HTON__u32(REINT_UNLINK);
87 ll_inode2fid(&rec->ul_fid1, inode);
88 rec->ul_namelen = HTON__u32(namelen + 1); /* for terminating \0 */
89 LOGL0(name, namelen, tmp);
92 void mds_link_pack(struct mds_rec_link *rec,
93 struct inode *inode, struct inode *dir,
94 const char *name, int namelen)
96 char *tmp = (char *)rec + sizeof(*rec);
97 rec->lk_reclen = HTON__u32(sizeof(*rec)) + size_round0(namelen);
98 rec->lk_opcode = HTON__u32(REINT_LINK);
100 ll_inode2fid(&rec->lk_fid1, inode);
101 ll_inode2fid(&rec->lk_fid2, dir);
102 rec->lk_namelen = HTON__u32(namelen + 1); /* for terminating \0 */
103 LOGL0(name, namelen, tmp);
106 void mds_rename_pack(struct mds_rec_rename *rec, struct inode *srcdir, struct inode *tgtdir, const char *name, int namelen, const char *tgt, int tgtlen)
108 char *tmp = (char *)rec + sizeof(*rec);
109 /* XXX do something about time, uid, gid */
111 HTON__u32(sizeof(*rec) + size_round0(namelen) +
112 size_round0(tgtlen));
113 rec->rn_opcode = HTON__u32(REINT_RENAME);
115 ll_inode2fid(&rec->rn_fid1, srcdir);
116 ll_inode2fid(&rec->rn_fid2, tgtdir);
117 rec->rn_namelen = HTON__u32(namelen + 1); /* for terminating \0 */
118 LOGL0(name, namelen, tmp);
120 rec->rn_tgtlen = HTON__u32(tgtlen + 1);
121 LOGL0(tgt, tgtlen, tmp);
127 static int mds_update_hdr_unpack(char *buf, int len, struct mds_update_record *r)
129 struct mds_update_record_hdr *hdr = (struct mds_update_record_hdr *)buf;
131 r->ur_reclen = NTOH__u32(hdr->ur_reclen);
132 if (len < sizeof(*hdr) || len != r->ur_reclen) {
133 printk(__FUNCTION__ ": invalid buffer length\n");
136 r->ur_opcode = NTOH__u32(hdr->ur_opcode);
140 static int mds_setattr_unpack(char *buf, int len, struct mds_update_record *r)
143 struct iattr *attr = &r->ur_iattr;
144 struct mds_rec_setattr *rec = (struct mds_rec_setattr *)buf;
146 if (len < sizeof(*rec)) {
147 printk(__FUNCTION__ "invalid buffer length\n");
151 r->ur_fid1 = &rec->sa_fid;
152 attr->ia_valid = NTOH__u32(rec->sa_valid);
153 attr->ia_mode = NTOH__u32(rec->sa_mode);
154 attr->ia_uid = NTOH__u32(rec->sa_uid);
155 attr->ia_gid = NTOH__u32(rec->sa_gid);
156 attr->ia_size = NTOH__u64(rec->sa_size);
157 attr->ia_atime = NTOH__u64(rec->sa_atime);
158 attr->ia_mtime = NTOH__u64(rec->sa_mtime);
159 attr->ia_ctime = NTOH__u64(rec->sa_ctime);
160 attr->ia_attr_flags = NTOH__u32(rec->sa_attr_flags);
164 static int mds_create_unpack(char *buf, int len, struct mds_update_record *r)
166 struct mds_rec_create *rec = (struct mds_rec_create *)buf;
169 if (len < sizeof(*rec)) {
170 printk(__FUNCTION__ "invalid buffer length\n");
174 ptr = (char *)rec + sizeof(*rec);
175 end = ptr + len - sizeof(*rec);
177 r->ur_fid1 = &rec->cr_fid;
178 r->ur_mode = NTOH__u32(rec->cr_mode);
179 r->ur_id = NTOH__u64(rec->cr_id);
180 r->ur_uid = NTOH__u32(rec->cr_uid);
181 r->ur_gid = NTOH__u32(rec->cr_gid);
182 r->ur_time = NTOH__u64(rec->cr_time);
183 r->ur_namelen = NTOH__u32(rec->cr_namelen);
184 r->ur_tgtlen = NTOH__u32(rec->cr_tgtlen);
186 UNLOGL0(r->ur_name, char, r->ur_namelen, ptr, end);
187 UNLOGL0(r->ur_tgt, char, r->ur_tgtlen, ptr, end);
191 static int mds_link_unpack(char *buf, int len, struct mds_update_record *r)
193 struct mds_rec_link *rec = (struct mds_rec_link *)buf;
196 if (len < sizeof(*rec)) {
197 printk(__FUNCTION__ "invalid buffer length\n");
201 ptr = (char *)rec + sizeof(*rec);
202 end = ptr + len - sizeof(*rec);
204 r->ur_fid1 = &rec->lk_fid1;
205 r->ur_fid2 = &rec->lk_fid2;
206 r->ur_namelen = NTOH__u32(rec->lk_namelen);
207 UNLOGL0(r->ur_name, char, r->ur_namelen, ptr, end);
212 static int mds_unlink_unpack(char *buf, int len, struct mds_update_record *r)
214 struct mds_rec_unlink *rec = (struct mds_rec_unlink *)buf;
218 if (len < sizeof(*rec)) {
219 printk(__FUNCTION__ "invalid buffer length\n");
223 ptr = (char *)rec + sizeof(*rec);
224 end = ptr + len - sizeof(*rec);
226 r->ur_fid1 = &rec->ul_fid1;
227 r->ur_namelen = NTOH__u32(rec->ul_namelen);
228 UNLOGL0(r->ur_name, char, r->ur_namelen, ptr, end);
233 static int mds_rename_unpack(char *buf, int len, struct mds_update_record *r)
235 struct mds_rec_rename *rec = (struct mds_rec_rename *)buf;
238 if (len < sizeof(*rec)) {
239 printk(__FUNCTION__ "invalid buffer length\n");
243 ptr = (char *)rec + sizeof(*rec);
244 end = ptr + len - sizeof(*rec);
246 r->ur_fid1 = &rec->rn_fid1;
247 r->ur_fid2 = &rec->rn_fid2;
248 r->ur_namelen = NTOH__u32(rec->rn_namelen);
249 r->ur_tgtlen = NTOH__u32(rec->rn_tgtlen);
251 UNLOGL0(r->ur_name, char, r->ur_namelen, ptr, end);
252 UNLOGL0(r->ur_tgt, char, r->ur_tgtlen, ptr, end);
256 typedef int (*update_unpacker)(char *, int , struct mds_update_record *);
258 static update_unpacker mds_unpackers[REINT_MAX + 1] = {
259 [REINT_SETATTR] mds_setattr_unpack,
260 [REINT_CREATE] mds_create_unpack,
261 [REINT_LINK] mds_link_unpack,
262 [REINT_UNLINK] mds_unlink_unpack,
263 [REINT_RENAME] mds_rename_unpack,
266 int mds_update_unpack(char *buf, int len, struct mds_update_record *r)
271 rc = mds_update_hdr_unpack(buf, len, r);
278 if ( r->ur_opcode<0 || r->ur_opcode > REINT_MAX) {
283 rc = mds_unpackers[r->ur_opcode](buf, len, r);