Whamcloud - gitweb
LU-8901 misc: update Intel copyright messages for 2016
[fs/lustre-release.git] / lustre / include / lustre / lustre_user.h
1 /*
2  * GPL HEADER START
3  *
4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License version 2 only,
8  * as published by the Free Software Foundation.
9  *
10  * This program is distributed in the hope that it will be useful, but
11  * WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13  * General Public License version 2 for more details (a copy is included
14  * in the LICENSE file that accompanied this code).
15  *
16  * You should have received a copy of the GNU General Public License
17  * version 2 along with this program; If not, see
18  * http://www.gnu.org/licenses/gpl-2.0.html
19  *
20  * GPL HEADER END
21  */
22 /*
23  * Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
24  * Use is subject to license terms.
25  *
26  * Copyright (c) 2010, 2016, Intel Corporation.
27  */
28 /*
29  * This file is part of Lustre, http://www.lustre.org/
30  * Lustre is a trademark of Sun Microsystems, Inc.
31  *
32  * lustre/include/lustre/lustre_user.h
33  *
34  * Lustre public user-space interface definitions.
35  */
36
37 #ifndef _LUSTRE_USER_H
38 #define _LUSTRE_USER_H
39
40 /** \defgroup lustreuser lustreuser
41  *
42  * @{
43  */
44
45 #include <linux/types.h>
46
47 #ifdef __KERNEL__
48 # include <linux/quota.h>
49 # include <linux/string.h> /* snprintf() */
50 # include <linux/version.h>
51 #else /* !__KERNEL__ */
52 # define NEED_QUOTA_DEFS
53 # include <limits.h>
54 # include <stdbool.h>
55 # include <stdio.h> /* snprintf() */
56 # include <string.h>
57 # include <sys/quota.h>
58 # include <sys/stat.h>
59 #endif /* __KERNEL__ */
60 #include <lustre/ll_fiemap.h>
61
62 #if defined(__x86_64__) || defined(__ia64__) || defined(__ppc64__) || \
63     defined(__craynv) || defined(__mips64__) || defined(__powerpc64__) || \
64     defined(__aarch64__)
65 typedef struct stat     lstat_t;
66 # define lstat_f        lstat
67 # define fstat_f        fstat
68 # define fstatat_f      fstatat
69 # define HAVE_LOV_USER_MDS_DATA
70 #elif defined(__USE_LARGEFILE64) || defined(__KERNEL__)
71 typedef struct stat64   lstat_t;
72 # define lstat_f        lstat64
73 # define fstat_f        fstat64
74 # define fstatat_f      fstatat64
75 # define HAVE_LOV_USER_MDS_DATA
76 #endif
77
78 #define LUSTRE_EOF 0xffffffffffffffffULL
79
80 /* for statfs() */
81 #define LL_SUPER_MAGIC 0x0BD00BD0
82
83 #ifndef FSFILT_IOC_GETFLAGS
84 #define FSFILT_IOC_GETFLAGS               _IOR('f', 1, long)
85 #define FSFILT_IOC_SETFLAGS               _IOW('f', 2, long)
86 #define FSFILT_IOC_GETVERSION             _IOR('f', 3, long)
87 #define FSFILT_IOC_SETVERSION             _IOW('f', 4, long)
88 #define FSFILT_IOC_GETVERSION_OLD         _IOR('v', 1, long)
89 #define FSFILT_IOC_SETVERSION_OLD         _IOW('v', 2, long)
90 #endif
91
92 /* FIEMAP flags supported by Lustre */
93 #define LUSTRE_FIEMAP_FLAGS_COMPAT (FIEMAP_FLAG_SYNC | FIEMAP_FLAG_DEVICE_ORDER)
94
95 enum obd_statfs_state {
96         OS_STATE_DEGRADED       = 0x00000001, /**< RAID degraded/rebuilding */
97         OS_STATE_READONLY       = 0x00000002, /**< filesystem is read-only */
98         OS_STATE_ENOSPC         = 0x00000020, /**< not enough free space */
99         OS_STATE_ENOINO         = 0x00000040, /**< not enough inodes */
100 };
101
102 struct obd_statfs {
103         __u64           os_type;
104         __u64           os_blocks;
105         __u64           os_bfree;
106         __u64           os_bavail;
107         __u64           os_files;
108         __u64           os_ffree;
109         __u8            os_fsid[40];
110         __u32           os_bsize;
111         __u32           os_namelen;
112         __u64           os_maxbytes;
113         __u32           os_state;       /**< obd_statfs_state OS_STATE_* flag */
114         __u32           os_fprecreated; /* objs available now to the caller */
115                                         /* used in QoS code to find preferred
116                                          * OSTs */
117         __u32           os_spare2;
118         __u32           os_spare3;
119         __u32           os_spare4;
120         __u32           os_spare5;
121         __u32           os_spare6;
122         __u32           os_spare7;
123         __u32           os_spare8;
124         __u32           os_spare9;
125 };
126
127 /**
128  * File IDentifier.
129  *
130  * FID is a cluster-wide unique identifier of a file or an object (stripe).
131  * FIDs are never reused.
132  **/
133 struct lu_fid {
134        /**
135         * FID sequence. Sequence is a unit of migration: all files (objects)
136         * with FIDs from a given sequence are stored on the same server.
137         * Lustre should support 2^64 objects, so even if each sequence
138         * has only a single object we can still enumerate 2^64 objects.
139         **/
140         __u64 f_seq;
141         /* FID number within sequence. */
142         __u32 f_oid;
143         /**
144          * FID version, used to distinguish different versions (in the sense
145          * of snapshots, etc.) of the same file system object. Not currently
146          * used.
147          **/
148         __u32 f_ver;
149 };
150
151 static inline bool fid_is_zero(const struct lu_fid *fid)
152 {
153         return fid->f_seq == 0 && fid->f_oid == 0;
154 }
155
156 /* Currently, the filter_fid::ff_parent::f_ver is not the real parent
157  * MDT-object's FID::f_ver, instead it is the OST-object index in its
158  * parent MDT-object's layout EA. */
159 #define f_stripe_idx f_ver
160
161 struct filter_fid {
162         struct lu_fid   ff_parent;  /* ff_parent.f_ver == file stripe number */
163 };
164
165 /* keep this one for compatibility */
166 struct filter_fid_old {
167         struct lu_fid   ff_parent;
168         __u64           ff_objid;
169         __u64           ff_seq;
170 };
171
172 /* Userspace should treat lu_fid as opaque, and only use the following methods
173  * to print or parse them.  Other functions (e.g. compare, swab) could be moved
174  * here from lustre_idl.h if needed. */
175 typedef struct lu_fid lustre_fid;
176
177 /**
178  * Following struct for object attributes, that will be kept inode's EA.
179  * Introduced in 2.0 release (please see b15993, for details)
180  * Added to all objects since Lustre 2.4 as contains self FID
181  */
182 struct lustre_mdt_attrs {
183         /**
184          * Bitfield for supported data in this structure. From enum lma_compat.
185          * lma_self_fid and lma_flags are always available.
186          */
187         __u32   lma_compat;
188         /**
189          * Per-file incompat feature list. Lustre version should support all
190          * flags set in this field. The supported feature mask is available in
191          * LMA_INCOMPAT_SUPP.
192          */
193         __u32   lma_incompat;
194         /** FID of this inode */
195         struct lu_fid  lma_self_fid;
196 };
197
198 /**
199  * Prior to 2.4, the LMA structure also included SOM attributes which has since
200  * been moved to a dedicated xattr
201  * lma_flags was also removed because of lma_compat/incompat fields.
202  */
203 #define LMA_OLD_SIZE (sizeof(struct lustre_mdt_attrs) + 5 * sizeof(__u64))
204
205 /**
206  * OST object IDentifier.
207  */
208 struct ost_id {
209         union {
210                 struct {
211                         __u64   oi_id;
212                         __u64   oi_seq;
213                 } oi;
214                 struct lu_fid oi_fid;
215         };
216 };
217
218 #define DOSTID "%#llx:%llu"
219 #define POSTID(oi) ((unsigned long long)ostid_seq(oi)), \
220                    ((unsigned long long)ostid_id(oi))
221
222 struct ll_futimes_3 {
223         __u64 lfu_atime_sec;
224         __u64 lfu_atime_nsec;
225         __u64 lfu_mtime_sec;
226         __u64 lfu_mtime_nsec;
227         __u64 lfu_ctime_sec;
228         __u64 lfu_ctime_nsec;
229 };
230
231 /*
232  * The ioctl naming rules:
233  * LL_*     - works on the currently opened filehandle instead of parent dir
234  * *_OBD_*  - gets data for both OSC or MDC (LOV, LMV indirectly)
235  * *_MDC_*  - gets/sets data related to MDC
236  * *_LOV_*  - gets/sets data related to OSC/LOV
237  * *FILE*   - called on parent dir and passes in a filename
238  * *STRIPE* - set/get lov_user_md
239  * *INFO    - set/get lov_user_mds_data
240  */
241 /*      lustre_ioctl.h                  101-150 */
242 #define LL_IOC_GETFLAGS                 _IOR ('f', 151, long)
243 #define LL_IOC_SETFLAGS                 _IOW ('f', 152, long)
244 #define LL_IOC_CLRFLAGS                 _IOW ('f', 153, long)
245 #define LL_IOC_LOV_SETSTRIPE            _IOW ('f', 154, long)
246 #define LL_IOC_LOV_GETSTRIPE            _IOW ('f', 155, long)
247 #define LL_IOC_LOV_SETEA                _IOW ('f', 156, long)
248 /*      LL_IOC_RECREATE_OBJ             157 obsolete */
249 /*      LL_IOC_RECREATE_FID             157 obsolete */
250 #define LL_IOC_GROUP_LOCK               _IOW ('f', 158, long)
251 #define LL_IOC_GROUP_UNLOCK             _IOW ('f', 159, long)
252 /*      LL_IOC_QUOTACHECK               160 OBD_IOC_QUOTACHECK */
253 /*      LL_IOC_POLL_QUOTACHECK          161 OBD_IOC_POLL_QUOTACHECK */
254 /*      LL_IOC_QUOTACTL                 162 OBD_IOC_QUOTACTL */
255 #define IOC_OBD_STATFS                  _IOWR('f', 164, struct obd_statfs *)
256 /*      IOC_LOV_GETINFO                 165 obsolete */
257 #define LL_IOC_FLUSHCTX                 _IOW ('f', 166, long)
258 /*      LL_IOC_RMTACL                   167 obsolete */
259 #define LL_IOC_GETOBDCOUNT              _IOR ('f', 168, long)
260 #define LL_IOC_LLOOP_ATTACH             _IOWR('f', 169, long)
261 #define LL_IOC_LLOOP_DETACH             _IOWR('f', 170, long)
262 #define LL_IOC_LLOOP_INFO               _IOWR('f', 171, struct lu_fid)
263 #define LL_IOC_LLOOP_DETACH_BYDEV       _IOWR('f', 172, long)
264 #define LL_IOC_PATH2FID                 _IOR ('f', 173, long)
265 #define LL_IOC_GET_CONNECT_FLAGS        _IOWR('f', 174, __u64 *)
266 #define LL_IOC_GET_MDTIDX               _IOR ('f', 175, int)
267 #define LL_IOC_FUTIMES_3                _IOWR('f', 176, struct ll_futimes_3)
268 /*      lustre_ioctl.h                  177-210 */
269 #define LL_IOC_HSM_STATE_GET            _IOR('f', 211, struct hsm_user_state)
270 #define LL_IOC_HSM_STATE_SET            _IOW('f', 212, struct hsm_state_set)
271 #define LL_IOC_HSM_CT_START             _IOW('f', 213, struct lustre_kernelcomm)
272 #define LL_IOC_HSM_COPY_START           _IOW('f', 214, struct hsm_copy *)
273 #define LL_IOC_HSM_COPY_END             _IOW('f', 215, struct hsm_copy *)
274 #define LL_IOC_HSM_PROGRESS             _IOW('f', 216, struct hsm_user_request)
275 #define LL_IOC_HSM_REQUEST              _IOW('f', 217, struct hsm_user_request)
276 #define LL_IOC_DATA_VERSION             _IOR('f', 218, struct ioc_data_version)
277 #define LL_IOC_LOV_SWAP_LAYOUTS         _IOW('f', 219, \
278                                                 struct lustre_swap_layouts)
279 #define LL_IOC_HSM_ACTION               _IOR('f', 220, \
280                                                 struct hsm_current_action)
281 /*      lustre_ioctl.h                  221-232 */
282 #define LL_IOC_LMV_SETSTRIPE            _IOWR('f', 240, struct lmv_user_md)
283 #define LL_IOC_LMV_GETSTRIPE            _IOWR('f', 241, struct lmv_user_md)
284 #define LL_IOC_REMOVE_ENTRY             _IOWR('f', 242, __u64)
285 #define LL_IOC_SET_LEASE                _IOWR('f', 243, long)
286 #define LL_IOC_GET_LEASE                _IO('f', 244)
287 #define LL_IOC_HSM_IMPORT               _IOWR('f', 245, struct hsm_user_import)
288 #define LL_IOC_LMV_SET_DEFAULT_STRIPE   _IOWR('f', 246, struct lmv_user_md)
289 #define LL_IOC_MIGRATE                  _IOR('f', 247, int)
290 #define LL_IOC_FID2MDTIDX               _IOWR('f', 248, struct lu_fid)
291 #define LL_IOC_GETPARENT                _IOWR('f', 249, struct getparent)
292 #define LL_IOC_LADVISE                  _IOR('f', 250, struct llapi_lu_ladvise)
293
294 /* Lease types for use as arg and return of LL_IOC_{GET,SET}_LEASE ioctl. */
295 enum ll_lease_type {
296         LL_LEASE_RDLCK  = 0x1,
297         LL_LEASE_WRLCK  = 0x2,
298         LL_LEASE_UNLCK  = 0x4,
299 };
300
301 #define LL_STATFS_LMV           1
302 #define LL_STATFS_LOV           2
303 #define LL_STATFS_NODELAY       4
304
305 #define IOC_MDC_TYPE            'i'
306 #define IOC_MDC_LOOKUP          _IOWR(IOC_MDC_TYPE, 20, struct obd_device *)
307 #define IOC_MDC_GETFILESTRIPE   _IOWR(IOC_MDC_TYPE, 21, struct lov_user_md *)
308 #define IOC_MDC_GETFILEINFO     _IOWR(IOC_MDC_TYPE, 22, struct lov_user_mds_data *)
309 #define LL_IOC_MDC_GETINFO      _IOWR(IOC_MDC_TYPE, 23, struct lov_user_mds_data *)
310
311 #define MAX_OBD_NAME 128 /* If this changes, a NEW ioctl must be added */
312
313 /* Define O_LOV_DELAY_CREATE to be a mask that is not useful for regular
314  * files, but are unlikely to be used in practice and are not harmful if
315  * used incorrectly.  O_NOCTTY and FASYNC are only meaningful for character
316  * devices and are safe for use on new files. See LU-4209. */
317 /* To be compatible with old statically linked binary we keep the check for
318  * the older 0100000000 flag.  This is already removed upstream.  LU-812. */
319 #define O_LOV_DELAY_CREATE_1_8  0100000000 /* FMODE_NONOTIFY masked in 2.6.36 */
320 #define O_LOV_DELAY_CREATE_MASK (O_NOCTTY | FASYNC)
321 #define O_LOV_DELAY_CREATE              (O_LOV_DELAY_CREATE_1_8 | \
322                                          O_LOV_DELAY_CREATE_MASK)
323
324 #define LL_FILE_IGNORE_LOCK     0x00000001
325 #define LL_FILE_GROUP_LOCKED    0x00000002
326 #define LL_FILE_READAHEA        0x00000004
327 #define LL_FILE_LOCKED_DIRECTIO 0x00000008 /* client-side locks with dio */
328 #define LL_FILE_LOCKLESS_IO     0x00000010 /* server-side locks with cio */
329
330 #define LOV_USER_MAGIC_V1       0x0BD10BD0
331 #define LOV_USER_MAGIC          LOV_USER_MAGIC_V1
332 #define LOV_USER_MAGIC_JOIN_V1  0x0BD20BD0
333 #define LOV_USER_MAGIC_V3       0x0BD30BD0
334 /* 0x0BD40BD0 is occupied by LOV_MAGIC_MIGRATE */
335 #define LOV_USER_MAGIC_SPECIFIC 0x0BD50BD0      /* for specific OSTs */
336
337 #define LMV_USER_MAGIC    0x0CD30CD0    /*default lmv magic*/
338
339 #define LOV_PATTERN_RAID0       0x001
340 #define LOV_PATTERN_RAID1       0x002
341 #define LOV_PATTERN_FIRST       0x100
342 #define LOV_PATTERN_CMOBD       0x200
343
344 #define LOV_PATTERN_F_MASK      0xffff0000
345 #define LOV_PATTERN_F_HOLE      0x40000000 /* there is hole in LOV EA */
346 #define LOV_PATTERN_F_RELEASED  0x80000000 /* HSM released file */
347
348 #define LOV_MAXPOOLNAME 15
349 #define LOV_POOLNAMEF "%.15s"
350
351 #define LOV_MIN_STRIPE_BITS 16   /* maximum PAGE_SIZE (ia64), power of 2 */
352 #define LOV_MIN_STRIPE_SIZE (1 << LOV_MIN_STRIPE_BITS)
353 #define LOV_MAX_STRIPE_COUNT_OLD 160
354 /* This calculation is crafted so that input of 4096 will result in 160
355  * which in turn is equal to old maximal stripe count.
356  * XXX: In fact this is too simpified for now, what it also need is to get
357  * ea_type argument to clearly know how much space each stripe consumes.
358  *
359  * The limit of 12 pages is somewhat arbitrary, but is a reasonably large
360  * allocation that is sufficient for the current generation of systems.
361  *
362  * (max buffer size - lov+rpc header) / sizeof(struct lov_ost_data_v1) */
363 #define LOV_MAX_STRIPE_COUNT 2000  /* ((12 * 4096 - 256) / 24) */
364 #define LOV_ALL_STRIPES       0xffff /* only valid for directories */
365 #define LOV_V1_INSANE_STRIPE_COUNT 65532 /* maximum stripe count bz13933 */
366
367 #define XATTR_LUSTRE_PREFIX     "lustre."
368 #define XATTR_LUSTRE_LOV        XATTR_LUSTRE_PREFIX"lov"
369
370 #define lov_user_ost_data lov_user_ost_data_v1
371 struct lov_user_ost_data_v1 {     /* per-stripe data structure */
372         struct ost_id l_ost_oi;   /* OST object ID */
373         __u32 l_ost_gen;          /* generation of this OST index */
374         __u32 l_ost_idx;          /* OST index in LOV */
375 } __attribute__((packed));
376
377 #define lov_user_md lov_user_md_v1
378 struct lov_user_md_v1 {           /* LOV EA user data (host-endian) */
379         __u32 lmm_magic;          /* magic number = LOV_USER_MAGIC_V1 */
380         __u32 lmm_pattern;        /* LOV_PATTERN_RAID0, LOV_PATTERN_RAID1 */
381         struct ost_id lmm_oi;     /* MDT parent inode id/seq (id/0 for 1.x) */
382         __u32 lmm_stripe_size;    /* size of stripe in bytes */
383         __u16 lmm_stripe_count;   /* num stripes in use for this object */
384         union {
385                 __u16 lmm_stripe_offset;  /* starting stripe offset in
386                                            * lmm_objects, use when writing */
387                 __u16 lmm_layout_gen;     /* layout generation number
388                                            * used when reading */
389         };
390         struct lov_user_ost_data_v1 lmm_objects[0]; /* per-stripe data */
391 } __attribute__((packed,  __may_alias__));
392
393 struct lov_user_md_v3 {           /* LOV EA user data (host-endian) */
394         __u32 lmm_magic;          /* magic number = LOV_USER_MAGIC_V3 */
395         __u32 lmm_pattern;        /* LOV_PATTERN_RAID0, LOV_PATTERN_RAID1 */
396         struct ost_id lmm_oi;     /* MDT parent inode id/seq (id/0 for 1.x) */
397         __u32 lmm_stripe_size;    /* size of stripe in bytes */
398         __u16 lmm_stripe_count;   /* num stripes in use for this object */
399         union {
400                 __u16 lmm_stripe_offset;  /* starting stripe offset in
401                                            * lmm_objects, use when writing */
402                 __u16 lmm_layout_gen;     /* layout generation number
403                                            * used when reading */
404         };
405         char  lmm_pool_name[LOV_MAXPOOLNAME + 1]; /* pool name */
406         struct lov_user_ost_data_v1 lmm_objects[0]; /* per-stripe data */
407 } __attribute__((packed));
408
409 static inline __u32 lov_user_md_size(__u16 stripes, __u32 lmm_magic)
410 {
411         if (lmm_magic == LOV_USER_MAGIC_V1)
412                 return sizeof(struct lov_user_md_v1) +
413                               stripes * sizeof(struct lov_user_ost_data_v1);
414         return sizeof(struct lov_user_md_v3) +
415                                 stripes * sizeof(struct lov_user_ost_data_v1);
416 }
417
418 /* Compile with -D_LARGEFILE64_SOURCE or -D_GNU_SOURCE (or #define) to
419  * use this.  It is unsafe to #define those values in this header as it
420  * is possible the application has already #included <sys/stat.h>. */
421 #ifdef HAVE_LOV_USER_MDS_DATA
422 #define lov_user_mds_data lov_user_mds_data_v1
423 struct lov_user_mds_data_v1 {
424         lstat_t lmd_st;                 /* MDS stat struct */
425         struct lov_user_md_v1 lmd_lmm;  /* LOV EA V1 user data */
426 } __attribute__((packed));
427
428 struct lov_user_mds_data_v3 {
429         lstat_t lmd_st;                 /* MDS stat struct */
430         struct lov_user_md_v3 lmd_lmm;  /* LOV EA V3 user data */
431 } __attribute__((packed));
432 #endif
433
434 struct lmv_user_mds_data {
435         struct lu_fid   lum_fid;
436         __u32           lum_padding;
437         __u32           lum_mds;
438 };
439
440 enum lmv_hash_type {
441         LMV_HASH_TYPE_UNKNOWN   = 0,    /* 0 is reserved for testing purpose */
442         LMV_HASH_TYPE_ALL_CHARS = 1,
443         LMV_HASH_TYPE_FNV_1A_64 = 2,
444 };
445
446 #define LMV_HASH_NAME_ALL_CHARS "all_char"
447 #define LMV_HASH_NAME_FNV_1A_64 "fnv_1a_64"
448
449 /* Got this according to how get LOV_MAX_STRIPE_COUNT, see above,
450  * (max buffer size - lmv+rpc header) / sizeof(struct lmv_user_mds_data) */
451 #define LMV_MAX_STRIPE_COUNT 2000  /* ((12 * 4096 - 256) / 24) */
452 #define lmv_user_md lmv_user_md_v1
453 struct lmv_user_md_v1 {
454         __u32   lum_magic;       /* must be the first field */
455         __u32   lum_stripe_count;  /* dirstripe count */
456         __u32   lum_stripe_offset; /* MDT idx for default dirstripe */
457         __u32   lum_hash_type;     /* Dir stripe policy */
458         __u32   lum_type;         /* LMV type: default or normal */
459         __u32   lum_padding1;
460         __u32   lum_padding2;
461         __u32   lum_padding3;
462         char    lum_pool_name[LOV_MAXPOOLNAME + 1];
463         struct  lmv_user_mds_data  lum_objects[0];
464 } __attribute__((packed));
465
466 static inline int lmv_user_md_size(int stripes, int lmm_magic)
467 {
468         return sizeof(struct lmv_user_md) +
469                       stripes * sizeof(struct lmv_user_mds_data);
470 }
471
472 struct ll_recreate_obj {
473         __u64 lrc_id;
474         __u32 lrc_ost_idx;
475 };
476
477 struct ll_fid {
478         __u64 id;         /* holds object id */
479         __u32 generation; /* holds object generation */
480         __u32 f_type;     /* holds object type or stripe idx when passing it to
481                            * OST for saving into EA. */
482 };
483
484 #define UUID_MAX        40
485 struct obd_uuid {
486         char uuid[UUID_MAX];
487 };
488
489 static inline bool obd_uuid_equals(const struct obd_uuid *u1,
490                                    const struct obd_uuid *u2)
491 {
492         return strcmp((char *)u1->uuid, (char *)u2->uuid) == 0;
493 }
494
495 static inline int obd_uuid_empty(struct obd_uuid *uuid)
496 {
497         return uuid->uuid[0] == '\0';
498 }
499
500 static inline void obd_str2uuid(struct obd_uuid *uuid, const char *tmp)
501 {
502         strncpy((char *)uuid->uuid, tmp, sizeof(*uuid));
503         uuid->uuid[sizeof(*uuid) - 1] = '\0';
504 }
505
506 /* For printf's only, make sure uuid is terminated */
507 static inline char *obd_uuid2str(const struct obd_uuid *uuid)
508 {
509         if (uuid == NULL)
510                 return NULL;
511
512         if (uuid->uuid[sizeof(*uuid) - 1] != '\0') {
513                 /* Obviously not safe, but for printfs, no real harm done...
514                    we're always null-terminated, even in a race. */
515                 static char temp[sizeof(*uuid)];
516                 memcpy(temp, uuid->uuid, sizeof(*uuid) - 1);
517                 temp[sizeof(*uuid) - 1] = '\0';
518                 return temp;
519         }
520         return (char *)(uuid->uuid);
521 }
522
523 /* Extract fsname from uuid (or target name) of a target
524    e.g. (myfs-OST0007_UUID -> myfs)
525    see also deuuidify. */
526 static inline void obd_uuid2fsname(char *buf, char *uuid, int buflen)
527 {
528         char *p;
529
530         strncpy(buf, uuid, buflen - 1);
531         buf[buflen - 1] = '\0';
532         p = strrchr(buf, '-');
533         if (p != NULL)
534                 *p = '\0';
535 }
536
537 /* printf display format for Lustre FIDs
538  * usage: printf("file FID is "DFID"\n", PFID(fid)); */
539 #define FID_NOBRACE_LEN 40
540 #define FID_LEN (FID_NOBRACE_LEN + 2)
541 #define DFID_NOBRACE "%#llx:0x%x:0x%x"
542 #define DFID "["DFID_NOBRACE"]"
543 #define PFID(fid) (unsigned long long)(fid)->f_seq, (fid)->f_oid, (fid)->f_ver
544
545 /* scanf input parse format for fids in DFID_NOBRACE format
546  * Need to strip '[' from DFID format first or use "["SFID"]" at caller.
547  * usage: sscanf(fidstr, SFID, RFID(&fid)); */
548 #define SFID "0x%llx:0x%x:0x%x"
549 #define RFID(fid) &((fid)->f_seq), &((fid)->f_oid), &((fid)->f_ver)
550
551 /********* Quotas **********/
552
553 #define LUSTRE_QUOTABLOCK_BITS 10
554 #define LUSTRE_QUOTABLOCK_SIZE (1 << LUSTRE_QUOTABLOCK_BITS)
555
556 static inline __u64 lustre_stoqb(size_t space)
557 {
558         return (space + LUSTRE_QUOTABLOCK_SIZE - 1) >> LUSTRE_QUOTABLOCK_BITS;
559 }
560
561 #define Q_QUOTACHECK    0x800100 /* deprecated as of 2.4 */
562 #define Q_INITQUOTA     0x800101 /* deprecated as of 2.4  */
563 #define Q_GETOINFO      0x800102 /* get obd quota info */
564 #define Q_GETOQUOTA     0x800103 /* get obd quotas */
565 #define Q_FINVALIDATE   0x800104 /* deprecated as of 2.4 */
566
567 /* these must be explicitly translated into linux Q_* in ll_dir_ioctl */
568 #define LUSTRE_Q_QUOTAON    0x800002     /* deprecated as of 2.4 */
569 #define LUSTRE_Q_QUOTAOFF   0x800003     /* deprecated as of 2.4 */
570 #define LUSTRE_Q_GETINFO    0x800005     /* get information about quota files */
571 #define LUSTRE_Q_SETINFO    0x800006     /* set information about quota files */
572 #define LUSTRE_Q_GETQUOTA   0x800007     /* get user quota structure */
573 #define LUSTRE_Q_SETQUOTA   0x800008     /* set user quota structure */
574 /* lustre-specific control commands */
575 #define LUSTRE_Q_INVALIDATE  0x80000b     /* deprecated as of 2.4 */
576 #define LUSTRE_Q_FINVALIDATE 0x80000c     /* deprecated as of 2.4 */
577
578 #define UGQUOTA 2       /* set both USRQUOTA and GRPQUOTA */
579
580 #define IDENTITY_DOWNCALL_MAGIC 0x6d6dd629
581
582 /* permission */
583 #define N_PERMS_MAX      64
584
585 struct perm_downcall_data {
586         __u64 pdd_nid;
587         __u32 pdd_perm;
588         __u32 pdd_padding;
589 };
590
591 struct identity_downcall_data {
592         __u32                            idd_magic;
593         __u32                            idd_err;
594         __u32                            idd_uid;
595         __u32                            idd_gid;
596         __u32                            idd_nperms;
597         __u32                            idd_ngroups;
598         struct perm_downcall_data idd_perms[N_PERMS_MAX];
599         __u32                            idd_groups[0];
600 };
601
602 #ifdef NEED_QUOTA_DEFS
603 #ifndef QIF_BLIMITS
604 #define QIF_BLIMITS     1
605 #define QIF_SPACE       2
606 #define QIF_ILIMITS     4
607 #define QIF_INODES      8
608 #define QIF_BTIME       16
609 #define QIF_ITIME       32
610 #define QIF_LIMITS      (QIF_BLIMITS | QIF_ILIMITS)
611 #define QIF_USAGE       (QIF_SPACE | QIF_INODES)
612 #define QIF_TIMES       (QIF_BTIME | QIF_ITIME)
613 #define QIF_ALL         (QIF_LIMITS | QIF_USAGE | QIF_TIMES)
614 #endif
615
616 #endif /* !__KERNEL__ */
617
618 /* lustre volatile file support
619  * file name header: .^L^S^T^R:volatile"
620  */
621 #define LUSTRE_VOLATILE_HDR     ".\x0c\x13\x14\x12:VOLATILE"
622 #define LUSTRE_VOLATILE_HDR_LEN 14
623
624 typedef enum lustre_quota_version {
625         LUSTRE_QUOTA_V2 = 1
626 } lustre_quota_version_t;
627
628 /* XXX: same as if_dqinfo struct in kernel */
629 struct obd_dqinfo {
630         __u64 dqi_bgrace;
631         __u64 dqi_igrace;
632         __u32 dqi_flags;
633         __u32 dqi_valid;
634 };
635
636 /* XXX: same as if_dqblk struct in kernel, plus one padding */
637 struct obd_dqblk {
638         __u64 dqb_bhardlimit;
639         __u64 dqb_bsoftlimit;
640         __u64 dqb_curspace;
641         __u64 dqb_ihardlimit;
642         __u64 dqb_isoftlimit;
643         __u64 dqb_curinodes;
644         __u64 dqb_btime;
645         __u64 dqb_itime;
646         __u32 dqb_valid;
647         __u32 dqb_padding;
648 };
649
650 enum {
651         QC_GENERAL      = 0,
652         QC_MDTIDX       = 1,
653         QC_OSTIDX       = 2,
654         QC_UUID         = 3
655 };
656
657 struct if_quotactl {
658         __u32                   qc_cmd;
659         __u32                   qc_type;
660         __u32                   qc_id;
661         __u32                   qc_stat;
662         __u32                   qc_valid;
663         __u32                   qc_idx;
664         struct obd_dqinfo       qc_dqinfo;
665         struct obd_dqblk        qc_dqblk;
666         char                    obd_type[16];
667         struct obd_uuid         obd_uuid;
668 };
669
670 /* swap layout flags */
671 #define SWAP_LAYOUTS_CHECK_DV1          (1 << 0)
672 #define SWAP_LAYOUTS_CHECK_DV2          (1 << 1)
673 #define SWAP_LAYOUTS_KEEP_MTIME         (1 << 2)
674 #define SWAP_LAYOUTS_KEEP_ATIME         (1 << 3)
675 #define SWAP_LAYOUTS_CLOSE              (1 << 4)
676
677 /* Swap XATTR_NAME_HSM as well, only on the MDT so far */
678 #define SWAP_LAYOUTS_MDS_HSM            (1 << 31)
679 struct lustre_swap_layouts {
680         __u64   sl_flags;
681         __u32   sl_fd;
682         __u32   sl_gid;
683         __u64   sl_dv1;
684         __u64   sl_dv2;
685 };
686
687
688 /********* Changelogs **********/
689 /** Changelog record types */
690 enum changelog_rec_type {
691         CL_MARK     = 0,
692         CL_CREATE   = 1,  /* namespace */
693         CL_MKDIR    = 2,  /* namespace */
694         CL_HARDLINK = 3,  /* namespace */
695         CL_SOFTLINK = 4,  /* namespace */
696         CL_MKNOD    = 5,  /* namespace */
697         CL_UNLINK   = 6,  /* namespace */
698         CL_RMDIR    = 7,  /* namespace */
699         CL_RENAME   = 8,  /* namespace */
700         CL_EXT      = 9,  /* namespace extended record (2nd half of rename) */
701         CL_OPEN     = 10, /* not currently used */
702         CL_CLOSE    = 11, /* may be written to log only with mtime change */
703         CL_LAYOUT   = 12, /* file layout/striping modified */
704         CL_TRUNC    = 13,
705         CL_SETATTR  = 14,
706         CL_XATTR    = 15,
707         CL_HSM      = 16, /* HSM specific events, see flags */
708         CL_MTIME    = 17, /* Precedence: setattr > mtime > ctime > atime */
709         CL_CTIME    = 18,
710         CL_ATIME    = 19,
711         CL_MIGRATE  = 20,
712         CL_LAST
713 };
714
715 static inline const char *changelog_type2str(int type) {
716         static const char *changelog_str[] = {
717                 "MARK",  "CREAT", "MKDIR", "HLINK", "SLINK", "MKNOD", "UNLNK",
718                 "RMDIR", "RENME", "RNMTO", "OPEN",  "CLOSE", "LYOUT", "TRUNC",
719                 "SATTR", "XATTR", "HSM",   "MTIME", "CTIME", "ATIME", "MIGRT"
720         };
721
722         if (type >= 0 && type < CL_LAST)
723                 return changelog_str[type];
724         return NULL;
725 }
726
727 /* per-record flags */
728 #define CLF_FLAGSHIFT   12
729 #define CLF_FLAGMASK    ((1U << CLF_FLAGSHIFT) - 1)
730 #define CLF_VERMASK     (~CLF_FLAGMASK)
731 enum changelog_rec_flags {
732         CLF_VERSION     = 0x1000,
733         CLF_RENAME      = 0x2000,
734         CLF_JOBID       = 0x4000,
735         CLF_SUPPORTED   = CLF_VERSION | CLF_RENAME | CLF_JOBID
736 };
737
738
739 /* Anything under the flagmask may be per-type (if desired) */
740 /* Flags for unlink */
741 #define CLF_UNLINK_LAST       0x0001 /* Unlink of last hardlink */
742 #define CLF_UNLINK_HSM_EXISTS 0x0002 /* File has something in HSM */
743                                      /* HSM cleaning needed */
744 /* Flags for rename */
745 #define CLF_RENAME_LAST         0x0001 /* rename unlink last hardlink
746                                         * of target */
747 #define CLF_RENAME_LAST_EXISTS  0x0002 /* rename unlink last hardlink of target
748                                         * has an archive in backend */
749
750 /* Flags for HSM */
751 /* 12b used (from high weight to low weight):
752  * 2b for flags
753  * 3b for event
754  * 7b for error code
755  */
756 #define CLF_HSM_ERR_L        0 /* HSM return code, 7 bits */
757 #define CLF_HSM_ERR_H        6
758 #define CLF_HSM_EVENT_L      7 /* HSM event, 3 bits, see enum hsm_event */
759 #define CLF_HSM_EVENT_H      9
760 #define CLF_HSM_FLAG_L      10 /* HSM flags, 2 bits, 1 used, 1 spare */
761 #define CLF_HSM_FLAG_H      11
762 #define CLF_HSM_SPARE_L     12 /* 4 spare bits */
763 #define CLF_HSM_SPARE_H     15
764 #define CLF_HSM_LAST        15
765
766 /* Remove bits higher than _h, then extract the value
767  * between _h and _l by shifting lower weigth to bit 0. */
768 #define CLF_GET_BITS(_b, _h, _l) (((_b << (CLF_HSM_LAST - _h)) & 0xFFFF) \
769                                    >> (CLF_HSM_LAST - _h + _l))
770
771 #define CLF_HSM_SUCCESS      0x00
772 #define CLF_HSM_MAXERROR     0x7E
773 #define CLF_HSM_ERROVERFLOW  0x7F
774
775 #define CLF_HSM_DIRTY        1 /* file is dirty after HSM request end */
776
777 /* 3 bits field => 8 values allowed */
778 enum hsm_event {
779         HE_ARCHIVE      = 0,
780         HE_RESTORE      = 1,
781         HE_CANCEL       = 2,
782         HE_RELEASE      = 3,
783         HE_REMOVE       = 4,
784         HE_STATE        = 5,
785         HE_SPARE1       = 6,
786         HE_SPARE2       = 7,
787 };
788
789 static inline enum hsm_event hsm_get_cl_event(__u16 flags)
790 {
791         return (enum hsm_event)CLF_GET_BITS(flags, CLF_HSM_EVENT_H,
792                                             CLF_HSM_EVENT_L);
793 }
794
795 static inline void hsm_set_cl_event(int *flags, enum hsm_event he)
796 {
797         *flags |= (he << CLF_HSM_EVENT_L);
798 }
799
800 static inline __u16 hsm_get_cl_flags(int flags)
801 {
802         return CLF_GET_BITS(flags, CLF_HSM_FLAG_H, CLF_HSM_FLAG_L);
803 }
804
805 static inline void hsm_set_cl_flags(int *flags, int bits)
806 {
807         *flags |= (bits << CLF_HSM_FLAG_L);
808 }
809
810 static inline int hsm_get_cl_error(int flags)
811 {
812         return CLF_GET_BITS(flags, CLF_HSM_ERR_H, CLF_HSM_ERR_L);
813 }
814
815 static inline void hsm_set_cl_error(int *flags, int error)
816 {
817         *flags |= (error << CLF_HSM_ERR_L);
818 }
819
820 enum changelog_send_flag {
821         /* Not yet implemented */
822         CHANGELOG_FLAG_FOLLOW   = 0x01,
823         /* Blocking IO makes sense in case of slow user parsing of the records,
824          * but it also prevents us from cleaning up if the records are not
825          * consumed. */
826         CHANGELOG_FLAG_BLOCK    = 0x02,
827         /* Pack jobid into the changelog records if available. */
828         CHANGELOG_FLAG_JOBID    = 0x04,
829 };
830
831 #define CR_MAXSIZE cfs_size_round(2 * NAME_MAX + 2 + \
832                                   changelog_rec_offset(CLF_SUPPORTED))
833
834 /* 31 usable bytes string + null terminator. */
835 #define LUSTRE_JOBID_SIZE       32
836
837 /* This is the minimal changelog record. It can contain extensions
838  * such as rename fields or process jobid. Its exact content is described
839  * by the cr_flags.
840  *
841  * Extensions are packed in the same order as their corresponding flags.
842  */
843 struct changelog_rec {
844         __u16                   cr_namelen;
845         __u16                   cr_flags; /**< \a changelog_rec_flags */
846         __u32                   cr_type;  /**< \a changelog_rec_type */
847         __u64                   cr_index; /**< changelog record number */
848         __u64                   cr_prev;  /**< last index for this target fid */
849         __u64                   cr_time;
850         union {
851                 lustre_fid      cr_tfid;        /**< target fid */
852                 __u32           cr_markerflags; /**< CL_MARK flags */
853         };
854         lustre_fid              cr_pfid;        /**< parent fid */
855 };
856
857 /* Changelog extension for RENAME. */
858 struct changelog_ext_rename {
859         lustre_fid              cr_sfid;     /**< source fid, or zero */
860         lustre_fid              cr_spfid;    /**< source parent fid, or zero */
861 };
862
863 /* Changelog extension to include JOBID. */
864 struct changelog_ext_jobid {
865         char    cr_jobid[LUSTRE_JOBID_SIZE];    /**< zero-terminated string. */
866 };
867
868
869 static inline size_t changelog_rec_offset(enum changelog_rec_flags crf)
870 {
871         size_t size = sizeof(struct changelog_rec);
872
873         if (crf & CLF_RENAME)
874                 size += sizeof(struct changelog_ext_rename);
875
876         if (crf & CLF_JOBID)
877                 size += sizeof(struct changelog_ext_jobid);
878
879         return size;
880 }
881
882 static inline size_t changelog_rec_size(const struct changelog_rec *rec)
883 {
884         return changelog_rec_offset(rec->cr_flags);
885 }
886
887 static inline size_t changelog_rec_varsize(const struct changelog_rec *rec)
888 {
889         return changelog_rec_size(rec) - sizeof(*rec) + rec->cr_namelen;
890 }
891
892 static inline
893 struct changelog_ext_rename *changelog_rec_rename(const struct changelog_rec *rec)
894 {
895         enum changelog_rec_flags crf = rec->cr_flags & CLF_VERSION;
896
897         return (struct changelog_ext_rename *)((char *)rec +
898                                                changelog_rec_offset(crf));
899 }
900
901 /* The jobid follows the rename extension, if present */
902 static inline
903 struct changelog_ext_jobid *changelog_rec_jobid(const struct changelog_rec *rec)
904 {
905         enum changelog_rec_flags crf = rec->cr_flags &
906                                         (CLF_VERSION | CLF_RENAME);
907
908         return (struct changelog_ext_jobid *)((char *)rec +
909                                               changelog_rec_offset(crf));
910 }
911
912 /* The name follows the rename and jobid extensions, if present */
913 static inline char *changelog_rec_name(const struct changelog_rec *rec)
914 {
915         return (char *)rec + changelog_rec_offset(rec->cr_flags &
916                                                   CLF_SUPPORTED);
917 }
918
919 static inline size_t changelog_rec_snamelen(const struct changelog_rec *rec)
920 {
921         return rec->cr_namelen - strlen(changelog_rec_name(rec)) - 1;
922 }
923
924 static inline char *changelog_rec_sname(const struct changelog_rec *rec)
925 {
926         char *cr_name = changelog_rec_name(rec);
927
928         return cr_name + strlen(cr_name) + 1;
929 }
930
931 /**
932  * Remap a record to the desired format as specified by the crf flags.
933  * The record must be big enough to contain the final remapped version.
934  * Superfluous extension fields are removed and missing ones are added
935  * and zeroed. The flags of the record are updated accordingly.
936  *
937  * The jobid and rename extensions can be added to a record, to match the
938  * format an application expects, typically. In this case, the newly added
939  * fields will be zeroed.
940  * The Jobid field can be removed, to guarantee compatibility with older
941  * clients that don't expect this field in the records they process.
942  *
943  * The following assumptions are being made:
944  *   - CLF_RENAME will not be removed
945  *   - CLF_JOBID will not be added without CLF_RENAME being added too
946  *
947  * @param[in,out]  rec         The record to remap.
948  * @param[in]      crf_wanted  Flags describing the desired extensions.
949  */
950 static inline void changelog_remap_rec(struct changelog_rec *rec,
951                                        enum changelog_rec_flags crf_wanted)
952 {
953         char *jid_mov;
954         char *rnm_mov;
955
956         crf_wanted &= CLF_SUPPORTED;
957
958         if ((rec->cr_flags & CLF_SUPPORTED) == crf_wanted)
959                 return;
960
961         /* First move the variable-length name field */
962         memmove((char *)rec + changelog_rec_offset(crf_wanted),
963                 changelog_rec_name(rec), rec->cr_namelen);
964
965         /* Locations of jobid and rename extensions in the remapped record */
966         jid_mov = (char *)rec +
967                   changelog_rec_offset(crf_wanted & ~CLF_JOBID);
968         rnm_mov = (char *)rec +
969                   changelog_rec_offset(crf_wanted & ~(CLF_JOBID | CLF_RENAME));
970
971         /* Move the extension fields to the desired positions */
972         if ((crf_wanted & CLF_JOBID) && (rec->cr_flags & CLF_JOBID))
973                 memmove(jid_mov, changelog_rec_jobid(rec),
974                         sizeof(struct changelog_ext_jobid));
975
976         if ((crf_wanted & CLF_RENAME) && (rec->cr_flags & CLF_RENAME))
977                 memmove(rnm_mov, changelog_rec_rename(rec),
978                         sizeof(struct changelog_ext_rename));
979
980         /* Clear newly added fields */
981         if ((crf_wanted & CLF_JOBID) && !(rec->cr_flags & CLF_JOBID))
982                 memset(jid_mov, 0, sizeof(struct changelog_ext_jobid));
983
984         if ((crf_wanted & CLF_RENAME) && !(rec->cr_flags & CLF_RENAME))
985                 memset(rnm_mov, 0, sizeof(struct changelog_ext_rename));
986
987         /* Update the record's flags accordingly */
988         rec->cr_flags = (rec->cr_flags & CLF_FLAGMASK) | crf_wanted;
989 }
990
991 struct ioc_changelog {
992         __u64 icc_recno;
993         __u32 icc_mdtindex;
994         __u32 icc_id;
995         __u32 icc_flags;
996 };
997
998 enum changelog_message_type {
999         CL_RECORD = 10, /* message is a changelog_rec */
1000         CL_EOF    = 11, /* at end of current changelog */
1001 };
1002
1003 /********* Misc **********/
1004
1005 struct ioc_data_version {
1006         __u64 idv_version;
1007         __u64 idv_flags;     /* See LL_DV_xxx */
1008 };
1009 #define LL_DV_RD_FLUSH (1 << 0) /* Flush dirty pages from clients */
1010 #define LL_DV_WR_FLUSH (1 << 1) /* Flush all caching pages from clients */
1011
1012 #ifndef offsetof
1013 #define offsetof(typ, memb)     ((unsigned long)((char *)&(((typ *)0)->memb)))
1014 #endif
1015
1016 #define dot_lustre_name ".lustre"
1017
1018
1019 /********* HSM **********/
1020
1021 /** HSM per-file state
1022  * See HSM_FLAGS below.
1023  */
1024 enum hsm_states {
1025         HS_NONE         = 0x00000000,
1026         HS_EXISTS       = 0x00000001,
1027         HS_DIRTY        = 0x00000002,
1028         HS_RELEASED     = 0x00000004,
1029         HS_ARCHIVED     = 0x00000008,
1030         HS_NORELEASE    = 0x00000010,
1031         HS_NOARCHIVE    = 0x00000020,
1032         HS_LOST         = 0x00000040,
1033 };
1034
1035 /* HSM user-setable flags. */
1036 #define HSM_USER_MASK   (HS_NORELEASE | HS_NOARCHIVE | HS_DIRTY)
1037
1038 /* Other HSM flags. */
1039 #define HSM_STATUS_MASK (HS_EXISTS | HS_LOST | HS_RELEASED | HS_ARCHIVED)
1040
1041 /*
1042  * All HSM-related possible flags that could be applied to a file.
1043  * This should be kept in sync with hsm_states.
1044  */
1045 #define HSM_FLAGS_MASK  (HSM_USER_MASK | HSM_STATUS_MASK)
1046
1047 /**
1048  * HSM request progress state
1049  */
1050 enum hsm_progress_states {
1051         HPS_WAITING     = 1,
1052         HPS_RUNNING     = 2,
1053         HPS_DONE        = 3,
1054 };
1055 #define HPS_NONE        0
1056
1057 static inline const char *hsm_progress_state2name(enum hsm_progress_states s)
1058 {
1059         switch  (s) {
1060         case HPS_WAITING:       return "waiting";
1061         case HPS_RUNNING:       return "running";
1062         case HPS_DONE:          return "done";
1063         default:                return "unknown";
1064         }
1065 }
1066
1067 struct hsm_extent {
1068         __u64 offset;
1069         __u64 length;
1070 } __attribute__((packed));
1071
1072 /**
1073  * Current HSM states of a Lustre file.
1074  *
1075  * This structure purpose is to be sent to user-space mainly. It describes the
1076  * current HSM flags and in-progress action.
1077  */
1078 struct hsm_user_state {
1079         /** Current HSM states, from enum hsm_states. */
1080         __u32                   hus_states;
1081         __u32                   hus_archive_id;
1082         /**  The current undergoing action, if there is one */
1083         __u32                   hus_in_progress_state;
1084         __u32                   hus_in_progress_action;
1085         struct hsm_extent       hus_in_progress_location;
1086         char                    hus_extended_info[];
1087 };
1088
1089 struct hsm_state_set_ioc {
1090         struct lu_fid   hssi_fid;
1091         __u64           hssi_setmask;
1092         __u64           hssi_clearmask;
1093 };
1094
1095 /*
1096  * This structure describes the current in-progress action for a file.
1097  * it is retuned to user space and send over the wire
1098  */
1099 struct hsm_current_action {
1100         /**  The current undergoing action, if there is one */
1101         /* state is one of hsm_progress_states */
1102         __u32                   hca_state;
1103         /* action is one of hsm_user_action */
1104         __u32                   hca_action;
1105         struct hsm_extent       hca_location;
1106 };
1107
1108 /***** HSM user requests ******/
1109 /* User-generated (lfs/ioctl) request types */
1110 enum hsm_user_action {
1111         HUA_NONE    =  1, /* no action (noop) */
1112         HUA_ARCHIVE = 10, /* copy to hsm */
1113         HUA_RESTORE = 11, /* prestage */
1114         HUA_RELEASE = 12, /* drop ost objects */
1115         HUA_REMOVE  = 13, /* remove from archive */
1116         HUA_CANCEL  = 14  /* cancel a request */
1117 };
1118
1119 static inline const char *hsm_user_action2name(enum hsm_user_action  a)
1120 {
1121         switch  (a) {
1122         case HUA_NONE:    return "NOOP";
1123         case HUA_ARCHIVE: return "ARCHIVE";
1124         case HUA_RESTORE: return "RESTORE";
1125         case HUA_RELEASE: return "RELEASE";
1126         case HUA_REMOVE:  return "REMOVE";
1127         case HUA_CANCEL:  return "CANCEL";
1128         default:          return "UNKNOWN";
1129         }
1130 }
1131
1132 /*
1133  * List of hr_flags (bit field)
1134  */
1135 #define HSM_FORCE_ACTION 0x0001
1136 /* used by CT, cannot be set by user */
1137 #define HSM_GHOST_COPY   0x0002
1138
1139 /**
1140  * Contains all the fixed part of struct hsm_user_request.
1141  *
1142  */
1143 struct hsm_request {
1144         __u32 hr_action;        /* enum hsm_user_action */
1145         __u32 hr_archive_id;    /* archive id, used only with HUA_ARCHIVE */
1146         __u64 hr_flags;         /* request flags */
1147         __u32 hr_itemcount;     /* item count in hur_user_item vector */
1148         __u32 hr_data_len;
1149 };
1150
1151 struct hsm_user_item {
1152        lustre_fid        hui_fid;
1153        struct hsm_extent hui_extent;
1154 } __attribute__((packed));
1155
1156 struct hsm_user_request {
1157         struct hsm_request      hur_request;
1158         struct hsm_user_item    hur_user_item[0];
1159         /* extra data blob at end of struct (after all
1160          * hur_user_items), only use helpers to access it
1161          */
1162 } __attribute__((packed));
1163
1164 /** Return pointer to data field in a hsm user request */
1165 static inline void *hur_data(struct hsm_user_request *hur)
1166 {
1167         return &(hur->hur_user_item[hur->hur_request.hr_itemcount]);
1168 }
1169
1170 /**
1171  * Compute the current length of the provided hsm_user_request.  This returns -1
1172  * instead of an errno because ssize_t is defined to be only [ -1, SSIZE_MAX ]
1173  *
1174  * return -1 on bounds check error.
1175  */
1176 static inline ssize_t hur_len(struct hsm_user_request *hur)
1177 {
1178         __u64   size;
1179
1180         /* can't overflow a __u64 since hr_itemcount is only __u32 */
1181         size = offsetof(struct hsm_user_request, hur_user_item[0]) +
1182                 (__u64)hur->hur_request.hr_itemcount *
1183                 sizeof(hur->hur_user_item[0]) + hur->hur_request.hr_data_len;
1184
1185         if (size != (ssize_t)size)
1186                 return -1;
1187
1188         return size;
1189 }
1190
1191 /****** HSM RPCs to copytool *****/
1192 /* Message types the copytool may receive */
1193 enum hsm_message_type {
1194         HMT_ACTION_LIST = 100, /* message is a hsm_action_list */
1195 };
1196
1197 /* Actions the copytool may be instructed to take for a given action_item */
1198 enum hsm_copytool_action {
1199         HSMA_NONE    = 10, /* no action */
1200         HSMA_ARCHIVE = 20, /* arbitrary offset */
1201         HSMA_RESTORE = 21,
1202         HSMA_REMOVE  = 22,
1203         HSMA_CANCEL  = 23
1204 };
1205
1206 static inline const char *hsm_copytool_action2name(enum hsm_copytool_action  a)
1207 {
1208         switch  (a) {
1209         case HSMA_NONE:    return "NOOP";
1210         case HSMA_ARCHIVE: return "ARCHIVE";
1211         case HSMA_RESTORE: return "RESTORE";
1212         case HSMA_REMOVE:  return "REMOVE";
1213         case HSMA_CANCEL:  return "CANCEL";
1214         default:           return "UNKNOWN";
1215         }
1216 }
1217
1218 /* Copytool item action description */
1219 struct hsm_action_item {
1220         __u32      hai_len;     /* valid size of this struct */
1221         __u32      hai_action;  /* hsm_copytool_action, but use known size */
1222         lustre_fid hai_fid;     /* Lustre FID to operate on */
1223         lustre_fid hai_dfid;    /* fid used for data access */
1224         struct hsm_extent hai_extent;  /* byte range to operate on */
1225         __u64      hai_cookie;  /* action cookie from coordinator */
1226         __u64      hai_gid;     /* grouplock id */
1227         char       hai_data[0]; /* variable length */
1228 } __attribute__((packed));
1229
1230 /**
1231  * helper function which print in hexa the first bytes of
1232  * hai opaque field
1233  *
1234  * \param hai [IN]        record to print
1235  * \param buffer [IN,OUT] buffer to write the hex string to
1236  * \param len [IN]        max buffer length
1237  *
1238  * \retval buffer
1239  */
1240 static inline char *hai_dump_data_field(const struct hsm_action_item *hai,
1241                                         char *buffer, size_t len)
1242 {
1243         int i;
1244         int data_len;
1245         char *ptr;
1246
1247         ptr = buffer;
1248         data_len = hai->hai_len - sizeof(*hai);
1249         for (i = 0; (i < data_len) && (len > 2); i++) {
1250                 snprintf(ptr, 3, "%02X", (unsigned char)hai->hai_data[i]);
1251                 ptr += 2;
1252                 len -= 2;
1253         }
1254
1255         *ptr = '\0';
1256
1257         return buffer;
1258 }
1259
1260 /* Copytool action list */
1261 #define HAL_VERSION 1
1262 #define HAL_MAXSIZE LNET_MTU /* bytes, used in userspace only */
1263 struct hsm_action_list {
1264         __u32 hal_version;
1265         __u32 hal_count;       /* number of hai's to follow */
1266         __u64 hal_compound_id; /* returned by coordinator */
1267         __u64 hal_flags;
1268         __u32 hal_archive_id; /* which archive backend */
1269         __u32 padding1;
1270         char  hal_fsname[0];   /* null-terminated */
1271         /* struct hsm_action_item[hal_count] follows, aligned on 8-byte
1272            boundaries. See hai_zero */
1273 } __attribute__((packed));
1274
1275 #ifndef HAVE_CFS_SIZE_ROUND
1276 static inline int cfs_size_round (int val)
1277 {
1278         return (val + 7) & (~0x7);
1279 }
1280 #define HAVE_CFS_SIZE_ROUND
1281 #endif
1282
1283 /* Return pointer to first hai in action list */
1284 static inline struct hsm_action_item *hai_first(struct hsm_action_list *hal)
1285 {
1286         return (struct hsm_action_item *)(hal->hal_fsname +
1287                                           cfs_size_round(strlen(hal-> \
1288                                                                 hal_fsname)
1289                                                          + 1));
1290 }
1291 /* Return pointer to next hai */
1292 static inline struct hsm_action_item * hai_next(struct hsm_action_item *hai)
1293 {
1294         return (struct hsm_action_item *)((char *)hai +
1295                                           cfs_size_round(hai->hai_len));
1296 }
1297
1298 /* Return size of an hsm_action_list */
1299 static inline size_t hal_size(struct hsm_action_list *hal)
1300 {
1301         __u32 i;
1302         size_t sz;
1303         struct hsm_action_item *hai;
1304
1305         sz = sizeof(*hal) + cfs_size_round(strlen(hal->hal_fsname) + 1);
1306         hai = hai_first(hal);
1307         for (i = 0; i < hal->hal_count ; i++, hai = hai_next(hai))
1308                 sz += cfs_size_round(hai->hai_len);
1309
1310         return sz;
1311 }
1312
1313 /* HSM file import
1314  * describe the attributes to be set on imported file
1315  */
1316 struct hsm_user_import {
1317         __u64           hui_size;
1318         __u64           hui_atime;
1319         __u64           hui_mtime;
1320         __u32           hui_atime_ns;
1321         __u32           hui_mtime_ns;
1322         __u32           hui_uid;
1323         __u32           hui_gid;
1324         __u32           hui_mode;
1325         __u32           hui_archive_id;
1326 };
1327
1328 /* Copytool progress reporting */
1329 #define HP_FLAG_COMPLETED 0x01
1330 #define HP_FLAG_RETRY     0x02
1331
1332 struct hsm_progress {
1333         lustre_fid              hp_fid;
1334         __u64                   hp_cookie;
1335         struct hsm_extent       hp_extent;
1336         __u16                   hp_flags;
1337         __u16                   hp_errval; /* positive val */
1338         __u32                   padding;
1339 };
1340
1341 struct hsm_copy {
1342         __u64                   hc_data_version;
1343         __u16                   hc_flags;
1344         __u16                   hc_errval; /* positive val */
1345         __u32                   padding;
1346         struct hsm_action_item  hc_hai;
1347 };
1348
1349 /* JSON objects */
1350 enum llapi_json_types {
1351         LLAPI_JSON_INTEGER = 1,
1352         LLAPI_JSON_BIGNUM,
1353         LLAPI_JSON_REAL,
1354         LLAPI_JSON_STRING
1355 };
1356
1357 struct llapi_json_item {
1358         char                    *lji_key;
1359         __u32                   lji_type;
1360         union {
1361                 int     lji_integer;
1362                 __u64   lji_u64;
1363                 double  lji_real;
1364                 char    *lji_string;
1365         };
1366         struct llapi_json_item  *lji_next;
1367 };
1368
1369 struct llapi_json_item_list {
1370         int                     ljil_item_count;
1371         struct llapi_json_item  *ljil_items;
1372 };
1373
1374 enum lu_ladvise_type {
1375         LU_LADVISE_INVALID      = 0,
1376         LU_LADVISE_WILLREAD     = 1,
1377         LU_LADVISE_DONTNEED     = 2,
1378 };
1379
1380 #define LU_LADVISE_NAMES {                                              \
1381         [LU_LADVISE_WILLREAD]   = "willread",                           \
1382         [LU_LADVISE_DONTNEED]   = "dontneed",                           \
1383 }
1384
1385 /* This is the userspace argument for ladvise.  It is currently the same as
1386  * what goes on the wire (struct lu_ladvise), but is defined separately as we
1387  * may need info which is only used locally. */
1388 struct llapi_lu_ladvise {
1389         __u16 lla_advice;       /* advice type */
1390         __u16 lla_value1;       /* values for different advice types */
1391         __u32 lla_value2;
1392         __u64 lla_start;        /* first byte of extent for advice */
1393         __u64 lla_end;          /* last byte of extent for advice */
1394         __u32 lla_value3;
1395         __u32 lla_value4;
1396 };
1397
1398 enum ladvise_flag {
1399         LF_ASYNC        = 0x00000001,
1400 };
1401
1402 #define LADVISE_MAGIC 0x1ADF1CE0
1403 #define LF_MASK LF_ASYNC
1404
1405 /* This is the userspace argument for ladvise, corresponds to ladvise_hdr which
1406  * is used on the wire.  It is defined separately as we may need info which is
1407  * only used locally. */
1408 struct llapi_ladvise_hdr {
1409         __u32                   lah_magic;      /* LADVISE_MAGIC */
1410         __u32                   lah_count;      /* number of advices */
1411         __u64                   lah_flags;      /* from enum ladvise_flag */
1412         __u32                   lah_value1;     /* unused */
1413         __u32                   lah_value2;     /* unused */
1414         __u64                   lah_value3;     /* unused */
1415         struct llapi_lu_ladvise lah_advise[0];  /* advices in this header */
1416 };
1417
1418 #define LAH_COUNT_MAX   (1024)
1419
1420 /* Shared key */
1421 enum sk_crypt_alg {
1422         SK_CRYPT_INVALID        = -1,
1423         SK_CRYPT_EMPTY          = 0,
1424         SK_CRYPT_AES256_CTR     = 1,
1425         SK_CRYPT_MAX            = 2,
1426 };
1427
1428 enum sk_hmac_alg {
1429         SK_HMAC_INVALID = -1,
1430         SK_HMAC_EMPTY   = 0,
1431         SK_HMAC_SHA256  = 1,
1432         SK_HMAC_SHA512  = 2,
1433         SK_HMAC_MAX     = 3,
1434 };
1435
1436 struct sk_crypt_type {
1437         char    *sct_name;
1438         size_t   sct_bytes;
1439 };
1440
1441 struct sk_hmac_type {
1442         char    *sht_name;
1443         size_t   sht_bytes;
1444 };
1445
1446 /** @} lustreuser */
1447 #endif /* _LUSTRE_USER_H */