Whamcloud - gitweb
3fa0a618d99d7e6f2199e18d25b93b4904f9e782
[fs/lustre-release.git] / lustre / include / linux / lustre_idl.h
1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=8:tabstop=8:
3  *
4  *  Copyright (C) 2001 Cluster File Systems, Inc. <braam@clusterfs.com>
5  *
6  *   This file is part of Lustre, http://www.lustre.org.
7  *
8  *   Lustre is free software; you can redistribute it and/or
9  *   modify it under the terms of version 2 of the GNU General Public
10  *   License as published by the Free Software Foundation.
11  *
12  *   Lustre is distributed in the hope that it will be useful,
13  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
14  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15  *   GNU General Public License for more details.
16  *
17  *   You should have received a copy of the GNU General Public License
18  *   along with Lustre; if not, write to the Free Software
19  *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20  *
21  * Lustre wire protocol definitions.
22  *
23  * All structs passing over the wire should be declared here (lov_mds_md
24  * being the lone exception).  Structs must be properly aligned to put
25  * 64-bit values on an 8-byte boundary.  Any structs being added here
26  * must also be added to utils/wirecheck.c and "make newwiretest" run
27  * to regenerate the utils/wiretest.c sources.  This allows us to verify
28  * that wire structs have the proper alignment/size on all architectures.
29  *
30  * We assume all nodes are either little-endian or big-endian, and we
31  * always send messages in the sender's native format.  The receiver
32  * detects the message format by checking the 'magic' field of the message
33  * (see lustre_msg_swabbed() below).
34  *
35  * Each wire type has corresponding 'lustre_swab_xxxtypexxx()' routines,
36  * implemented either here, inline (trivial implementations) or in
37  * ptlrpc/pack_generic.c.  These 'swabbers' convert the type from "other"
38  * endian, in-place in the message buffer.
39  *
40  * A swabber takes a single pointer argument.  The caller must already have
41  * verified that the length of the message buffer >= sizeof (type).
42  *
43  * For variable length types, a second 'lustre_swab_v_xxxtypexxx()' routine
44  * may be defined that swabs just the variable part, after the caller has
45  * verified that the message buffer is large enough.
46  */
47
48 #ifndef _LUSTRE_IDL_H_
49 #define _LUSTRE_IDL_H_
50
51 #ifdef __KERNEL__
52 # include <linux/ioctl.h>
53 # include <asm/types.h>
54 # include <linux/types.h>
55 # include <linux/list.h>
56 # include <linux/string.h> /* for strncpy, below */
57 # include <asm/byteorder.h>
58 # include <linux/fs.h> /* to check for FMODE_EXEC, lest we redefine */
59 #else
60 #ifdef __CYGWIN__
61 # include <sys/types.h>
62 #else
63 # include <asm/types.h>
64 # include <stdint.h>
65 #endif
66 # include <portals/list.h>
67 # include <string.h>
68 #endif
69
70 /* Defn's shared with user-space. */
71 #include <linux/lustre_user.h>
72
73 /*
74  * this file contains all data structures used in Lustre interfaces:
75  * - obdo and obd_request records
76  * - mds_request records
77  * - ldlm data
78  * - ioctl's
79  */
80
81 /*
82  *  GENERAL STUFF
83  */
84 struct obd_uuid {
85         __u8 uuid[40];
86 };
87
88 static inline int obd_uuid_equals(struct obd_uuid *u1, struct obd_uuid *u2)
89 {
90         return strcmp(u1->uuid, u2->uuid) == 0;
91 }
92
93 static inline void obd_str2uuid(struct obd_uuid *uuid, char *tmp)
94 {
95         strncpy(uuid->uuid, tmp, sizeof(*uuid));
96         uuid->uuid[sizeof(*uuid) - 1] = '\0';
97 }
98
99 /* FOO_REQUEST_PORTAL is for incoming requests on the FOO
100  * FOO_REPLY_PORTAL   is for incoming replies on the FOO
101  * FOO_BULK_PORTAL    is for incoming bulk on the FOO
102  */
103
104 #define CONNMGR_REQUEST_PORTAL          1
105 #define CONNMGR_REPLY_PORTAL            2
106 //#define OSC_REQUEST_PORTAL            3
107 #define OSC_REPLY_PORTAL                4
108 //#define OSC_BULK_PORTAL               5
109 #define OST_REQUEST_PORTAL              6
110 #define OST_CREATE_PORTAL               7
111 #define OST_BULK_PORTAL                 8
112 //#define MDC_REQUEST_PORTAL            9
113 #define MDC_REPLY_PORTAL               10
114 //#define MDC_BULK_PORTAL              11
115 #define MDS_REQUEST_PORTAL             12
116 //#define MDS_REPLY_PORTAL             13
117 #define MDS_BULK_PORTAL                14
118 #define LDLM_CB_REQUEST_PORTAL         15
119 #define LDLM_CB_REPLY_PORTAL           16
120 #define LDLM_CANCEL_REQUEST_PORTAL     17
121 #define LDLM_CANCEL_REPLY_PORTAL       18
122 #define PTLBD_REQUEST_PORTAL           19
123 #define PTLBD_REPLY_PORTAL             20
124 #define PTLBD_BULK_PORTAL              21
125 #define MDS_SETATTR_PORTAL             22
126 #define MDS_READPAGE_PORTAL            23
127 #define MGMT_REQUEST_PORTAL            24
128 #define MGMT_REPLY_PORTAL              25
129 #define MGMT_CLI_REQUEST_PORTAL        26
130 #define MGMT_CLI_REPLY_PORTAL          27
131
132 #define SVC_KILLED               1
133 #define SVC_EVENT                2
134 #define SVC_SIGNAL               4
135 #define SVC_RUNNING              8
136 #define SVC_STOPPING            16
137 #define SVC_STOPPED             32
138
139 /* packet types */
140 #define PTL_RPC_MSG_REQUEST 4711
141 #define PTL_RPC_MSG_ERR     4712
142 #define PTL_RPC_MSG_REPLY   4713
143
144 #define PTLRPC_MSG_MAGIC    0x0BD00BD0
145
146
147 #define PTLRPC_MSG_VERSION  0x00000003
148 #define LUSTRE_MDS_VERSION  (0x00040000|PTLRPC_MSG_VERSION)
149 #define LUSTRE_OST_VERSION  (0x00040000|PTLRPC_MSG_VERSION)
150 #define LUSTRE_DLM_VERSION  (0x00040000|PTLRPC_MSG_VERSION)
151
152 struct lustre_handle {
153         __u64 cookie;
154 };
155 #define DEAD_HANDLE_MAGIC 0xdeadbeefcafebabeULL
156
157 /* we depend on this structure to be 8-byte aligned */
158 /* this type is only endian-adjusted in lustre_unpack_msg() */
159 struct lustre_msg {
160         struct lustre_handle handle;
161         __u32 magic;
162         __u32 type;
163         __u32 version;
164         __u32 opc;
165         __u64 last_xid;
166         __u64 last_committed;
167         __u64 transno;
168         __u32 status;
169         __u32 flags;
170         __u32 conn_cnt;
171         __u32 bufcount;
172         __u32 buflens[0];
173 };
174
175 /* Flags that are operation-specific go in the top 16 bits. */
176 #define MSG_OP_FLAG_MASK   0xffff0000
177 #define MSG_OP_FLAG_SHIFT  16
178
179 /* Flags that apply to all requests are in the bottom 16 bits */
180 #define MSG_GEN_FLAG_MASK      0x0000ffff
181 #define MSG_LAST_REPLAY        1
182 #define MSG_RESENT             2
183
184 static inline int lustre_msg_get_flags(struct lustre_msg *msg)
185 {
186         return (msg->flags & MSG_GEN_FLAG_MASK);
187 }
188
189 static inline void lustre_msg_add_flags(struct lustre_msg *msg, int flags)
190 {
191         msg->flags |= MSG_GEN_FLAG_MASK & flags;
192 }
193
194 static inline void lustre_msg_set_flags(struct lustre_msg *msg, int flags)
195 {
196         msg->flags &= ~MSG_GEN_FLAG_MASK;
197         lustre_msg_add_flags(msg, flags);
198 }
199
200 static inline void lustre_msg_clear_flags(struct lustre_msg *msg, int flags)
201 {
202         msg->flags &= ~(MSG_GEN_FLAG_MASK & flags);
203 }
204
205 static inline int lustre_msg_get_op_flags(struct lustre_msg *msg)
206 {
207         return (msg->flags >> MSG_OP_FLAG_SHIFT);
208 }
209
210 static inline void lustre_msg_add_op_flags(struct lustre_msg *msg, int flags)
211 {
212         msg->flags |= ((flags & MSG_GEN_FLAG_MASK) << MSG_OP_FLAG_SHIFT);
213 }
214
215 static inline void lustre_msg_set_op_flags(struct lustre_msg *msg, int flags)
216 {
217         msg->flags &= ~MSG_OP_FLAG_MASK;
218         lustre_msg_add_op_flags(msg, flags);
219 }
220
221 /*
222  * Flags for all connect opcodes (MDS_CONNECT, OST_CONNECT)
223  */
224
225 #define MSG_CONNECT_RECOVERING  0x1
226 #define MSG_CONNECT_RECONNECT   0x2
227 #define MSG_CONNECT_REPLAYABLE  0x4
228 //#define MSG_CONNECT_PEER        0x8
229 #define MSG_CONNECT_LIBCLIENT   0x10
230
231 /*
232  *   OST requests: OBDO & OBD request records
233  */
234
235 /* opcodes */
236 typedef enum {
237         OST_REPLY      =  0,       /* reply ? */
238         OST_GETATTR    =  1,
239         OST_SETATTR    =  2,
240         OST_READ       =  3,
241         OST_WRITE      =  4,
242         OST_CREATE     =  5,
243         OST_DESTROY    =  6,
244         OST_GET_INFO   =  7,
245         OST_CONNECT    =  8,
246         OST_DISCONNECT =  9,
247         OST_PUNCH      = 10,
248         OST_OPEN       = 11,
249         OST_CLOSE      = 12,
250         OST_STATFS     = 13,
251         OST_SAN_READ   = 14,
252         OST_SAN_WRITE  = 15,
253         OST_SYNC       = 16,
254         OST_SET_INFO   = 17,
255         OST_LAST_OPC
256 } ost_cmd_t;
257 #define OST_FIRST_OPC  OST_REPLY
258
259 typedef uint64_t        obd_id;
260 typedef uint64_t        obd_gr;
261 typedef uint64_t        obd_time;
262 typedef uint64_t        obd_size;
263 typedef uint64_t        obd_off;
264 typedef uint64_t        obd_blocks;
265 typedef uint32_t        obd_blksize;
266 typedef uint32_t        obd_mode;
267 typedef uint32_t        obd_uid;
268 typedef uint32_t        obd_gid;
269 typedef uint32_t        obd_flag;
270 typedef uint32_t        obd_count;
271
272 #define OBD_FL_INLINEDATA   (0x00000001)
273 #define OBD_FL_OBDMDEXISTS  (0x00000002)
274 #define OBD_FL_DELORPHAN    (0x00000004) /* if set in o_flags delete orphans */
275 #define OBD_FL_NORPC        (0x00000008) // if set in o_flags set in OSC not OST
276 #define OBD_FL_IDONLY       (0x00000010) // if set in o_flags only adjust obj id
277 #define OBD_FL_RECREATE_OBJS (0x00000020) // recreate missing obj
278
279 #define OBD_INLINESZ    64
280
281 /* Note: 64-bit types are 64-bit aligned in structure */
282 struct obdo {
283         obd_id                  o_id;
284         obd_gr                  o_gr;
285         obd_time                o_atime;
286         obd_time                o_mtime;
287         obd_time                o_ctime;
288         obd_size                o_size;
289         obd_blocks              o_blocks;       /* brw: cli sent cached bytes */
290         obd_size                o_grant;
291         obd_blksize             o_blksize;      /* optimal IO blocksize */
292         obd_mode                o_mode;         /* brw: cli sent cache remain */
293         obd_uid                 o_uid;
294         obd_gid                 o_gid;
295         obd_flag                o_flags;
296         obd_count               o_nlink;        /* brw: checksum */
297         obd_count               o_generation;
298         obd_flag                o_valid;        /* hot fields in this obdo */
299         obd_count               o_misc;
300         __u32                   o_easize;       /* epoch in ost writes */
301         char                    o_inline[OBD_INLINESZ]; /* fid in ost writes */
302 };
303
304 #define o_dirty   o_blocks
305 #define o_undirty o_mode
306 #define o_dropped o_misc
307 #define o_cksum   o_nlink
308
309 extern void lustre_swab_obdo (struct obdo *o);
310
311 #define LOV_MAGIC_V1      0x0BD10BD0
312 #define LOV_MAGIC         LOV_MAGIC_V1
313
314 #define LOV_PATTERN_RAID0 0x001   /* stripes are used round-robin */
315 #define LOV_PATTERN_RAID1 0x002   /* stripes are mirrors of each other */
316 #define LOV_PATTERN_FIRST 0x100   /* first stripe is not in round-robin */
317
318 #define lov_ost_data lov_ost_data_v1
319 struct lov_ost_data_v1 {          /* per-stripe data structure (little-endian)*/
320         __u64 l_object_id;        /* OST object ID */
321         __u64 l_object_gr;        /* OST object group (creating MDS number) */
322         __u32 l_ost_gen;          /* generation of this l_ost_idx */
323         __u32 l_ost_idx;          /* OST index in LOV (lov_tgt_desc->tgts) */
324 };
325
326 #define lov_mds_md lov_mds_md_v1
327 struct lov_mds_md_v1 {            /* LOV EA mds/wire data (little-endian) */
328         __u32 lmm_magic;          /* magic number = LOV_MAGIC_V1 */
329         __u32 lmm_pattern;        /* LOV_PATTERN_RAID0, LOV_PATTERN_RAID1 */
330         __u64 lmm_object_id;      /* LOV object ID */
331         __u64 lmm_object_gr;      /* LOV object group */
332         __u32 lmm_stripe_size;    /* size of stripe in bytes */
333         __u32 lmm_stripe_count;   /* num stripes in use for this object */
334         struct lov_ost_data_v1 lmm_objects[0]; /* per-stripe data */
335 };
336
337 #define LOV_MAGIC_V0      0x0BD00BD0
338
339 struct lov_ost_data_v0 {          /* per-stripe data structure (little-endian)*/
340         __u64 l_object_id;        /* OST object ID */
341 };
342
343 struct lov_mds_md_v0 {            /* LOV EA mds/wire data (little-endian) */
344         __u32 lmm_magic;          /* magic number = LOV_MAGIC_V0 */
345         __u64 lmm_object_id;      /* LOV object ID */
346         __u32 lmm_stripe_size;    /* size of the stripe in bytes (not RAID1) */
347         __u32 lmm_stripe_offset;  /* starting stripe offset in lmm_objects */
348         __u16 lmm_stripe_count;   /* number of stipes in use for this object */
349         __u16 lmm_ost_count;      /* how many OST idx are in this LOV md */
350         struct lov_ost_data_v0 lmm_objects[0];
351 } __attribute__((packed));
352
353 #define OBD_MD_FLALL    (0xffffffff)
354 #define OBD_MD_FLID     (0x00000001)    /* object ID */
355 #define OBD_MD_FLATIME  (0x00000002)    /* access time */
356 #define OBD_MD_FLMTIME  (0x00000004)    /* data modification time */
357 #define OBD_MD_FLCTIME  (0x00000008)    /* change time */
358 #define OBD_MD_FLSIZE   (0x00000010)    /* size */
359 #define OBD_MD_FLBLOCKS (0x00000020)    /* allocated blocks count */
360 #define OBD_MD_FLBLKSZ  (0x00000040)    /* block size */
361 #define OBD_MD_FLMODE   (0x00000080)    /* access bits (mode & ~S_IFMT) */
362 #define OBD_MD_FLTYPE   (0x00000100)    /* object type (mode & S_IFMT) */
363 #define OBD_MD_FLUID    (0x00000200)    /* user ID */
364 #define OBD_MD_FLGID    (0x00000400)    /* group ID */
365 #define OBD_MD_FLFLAGS  (0x00000800)    /* flags word */
366 #define OBD_MD_FLNLINK  (0x00002000)    /* link count */
367 #define OBD_MD_FLGENER  (0x00004000)    /* generation number */
368 #define OBD_MD_FLINLINE (0x00008000)    /* inline data */
369 #define OBD_MD_FLRDEV   (0x00010000)    /* device number */
370 #define OBD_MD_FLEASIZE (0x00020000)    /* extended attribute data */
371 #define OBD_MD_LINKNAME (0x00040000)    /* symbolic link target */
372 #define OBD_MD_FLHANDLE (0x00080000)    /* file handle */
373 #define OBD_MD_FLCKSUM  (0x00100000)    /* bulk data checksum */
374 #define OBD_MD_FLQOS    (0x00200000)    /* quality of service stats */
375 #define OBD_MD_FLOSCOPQ (0x00400000)    /* osc opaque data */
376 #define OBD_MD_FLCOOKIE (0x00800000)    /* log cancellation cookie */
377 #define OBD_MD_FLGROUP  (0x01000000)    /* group */
378 #define OBD_MD_FLIFID   (0x02000000)    /* ->ost write inline fid */
379 #define OBD_MD_FLEPOCH  (0x04000000)    /* ->ost write easize is epoch */
380 #define OBD_MD_FLGRANT  (0x08000000)    /* ost preallocation space grant */
381 #define OBD_MD_FLNOTOBD (~(OBD_MD_FLBLOCKS | OBD_MD_LINKNAME|\
382                            OBD_MD_FLEASIZE | OBD_MD_FLHANDLE | OBD_MD_FLCKSUM|\
383                            OBD_MD_FLQOS | OBD_MD_FLOSCOPQ | OBD_MD_FLCOOKIE))
384
385
386 static inline struct lustre_handle *obdo_handle(struct obdo *oa)
387 {
388         return (struct lustre_handle *)oa->o_inline;
389 }
390
391 static inline struct llog_cookie *obdo_logcookie(struct obdo *oa)
392 {
393         return (struct llog_cookie *)(oa->o_inline +
394                                       sizeof(struct lustre_handle));
395 }
396 /* don't forget obdo_fid which is way down at the bottom so it can
397  * come after the definition of llog_cookie */
398
399 struct obd_statfs {
400         __u64           os_type;
401         __u64           os_blocks;
402         __u64           os_bfree;
403         __u64           os_bavail;
404         __u64           os_files;
405         __u64           os_ffree;
406         __u8            os_fsid[40];
407         __u32           os_bsize;
408         __u32           os_namelen;
409         __u64           os_maxbytes;
410         __u32           os_spare[10];
411 };
412
413 extern void lustre_swab_obd_statfs (struct obd_statfs *os);
414
415 /* ost_body.data values for OST_BRW */
416
417 #define OBD_BRW_READ       0x01
418 #define OBD_BRW_WRITE      0x02
419 #define OBD_BRW_RWMASK     (OBD_BRW_READ | OBD_BRW_WRITE)
420 #define OBD_BRW_SYNC       0x08
421 #define OBD_BRW_CHECK      0x10
422 #define OBD_BRW_FROM_GRANT 0x20 /* the osc manages this under llite */
423 #define OBD_BRW_GRANTED    0x40 /* the ost manages this */
424
425 #define OBD_OBJECT_EOF 0xffffffffffffffffULL
426
427 struct obd_ioobj {
428         obd_id               ioo_id;
429         obd_gr               ioo_gr;
430         __u32                ioo_type;
431         __u32                ioo_bufcnt;
432 };
433
434 extern void lustre_swab_obd_ioobj (struct obd_ioobj *ioo);
435
436 /* multiple of 8 bytes => can array */
437 struct niobuf_remote {
438         __u64 offset;
439         __u32 len;
440         __u32 flags;
441 };
442
443 extern void lustre_swab_niobuf_remote (struct niobuf_remote *nbr);
444
445 /* request structure for OST's */
446
447 #define OST_REQ_HAS_OA1  0x1
448
449 struct ost_body {
450         struct  obdo oa;
451 };
452
453 extern void lustre_swab_ost_body (struct ost_body *b);
454 extern void lustre_swab_ost_last_id(obd_id *id);
455
456 /*
457  *   MDS REQ RECORDS
458  */
459
460 /* opcodes */
461 typedef enum {
462         MDS_GETATTR      = 33,
463         MDS_GETATTR_NAME = 34,
464         MDS_CLOSE        = 35,
465         MDS_REINT        = 36,
466         MDS_READPAGE     = 37,
467         MDS_CONNECT      = 38,
468         MDS_DISCONNECT   = 39,
469         MDS_GETSTATUS    = 40,
470         MDS_STATFS       = 41,
471         MDS_PIN          = 42,
472         MDS_UNPIN        = 43,
473         MDS_SYNC         = 44,
474         MDS_DONE_WRITING = 45,
475         MDS_LAST_OPC
476 } mds_cmd_t;
477 #define MDS_FIRST_OPC    MDS_GETATTR
478
479 /*
480  * Do not exceed 63
481  */
482
483 #define REINT_SETATTR  1
484 #define REINT_CREATE   2
485 #define REINT_LINK     3
486 #define REINT_UNLINK   4
487 #define REINT_RENAME   5
488 #define REINT_OPEN     6
489 #define REINT_MAX      6
490
491 /* the disposition of the intent outlines what was executed */
492 #define DISP_IT_EXECD   1
493 #define DISP_LOOKUP_EXECD  (1 << 1)
494 #define DISP_LOOKUP_NEG     (1 << 2)
495 #define DISP_LOOKUP_POS     (1 << 3)
496 #define DISP_OPEN_CREATE  (1 << 4)
497 #define DISP_OPEN_OPEN    (1 << 5)
498 #define DISP_ENQ_COMPLETE (1<<6)
499
500 struct ll_fid {
501         __u64 id;
502         __u32 generation;
503         __u32 f_type;
504 };
505
506 struct ll_recreate_obj {
507         __u64 lrc_id;
508         __u32 lrc_ost_idx;
509 };
510
511 extern void lustre_swab_ll_fid (struct ll_fid *fid);
512
513 #define MDS_STATUS_CONN 1
514 #define MDS_STATUS_LOV 2
515
516 struct mds_status_req {
517         __u32  flags;
518         __u32  repbuf;
519 };
520
521 extern void lustre_swab_mds_status_req (struct mds_status_req *r);
522
523 #define MDS_BFLAG_UNCOMMITTED_WRITES   0x1
524
525 struct mds_body {
526         struct ll_fid  fid1;
527         struct ll_fid  fid2;
528         struct lustre_handle handle;
529         __u64          size;   /* Offset, in the case of MDS_READPAGE */
530         __u64          blocks; /* XID, in the case of MDS_READPAGE */
531         __u64          io_epoch;
532         __u32          ino;   /* make this a __u64 */
533         __u32          valid;
534         __u32          fsuid;
535         __u32          fsgid;
536         __u32          capability;
537         __u32          mode;
538         __u32          uid;
539         __u32          gid;
540         __u32          mtime;
541         __u32          ctime;
542         __u32          atime;
543         __u32          flags; /* from vfs for pin/unpin, MDS_BFLAG for close */
544         __u32          rdev;
545         __u32          nlink; /* #bytes to read in the case of MDS_READPAGE */
546         __u32          generation;
547         __u32          suppgid;
548         __u32          eadatasize;
549         __u32          packing;
550 };
551
552 extern void lustre_swab_mds_body (struct mds_body *b);
553
554
555 /* MDS update records */
556
557 //struct mds_update_record_hdr {
558 //        __u32 ur_opcode;
559 //};
560
561 struct mds_rec_setattr {
562         __u32           sa_opcode;
563         __u32           sa_fsuid;
564         __u32           sa_fsgid;
565         __u32           sa_cap;
566         __u32           sa_suppgid;
567         __u32           sa_valid;
568         struct ll_fid   sa_fid;
569         __u32           sa_mode;
570         __u32           sa_uid;
571         __u32           sa_gid;
572         __u32           sa_attr_flags;
573         __u64           sa_size;
574         __u64           sa_atime;
575         __u64           sa_mtime;
576         __u64           sa_ctime;
577 };
578
579 /* Remove this once we declare it in include/linux/fs.h (v21 kernel patch?) */
580 #ifndef ATTR_CTIME_SET
581 #define ATTR_CTIME_SET 0x2000
582 #endif
583
584 extern void lustre_swab_mds_rec_setattr (struct mds_rec_setattr *sa);
585
586 #ifndef FMODE_READ
587 #define FMODE_READ               00000001
588 #define FMODE_WRITE              00000002
589 #endif
590 #ifndef FMODE_EXEC
591 #define FMODE_EXEC               00000004
592 #endif
593 #define MDS_OPEN_CREAT           00000100
594 #define MDS_OPEN_EXCL            00000200
595 #define MDS_OPEN_TRUNC           00001000
596 #define MDS_OPEN_APPEND          00002000
597 #define MDS_OPEN_SYNC            00010000
598 #define MDS_OPEN_DIRECTORY       00200000
599
600 #define MDS_OPEN_DELAY_CREATE  0100000000 /* delay initial object create */
601 #define MDS_OPEN_HAS_EA      010000000000 /* specify object create pattern */
602 #define MDS_OPEN_HAS_OBJS    020000000000 /* Just set the EA the obj exist */
603
604 struct mds_rec_create {
605         __u32           cr_opcode;
606         __u32           cr_fsuid;
607         __u32           cr_fsgid;
608         __u32           cr_cap;
609         __u32           cr_flags; /* for use with open */
610         __u32           cr_mode;
611         struct ll_fid   cr_fid;
612         struct ll_fid   cr_replayfid;
613         __u64           cr_time;
614         __u64           cr_rdev;
615         __u32           cr_suppgid;
616         __u32           cr_packing;
617 };
618
619 extern void lustre_swab_mds_rec_create (struct mds_rec_create *cr);
620
621 struct mds_rec_link {
622         __u32           lk_opcode;
623         __u32           lk_fsuid;
624         __u32           lk_fsgid;
625         __u32           lk_cap;
626         __u32           lk_suppgid1;
627         __u32           lk_suppgid2;
628         struct ll_fid   lk_fid1;
629         struct ll_fid   lk_fid2;
630         __u64           lk_time;
631 };
632
633 extern void lustre_swab_mds_rec_link (struct mds_rec_link *lk);
634
635 struct mds_rec_unlink {
636         __u32           ul_opcode;
637         __u32           ul_fsuid;
638         __u32           ul_fsgid;
639         __u32           ul_cap;
640         __u32           ul_suppgid;
641         __u32           ul_mode;
642         struct ll_fid   ul_fid1;
643         struct ll_fid   ul_fid2;
644         __u64           ul_time;
645 };
646
647 extern void lustre_swab_mds_rec_unlink (struct mds_rec_unlink *ul);
648
649 struct mds_rec_rename {
650         __u32           rn_opcode;
651         __u32           rn_fsuid;
652         __u32           rn_fsgid;
653         __u32           rn_cap;
654         __u32           rn_suppgid1;
655         __u32           rn_suppgid2;
656         struct ll_fid   rn_fid1;
657         struct ll_fid   rn_fid2;
658         __u64           rn_time;
659 };
660
661 extern void lustre_swab_mds_rec_rename (struct mds_rec_rename *rn);
662
663 /*
664  *  LOV data structures
665  */
666
667 #define LOV_MAX_UUID_BUFFER_SIZE  8192
668 /* The size of the buffer the lov/mdc reserves for the
669  * array of UUIDs returned by the MDS.  With the current
670  * protocol, this will limit the max number of OSTs per LOV */
671
672 struct lov_desc {
673         __u32 ld_tgt_count;                /* how many OBD's */
674         __u32 ld_active_tgt_count;         /* how many active */
675         __u32 ld_default_stripe_count;     /* how many objects are used */
676         __u32 ld_pattern;                  /* PATTERN_RAID0, PATTERN_RAID1 */
677         __u64 ld_default_stripe_size;      /* in bytes */
678         __u64 ld_default_stripe_offset;    /* in bytes */
679         struct obd_uuid ld_uuid;
680 };
681
682 extern void lustre_swab_lov_desc (struct lov_desc *ld);
683
684 /*
685  *   LDLM requests:
686  */
687 /* opcodes -- MUST be distinct from OST/MDS opcodes */
688 typedef enum {
689         LDLM_ENQUEUE     = 101,
690         LDLM_CONVERT     = 102,
691         LDLM_CANCEL      = 103,
692         LDLM_BL_CALLBACK = 104,
693         LDLM_CP_CALLBACK = 105,
694         LDLM_LAST_OPC
695 } ldlm_cmd_t;
696 #define LDLM_FIRST_OPC LDLM_ENQUEUE
697
698 #define RES_NAME_SIZE 4
699 #define RES_VERSION_SIZE 4
700
701 struct ldlm_res_id {
702         __u64 name[RES_NAME_SIZE];
703 };
704
705 extern void lustre_swab_ldlm_res_id (struct ldlm_res_id *id);
706
707 /* lock types */
708 typedef enum {
709         LCK_EX = 1,
710         LCK_PW,
711         LCK_PR,
712         LCK_CW,
713         LCK_CR,
714         LCK_NL
715 } ldlm_mode_t;
716
717 struct ldlm_extent {
718         __u64 start;
719         __u64 end;
720 };
721
722 struct ldlm_flock {
723         __u64 start;
724         __u64 end;
725         __u64 blocking_export;
726         pid_t blocking_pid;
727         pid_t pid;
728 };
729
730 /* it's important that the fields of the ldlm_extent structure match
731  * the first fields of the ldlm_flock structure because there is only
732  * one ldlm_swab routine to process the ldlm_policy_data_t union. if
733  * this ever changes we will need to swab the union differently based
734  * on the resource type. */
735
736 typedef union {
737         struct ldlm_extent l_extent;
738         struct ldlm_flock  l_flock;
739 } ldlm_policy_data_t;
740
741 extern void lustre_swab_ldlm_policy_data (ldlm_policy_data_t *d);
742
743 struct ldlm_intent {
744         __u64 opc;
745 };
746
747 extern void lustre_swab_ldlm_intent (struct ldlm_intent *i);
748
749 /* Note this unaligned structure; as long as it's only used in ldlm_request
750  * below, we're probably fine. */
751 struct ldlm_resource_desc {
752         __u32 lr_type;
753         struct ldlm_res_id lr_name;
754         __u32 lr_version[RES_VERSION_SIZE];
755 } __attribute__((packed));
756
757 extern void lustre_swab_ldlm_resource_desc (struct ldlm_resource_desc *r);
758
759 struct ldlm_lock_desc {
760         struct ldlm_resource_desc l_resource;
761         ldlm_mode_t l_req_mode;
762         ldlm_mode_t l_granted_mode;
763         ldlm_policy_data_t l_policy_data;
764         __u32 l_version[RES_VERSION_SIZE];
765 } __attribute__((packed));
766
767 extern void lustre_swab_ldlm_lock_desc (struct ldlm_lock_desc *l);
768
769 struct ldlm_request {
770         __u32 lock_flags;
771         struct ldlm_lock_desc lock_desc;
772         struct lustre_handle lock_handle1;
773         struct lustre_handle lock_handle2;
774 } __attribute__((packed));
775
776 extern void lustre_swab_ldlm_request (struct ldlm_request *rq);
777
778 struct ldlm_reply {
779         __u32 lock_flags;
780         __u32 lock_mode;
781         struct ldlm_res_id lock_resource_name;
782         struct lustre_handle lock_handle;
783         ldlm_policy_data_t lock_policy_data;
784         __u64  lock_policy_res1;
785         __u64  lock_policy_res2;
786 };
787
788 extern void lustre_swab_ldlm_reply (struct ldlm_reply *r);
789
790 /*
791  * ptlbd, portal block device requests
792  */
793 typedef enum {
794         PTLBD_QUERY = 200,
795         PTLBD_READ = 201,
796         PTLBD_WRITE = 202,
797         PTLBD_FLUSH = 203,
798         PTLBD_CONNECT = 204,
799         PTLBD_DISCONNECT = 205,
800         PTLBD_LAST_OPC
801 } ptlbd_cmd_t;
802 #define PTLBD_FIRST_OPC PTLBD_QUERY
803
804 struct ptlbd_op {
805         __u16 op_cmd;
806         __u16 op_lun;
807         __u16 op_niob_cnt;
808         __u16 op__padding;
809         __u32 op_block_cnt;
810 };
811
812 extern void lustre_swab_ptlbd_op (struct ptlbd_op *op);
813
814 struct ptlbd_niob {
815         __u64 n_xid;
816         __u64 n_block_nr;
817         __u32 n_offset;
818         __u32 n_length;
819 };
820
821 extern void lustre_swab_ptlbd_niob (struct ptlbd_niob *n);
822
823 struct ptlbd_rsp {
824         __u16 r_status;
825         __u16 r_error_cnt;
826 };
827
828 extern void lustre_swab_ptlbd_rsp (struct ptlbd_rsp *r);
829
830 /*
831  * Opcodes for management/monitoring node.
832  */
833 typedef enum {
834         MGMT_CONNECT = 250,
835         MGMT_DISCONNECT,
836         MGMT_EXCEPTION,         /* node died, etc. */
837         MGMT_LAST_OPC
838 } mgmt_cmd_t;
839 #define MGMT_FIRST_OPC MGMT_CONNECT
840
841 /*
842  * Opcodes for multiple servers.
843  */
844
845 typedef enum {
846         OBD_PING = 400,
847         OBD_LOG_CANCEL,
848         OBD_LAST_OPC
849 } obd_cmd_t;
850 #define OBD_FIRST_OPC OBD_PING
851
852 /* catalog of log objects */
853
854 /* Identifier for a single log object */
855 struct llog_logid {
856         __u64                   lgl_oid;
857         __u64                   lgl_ogr;
858         __u32                   lgl_ogen;
859 } __attribute__((packed));
860
861 /* Log data record types - there is no specific reason that these need to
862  * be related to the RPC opcodes, but no reason not to (may be handy later?)
863  */
864 typedef enum {
865         OST_SZ_REC       = 0x10600000 | (OST_SAN_WRITE << 8),
866         OST_RAID1_REC    = 0x10600000 | ((OST_SAN_WRITE + 1) << 8),
867         MDS_UNLINK_REC   = 0x10610000 | (MDS_REINT << 8) | REINT_UNLINK,
868         OBD_CFG_REC      = 0x10620000,
869         PTL_CFG_REC      = 0x10630000,
870         LLOG_GEN_REC     = 0x10640000,
871         LLOG_HDR_MAGIC   = 0x10645539,
872         LLOG_LOGID_MAGIC = 0x1064553a,
873 } llog_op_type;
874
875 /* Log record header - stored in little endian order.
876  * Each record must start with this struct, end with a llog_rec_tail,
877  * and be a multiple of 256 bits in size.
878  */
879 struct llog_rec_hdr {
880         __u32                   lrh_len;
881         __u32                   lrh_index;
882         __u32                   lrh_type;
883         __u32                   padding;
884 };
885
886 struct llog_rec_tail {
887         __u32 lrt_len;
888         __u32 lrt_index;
889 };
890
891 struct llog_logid_rec {
892         struct llog_rec_hdr     lid_hdr;
893         struct llog_logid       lid_id;
894         __u32                   padding;
895         struct llog_rec_tail    lid_tail;
896 } __attribute__((packed));
897
898 struct llog_create_rec {
899         struct llog_rec_hdr     lcr_hdr;
900         struct ll_fid           lcr_fid;
901         obd_id                  lcr_oid;
902         obd_count               lcr_ogen;
903         __u32                   padding;
904         struct llog_rec_tail    lcr_tail;
905 } __attribute__((packed));
906
907 struct llog_orphan_rec {
908         struct llog_rec_hdr     lor_hdr;
909         obd_id                  lor_oid;
910         obd_count               lor_ogen;
911         __u32                   padding;
912         struct llog_rec_tail    lor_tail;
913 } __attribute__((packed));
914
915 struct llog_unlink_rec {
916         struct llog_rec_hdr     lur_hdr;
917         obd_id                  lur_oid;
918         obd_count               lur_ogen;
919         __u32                   padding;
920         struct llog_rec_tail    lur_tail;
921 } __attribute__((packed));
922
923 struct llog_size_change_rec {
924         struct llog_rec_hdr     lsc_hdr;
925         struct ll_fid           lsc_fid;
926         __u32                   lsc_io_epoch;
927         __u32                   padding;
928         struct llog_rec_tail    lsc_tail;
929 } __attribute__((packed));
930
931 struct llog_gen {
932         __u64 mnt_cnt;
933         __u64 conn_cnt;
934 } __attribute__((packed));
935
936 struct llog_gen_rec {
937         struct llog_rec_hdr     lgr_hdr;
938         struct llog_gen         lgr_gen;
939         struct llog_rec_tail    lgr_tail;
940 };
941 /* On-disk header structure of each log object, stored in little endian order */
942 #define LLOG_CHUNK_SIZE         4096
943 #define LLOG_HEADER_SIZE        (96)
944 #define LLOG_BITMAP_BYTES       (LLOG_CHUNK_SIZE - LLOG_HEADER_SIZE)
945
946 #define LLOG_MIN_REC_SIZE       (24) /* round(llog_rec_hdr + llog_rec_tail) */
947
948 /* flags for the logs */
949 #define LLOG_F_ZAP_WHEN_EMPTY   0x1
950 #define LLOG_F_IS_CAT           0x2
951 #define LLOG_F_IS_PLAIN         0x4
952
953 struct llog_log_hdr {
954         struct llog_rec_hdr     llh_hdr;
955         __u64                   llh_timestamp;
956         __u32                   llh_count;
957         __u32                   llh_bitmap_offset;
958         __u32                   llh_size;
959         __u32                   llh_flags;
960         __u32                   llh_cat_idx;
961         /* for a catlog the first plain slot is next to it */
962         struct obd_uuid         llh_tgtuuid;
963         __u32                   llh_reserved[LLOG_HEADER_SIZE/sizeof(__u32) - 23];
964         __u32                   llh_bitmap[LLOG_BITMAP_BYTES/sizeof(__u32)];
965         struct llog_rec_tail    llh_tail;
966 } __attribute__((packed));
967
968 /* log cookies are used to reference a specific log file and a record therein */
969 struct llog_cookie {
970         struct llog_logid       lgc_lgl;
971         __u32                   lgc_subsys;
972         __u32                   lgc_index;
973         __u32                   lgc_padding;
974 } __attribute__((packed));
975
976 /* llog protocol */
977 enum llogd_rpc_ops {
978         LLOG_ORIGIN_HANDLE_CREATE       = 501,
979         LLOG_ORIGIN_HANDLE_NEXT_BLOCK   = 502,
980         LLOG_ORIGIN_HANDLE_READ_HEADER  = 503,
981         LLOG_ORIGIN_HANDLE_WRITE_REC    = 504,
982         LLOG_ORIGIN_HANDLE_CLOSE        = 505,
983         LLOG_ORIGIN_CONNECT             = 506,
984         LLOG_CATINFO                    = 507,  /* for lfs catinfo */
985 };
986
987 struct llogd_body {
988         struct llog_logid  lgd_logid;
989         __u32 lgd_ctxt_idx;
990         __u32 lgd_llh_flags;
991         __u32 lgd_index;
992         __u32 lgd_saved_index;
993         __u32 lgd_len;
994         __u64 lgd_cur_offset;
995 } __attribute__((packed));
996
997 struct llogd_conn_body {
998         struct llog_gen         lgdc_gen;
999         struct llog_logid       lgdc_logid;
1000         __u32                   lgdc_ctxt_idx;
1001 } __attribute__((packed));
1002
1003 extern void lustre_swab_llogd_body (struct llogd_body *d);
1004 extern void lustre_swab_llog_hdr (struct llog_log_hdr *h);
1005 extern void lustre_swab_llogd_conn_body (struct llogd_conn_body *d);
1006
1007 static inline struct ll_fid *obdo_fid(struct obdo *oa)
1008 {
1009         return (struct ll_fid *)(oa->o_inline + sizeof(struct lustre_handle) +
1010                                  sizeof(struct llog_cookie));
1011 }
1012
1013 #endif