Whamcloud - gitweb
LU-4217 build: bump build warnings to 2.7 development
[fs/lustre-release.git] / lustre / include / obd.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.sun.com/software/products/lustre/docs/GPLv2.pdf
19  *
20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
21  * CA 95054 USA or visit www.sun.com if you need additional information or
22  * have any questions.
23  *
24  * GPL HEADER END
25  */
26 /*
27  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
28  * Use is subject to license terms.
29  *
30  * Copyright (c) 2011, 2013, Intel Corporation.
31  */
32 /*
33  * This file is part of Lustre, http://www.lustre.org/
34  * Lustre is a trademark of Sun Microsystems, Inc.
35  */
36
37 #ifndef __OBD_H
38 #define __OBD_H
39
40 #if defined(__linux__)
41 #include <linux/obd.h>
42 #elif defined(__APPLE__)
43 #include <darwin/obd.h>
44 #elif defined(__WINNT__)
45 #include <winnt/obd.h>
46 #else
47 #error Unsupported operating system.
48 #endif
49
50 #define IOC_OSC_TYPE         'h'
51 #define IOC_OSC_MIN_NR       20
52 #define IOC_OSC_SET_ACTIVE   _IOWR(IOC_OSC_TYPE, 21, struct obd_device *)
53 #define IOC_OSC_MAX_NR       50
54
55 #define IOC_MDC_TYPE         'i'
56 #define IOC_MDC_MIN_NR       20
57 #define IOC_MDC_MAX_NR       50
58
59 #include <lustre/lustre_idl.h>
60 #include <lustre_lib.h>
61 #include <libcfs/bitmap.h>
62 #ifdef HAVE_SERVER_SUPPORT
63 # include <lu_target.h>
64 # include <obd_target.h>
65 #endif
66 #include <lu_ref.h>
67 #include <lustre_export.h>
68 #include <lustre_fid.h>
69 #include <lustre_fld.h>
70 #include <lustre_capa.h>
71
72 #define MAX_OBD_DEVICES 8192
73
74 struct osc_async_rc {
75         int     ar_rc;
76         int     ar_force_sync;
77         __u64   ar_min_xid;
78 };
79
80 struct lov_oinfo {                 /* per-stripe data structure */
81         struct ost_id   loi_oi;    /* object ID/Sequence on the target OST */
82         int loi_ost_idx;           /* OST stripe index in lov_tgt_desc->tgts */
83         int loi_ost_gen;           /* generation of this loi_ost_idx */
84
85         unsigned long loi_kms_valid:1;
86         __u64 loi_kms;             /* known minimum size */
87         struct ost_lvb loi_lvb;
88         struct osc_async_rc     loi_ar;
89 };
90
91 static inline void loi_kms_set(struct lov_oinfo *oinfo, __u64 kms)
92 {
93         oinfo->loi_kms = kms;
94         oinfo->loi_kms_valid = 1;
95 }
96
97 static inline void loi_init(struct lov_oinfo *loi)
98 {
99 }
100
101 struct lov_stripe_md {
102         cfs_atomic_t     lsm_refc;
103         spinlock_t      lsm_lock;
104         pid_t            lsm_lock_owner; /* debugging */
105
106         /* maximum possible file size, might change as OSTs status changes,
107          * e.g. disconnected, deactivated */
108         __u64            lsm_maxbytes;
109         struct {
110                 /* Public members. */
111                 struct ost_id lw_object_oi; /* lov object id/seq */
112
113                 /* LOV-private members start here -- only for use in lov/. */
114                 __u32 lw_magic;
115                 __u32 lw_stripe_size;      /* size of the stripe */
116                 __u32 lw_pattern;          /* striping pattern (RAID0, RAID1) */
117                 __u16 lw_stripe_count;  /* number of objects being striped over */
118                 __u16 lw_layout_gen;       /* generation of the layout */
119                 char  lw_pool_name[LOV_MAXPOOLNAME]; /* pool name */
120         } lsm_wire;
121
122         struct lov_oinfo *lsm_oinfo[0];
123 };
124
125 #define lsm_oi           lsm_wire.lw_object_oi
126 #define lsm_magic        lsm_wire.lw_magic
127 #define lsm_layout_gen   lsm_wire.lw_layout_gen
128 #define lsm_stripe_size  lsm_wire.lw_stripe_size
129 #define lsm_pattern      lsm_wire.lw_pattern
130 #define lsm_stripe_count lsm_wire.lw_stripe_count
131 #define lsm_pool_name    lsm_wire.lw_pool_name
132
133 static inline bool lsm_is_released(struct lov_stripe_md *lsm)
134 {
135         return !!(lsm->lsm_pattern & LOV_PATTERN_F_RELEASED);
136 }
137
138 static inline bool lsm_has_objects(struct lov_stripe_md *lsm)
139 {
140         if (lsm == NULL)
141                 return false;
142         if (lsm_is_released(lsm))
143                 return false;
144         return true;
145 }
146
147 struct obd_info;
148
149 typedef int (*obd_enqueue_update_f)(void *cookie, int rc);
150
151 /* obd info for a particular level (lov, osc). */
152 struct obd_info {
153         /* Lock policy. It keeps an extent which is specific for a particular
154          * OSC. (e.g. lov_prep_enqueue_set initialises extent of the policy,
155          * and osc_enqueue passes it into ldlm_lock_match & ldlm_cli_enqueue. */
156         ldlm_policy_data_t      oi_policy;
157         /* Flags used for set request specific flags:
158            - while lock handling, the flags obtained on the enqueue
159            request are set here.
160            - while stats, the flags used for control delay/resend.
161            - while setattr, the flags used for distinguish punch operation
162          */
163         __u64                   oi_flags;
164         /* Lock handle specific for every OSC lock. */
165         struct lustre_handle   *oi_lockh;
166         /* lsm data specific for every OSC. */
167         struct lov_stripe_md   *oi_md;
168         /* obdo data specific for every OSC, if needed at all. */
169         struct obdo            *oi_oa;
170         /* statfs data specific for every OSC, if needed at all. */
171         struct obd_statfs      *oi_osfs;
172         /* An update callback which is called to update some data on upper
173          * level. E.g. it is used for update lsm->lsm_oinfo at every recieved
174          * request in osc level for enqueue requests. It is also possible to
175          * update some caller data from LOV layer if needed. */
176         obd_enqueue_update_f    oi_cb_up;
177         /* oss capability, its type is obd_capa in client to avoid copy.
178          * in contrary its type is lustre_capa in OSS. */
179         void                   *oi_capa;
180         /* transfer jobid from ost_sync() to filter_sync()... */
181         char                   *oi_jobid;
182 };
183
184 /* compare all relevant fields. */
185 static inline int lov_stripe_md_cmp(struct lov_stripe_md *m1,
186                                     struct lov_stripe_md *m2)
187 {
188         /*
189          * ->lsm_wire contains padding, but it should be zeroed out during
190          * allocation.
191          */
192         return memcmp(&m1->lsm_wire, &m2->lsm_wire, sizeof m1->lsm_wire);
193 }
194
195 static inline int lov_lum_lsm_cmp(struct lov_user_md *lum,
196                                   struct lov_stripe_md  *lsm)
197 {
198         if (lsm->lsm_magic != lum->lmm_magic)
199                 return 1;
200         if ((lsm->lsm_stripe_count != 0) && (lum->lmm_stripe_count != 0) &&
201             (lsm->lsm_stripe_count != lum->lmm_stripe_count))
202                 return 2;
203         if ((lsm->lsm_stripe_size != 0) && (lum->lmm_stripe_size != 0) &&
204             (lsm->lsm_stripe_size != lum->lmm_stripe_size))
205                 return 3;
206         if ((lsm->lsm_pattern != 0) && (lum->lmm_pattern != 0) &&
207             (lsm->lsm_pattern != lum->lmm_pattern))
208                 return 4;
209         if ((lsm->lsm_magic == LOV_MAGIC_V3) &&
210             (strncmp(lsm->lsm_pool_name,
211                      ((struct lov_user_md_v3 *)lum)->lmm_pool_name,
212                      LOV_MAXPOOLNAME) != 0))
213                 return 5;
214         return 0;
215 }
216
217 static inline int lov_lum_swab_if_needed(struct lov_user_md_v3 *lumv3,
218                                          int *lmm_magic,
219                                          struct lov_user_md *lum)
220 {
221         if (lum && copy_from_user(lumv3, lum, sizeof(struct lov_user_md_v1)))
222                 return -EFAULT;
223
224         *lmm_magic = lumv3->lmm_magic;
225
226         if (*lmm_magic == __swab32(LOV_USER_MAGIC_V1)) {
227                 lustre_swab_lov_user_md_v1((struct lov_user_md_v1 *)lumv3);
228                 *lmm_magic = LOV_USER_MAGIC_V1;
229         } else if (*lmm_magic == LOV_USER_MAGIC_V3) {
230                 if (lum && copy_from_user(lumv3, lum, sizeof(*lumv3)))
231                         return -EFAULT;
232         } else if (*lmm_magic == __swab32(LOV_USER_MAGIC_V3)) {
233                 if (lum && copy_from_user(lumv3, lum, sizeof(*lumv3)))
234                         return -EFAULT;
235                 lustre_swab_lov_user_md_v3(lumv3);
236                 *lmm_magic = LOV_USER_MAGIC_V3;
237         } else if (*lmm_magic != LOV_USER_MAGIC_V1) {
238                 CDEBUG(D_IOCTL,
239                        "bad userland LOV MAGIC: %#08x != %#08x nor %#08x\n",
240                        *lmm_magic, LOV_USER_MAGIC_V1, LOV_USER_MAGIC_V3);
241                        return -EINVAL;
242         }
243         return 0;
244 }
245
246 void lov_stripe_lock(struct lov_stripe_md *md);
247 void lov_stripe_unlock(struct lov_stripe_md *md);
248
249 struct obd_type {
250         cfs_list_t typ_chain;
251         struct obd_ops *typ_dt_ops;
252         struct md_ops *typ_md_ops;
253         cfs_proc_dir_entry_t *typ_procroot;
254         char *typ_name;
255         int  typ_refcnt;
256         struct lu_device_type *typ_lu;
257         spinlock_t obd_type_lock;
258 };
259
260 struct brw_page {
261         obd_off  off;
262         struct page *pg;
263         int count;
264         obd_flag flag;
265 };
266
267 /* llog contexts */
268 enum llog_ctxt_id {
269         LLOG_CONFIG_ORIG_CTXT  =  0,
270         LLOG_CONFIG_REPL_CTXT,
271         LLOG_MDS_OST_ORIG_CTXT,
272         LLOG_MDS_OST_REPL_CTXT,
273         LLOG_SIZE_ORIG_CTXT,
274         LLOG_SIZE_REPL_CTXT,
275         LLOG_RD1_ORIG_CTXT,
276         LLOG_RD1_REPL_CTXT,
277         LLOG_TEST_ORIG_CTXT,
278         LLOG_TEST_REPL_CTXT,
279         LLOG_LOVEA_ORIG_CTXT,
280         LLOG_LOVEA_REPL_CTXT,
281         LLOG_CHANGELOG_ORIG_CTXT,       /**< changelog generation on mdd */
282         LLOG_CHANGELOG_REPL_CTXT,       /**< changelog access on clients */
283         LLOG_CHANGELOG_USER_ORIG_CTXT,  /**< for multiple changelog consumers */
284         LLOG_AGENT_ORIG_CTXT,           /**< agent requests generation on cdt */
285         LLOG_MAX_CTXTS
286 };
287
288 struct timeout_item {
289         enum timeout_event ti_event;
290         cfs_time_t         ti_timeout;
291         timeout_cb_t       ti_cb;
292         void              *ti_cb_data;
293         cfs_list_t         ti_obd_list;
294         cfs_list_t         ti_chain;
295 };
296
297 #define OSC_MAX_RIF_DEFAULT       8
298 #define MDS_OSC_MAX_RIF_DEFAULT   50
299 #define OSC_MAX_RIF_MAX         256
300 #define OSC_MAX_DIRTY_DEFAULT  (OSC_MAX_RIF_DEFAULT * 4)
301 #define OSC_MAX_DIRTY_MB_MAX   2048     /* arbitrary, but < MAX_LONG bytes */
302 #define OSC_DEFAULT_RESENDS      10
303
304 /* possible values for fo_sync_lock_cancel */
305 enum {
306         NEVER_SYNC_ON_CANCEL = 0,
307         BLOCKING_SYNC_ON_CANCEL = 1,
308         ALWAYS_SYNC_ON_CANCEL = 2,
309         NUM_SYNC_ON_CANCEL_STATES
310 };
311
312 #define MDC_MAX_RIF_DEFAULT       8
313 #define MDC_MAX_RIF_MAX         512
314
315 struct mdc_rpc_lock;
316 struct obd_import;
317 struct client_obd {
318         struct rw_semaphore  cl_sem;
319         struct obd_uuid          cl_target_uuid;
320         struct obd_import       *cl_import; /* ptlrpc connection state */
321         int                      cl_conn_count;
322         /* max_mds_easize is purely a performance thing so we don't have to
323          * call obd_size_diskmd() all the time. */
324         int                      cl_default_mds_easize;
325         int                      cl_max_mds_easize;
326         int                      cl_max_mds_cookiesize;
327
328         enum lustre_sec_part     cl_sp_me;
329         enum lustre_sec_part     cl_sp_to;
330         struct sptlrpc_flavor    cl_flvr_mgc;   /* fixed flavor of mgc->mgs */
331
332         /* the grant values are protected by loi_list_lock below */
333         long                     cl_dirty;         /* all _dirty_ in bytes */
334         long                     cl_dirty_max;     /* allowed w/o rpc */
335         long                     cl_dirty_transit; /* dirty synchronous */
336         long                     cl_avail_grant;   /* bytes of credit for ost */
337         long                     cl_lost_grant;    /* lost credits (trunc) */
338
339         /* since we allocate grant by blocks, we don't know how many grant will
340          * be used to add a page into cache. As a solution, we reserve maximum
341          * grant before trying to dirty a page and unreserve the rest.
342          * See osc_{reserve|unreserve}_grant for details. */
343         long                 cl_reserved_grant;
344         cfs_list_t           cl_cache_waiters; /* waiting for cache/grant */
345         cfs_time_t           cl_next_shrink_grant;   /* jiffies */
346         cfs_list_t           cl_grant_shrink_list;  /* Timeout event list */
347         int                  cl_grant_shrink_interval; /* seconds */
348
349         /* A chunk is an optimal size used by osc_extent to determine
350          * the extent size. A chunk is max(PAGE_CACHE_SIZE, OST block size) */
351         int                  cl_chunkbits;
352         int                  cl_chunk;
353         int                  cl_extent_tax; /* extent overhead, by bytes */
354
355         /* keep track of objects that have lois that contain pages which
356          * have been queued for async brw.  this lock also protects the
357          * lists of osc_client_pages that hang off of the loi */
358         /*
359          * ->cl_loi_list_lock protects consistency of
360          * ->cl_loi_{ready,read,write}_list. ->ap_make_ready() and
361          * ->ap_completion() call-backs are executed under this lock. As we
362          * cannot guarantee that these call-backs never block on all platforms
363          * (as a matter of fact they do block on Mac OS X), type of
364          * ->cl_loi_list_lock is platform dependent: it's a spin-lock on Linux
365          * and blocking mutex on Mac OS X. (Alternative is to make this lock
366          * blocking everywhere, but we don't want to slow down fast-path of
367          * our main platform.)
368          *
369          * Exact type of ->cl_loi_list_lock is defined in arch/obd.h together
370          * with client_obd_list_{un,}lock() and
371          * client_obd_list_lock_{init,done}() functions.
372          *
373          * NB by Jinshan: though field names are still _loi_, but actually
374          * osc_object{}s are in the list.
375          */
376         client_obd_lock_t        cl_loi_list_lock;
377         cfs_list_t               cl_loi_ready_list;
378         cfs_list_t               cl_loi_hp_ready_list;
379         cfs_list_t               cl_loi_write_list;
380         cfs_list_t               cl_loi_read_list;
381         int                      cl_r_in_flight;
382         int                      cl_w_in_flight;
383         /* just a sum of the loi/lop pending numbers to be exported by /proc */
384         cfs_atomic_t             cl_pending_w_pages;
385         cfs_atomic_t             cl_pending_r_pages;
386         __u32                    cl_max_pages_per_rpc;
387         int                      cl_max_rpcs_in_flight;
388         struct obd_histogram     cl_read_rpc_hist;
389         struct obd_histogram     cl_write_rpc_hist;
390         struct obd_histogram     cl_read_page_hist;
391         struct obd_histogram     cl_write_page_hist;
392         struct obd_histogram     cl_read_offset_hist;
393         struct obd_histogram     cl_write_offset_hist;
394
395         /* lru for osc caching pages */
396         struct cl_client_cache  *cl_cache;
397         cfs_list_t               cl_lru_osc; /* member of cl_cache->ccc_lru */
398         cfs_atomic_t            *cl_lru_left;
399         cfs_atomic_t             cl_lru_busy;
400         cfs_atomic_t             cl_lru_shrinkers;
401         cfs_atomic_t             cl_lru_in_list;
402         cfs_list_t               cl_lru_list; /* lru page list */
403         client_obd_lock_t        cl_lru_list_lock; /* page list protector */
404         cfs_atomic_t             cl_unstable_count;
405
406         /* number of in flight destroy rpcs is limited to max_rpcs_in_flight */
407         cfs_atomic_t             cl_destroy_in_flight;
408         wait_queue_head_t        cl_destroy_waitq;
409
410         struct mdc_rpc_lock     *cl_rpc_lock;
411         struct mdc_rpc_lock     *cl_close_lock;
412
413         /* mgc datastruct */
414         struct semaphore         cl_mgc_sem;
415         struct local_oid_storage *cl_mgc_los;
416         struct dt_object        *cl_mgc_configs_dir;
417         cfs_atomic_t             cl_mgc_refcount;
418         struct obd_export       *cl_mgc_mgsexp;
419
420         /* checksumming for data sent over the network */
421         unsigned int             cl_checksum:1; /* 0 = disabled, 1 = enabled */
422         /* supported checksum types that are worked out at connect time */
423         __u32                    cl_supp_cksum_types;
424         /* checksum algorithm to be used */
425         cksum_type_t             cl_cksum_type;
426
427         /* also protected by the poorly named _loi_list_lock lock above */
428         struct osc_async_rc      cl_ar;
429
430         /* used by quotacheck when the servers are older than 2.4 */
431         int                      cl_qchk_stat; /* quotacheck stat of the peer */
432 #define CL_NOT_QUOTACHECKED 1   /* client->cl_qchk_stat init value */
433 #if LUSTRE_VERSION_CODE >= OBD_OCD_VERSION(2, 7, 50, 0)
434 #warning "please consider removing quotacheck compatibility code"
435 #endif
436
437         /* sequence manager */
438         struct lu_client_seq    *cl_seq;
439
440         cfs_atomic_t             cl_resends; /* resend count */
441
442         /* ptlrpc work for writeback in ptlrpcd context */
443         void                    *cl_writeback_work;
444         void                    *cl_lru_work;
445         /* hash tables for osc_quota_info */
446         cfs_hash_t              *cl_quota_hash[MAXQUOTAS];
447 };
448 #define obd2cli_tgt(obd) ((char *)(obd)->u.cli.cl_target_uuid.uuid)
449
450 struct obd_id_info {
451         __u32   idx;
452         obd_id  *data;
453 };
454
455 struct echo_client_obd {
456         struct obd_export       *ec_exp;   /* the local connection to osc/lov */
457         spinlock_t              ec_lock;
458         cfs_list_t           ec_objects;
459         cfs_list_t           ec_locks;
460         int                  ec_nstripes;
461         __u64                ec_unique;
462 };
463
464 struct lov_qos_oss {
465         struct obd_uuid     lqo_uuid;       /* ptlrpc's c_remote_uuid */
466         cfs_list_t          lqo_oss_list;   /* link to lov_qos */
467         __u64               lqo_bavail;     /* total bytes avail on OSS */
468         __u64               lqo_penalty;    /* current penalty */
469         __u64               lqo_penalty_per_obj;/* penalty decrease every obj*/
470         time_t              lqo_used;       /* last used time, seconds */
471         __u32               lqo_ost_count;  /* number of osts on this oss */
472 };
473
474 struct ltd_qos {
475         struct lov_qos_oss *ltq_oss;         /* oss info */
476         __u64               ltq_penalty;     /* current penalty */
477         __u64               ltq_penalty_per_obj; /* penalty decrease every obj*/
478         __u64               ltq_weight;      /* net weighting */
479         time_t              ltq_used;        /* last used time, seconds */
480         unsigned int        ltq_usable:1;    /* usable for striping */
481 };
482
483 /* Generic subset of OSTs */
484 struct ost_pool {
485         __u32              *op_array;      /* array of index of
486                                                    lov_obd->lov_tgts */
487         unsigned int        op_count;      /* number of OSTs in the array */
488         unsigned int        op_size;       /* allocated size of lp_array */
489         struct rw_semaphore op_rw_sem;     /* to protect ost_pool use */
490 };
491
492 /* Round-robin allocator data */
493 struct lov_qos_rr {
494         __u32               lqr_start_idx;   /* start index of new inode */
495         __u32               lqr_offset_idx;  /* aliasing for start_idx  */
496         int                 lqr_start_count; /* reseed counter */
497         struct ost_pool     lqr_pool;        /* round-robin optimized list */
498         unsigned long       lqr_dirty:1;     /* recalc round-robin list */
499 };
500
501 /* allow statfs data caching for 1 second */
502 #define OBD_STATFS_CACHE_SECONDS 1
503
504 struct lov_statfs_data {
505         struct obd_info   lsd_oi;
506         struct obd_statfs lsd_statfs;
507 };
508 /* Stripe placement optimization */
509 struct lov_qos {
510         cfs_list_t          lq_oss_list; /* list of OSSs that targets use */
511         struct rw_semaphore lq_rw_sem;
512         __u32               lq_active_oss_count;
513         unsigned int        lq_prio_free;   /* priority for free space */
514         unsigned int        lq_threshold_rr;/* priority for rr */
515         struct lov_qos_rr   lq_rr;          /* round robin qos data */
516         unsigned long       lq_dirty:1,     /* recalc qos data */
517                             lq_same_space:1,/* the ost's all have approx.
518                                                the same space avail */
519                             lq_reset:1,     /* zero current penalties */
520                             lq_statfs_in_progress:1; /* statfs op in
521                                                         progress */
522         /* qos statfs data */
523         struct lov_statfs_data *lq_statfs_data;
524         wait_queue_head_t   lq_statfs_waitq; /* waitqueue to notify statfs
525                                               * requests completion */
526 };
527
528 struct lov_tgt_desc {
529         cfs_list_t          ltd_kill;
530         struct obd_uuid     ltd_uuid;
531         struct obd_device  *ltd_obd;
532         struct obd_export  *ltd_exp;
533         struct ltd_qos      ltd_qos;     /* qos info per target */
534         __u32               ltd_gen;
535         __u32               ltd_index;   /* index in lov_obd->tgts */
536         unsigned long       ltd_active:1,/* is this target up for requests */
537                             ltd_activate:1,/* should  target be activated */
538                             ltd_reap:1;  /* should this target be deleted */
539 };
540
541 /* Pool metadata */
542 #define pool_tgt_size(_p)   _p->pool_obds.op_size
543 #define pool_tgt_count(_p)  _p->pool_obds.op_count
544 #define pool_tgt_array(_p)  _p->pool_obds.op_array
545 #define pool_tgt_rw_sem(_p) _p->pool_obds.op_rw_sem
546
547 struct pool_desc {
548         char                  pool_name[LOV_MAXPOOLNAME + 1]; /* name of pool */
549         struct ost_pool       pool_obds;              /* pool members */
550         cfs_atomic_t          pool_refcount;          /* pool ref. counter */
551         struct lov_qos_rr     pool_rr;                /* round robin qos */
552         cfs_hlist_node_t      pool_hash;              /* access by poolname */
553         cfs_list_t            pool_list;              /* serial access */
554         cfs_proc_dir_entry_t *pool_proc_entry;        /* file in /proc */
555         struct obd_device    *pool_lobd;              /* obd of the lov/lod to which
556                                                        * this pool belongs */
557 };
558
559 struct lov_obd {
560         struct lov_desc         desc;
561         struct lov_tgt_desc   **lov_tgts;              /* sparse array */
562         struct ost_pool         lov_packed;            /* all OSTs in a packed
563                                                           array */
564         struct mutex            lov_lock;
565         struct obd_connect_data lov_ocd;
566         cfs_atomic_t            lov_refcount;
567         __u32                   lov_tgt_count;         /* how many OBD's */
568         __u32                   lov_active_tgt_count;  /* how many active */
569         __u32                   lov_death_row;/* tgts scheduled to be deleted */
570         __u32                   lov_tgt_size;   /* size of tgts array */
571         int                     lov_connects;
572         int                     lov_pool_count;
573         cfs_hash_t             *lov_pools_hash_body; /* used for key access */
574         cfs_list_t              lov_pool_list; /* used for sequential access */
575         cfs_proc_dir_entry_t   *lov_pool_proc_entry;
576         enum lustre_sec_part    lov_sp_me;
577
578         /* Cached LRU and unstable data from upper layer */
579         void                   *lov_cache;
580
581         struct rw_semaphore     lov_notify_lock;
582 };
583
584 struct lmv_tgt_desc {
585         struct obd_uuid         ltd_uuid;
586         struct obd_export       *ltd_exp;
587         int                     ltd_idx;
588         struct mutex            ltd_fid_mutex;
589         unsigned long           ltd_active:1; /* target up for requests */
590 };
591
592 enum placement_policy {
593         PLACEMENT_CHAR_POLICY   = 0,
594         PLACEMENT_NID_POLICY    = 1,
595         PLACEMENT_INVAL_POLICY  = 2,
596         PLACEMENT_MAX_POLICY
597 };
598
599 typedef enum placement_policy placement_policy_t;
600
601 struct lmv_obd {
602         int                     refcount;
603         struct lu_client_fld    lmv_fld;
604         spinlock_t              lmv_lock;
605         placement_policy_t      lmv_placement;
606         struct lmv_desc         desc;
607         struct obd_uuid         cluuid;
608         struct obd_export       *exp;
609
610         struct mutex            init_mutex;
611         int                     connected;
612         int                     max_easize;
613         int                     max_def_easize;
614         int                     max_cookiesize;
615         int                     server_timeout;
616
617         int                     tgts_size; /* size of tgts array */
618         struct lmv_tgt_desc     **tgts;
619
620         struct obd_connect_data conn_data;
621 };
622
623 struct niobuf_local {
624         __u64           lnb_file_offset;
625         __u32           lnb_page_offset;
626         __u32           len;
627         __u32           flags;
628         struct page     *page;
629         struct dentry   *dentry;
630         int             lnb_grant_used;
631         int             rc;
632 };
633
634 #define LUSTRE_FLD_NAME         "fld"
635 #define LUSTRE_SEQ_NAME         "seq"
636
637 #define LUSTRE_MDD_NAME         "mdd"
638 #define LUSTRE_OSD_LDISKFS_NAME "osd-ldiskfs"
639 #define LUSTRE_OSD_ZFS_NAME     "osd-zfs"
640 #define LUSTRE_VVP_NAME         "vvp"
641 #define LUSTRE_LMV_NAME         "lmv"
642 #define LUSTRE_SLP_NAME         "slp"
643 #define LUSTRE_LOD_NAME         "lod"
644 #define LUSTRE_OSP_NAME         "osp"
645 #define LUSTRE_LWP_NAME         "lwp"
646
647 /* obd device type names */
648  /* FIXME all the references to LUSTRE_MDS_NAME should be swapped with LUSTRE_MDT_NAME */
649 #define LUSTRE_MDS_NAME         "mds"
650 #define LUSTRE_MDT_NAME         "mdt"
651 #define LUSTRE_MDC_NAME         "mdc"
652 #define LUSTRE_OSS_NAME         "ost"       /* FIXME change name to oss */
653 #define LUSTRE_OST_NAME         "obdfilter" /* FIXME change name to ost */
654 #define LUSTRE_OSC_NAME         "osc"
655 #define LUSTRE_LOV_NAME         "lov"
656 #define LUSTRE_MGS_NAME         "mgs"
657 #define LUSTRE_MGC_NAME         "mgc"
658
659 #define LUSTRE_ECHO_NAME        "obdecho"
660 #define LUSTRE_ECHO_CLIENT_NAME "echo_client"
661 #define LUSTRE_QMT_NAME         "qmt"
662
663 /* Constant obd names (post-rename) */
664 #define LUSTRE_MDS_OBDNAME "MDS"
665 #define LUSTRE_OSS_OBDNAME "OSS"
666 #define LUSTRE_MGS_OBDNAME "MGS"
667 #define LUSTRE_MGC_OBDNAME "MGC"
668
669 static inline int is_osp_on_mdt(char *name)
670 {
671         char   *ptr;
672
673         ptr = strrchr(name, '-');
674         if (ptr == NULL) {
675                 CERROR("%s is not a obdname\n", name);
676                 return 0;
677         }
678
679         /* 1.8 OSC/OSP name on MDT is fsname-OSTxxxx-osc */
680         if (strncmp(ptr + 1, "osc", 3) == 0)
681                 return 1;
682
683         if (strncmp(ptr + 1, "MDT", 3) != 0)
684                 return 0;
685
686         while (*(--ptr) != '-' && ptr != name);
687
688         if (ptr == name)
689                 return 0;
690
691         if (strncmp(ptr + 1, LUSTRE_OSP_NAME, strlen(LUSTRE_OSP_NAME)) != 0 &&
692             strncmp(ptr + 1, LUSTRE_OSC_NAME, strlen(LUSTRE_OSC_NAME)) != 0)
693                 return 0;
694
695         return 1;
696 }
697
698 /* Don't conflict with on-wire flags OBD_BRW_WRITE, etc */
699 #define N_LOCAL_TEMP_PAGE 0x10000000
700
701 struct obd_trans_info {
702         __u64                    oti_transno;
703         __u64                    oti_xid;
704         /* Only used on the server side for tracking acks. */
705         struct oti_req_ack_lock {
706                 struct lustre_handle lock;
707                 __u32                mode;
708         }                        oti_ack_locks[4];
709         void                    *oti_handle;
710         struct llog_cookie       oti_onecookie;
711         struct llog_cookie      *oti_logcookies;
712         int                      oti_numcookies;
713         /** synchronous write is needed */
714         unsigned long            oti_sync_write:1;
715
716         /* initial thread handling transaction */
717         struct ptlrpc_thread *   oti_thread;
718         __u32                    oti_conn_cnt;
719         /** VBR: versions */
720         __u64                    oti_pre_version;
721         /** JobID */
722         char                    *oti_jobid;
723
724         struct obd_uuid         *oti_ost_uuid;
725 };
726
727 static inline void oti_init(struct obd_trans_info *oti,
728                             struct ptlrpc_request *req)
729 {
730         if (oti == NULL)
731                 return;
732         memset(oti, 0, sizeof(*oti));
733
734         if (req == NULL)
735                 return;
736
737         oti->oti_xid = req->rq_xid;
738         /** VBR: take versions from request */
739         if (req->rq_reqmsg != NULL &&
740             lustre_msg_get_flags(req->rq_reqmsg) & MSG_REPLAY) {
741                 __u64 *pre_version = lustre_msg_get_versions(req->rq_reqmsg);
742                 oti->oti_pre_version = pre_version ? pre_version[0] : 0;
743                 oti->oti_transno = lustre_msg_get_transno(req->rq_reqmsg);
744         }
745
746         /** called from mds_create_objects */
747         if (req->rq_repmsg != NULL)
748                 oti->oti_transno = lustre_msg_get_transno(req->rq_repmsg);
749         oti->oti_thread = req->rq_svc_thread;
750         if (req->rq_reqmsg != NULL)
751                 oti->oti_conn_cnt = lustre_msg_get_conn_cnt(req->rq_reqmsg);
752 }
753
754 static inline void oti_alloc_cookies(struct obd_trans_info *oti,int num_cookies)
755 {
756         if (!oti)
757                 return;
758
759         if (num_cookies == 1)
760                 oti->oti_logcookies = &oti->oti_onecookie;
761         else
762                 OBD_ALLOC_LARGE(oti->oti_logcookies,
763                                 num_cookies * sizeof(oti->oti_onecookie));
764
765         oti->oti_numcookies = num_cookies;
766 }
767
768 static inline void oti_free_cookies(struct obd_trans_info *oti)
769 {
770         if (!oti || !oti->oti_logcookies)
771                 return;
772
773         if (oti->oti_logcookies == &oti->oti_onecookie)
774                 LASSERT(oti->oti_numcookies == 1);
775         else
776                 OBD_FREE_LARGE(oti->oti_logcookies,
777                                oti->oti_numcookies*sizeof(oti->oti_onecookie));
778         oti->oti_logcookies = NULL;
779         oti->oti_numcookies = 0;
780 }
781
782 /*
783  * Events signalled through obd_notify() upcall-chain.
784  */
785 enum obd_notify_event {
786         /* target added */
787         OBD_NOTIFY_CREATE,
788         /* Device connect start */
789         OBD_NOTIFY_CONNECT,
790         /* Device activated */
791         OBD_NOTIFY_ACTIVE,
792         /* Device deactivated */
793         OBD_NOTIFY_INACTIVE,
794         /* Device disconnected */
795         OBD_NOTIFY_DISCON,
796         /* Connect data for import were changed */
797         OBD_NOTIFY_OCD,
798         /* Sync request */
799         OBD_NOTIFY_SYNC_NONBLOCK,
800         OBD_NOTIFY_SYNC,
801         /* Configuration event */
802         OBD_NOTIFY_CONFIG,
803         /* Administratively deactivate/activate event */
804         OBD_NOTIFY_DEACTIVATE,
805         OBD_NOTIFY_ACTIVATE
806 };
807
808 /* bit-mask flags for config events */
809 enum config_flags {
810         CONFIG_LOG      = 0x1,  /* finished processing config log */
811         CONFIG_SYNC     = 0x2,  /* mdt synced 1 ost */
812         CONFIG_TARGET   = 0x4   /* one target is added */
813 };
814
815 /*
816  * Data structure used to pass obd_notify()-event to non-obd listeners (llite
817  * and liblustre being main examples).
818  */
819 struct obd_notify_upcall {
820         int (*onu_upcall)(struct obd_device *host, struct obd_device *watched,
821                           enum obd_notify_event ev, void *owner, void *data);
822         /* Opaque datum supplied by upper layer listener */
823         void *onu_owner;
824 };
825
826 struct target_recovery_data {
827         svc_handler_t           trd_recovery_handler;
828         pid_t                   trd_processing_task;
829         struct completion       trd_starting;
830         struct completion       trd_finishing;
831 };
832
833 struct obd_llog_group {
834         int                olg_seq;
835         struct llog_ctxt   *olg_ctxts[LLOG_MAX_CTXTS];
836         wait_queue_head_t  olg_waitq;
837         spinlock_t         olg_lock;
838         struct mutex       olg_cat_processing;
839 };
840
841 /* corresponds to one of the obd's */
842 #define OBD_DEVICE_MAGIC        0XAB5CD6EF
843 #define OBD_DEV_BY_DEVNAME      0xffffd0de
844
845 struct obd_device {
846         struct obd_type         *obd_type;
847         __u32                    obd_magic;
848
849         /* common and UUID name of this device */
850         char                     obd_name[MAX_OBD_NAME];
851         struct obd_uuid          obd_uuid;
852         int                      obd_minor;
853         struct lu_device        *obd_lu_dev;
854
855         /* bitfield modification is protected by obd_dev_lock */
856         unsigned long
857                 obd_attached:1,         /* finished attach */
858                 obd_set_up:1,           /* finished setup */
859                 obd_recovering:1,       /* there are recoverable clients */
860                 obd_abort_recovery:1,   /* recovery expired */
861                 obd_version_recov:1,    /* obd uses version checking */
862                 obd_replayable:1,       /* recovery is enabled;
863                                          * inform clients */
864                 obd_no_transno:1,       /* no committed-transno notification */
865                 obd_no_recov:1,         /* fail instead of retry messages */
866                 obd_stopping:1,         /* started cleanup */
867                 obd_starting:1,         /* started setup */
868                 obd_force:1,            /* cleanup with > 0 obd refcount */
869                 obd_fail:1,             /* cleanup with failover */
870                 obd_async_recov:1,      /* allow asynchronous orphan cleanup */
871                 obd_no_conn:1,          /* deny new connections */
872                 obd_inactive:1,         /* device active/inactive
873                                          * (for /proc/status only!!) */
874                 obd_no_ir:1,            /* no imperative recovery. */
875                 obd_process_conf:1,     /* device is processing mgs config */
876                 obd_uses_nid_stats:1;   /* maintain per-client OBD stats */
877
878         /* use separate field as it is set in interrupt to don't mess with
879          * protection of other bits using _bh lock */
880         unsigned long obd_recovery_expired:1;
881         /* uuid-export hash body */
882         cfs_hash_t             *obd_uuid_hash;
883         /* nid-export hash body */
884         cfs_hash_t             *obd_nid_hash;
885         /* nid stats body */
886         cfs_hash_t             *obd_nid_stats_hash;
887         cfs_list_t              obd_nid_stats;
888         cfs_atomic_t            obd_refcount;
889         cfs_list_t              obd_exports;
890         cfs_list_t              obd_unlinked_exports;
891         cfs_list_t              obd_delayed_exports;
892         int                     obd_num_exports;
893         spinlock_t              obd_nid_lock;
894         struct ldlm_namespace  *obd_namespace;
895         struct ptlrpc_client    obd_ldlm_client; /* XXX OST/MDS only */
896         /* a spinlock is OK for what we do now, may need a semaphore later */
897         spinlock_t              obd_dev_lock; /* protect OBD bitfield above */
898         struct mutex            obd_dev_mutex;
899         __u64                   obd_last_committed;
900         spinlock_t              obd_osfs_lock;
901         struct obd_statfs       obd_osfs;       /* locked by obd_osfs_lock */
902         __u64                   obd_osfs_age;
903         struct lvfs_run_ctxt    obd_lvfs_ctxt;
904         struct obd_llog_group   obd_olg;        /* default llog group */
905         struct obd_device       *obd_observer;
906         struct rw_semaphore     obd_observer_link_sem;
907         struct obd_notify_upcall obd_upcall;
908         struct obd_export       *obd_self_export;
909         /* list of exports in LRU order, for ping evictor, with obd_dev_lock */
910         cfs_list_t              obd_exports_timed;
911         time_t                  obd_eviction_timer; /* for ping evictor */
912
913         int                              obd_max_recoverable_clients;
914         cfs_atomic_t                     obd_connected_clients;
915         int                              obd_stale_clients;
916         int                              obd_delayed_clients;
917         /* this lock protects all recovery list_heads, timer and
918          * obd_next_recovery_transno value */
919         spinlock_t                       obd_recovery_task_lock;
920         __u64                            obd_next_recovery_transno;
921         int                              obd_replayed_requests;
922         int                              obd_requests_queued_for_recovery;
923         wait_queue_head_t                obd_next_transno_waitq;
924         /* protected by obd_recovery_task_lock */
925         struct timer_list                obd_recovery_timer;
926         time_t                           obd_recovery_start; /* seconds */
927         time_t                           obd_recovery_end; /* seconds, for lprocfs_status */
928         int                              obd_recovery_time_hard;
929         int                              obd_recovery_timeout;
930         int                              obd_recovery_ir_factor;
931
932         /* new recovery stuff from CMD2 */
933         struct target_recovery_data      obd_recovery_data;
934         int                              obd_replayed_locks;
935         cfs_atomic_t                     obd_req_replay_clients;
936         cfs_atomic_t                     obd_lock_replay_clients;
937         /* all lists are protected by obd_recovery_task_lock */
938         cfs_list_t                       obd_req_replay_queue;
939         cfs_list_t                       obd_lock_replay_queue;
940         cfs_list_t                       obd_final_req_queue;
941
942         union {
943 #ifdef HAVE_SERVER_SUPPORT
944                 struct obd_device_target obt;
945                 struct filter_obd filter;
946                 struct ost_obd ost;
947                 struct echo_obd echo;
948 #endif
949                 struct client_obd cli;
950                 struct echo_client_obd echo_client;
951                 struct lov_obd lov;
952                 struct lmv_obd lmv;
953         } u;
954         /* Fields used by LProcFS */
955         unsigned int           obd_cntr_base;
956         struct lprocfs_stats  *obd_stats;
957
958         unsigned int           obd_md_cntr_base;
959         struct lprocfs_stats  *obd_md_stats;
960
961         struct proc_dir_entry   *obd_proc_entry;
962         struct proc_dir_entry   *obd_proc_exports_entry;
963         void                    *obd_proc_private;      /* type private PDEs */
964         struct proc_dir_entry   *obd_svc_procroot;
965         struct lprocfs_stats    *obd_svc_stats;
966         struct lprocfs_seq_vars *obd_vars;
967         cfs_atomic_t           obd_evict_inprogress;
968         wait_queue_head_t      obd_evict_inprogress_waitq;
969         cfs_list_t             obd_evict_list; /* protected with pet_lock */
970
971         /**
972          * Ldlm pool part. Save last calculated SLV and Limit.
973          */
974         rwlock_t                obd_pool_lock;
975         int                    obd_pool_limit;
976         __u64                  obd_pool_slv;
977
978         /**
979          * A list of outstanding class_incref()'s against this obd. For
980          * debugging.
981          */
982         struct lu_ref          obd_reference;
983
984         int                    obd_conn_inprogress;
985 };
986
987 #define OBD_LLOG_FL_SENDNOW     0x0001
988 #define OBD_LLOG_FL_EXIT        0x0002
989
990 enum obd_cleanup_stage {
991 /* Special case hack for MDS LOVs */
992         OBD_CLEANUP_EARLY,
993 /* can be directly mapped to .ldto_device_fini() */
994         OBD_CLEANUP_EXPORTS,
995 };
996
997 /* get/set_info keys */
998 #define KEY_ASYNC               "async"
999 #define KEY_BLOCKSIZE_BITS      "blocksize_bits"
1000 #define KEY_BLOCKSIZE           "blocksize"
1001 #define KEY_CAPA_KEY            "capa_key"
1002 #define KEY_CHANGELOG_CLEAR     "changelog_clear"
1003 #define KEY_FID2PATH            "fid2path"
1004 #define KEY_CHECKSUM            "checksum"
1005 #define KEY_CLEAR_FS            "clear_fs"
1006 #define KEY_CONN_DATA           "conn_data"
1007 #define KEY_EVICT_BY_NID        "evict_by_nid"
1008 #define KEY_FIEMAP              "fiemap"
1009 #define KEY_FLUSH_CTX           "flush_ctx"
1010 #define KEY_GRANT_SHRINK        "grant_shrink"
1011 #define KEY_HSM_COPYTOOL_SEND   "hsm_send"
1012 #define KEY_INIT_RECOV_BACKUP   "init_recov_bk"
1013 #define KEY_INIT_RECOV          "initial_recov"
1014 #define KEY_INTERMDS            "inter_mds"
1015 #define KEY_LAST_ID             "last_id"
1016 #define KEY_LAST_FID            "last_fid"
1017 #define KEY_LOCK_TO_STRIPE      "lock_to_stripe"
1018 #define KEY_LOVDESC             "lovdesc"
1019 #define KEY_LOV_IDX             "lov_idx"
1020 #define KEY_MAX_EASIZE          "max_easize"
1021 #define KEY_MDS_CONN            "mds_conn"
1022 #define KEY_MGSSEC              "mgssec"
1023 #define KEY_NEXT_ID             "next_id"
1024 #define KEY_READ_ONLY           "read-only"
1025 #define KEY_REGISTER_TARGET     "register_target"
1026 #define KEY_SET_FS              "set_fs"
1027 #define KEY_TGT_COUNT           "tgt_count"
1028 /*      KEY_SET_INFO in lustre_idl.h */
1029 #define KEY_SPTLRPC_CONF        "sptlrpc_conf"
1030 #define KEY_CONNECT_FLAG        "connect_flags"
1031 #define KEY_SYNC_LOCK_CANCEL    "sync_lock_cancel"
1032
1033 #define KEY_CACHE_SET           "cache_set"
1034 #define KEY_CACHE_LRU_SHRINK    "cache_lru_shrink"
1035 #define KEY_CHANGELOG_INDEX     "changelog_index"
1036 #define KEY_OSP_CONNECTED       "osp_connected"
1037
1038 struct lu_context;
1039
1040 /* /!\ must be coherent with include/linux/namei.h on patched kernel */
1041 #define IT_OPEN     (1 << 0)
1042 #define IT_CREAT    (1 << 1)
1043 #define IT_READDIR  (1 << 2)
1044 #define IT_GETATTR  (1 << 3)
1045 #define IT_LOOKUP   (1 << 4)
1046 #define IT_UNLINK   (1 << 5)
1047 #define IT_TRUNC    (1 << 6)
1048 #define IT_GETXATTR (1 << 7)
1049 #define IT_EXEC     (1 << 8)
1050 #define IT_PIN      (1 << 9)
1051 #define IT_LAYOUT   (1 << 10)
1052 #define IT_QUOTA_DQACQ (1 << 11)
1053 #define IT_QUOTA_CONN  (1 << 12)
1054 #define IT_SETXATTR (1 << 13)
1055
1056 static inline int it_to_lock_mode(struct lookup_intent *it)
1057 {
1058         /* CREAT needs to be tested before open (both could be set) */
1059         if (it->it_op & IT_CREAT)
1060                 return LCK_CW;
1061         else if (it->it_op & (IT_READDIR | IT_GETATTR | IT_OPEN | IT_LOOKUP |
1062                               IT_LAYOUT))
1063                 return LCK_CR;
1064         else if (it->it_op &  IT_GETXATTR)
1065                 return LCK_PR;
1066         else if (it->it_op &  IT_SETXATTR)
1067                 return LCK_PW;
1068
1069         LASSERTF(0, "Invalid it_op: %d\n", it->it_op);
1070         return -EINVAL;
1071 }
1072
1073 struct md_op_data {
1074         struct lu_fid           op_fid1; /* operation fid1 (usualy parent) */
1075         struct lu_fid           op_fid2; /* operation fid2 (usualy child) */
1076         struct lu_fid           op_fid3; /* 2 extra fids to find conflicting */
1077         struct lu_fid           op_fid4; /* to the operation locks. */
1078         mdsno_t                 op_mds;  /* what mds server open will go to */
1079         struct lustre_handle    op_handle;
1080         obd_time                op_mod_time;
1081         const char             *op_name;
1082         int                     op_namelen;
1083         __u32                   op_mode;
1084         struct lmv_stripe_md   *op_mea1;
1085         struct lmv_stripe_md   *op_mea2;
1086         __u32                   op_suppgids[2];
1087         __u32                   op_fsuid;
1088         __u32                   op_fsgid;
1089         cfs_cap_t               op_cap;
1090         void                   *op_data;
1091
1092         /* iattr fields and blocks. */
1093         struct iattr            op_attr;
1094 #ifdef __KERNEL__
1095         unsigned int            op_attr_flags;
1096 #endif
1097         __u64                   op_valid;
1098         loff_t                  op_attr_blocks;
1099
1100         /* Size-on-MDS epoch and flags. */
1101         __u64                   op_ioepoch;
1102         __u32                   op_flags;
1103
1104         /* Capa fields */
1105         struct obd_capa        *op_capa1;
1106         struct obd_capa        *op_capa2;
1107
1108         /* Various operation flags. */
1109         enum mds_op_bias        op_bias;
1110
1111         /* Operation type */
1112         __u32                   op_opc;
1113
1114         /* Used by readdir */
1115         __u64                   op_offset;
1116
1117         /* Used by readdir */
1118         __u32                   op_npages;
1119
1120         /* used to transfer info between the stacks of MD client
1121          * see enum op_cli_flags */
1122         __u32                   op_cli_flags;
1123
1124         /* File object data version for HSM release, on client */
1125         __u64                   op_data_version;
1126         struct lustre_handle    op_lease_handle;
1127 };
1128
1129 enum op_cli_flags {
1130         CLI_SET_MEA     = 1 << 0,
1131         CLI_RM_ENTRY    = 1 << 1,
1132 };
1133
1134 struct md_enqueue_info;
1135 /* metadata stat-ahead */
1136 typedef int (* md_enqueue_cb_t)(struct ptlrpc_request *req,
1137                                 struct md_enqueue_info *minfo,
1138                                 int rc);
1139
1140 struct md_enqueue_info {
1141         struct md_op_data       mi_data;
1142         struct lookup_intent    mi_it;
1143         struct lustre_handle    mi_lockh;
1144         struct inode           *mi_dir;
1145         md_enqueue_cb_t         mi_cb;
1146         __u64                   mi_cbdata;
1147         unsigned int            mi_generation;
1148 };
1149
1150 struct obd_ops {
1151         struct module *o_owner;
1152         int (*o_iocontrol)(unsigned int cmd, struct obd_export *exp, int len,
1153                            void *karg, void *uarg);
1154         int (*o_get_info)(const struct lu_env *env, struct obd_export *,
1155                           __u32 keylen, void *key, __u32 *vallen, void *val,
1156                           struct lov_stripe_md *lsm);
1157         int (*o_set_info_async)(const struct lu_env *, struct obd_export *,
1158                                 __u32 keylen, void *key,
1159                                 __u32 vallen, void *val,
1160                                 struct ptlrpc_request_set *set);
1161         int (*o_attach)(struct obd_device *dev, obd_count len, void *data);
1162         int (*o_detach)(struct obd_device *dev);
1163         int (*o_setup) (struct obd_device *dev, struct lustre_cfg *cfg);
1164         int (*o_precleanup)(struct obd_device *dev,
1165                             enum obd_cleanup_stage cleanup_stage);
1166         int (*o_cleanup)(struct obd_device *dev);
1167         int (*o_process_config)(struct obd_device *dev, obd_count len,
1168                                 void *data);
1169         int (*o_postrecov)(struct obd_device *dev);
1170         int (*o_add_conn)(struct obd_import *imp, struct obd_uuid *uuid,
1171                           int priority);
1172         int (*o_del_conn)(struct obd_import *imp, struct obd_uuid *uuid);
1173         /* connect to the target device with given connection
1174          * data. @ocd->ocd_connect_flags is modified to reflect flags actually
1175          * granted by the target, which are guaranteed to be a subset of flags
1176          * asked for. If @ocd == NULL, use default parameters. */
1177         int (*o_connect)(const struct lu_env *env,
1178                          struct obd_export **exp, struct obd_device *src,
1179                          struct obd_uuid *cluuid, struct obd_connect_data *ocd,
1180                          void *localdata);
1181         int (*o_reconnect)(const struct lu_env *env,
1182                            struct obd_export *exp, struct obd_device *src,
1183                            struct obd_uuid *cluuid,
1184                            struct obd_connect_data *ocd,
1185                            void *localdata);
1186         int (*o_disconnect)(struct obd_export *exp);
1187
1188         /* Initialize/finalize fids infrastructure. */
1189         int (*o_fid_init)(struct obd_device *obd,
1190                           struct obd_export *exp, enum lu_cli_type type);
1191         int (*o_fid_fini)(struct obd_device *obd);
1192
1193         /* Allocate new fid according to passed @hint. */
1194         int (*o_fid_alloc)(struct obd_export *exp, struct lu_fid *fid,
1195                            struct md_op_data *op_data);
1196
1197         /*
1198          * Object with @fid is getting deleted, we may want to do something
1199          * about this.
1200          */
1201         int (*o_statfs)(const struct lu_env *, struct obd_export *exp,
1202                         struct obd_statfs *osfs, __u64 max_age, __u32 flags);
1203         int (*o_statfs_async)(struct obd_export *exp, struct obd_info *oinfo,
1204                               __u64 max_age, struct ptlrpc_request_set *set);
1205         int (*o_packmd)(struct obd_export *exp, struct lov_mds_md **disk_tgt,
1206                         struct lov_stripe_md *mem_src);
1207         int (*o_unpackmd)(struct obd_export *exp,struct lov_stripe_md **mem_tgt,
1208                           struct lov_mds_md *disk_src, int disk_len);
1209         int (*o_preallocate)(struct lustre_handle *, obd_count *req,
1210                              obd_id *ids);
1211         /* FIXME: add fid capability support for create & destroy! */
1212         int (*o_precreate)(struct obd_export *exp);
1213         int (*o_create)(const struct lu_env *env, struct obd_export *exp,
1214                         struct obdo *oa, struct lov_stripe_md **ea,
1215                         struct obd_trans_info *oti);
1216         int (*o_create_async)(struct obd_export *exp,  struct obd_info *oinfo,
1217                               struct lov_stripe_md **ea,
1218                               struct obd_trans_info *oti);
1219         int (*o_destroy)(const struct lu_env *env, struct obd_export *exp,
1220                          struct obdo *oa, struct lov_stripe_md *ea,
1221                          struct obd_trans_info *oti, struct obd_export *md_exp,
1222                          void *capa);
1223         int (*o_setattr)(const struct lu_env *, struct obd_export *exp,
1224                          struct obd_info *oinfo, struct obd_trans_info *oti);
1225         int (*o_setattr_async)(struct obd_export *exp, struct obd_info *oinfo,
1226                                struct obd_trans_info *oti,
1227                                struct ptlrpc_request_set *rqset);
1228         int (*o_getattr)(const struct lu_env *env, struct obd_export *exp,
1229                          struct obd_info *oinfo);
1230         int (*o_getattr_async)(struct obd_export *exp, struct obd_info *oinfo,
1231                                struct ptlrpc_request_set *set);
1232         int (*o_brw)(int rw, struct obd_export *exp, struct obd_info *oinfo,
1233                      obd_count oa_bufs, struct brw_page *pgarr,
1234                      struct obd_trans_info *oti);
1235         int (*o_merge_lvb)(struct obd_export *exp, struct lov_stripe_md *lsm,
1236                            struct ost_lvb *lvb, int kms_only);
1237         int (*o_adjust_kms)(struct obd_export *exp, struct lov_stripe_md *lsm,
1238                             obd_off size, int shrink);
1239         int (*o_punch)(const struct lu_env *, struct obd_export *exp,
1240                        struct obd_info *oinfo, struct obd_trans_info *oti,
1241                        struct ptlrpc_request_set *rqset);
1242         int (*o_sync)(const struct lu_env *env, struct obd_export *exp,
1243                       struct obd_info *oinfo, obd_size start, obd_size end,
1244                       struct ptlrpc_request_set *set);
1245         int (*o_migrate)(struct lustre_handle *conn, struct lov_stripe_md *dst,
1246                          struct lov_stripe_md *src, obd_size start,
1247                          obd_size end, struct obd_trans_info *oti);
1248         int (*o_copy)(struct lustre_handle *dstconn, struct lov_stripe_md *dst,
1249                       struct lustre_handle *srconn, struct lov_stripe_md *src,
1250                       obd_size start, obd_size end, struct obd_trans_info *);
1251         int (*o_iterate)(struct lustre_handle *conn,
1252                          int (*)(obd_id, obd_seq, void *),
1253                          obd_id *startid, obd_seq seq, void *data);
1254         int (*o_preprw)(const struct lu_env *env, int cmd,
1255                         struct obd_export *exp, struct obdo *oa, int objcount,
1256                         struct obd_ioobj *obj, struct niobuf_remote *remote,
1257                         int *nr_pages, struct niobuf_local *local,
1258                         struct obd_trans_info *oti, struct lustre_capa *capa);
1259         int (*o_commitrw)(const struct lu_env *env, int cmd,
1260                           struct obd_export *exp, struct obdo *oa,
1261                           int objcount, struct obd_ioobj *obj,
1262                           struct niobuf_remote *remote, int pages,
1263                           struct niobuf_local *local,
1264                           struct obd_trans_info *oti, int rc);
1265         int (*o_enqueue)(struct obd_export *, struct obd_info *oinfo,
1266                          struct ldlm_enqueue_info *einfo,
1267                          struct ptlrpc_request_set *rqset);
1268         int (*o_change_cbdata)(struct obd_export *, struct lov_stripe_md *,
1269                                ldlm_iterator_t it, void *data);
1270         int (*o_find_cbdata)(struct obd_export *, struct lov_stripe_md *,
1271                              ldlm_iterator_t it, void *data);
1272         int (*o_cancel)(struct obd_export *, struct lov_stripe_md *md,
1273                         __u32 mode, struct lustre_handle *);
1274         int (*o_cancel_unused)(struct obd_export *, struct lov_stripe_md *,
1275                                ldlm_cancel_flags_t flags, void *opaque);
1276         int (*o_init_export)(struct obd_export *exp);
1277         int (*o_destroy_export)(struct obd_export *exp);
1278         int (*o_extent_calc)(struct obd_export *, struct lov_stripe_md *,
1279                              int cmd, obd_off *);
1280
1281         /* llog related obd_methods */
1282         int (*o_llog_init)(struct obd_device *obd, struct obd_llog_group *grp,
1283                            struct obd_device *disk_obd, int *idx);
1284         int (*o_llog_finish)(struct obd_device *obd, int count);
1285         int (*o_llog_connect)(struct obd_export *, struct llogd_conn_body *);
1286
1287         /* metadata-only methods */
1288         int (*o_pin)(struct obd_export *, const struct lu_fid *fid,
1289                      struct obd_capa *, struct obd_client_handle *, int flag);
1290         int (*o_unpin)(struct obd_export *, struct obd_client_handle *, int);
1291
1292         int (*o_import_event)(struct obd_device *, struct obd_import *,
1293                               enum obd_import_event);
1294
1295         int (*o_notify)(struct obd_device *obd, struct obd_device *watched,
1296                         enum obd_notify_event ev, void *data);
1297
1298         int (*o_health_check)(const struct lu_env *env, struct obd_device *);
1299         struct obd_uuid *(*o_get_uuid) (struct obd_export *exp);
1300
1301         /* quota methods */
1302         int (*o_quotacheck)(struct obd_device *, struct obd_export *,
1303                             struct obd_quotactl *);
1304         int (*o_quotactl)(struct obd_device *, struct obd_export *,
1305                           struct obd_quotactl *);
1306
1307         int (*o_ping)(const struct lu_env *, struct obd_export *exp);
1308
1309         /* pools methods */
1310         int (*o_pool_new)(struct obd_device *obd, char *poolname);
1311         int (*o_pool_del)(struct obd_device *obd, char *poolname);
1312         int (*o_pool_add)(struct obd_device *obd, char *poolname,
1313                           char *ostname);
1314         int (*o_pool_rem)(struct obd_device *obd, char *poolname,
1315                           char *ostname);
1316         void (*o_getref)(struct obd_device *obd);
1317         void (*o_putref)(struct obd_device *obd);
1318         /*
1319          * NOTE: If adding ops, add another LPROCFS_OBD_OP_INIT() line
1320          * to lprocfs_alloc_obd_stats() in obdclass/lprocfs_status.c.
1321          * Also, add a wrapper function in include/linux/obd_class.h. */
1322 };
1323
1324 enum {
1325         LUSTRE_OPC_MKDIR    = (1 << 0),
1326         LUSTRE_OPC_SYMLINK  = (1 << 1),
1327         LUSTRE_OPC_MKNOD    = (1 << 2),
1328         LUSTRE_OPC_CREATE   = (1 << 3),
1329         LUSTRE_OPC_ANY      = (1 << 4)
1330 };
1331
1332 /* lmv structures */
1333 #define MEA_MAGIC_LAST_CHAR      0xb2221ca1
1334 #define MEA_MAGIC_ALL_CHARS      0xb222a11c
1335 #define MEA_MAGIC_HASH_SEGMENT   0xb222a11b
1336
1337 #define MAX_HASH_SIZE_32         0x7fffffffUL
1338 #define MAX_HASH_SIZE            0x7fffffffffffffffULL
1339 #define MAX_HASH_HIGHEST_BIT     0x1000000000000000ULL
1340
1341 struct lustre_md {
1342         struct mdt_body         *body;
1343         struct lov_stripe_md    *lsm;
1344         struct lmv_stripe_md    *mea;
1345 #ifdef CONFIG_FS_POSIX_ACL
1346         struct posix_acl        *posix_acl;
1347 #endif
1348         struct mdt_remote_perm  *remote_perm;
1349         struct obd_capa         *mds_capa;
1350         struct obd_capa         *oss_capa;
1351 };
1352
1353 struct md_open_data {
1354         struct obd_client_handle        *mod_och;
1355         struct ptlrpc_request           *mod_open_req;
1356         struct ptlrpc_request           *mod_close_req;
1357         cfs_atomic_t                     mod_refcount;
1358         bool                             mod_is_create;
1359 };
1360
1361 struct lookup_intent;
1362
1363 struct md_ops {
1364         /* Every operation from MD_STATS_FIRST_OP up to and including
1365          * MD_STATS_LAST_OP will be counted by EXP_MD_OP_INCREMENT()
1366          * and will appear in /proc/fs/lustre/{lmv,mdc}/.../md_stats.
1367          * Operations after MD_STATS_LAST_OP are excluded from stats.
1368          * There are a few reasons for doing this: we prune the 17
1369          * counters which will be of minimal use in understanding
1370          * metadata utilization, we save memory by allocating 15
1371          * instead of 32 counters, we save cycles by not counting.
1372          *
1373          * MD_STATS_FIRST_OP must be the first member of md_ops.
1374          */
1375 #define MD_STATS_FIRST_OP m_close
1376         int (*m_close)(struct obd_export *, struct md_op_data *,
1377                        struct md_open_data *, struct ptlrpc_request **);
1378
1379         int (*m_create)(struct obd_export *, struct md_op_data *,
1380                         const void *, int, int, __u32, __u32, cfs_cap_t,
1381                         __u64, struct ptlrpc_request **);
1382
1383         int (*m_enqueue)(struct obd_export *, struct ldlm_enqueue_info *,
1384                          struct lookup_intent *, struct md_op_data *,
1385                          struct lustre_handle *, void *, int,
1386                          struct ptlrpc_request **, __u64);
1387
1388         int (*m_getattr)(struct obd_export *, struct md_op_data *,
1389                          struct ptlrpc_request **);
1390
1391         int (*m_intent_lock)(struct obd_export *, struct md_op_data *,
1392                              void *, int, struct lookup_intent *, int,
1393                              struct ptlrpc_request **,
1394                              ldlm_blocking_callback, __u64);
1395
1396         int (*m_link)(struct obd_export *, struct md_op_data *,
1397                       struct ptlrpc_request **);
1398
1399         int (*m_rename)(struct obd_export *, struct md_op_data *,
1400                         const char *, int, const char *, int,
1401                         struct ptlrpc_request **);
1402
1403         int (*m_setattr)(struct obd_export *, struct md_op_data *, void *,
1404                          int , void *, int, struct ptlrpc_request **,
1405                          struct md_open_data **mod);
1406
1407         int (*m_fsync)(struct obd_export *, const struct lu_fid *,
1408                        struct obd_capa *, struct ptlrpc_request **);
1409
1410         int (*m_readpage)(struct obd_export *, struct md_op_data *,
1411                           struct page **, struct ptlrpc_request **);
1412
1413         int (*m_unlink)(struct obd_export *, struct md_op_data *,
1414                         struct ptlrpc_request **);
1415
1416         int (*m_setxattr)(struct obd_export *, const struct lu_fid *,
1417                           struct obd_capa *, obd_valid, const char *,
1418                           const char *, int, int, int, __u32,
1419                           struct ptlrpc_request **);
1420
1421         int (*m_getxattr)(struct obd_export *, const struct lu_fid *,
1422                           struct obd_capa *, obd_valid, const char *,
1423                           const char *, int, int, int,
1424                           struct ptlrpc_request **);
1425
1426         int (*m_intent_getattr_async)(struct obd_export *,
1427                                       struct md_enqueue_info *,
1428                                       struct ldlm_enqueue_info *);
1429
1430         int (*m_revalidate_lock)(struct obd_export *, struct lookup_intent *,
1431                                  struct lu_fid *, __u64 *bits);
1432 #define MD_STATS_LAST_OP m_revalidate_lock
1433
1434         int (*m_getstatus)(struct obd_export *, struct lu_fid *,
1435                            struct obd_capa **);
1436
1437         int (*m_null_inode)(struct obd_export *, const struct lu_fid *);
1438
1439         int (*m_find_cbdata)(struct obd_export *, const struct lu_fid *,
1440                              ldlm_iterator_t, void *);
1441
1442         int (*m_done_writing)(struct obd_export *, struct md_op_data  *,
1443                               struct md_open_data *);
1444
1445         int (*m_getattr_name)(struct obd_export *, struct md_op_data *,
1446                               struct ptlrpc_request **);
1447
1448         int (*m_is_subdir)(struct obd_export *, const struct lu_fid *,
1449                            const struct lu_fid *,
1450                            struct ptlrpc_request **);
1451
1452         int (*m_init_ea_size)(struct obd_export *, int, int, int);
1453
1454         int (*m_get_lustre_md)(struct obd_export *, struct ptlrpc_request *,
1455                                struct obd_export *, struct obd_export *,
1456                                struct lustre_md *);
1457
1458         int (*m_free_lustre_md)(struct obd_export *, struct lustre_md *);
1459
1460         int (*m_set_open_replay_data)(struct obd_export *,
1461                                       struct obd_client_handle *,
1462                                       struct lookup_intent *);
1463
1464         int (*m_clear_open_replay_data)(struct obd_export *,
1465                                         struct obd_client_handle *);
1466
1467         int (*m_set_lock_data)(struct obd_export *, __u64 *, void *, __u64 *);
1468
1469         ldlm_mode_t (*m_lock_match)(struct obd_export *, __u64,
1470                                     const struct lu_fid *, ldlm_type_t,
1471                                     ldlm_policy_data_t *, ldlm_mode_t,
1472                                     struct lustre_handle *);
1473
1474         int (*m_cancel_unused)(struct obd_export *, const struct lu_fid *,
1475                                ldlm_policy_data_t *, ldlm_mode_t,
1476                                ldlm_cancel_flags_t flags, void *opaque);
1477
1478         int (*m_renew_capa)(struct obd_export *, struct obd_capa *oc,
1479                             renew_capa_cb_t cb);
1480
1481         int (*m_unpack_capa)(struct obd_export *, struct ptlrpc_request *,
1482                              const struct req_msg_field *, struct obd_capa **);
1483
1484         int (*m_get_remote_perm)(struct obd_export *, const struct lu_fid *,
1485                                  struct obd_capa *, __u32,
1486                                  struct ptlrpc_request **);
1487 };
1488
1489 struct lsm_operations {
1490         void (*lsm_free)(struct lov_stripe_md *);
1491         int (*lsm_destroy)(struct lov_stripe_md *, struct obdo *oa,
1492                            struct obd_export *md_exp);
1493         void (*lsm_stripe_by_index)(struct lov_stripe_md *, int *, obd_off *,
1494                                     obd_off *);
1495         void (*lsm_stripe_by_offset)(struct lov_stripe_md *, int *, obd_off *,
1496                                      obd_off *);
1497         int (*lsm_lmm_verify) (struct lov_mds_md *lmm, int lmm_bytes,
1498                                __u16 *stripe_count);
1499         int (*lsm_unpackmd) (struct lov_obd *lov, struct lov_stripe_md *lsm,
1500                              struct lov_mds_md *lmm);
1501 };
1502
1503 extern const struct lsm_operations lsm_v1_ops;
1504 extern const struct lsm_operations lsm_v3_ops;
1505 static inline const struct lsm_operations *lsm_op_find(int magic)
1506 {
1507         switch(magic) {
1508         case LOV_MAGIC_V1:
1509                return &lsm_v1_ops;
1510         case LOV_MAGIC_V3:
1511                return &lsm_v3_ops;
1512         default:
1513                CERROR("Cannot recognize lsm_magic %08x\n", magic);
1514                return NULL;
1515         }
1516 }
1517
1518 /* Requests for obd_extent_calc() */
1519 #define OBD_CALC_STRIPE_START   1
1520 #define OBD_CALC_STRIPE_END     2
1521
1522 static inline struct lustre_capa *oinfo_capa(struct obd_info *oinfo)
1523 {
1524         return oinfo->oi_capa;
1525 }
1526
1527 static inline struct md_open_data *obd_mod_alloc(void)
1528 {
1529         struct md_open_data *mod;
1530         OBD_ALLOC_PTR(mod);
1531         if (mod == NULL)
1532                 return NULL;
1533         cfs_atomic_set(&mod->mod_refcount, 1);
1534         return mod;
1535 }
1536
1537 #define obd_mod_get(mod) cfs_atomic_inc(&(mod)->mod_refcount)
1538 #define obd_mod_put(mod)                                          \
1539 ({                                                                \
1540         if (cfs_atomic_dec_and_test(&(mod)->mod_refcount)) {      \
1541                 if ((mod)->mod_open_req)                          \
1542                         ptlrpc_req_finished((mod)->mod_open_req); \
1543                 OBD_FREE_PTR(mod);                                \
1544         }                                                         \
1545 })
1546
1547 void obdo_from_inode(struct obdo *dst, struct inode *src, obd_flag valid);
1548 void obdo_set_parent_fid(struct obdo *dst, const struct lu_fid *parent);
1549
1550 /* return 1 if client should be resend request */
1551 static inline int client_should_resend(int resend, struct client_obd *cli)
1552 {
1553         return cfs_atomic_read(&cli->cl_resends) ?
1554                cfs_atomic_read(&cli->cl_resends) > resend : 1;
1555 }
1556
1557 /**
1558  * Return device name for this device
1559  *
1560  * XXX: lu_device is declared before obd_device, while a pointer pointing
1561  * back to obd_device in lu_device, so this helper function defines here
1562  * instead of in lu_object.h
1563  */
1564 static inline const char *lu_dev_name(const struct lu_device *lu_dev)
1565 {
1566         return lu_dev->ld_obd->obd_name;
1567 }
1568
1569 static inline bool filename_is_volatile(const char *name, int namelen, int *idx)
1570 {
1571         const char      *start;
1572         char            *end;
1573
1574         if (strncmp(name, LUSTRE_VOLATILE_HDR, LUSTRE_VOLATILE_HDR_LEN) != 0)
1575                 return false;
1576
1577         /* caller does not care of idx */
1578         if (idx == NULL)
1579                 return true;
1580
1581         /* volatile file, the MDT can be set from name */
1582         /* name format is LUSTRE_VOLATILE_HDR:[idx]: */
1583         /* if no MDT is specified, use std way */
1584         if (namelen < LUSTRE_VOLATILE_HDR_LEN + 2)
1585                 goto bad_format;
1586         /* test for no MDT idx case */
1587         if ((*(name + LUSTRE_VOLATILE_HDR_LEN) == ':') &&
1588             (*(name + LUSTRE_VOLATILE_HDR_LEN + 1) == ':')) {
1589                 *idx = -1;
1590                 return true;
1591         }
1592         /* we have an idx, read it */
1593         start = name + LUSTRE_VOLATILE_HDR_LEN + 1;
1594         *idx = strtoul(start, &end, 16);
1595         /* error cases:
1596          * no digit, no trailing :, negative value
1597          */
1598         if (((*idx == 0) && (end == start)) ||
1599             (*end != ':') || (*idx < 0))
1600                 goto bad_format;
1601
1602         return true;
1603 bad_format:
1604         /* bad format of mdt idx, we cannot return an error
1605          * to caller so we use hash algo */
1606         CERROR("Bad volatile file name format: %s\n",
1607                name + LUSTRE_VOLATILE_HDR_LEN);
1608         return false;
1609 }
1610
1611 static inline int cli_brw_size(struct obd_device *obd)
1612 {
1613         LASSERT(obd != NULL);
1614         return obd->u.cli.cl_max_pages_per_rpc << PAGE_CACHE_SHIFT;
1615 }
1616
1617 #endif /* __OBD_H */