Whamcloud - gitweb
97f6cb64e37dc851763d8048849de322dcd64190
[fs/lustre-release.git] / lustre / mdd / mdd_internal.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, 2012, 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  * lustre/mdd/mdd_internal.h
37  *
38  * Author: Wang Di <wangdi@clusterfs.com>
39  */
40
41 #ifndef _MDD_INTERNAL_H
42 #define _MDD_INTERNAL_H
43
44 #include <lustre_acl.h>
45 #include <lustre_eacl.h>
46 #include <md_object.h>
47 #include <dt_object.h>
48 #include <lustre_fsfilt.h>
49 #include <lustre/lustre_lfsck_user.h>
50 #include <lustre_fid.h>
51 #include <lustre_capa.h>
52 #include <lprocfs_status.h>
53 #include <lustre_log.h>
54
55 #include "mdd_lfsck.h"
56
57 /* PDO lock is unnecessary for current MDT stack because operations
58  * are already protected by ldlm lock */
59 #define MDD_DISABLE_PDO_LOCK    1
60
61 /* Changelog flags */
62 /** changelog is recording */
63 #define CLM_ON    0x00001
64 /** internal error prevented changelogs from starting */
65 #define CLM_ERR   0x00002
66 /* Marker flags */
67 /** changelogs turned on */
68 #define CLM_START 0x10000
69 /** changelogs turned off */
70 #define CLM_FINI  0x20000
71 /** some changelog records purged */
72 #define CLM_PURGE 0x40000
73
74 struct mdd_changelog {
75         spinlock_t              mc_lock;        /* for index */
76         int                     mc_flags;
77         int                     mc_mask;
78         __u64                   mc_index;
79         __u64                   mc_starttime;
80         spinlock_t              mc_user_lock;
81         int                     mc_lastuser;
82 };
83
84 static inline __u64 cl_time(void) {
85         cfs_fs_time_t time;
86
87         cfs_fs_time_current(&time);
88         return (((__u64)time.tv_sec) << 30) + time.tv_nsec;
89 }
90
91 /** Objects in .lustre dir */
92 struct mdd_dot_lustre_objs {
93         struct mdd_object *mdd_obf;
94 };
95
96 extern const char lfsck_bookmark_name[];
97 extern const char lfsck_namespace_name[];
98
99 struct mdd_device {
100         struct md_device                 mdd_md_dev;
101         struct obd_export               *mdd_child_exp;
102         struct dt_device                *mdd_child;
103         struct dt_device                *mdd_bottom;
104         struct lu_fid                    mdd_root_fid;
105         struct lu_fid                    mdd_local_root_fid;
106         struct dt_device_param           mdd_dt_conf;
107         struct dt_object                *mdd_orphans; /* PENDING directory */
108         struct dt_object                *mdd_capa;
109         cfs_proc_dir_entry_t            *mdd_proc_entry;
110         struct mdd_changelog             mdd_cl;
111         unsigned long                    mdd_atime_diff;
112         struct mdd_object               *mdd_dot_lustre;
113         struct mdd_dot_lustre_objs       mdd_dot_lustre_objs;
114         struct md_lfsck                  mdd_lfsck;
115         unsigned int                     mdd_sync_permission;
116         int                              mdd_connects;
117 };
118
119 enum mod_flags {
120         /* The dir object has been unlinked */
121         DEAD_OBJ   = 1 << 0,
122         APPEND_OBJ = 1 << 1,
123         IMMUTE_OBJ = 1 << 2,
124         ORPHAN_OBJ = 1 << 3,
125 };
126
127 struct mdd_object {
128         struct md_object   mod_obj;
129         /* open count */
130         __u32             mod_count;
131         __u32             mod_valid;
132         __u64             mod_cltime;
133         unsigned long     mod_flags;
134 #ifndef MDD_DISABLE_PDO_LOCK
135         struct dynlock    mod_pdlock;
136 #endif
137 #ifdef CONFIG_LOCKDEP
138         /* "dep_map" name is assumed by lockdep.h macros. */
139         struct lockdep_map dep_map;
140 #endif
141 };
142
143 struct mdd_thread_info {
144         struct lu_fid             mti_fid;
145         struct lu_fid             mti_fid2; /* used for be & cpu converting */
146         struct lu_attr            mti_la;
147         struct lu_attr            mti_la_for_fix;
148         struct lu_attr            mti_pattr;
149         struct lu_attr            mti_cattr;
150         struct md_attr            mti_ma;
151         struct obd_info           mti_oi;
152         /* mti_ent and mti_key must be conjoint,
153          * then mti_ent::lde_name will be mti_key. */
154         struct lu_dirent          mti_ent;
155         char                      mti_key[NAME_MAX + 16];
156         struct obd_trans_info     mti_oti;
157         struct lu_buf             mti_buf;
158         struct lu_buf             mti_big_buf; /* biggish persistent buf */
159         struct lu_name            mti_name;
160         struct lu_name            mti_name2;
161         struct obdo               mti_oa;
162         char                      mti_xattr_buf[LUSTRE_POSIX_ACL_MAX_SIZE];
163         struct dt_allocation_hint mti_hint;
164         struct lov_mds_md        *mti_max_lmm;
165         int                       mti_max_lmm_size;
166         struct llog_cookie       *mti_max_cookie;
167         int                       mti_max_cookie_size;
168         struct dt_object_format   mti_dof;
169         struct obd_quotactl       mti_oqctl;
170 };
171
172 /**
173  * The data that link search is done on.
174  */
175 struct mdd_link_data {
176         /**
177          * Buffer to keep link EA body.
178          */
179         struct lu_buf           *ml_buf;
180         /**
181          * The matched header, entry and its lenght in the EA
182          */
183         struct link_ea_header   *ml_leh;
184         struct link_ea_entry    *ml_lee;
185         int                      ml_reclen;
186 };
187
188 extern const char orph_index_name[];
189
190 extern const struct dt_index_features orph_index_features;
191
192 struct lov_mds_md *mdd_max_lmm_buffer(const struct lu_env *env, int size);
193 struct lov_mds_md *mdd_max_lmm_get(const struct lu_env *env,
194                                    struct mdd_device *mdd);
195
196 struct llog_cookie *mdd_max_cookie_get(const struct lu_env *env,
197                                        struct mdd_device *mdd);
198
199 int mdd_init_obd(const struct lu_env *env, struct mdd_device *mdd,
200                  struct lustre_cfg *cfg);
201 int mdd_fini_obd(const struct lu_env *env, struct mdd_device *mdd,
202                  struct lustre_cfg *lcfg);
203 int __mdd_xattr_set(const struct lu_env *env, struct mdd_object *obj,
204                     const struct lu_buf *buf, const char *name,
205                     int fl, struct thandle *handle);
206 int mdd_xattr_set_txn(const struct lu_env *env, struct mdd_object *obj,
207                       const struct lu_buf *buf, const char *name, int fl,
208                       struct thandle *txn);
209 int mdd_lsm_sanity_check(const struct lu_env *env, struct mdd_object *obj);
210 int mdd_lov_set_md(const struct lu_env *env, struct mdd_object *pobj,
211                    struct mdd_object *child, struct lov_mds_md *lmm,
212                    int lmm_size, struct thandle *handle, int set_stripe);
213 int mdd_lov_create(const struct lu_env *env, struct mdd_device *mdd,
214                    struct mdd_object *parent, struct mdd_object *child,
215                    struct lov_mds_md **lmm, int *lmm_size,
216                    const struct md_op_spec *spec, struct md_attr *ma);
217 int mdd_lov_objid_prepare(struct mdd_device *mdd, struct lov_mds_md *lmm);
218 int mdd_declare_lov_objid_update(const struct lu_env *, struct mdd_device *,
219                                  struct thandle *);
220 void mdd_lov_objid_update(struct mdd_device *mdd, struct lov_mds_md *lmm);
221 void mdd_lov_create_finish(const struct lu_env *env, struct mdd_device *mdd,
222                            struct lov_mds_md *lmm, int lmm_size,
223                            const struct md_op_spec *spec);
224 int mdd_file_lock(const struct lu_env *env, struct md_object *obj,
225                   struct lov_mds_md *lmm, struct ldlm_extent *extent,
226                   struct lustre_handle *lockh);
227 int mdd_file_unlock(const struct lu_env *env, struct md_object *obj,
228                     struct lov_mds_md *lmm, struct lustre_handle *lockh);
229 int mdd_lum_lmm_cmp(const struct lu_env *env, struct md_object *cobj,
230                     const struct md_op_spec *spec, struct md_attr *ma);
231 int mdd_get_md(const struct lu_env *env, struct mdd_object *obj,
232                void *md, int *md_size, const char *name);
233 int mdd_get_md_locked(const struct lu_env *env, struct mdd_object *obj,
234                       void *md, int *md_size, const char *name);
235 int mdd_data_get(const struct lu_env *env, struct mdd_object *obj, void **data);
236 int mdd_la_get(const struct lu_env *env, struct mdd_object *obj,
237                struct lu_attr *la, struct lustre_capa *capa);
238 int mdd_attr_get(const struct lu_env *env, struct md_object *obj,
239                  struct md_attr *ma);
240 int mdd_attr_set(const struct lu_env *env, struct md_object *obj,
241                  const struct md_attr *ma);
242 int mdd_attr_set_internal(const struct lu_env *env,
243                           struct mdd_object *obj,
244                           struct lu_attr *attr,
245                           struct thandle *handle,
246                           int needacl);
247 int mdd_attr_check_set_internal(const struct lu_env *env,
248                                 struct mdd_object *obj,
249                                 struct lu_attr *attr,
250                                 struct thandle *handle,
251                                 int needacl);
252 int mdd_declare_object_kill(const struct lu_env *env, struct mdd_object *obj,
253                             struct md_attr *ma, struct thandle *handle);
254 int mdd_object_kill(const struct lu_env *env, struct mdd_object *obj,
255                     struct md_attr *ma, struct thandle *handle);
256 int mdd_iattr_get(const struct lu_env *env, struct mdd_object *mdd_obj,
257                   struct md_attr *ma);
258 int mdd_object_create_internal(const struct lu_env *env, struct mdd_object *p,
259                                struct mdd_object *c, struct lu_attr *attr,
260                                struct thandle *handle,
261                                const struct md_op_spec *spec);
262 int mdd_attr_check_set_internal_locked(const struct lu_env *env,
263                                        struct mdd_object *obj,
264                                        struct lu_attr *attr,
265                                        struct thandle *handle,
266                                        int needacl);
267 int mdd_lmm_get_locked(const struct lu_env *env, struct mdd_object *mdd_obj,
268                        struct md_attr *ma);
269
270 /* mdd_lock.c */
271 void mdd_write_lock(const struct lu_env *env, struct mdd_object *obj,
272                     enum mdd_object_role role);
273 void mdd_read_lock(const struct lu_env *env, struct mdd_object *obj,
274                    enum mdd_object_role role);
275 void mdd_write_unlock(const struct lu_env *env, struct mdd_object *obj);
276 void mdd_read_unlock(const struct lu_env *env, struct mdd_object *obj);
277 int mdd_write_locked(const struct lu_env *env, struct mdd_object *obj);
278
279 void mdd_pdlock_init(struct mdd_object *obj);
280 unsigned long mdd_name2hash(const char *name);
281 void *mdd_pdo_write_lock(const struct lu_env *env, struct mdd_object *obj,
282                          const char *name, enum mdd_object_role role);
283 void *mdd_pdo_read_lock(const struct lu_env *env, struct mdd_object *obj,
284                         const char *name, enum mdd_object_role role);
285 void mdd_pdo_write_unlock(const struct lu_env *env, struct mdd_object *obj,
286                           void *dlh);
287 void mdd_pdo_read_unlock(const struct lu_env *env, struct mdd_object *obj,
288                          void *dlh);
289 /* mdd_dir.c */
290 int mdd_parent_fid(const struct lu_env *env, struct mdd_object *obj,
291                    struct lu_fid *fid);
292 int mdd_is_subdir(const struct lu_env *env, struct md_object *mo,
293                   const struct lu_fid *fid, struct lu_fid *sfid);
294 int mdd_may_create(const struct lu_env *env, struct mdd_object *pobj,
295                    struct mdd_object *cobj, int check_perm, int check_nlink);
296 int mdd_may_unlink(const struct lu_env *env, struct mdd_object *pobj,
297                    const struct lu_attr *attr);
298 int mdd_may_delete(const struct lu_env *env, struct mdd_object *pobj,
299                    struct mdd_object *cobj, struct lu_attr *cattr,
300                    struct lu_attr *src_attr, int check_perm, int check_empty);
301 int mdd_unlink_sanity_check(const struct lu_env *env, struct mdd_object *pobj,
302                             struct mdd_object *cobj, struct lu_attr *cattr);
303 int mdd_finish_unlink(const struct lu_env *env, struct mdd_object *obj,
304                       struct md_attr *ma, struct thandle *th);
305 int mdd_object_initialize(const struct lu_env *env, const struct lu_fid *pfid,
306                           const struct lu_name *lname, struct mdd_object *child,
307                           struct lu_attr *attr, struct thandle *handle,
308                           const struct md_op_spec *spec);
309 int mdd_link_sanity_check(const struct lu_env *env, struct mdd_object *tgt_obj,
310                           const struct lu_name *lname, struct mdd_object *src_obj);
311 int mdd_is_root(struct mdd_device *mdd, const struct lu_fid *fid);
312 int mdd_lookup(const struct lu_env *env,
313                struct md_object *pobj, const struct lu_name *lname,
314                struct lu_fid* fid, struct md_op_spec *spec);
315 int mdd_links_read(const struct lu_env *env, struct mdd_object *mdd_obj,
316                    struct mdd_link_data *ldata);
317 int mdd_links_find(const struct lu_env *env, struct mdd_object *mdd_obj,
318                    struct mdd_link_data *ldata, const struct lu_name *lname,
319                    const struct lu_fid  *pfid);
320 int mdd_links_new(const struct lu_env *env, struct mdd_link_data *ldata);
321 int mdd_links_add_buf(const struct lu_env *env, struct mdd_link_data *ldata,
322                       const struct lu_name *lname, const struct lu_fid *pfid);
323 void mdd_links_del_buf(const struct lu_env *env, struct mdd_link_data *ldata,
324                        const struct lu_name *lname);
325 int mdd_declare_links_add(const struct lu_env *env,
326                           struct mdd_object *mdd_obj,
327                           struct thandle *handle);
328 int mdd_links_write(const struct lu_env *env, struct mdd_object *mdd_obj,
329                     struct mdd_link_data *ldata, struct thandle *handle);
330 struct lu_buf *mdd_links_get(const struct lu_env *env,
331                              struct mdd_object *mdd_obj);
332 void mdd_lee_unpack(const struct link_ea_entry *lee, int *reclen,
333                     struct lu_name *lname, struct lu_fid *pfid);
334
335 /* mdd_lov.c */
336 int mdd_declare_unlink_log(const struct lu_env *env, struct mdd_object *obj,
337                            struct md_attr *ma, struct thandle *handle);
338 int mdd_unlink_log(const struct lu_env *env, struct mdd_device *mdd,
339                    struct mdd_object *mdd_cobj, struct md_attr *ma);
340
341 int mdd_setattr_log(const struct lu_env *env, struct mdd_device *mdd,
342                     const struct md_attr *ma,
343                     struct lov_mds_md *lmm, int lmm_size,
344                     struct llog_cookie *logcookies, int cookies_size);
345
346 int mdd_get_cookie_size(const struct lu_env *env, struct mdd_device *mdd,
347                         struct lov_mds_md *lmm);
348
349 int mdd_lov_setattr_async(const struct lu_env *env, struct mdd_object *obj,
350                           struct lov_mds_md *lmm, int lmm_size,
351                           struct llog_cookie *logcookies);
352
353 int mdd_lovobj_unlink(const struct lu_env *env, struct mdd_device *mdd,
354                       struct mdd_object *obj, struct lu_attr *la,
355                       struct md_attr *ma, int log_unlink);
356
357 struct mdd_thread_info *mdd_env_info(const struct lu_env *env);
358
359 const struct lu_name *mdd_name_get_const(const struct lu_env *env,
360                                          const void *area, ssize_t len);
361 struct lu_buf *mdd_buf_get(const struct lu_env *env, void *area, ssize_t len);
362 const struct lu_buf *mdd_buf_get_const(const struct lu_env *env,
363                                        const void *area, ssize_t len);
364
365 int __mdd_orphan_cleanup(const struct lu_env *env, struct mdd_device *d);
366 int __mdd_orphan_add(const struct lu_env *, struct mdd_object *,
367                      struct thandle *);
368 int __mdd_orphan_del(const struct lu_env *, struct mdd_object *,
369                      struct thandle *);
370 int orph_index_init(const struct lu_env *env, struct mdd_device *mdd);
371 void orph_index_fini(const struct lu_env *env, struct mdd_device *mdd);
372 int orph_declare_index_insert(const struct lu_env *, struct mdd_object *,
373                               cfs_umode_t mode, struct thandle *);
374 int orph_declare_index_delete(const struct lu_env *, struct mdd_object *,
375                               struct thandle *);
376
377 /* mdd_lproc.c */
378 void lprocfs_mdd_init_vars(struct lprocfs_static_vars *lvars);
379 int mdd_procfs_init(struct mdd_device *mdd, const char *name);
380 int mdd_procfs_fini(struct mdd_device *mdd);
381
382 /* mdd_object.c */
383 int mdd_get_flags(const struct lu_env *env, struct mdd_object *obj);
384 struct lu_buf *mdd_buf_alloc(const struct lu_env *env, ssize_t len);
385 int mdd_buf_grow(const struct lu_env *env, ssize_t len);
386 void mdd_buf_put(struct lu_buf *buf);
387
388 extern const struct md_dir_operations    mdd_dir_ops;
389 extern const struct md_object_operations mdd_obj_ops;
390
391 int accmode(const struct lu_env *env, struct lu_attr *la, int flags);
392 extern struct lu_context_key mdd_thread_key;
393 extern const struct lu_device_operations mdd_lu_ops;
394
395 struct mdd_object *mdd_object_find(const struct lu_env *env,
396                                    struct mdd_device *d,
397                                    const struct lu_fid *f);
398 int mdd_get_default_md(struct mdd_object *mdd_obj, struct lov_mds_md *lmm);
399 int mdd_readpage(const struct lu_env *env, struct md_object *obj,
400                  const struct lu_rdpg *rdpg);
401 int mdd_declare_llog_record(const struct lu_env *env, struct mdd_device *mdd,
402                             int reclen, struct thandle *handle);
403 int mdd_declare_changelog_store(const struct lu_env *env,
404                                 struct mdd_device *mdd,
405                                 const struct lu_name *fname,
406                                 struct thandle *handle);
407 int mdd_changelog_store(const struct lu_env *env, struct mdd_device *mdd,
408                         struct llog_changelog_rec *rec, struct thandle *th);
409 int mdd_changelog_ns_store(const struct lu_env *env, struct mdd_device *mdd,
410                            enum changelog_rec_type type, unsigned flags,
411                            struct mdd_object *target, struct mdd_object *parent,
412                            const struct lu_name *tname, struct thandle *handle);
413 int mdd_declare_object_create_internal(const struct lu_env *env,
414                                        struct mdd_object *p,
415                                        struct mdd_object *c,
416                                        struct lu_attr *attr,
417                                        struct thandle *handle,
418                                        const struct md_op_spec *spec);
419
420 /* mdd_trans.c */
421 int mdd_lov_destroy(const struct lu_env *env, struct mdd_device *mdd,
422                     struct mdd_object *obj, struct lu_attr *la);
423
424 void mdd_object_make_hint(const struct lu_env *env, struct mdd_object *parent,
425                           struct mdd_object *child, struct lu_attr *attr);
426
427 static inline void mdd_object_get(struct mdd_object *o)
428 {
429         lu_object_get(&o->mod_obj.mo_lu);
430 }
431
432 static inline void mdd_object_put(const struct lu_env *env,
433                                   struct mdd_object *o)
434 {
435         lu_object_put(env, &o->mod_obj.mo_lu);
436 }
437
438 struct thandle *mdd_trans_create(const struct lu_env *env,
439                                  struct mdd_device *mdd);
440 int mdd_trans_start(const struct lu_env *env, struct mdd_device *mdd,
441                     struct thandle *th);
442 void mdd_trans_stop(const struct lu_env *env, struct mdd_device *mdd,
443                     int rc, struct thandle *handle);
444 int mdd_txn_stop_cb(const struct lu_env *env, struct thandle *txn,
445                     void *cookie);
446 int mdd_txn_start_cb(const struct lu_env *env, struct thandle *,
447                      void *cookie);
448
449 /* mdd_lfsck.c */
450 int mdd_lfsck_set_speed(const struct lu_env *env, struct md_lfsck *lfsck,
451                         __u32 limit);
452 int mdd_lfsck_start(const struct lu_env *env, struct md_lfsck *lfsck,
453                     struct lfsck_start *start);
454 int mdd_lfsck_stop(const struct lu_env *env, struct md_lfsck *lfsck,
455                    bool pause);
456 int mdd_lfsck_setup(const struct lu_env *env, struct mdd_device *mdd);
457 void mdd_lfsck_cleanup(const struct lu_env *env, struct mdd_device *mdd);
458 int mdd_lfsck_dump(const struct lu_env *env, struct md_lfsck *lfsck,
459                    __u16 type, char *buf, int len);
460
461 /* mdd_device.c */
462 struct lu_object *mdd_object_alloc(const struct lu_env *env,
463                                    const struct lu_object_header *hdr,
464                                    struct lu_device *d);
465
466 int mdd_acl_chmod(const struct lu_env *env, struct mdd_object *o, __u32 mode,
467                   struct thandle *handle);
468 int __mdd_declare_acl_init(const struct lu_env *env, struct mdd_object *obj,
469                            int is_dir, struct thandle *handle);
470 int mdd_acl_set(const struct lu_env *env, struct mdd_object *obj,
471                 const struct lu_buf *buf, int fl);
472 int __mdd_acl_init(const struct lu_env *env, struct mdd_object *obj,
473                    struct lu_buf *buf, __u32 *mode, struct thandle *handle);
474 int __mdd_permission_internal(const struct lu_env *env, struct mdd_object *obj,
475                               struct lu_attr *la, int mask, int role);
476 int mdd_permission(const struct lu_env *env,
477                    struct md_object *pobj, struct md_object *cobj,
478                    struct md_attr *ma, int mask);
479 int mdd_capa_get(const struct lu_env *env, struct md_object *obj,
480                  struct lustre_capa *capa, int renewal);
481
482 static inline int lu_device_is_mdd(struct lu_device *d)
483 {
484         return ergo(d != NULL && d->ld_ops != NULL, d->ld_ops == &mdd_lu_ops);
485 }
486
487 static inline struct mdd_device* lu2mdd_dev(struct lu_device *d)
488 {
489         LASSERT(lu_device_is_mdd(d));
490         return container_of0(d, struct mdd_device, mdd_md_dev.md_lu_dev);
491 }
492
493 static inline struct lu_device *mdd2lu_dev(struct mdd_device *d)
494 {
495         return (&d->mdd_md_dev.md_lu_dev);
496 }
497
498 static inline struct mdd_object *lu2mdd_obj(struct lu_object *o)
499 {
500         LASSERT(ergo(o != NULL, lu_device_is_mdd(o->lo_dev)));
501         return container_of0(o, struct mdd_object, mod_obj.mo_lu);
502 }
503
504 static inline struct mdd_device* mdo2mdd(struct md_object *mdo)
505 {
506         return lu2mdd_dev(mdo->mo_lu.lo_dev);
507 }
508
509 static inline struct mdd_object* md2mdd_obj(struct md_object *mdo)
510 {
511         return container_of0(mdo, struct mdd_object, mod_obj);
512 }
513
514 static inline const struct dt_device_operations *
515 mdd_child_ops(struct mdd_device *d)
516 {
517         return d->mdd_child->dd_ops;
518 }
519
520 static inline struct lu_object *mdd2lu_obj(struct mdd_object *obj)
521 {
522         return &obj->mod_obj.mo_lu;
523 }
524
525 static inline struct dt_object* mdd_object_child(struct mdd_object *o)
526 {
527         return container_of0(lu_object_next(mdd2lu_obj(o)),
528                              struct dt_object, do_lu);
529 }
530
531 static inline struct obd_device *mdd2obd_dev(struct mdd_device *mdd)
532 {
533         return (mdd->mdd_md_dev.md_lu_dev.ld_obd);
534 }
535
536 static inline struct mdd_device *mdd_obj2mdd_dev(struct mdd_object *obj)
537 {
538         return mdo2mdd(&obj->mod_obj);
539 }
540
541 static inline const struct lu_fid *mdo2fid(const struct mdd_object *obj)
542 {
543         return lu_object_fid(&obj->mod_obj.mo_lu);
544 }
545
546 static inline int mdd_object_obf(const struct mdd_object *obj)
547 {
548         return lu_fid_eq(mdo2fid(obj), &LU_OBF_FID);
549 }
550
551 static inline cfs_umode_t mdd_object_type(const struct mdd_object *obj)
552 {
553         return lu_object_attr(&obj->mod_obj.mo_lu);
554 }
555
556 static inline int mdd_is_immutable(struct mdd_object *obj)
557 {
558         return obj->mod_flags & IMMUTE_OBJ;
559 }
560
561 static inline int mdd_is_dead_obj(struct mdd_object *obj)
562 {
563         return obj && obj->mod_flags & DEAD_OBJ;
564 }
565
566 static inline int mdd_is_append(struct mdd_object *obj)
567 {
568         return obj->mod_flags & APPEND_OBJ;
569 }
570
571 static inline int mdd_object_exists(struct mdd_object *obj)
572 {
573         return lu_object_exists(mdd2lu_obj(obj));
574 }
575
576 static inline int mdd_object_remote(struct mdd_object *obj)
577 {
578         return lu_object_remote(mdd2lu_obj(obj));
579 }
580
581 static inline const struct lu_fid *mdd_object_fid(struct mdd_object *obj)
582 {
583         return lu_object_fid(mdd2lu_obj(obj));
584 }
585
586 static inline struct seq_server_site *mdd_seq_site(struct mdd_device *mdd)
587 {
588         return mdd2lu_dev(mdd)->ld_site->ld_seq_site;
589 }
590
591 static inline struct lustre_capa *mdd_object_capa(const struct lu_env *env,
592                                                   const struct mdd_object *obj)
593 {
594         struct md_capainfo *ci = md_capainfo(env);
595         const struct lu_fid *fid = mdo2fid(obj);
596         int i;
597
598         /* NB: in mdt_init0 */
599         if (!ci)
600                 return BYPASS_CAPA;
601         for (i = 0; i < MD_CAPAINFO_MAX; i++)
602                 if (lu_fid_eq(&ci->mc_fid[i], fid))
603                         return ci->mc_capa[i];
604         return NULL;
605 }
606
607 static inline void mdd_set_capainfo(const struct lu_env *env, int offset,
608                                     const struct mdd_object *obj,
609                                     struct lustre_capa *capa)
610 {
611         struct md_capainfo *ci = md_capainfo(env);
612         const struct lu_fid *fid = mdo2fid(obj);
613
614         LASSERT(offset >= 0 && offset < MD_CAPAINFO_MAX);
615         /* NB: in mdt_init0 */
616         if (!ci)
617                 return;
618         ci->mc_fid[offset]  = *fid;
619         ci->mc_capa[offset] = capa;
620 }
621
622 static inline const char *mdd_obj_dev_name(const struct mdd_object *obj)
623 {
624         return lu_dev_name(obj->mod_obj.mo_lu.lo_dev);
625 }
626
627 #define MAX_ATIME_DIFF 60
628
629 enum {
630         LPROC_MDD_NR
631 };
632
633 static inline int mdd_permission_internal(const struct lu_env *env,
634                                           struct mdd_object *obj,
635                                           struct lu_attr *la, int mask)
636 {
637         return __mdd_permission_internal(env, obj, la, mask, -1);
638 }
639
640 static inline int mdd_permission_internal_locked(const struct lu_env *env,
641                                                  struct mdd_object *obj,
642                                                  struct lu_attr *la, int mask,
643                                                  enum mdd_object_role role)
644 {
645         return __mdd_permission_internal(env, obj, la, mask, role);
646 }
647
648 static inline int mdo_data_get(const struct lu_env *env,
649                                struct mdd_object *obj,
650                                void **data)
651 {
652         struct dt_object *next = mdd_object_child(obj);
653         next->do_ops->do_data_get(env, next, data);
654         return 0;
655 }
656
657 /* mdd inline func for calling osd_dt_object ops */
658 static inline int mdo_attr_get(const struct lu_env *env, struct mdd_object *obj,
659                                struct lu_attr *la, struct lustre_capa *capa)
660 {
661         struct dt_object *next = mdd_object_child(obj);
662         return next->do_ops->do_attr_get(env, next, la, capa);
663 }
664
665 static inline int mdo_declare_attr_set(const struct lu_env *env,
666                                        struct mdd_object *obj,
667                                        const struct lu_attr *la,
668                                        struct thandle *handle)
669 {
670         struct dt_object *next = mdd_object_child(obj);
671         return dt_declare_attr_set(env, next, la, handle);
672 }
673
674 static inline int mdo_attr_set(const struct lu_env *env,
675                                struct mdd_object *obj,
676                                const struct lu_attr *la,
677                                struct thandle *handle,
678                                struct lustre_capa *capa)
679 {
680         struct dt_object *next = mdd_object_child(obj);
681         if (mdd_object_exists(obj) == 0) {
682                 CERROR("%s: object "DFID" not found: rc = -2\n",
683                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
684                 return -ENOENT;
685         }
686         return next->do_ops->do_attr_set(env, next, la, handle, capa);
687 }
688
689 static inline int mdo_xattr_get(const struct lu_env *env,struct mdd_object *obj,
690                                 struct lu_buf *buf, const char *name,
691                                 struct lustre_capa *capa)
692 {
693         struct dt_object *next = mdd_object_child(obj);
694         return next->do_ops->do_xattr_get(env, next, buf, name, capa);
695 }
696
697 static inline int mdo_declare_xattr_set(const struct lu_env *env,
698                                         struct mdd_object *obj,
699                                         const struct lu_buf *buf,
700                                         const char *name,
701                                         int fl, struct thandle *handle)
702 {
703         struct dt_object *next = mdd_object_child(obj);
704         return dt_declare_xattr_set(env, next, buf, name, fl, handle);
705 }
706
707 static inline int mdo_xattr_set(const struct lu_env *env,struct mdd_object *obj,
708                                 const struct lu_buf *buf, const char *name,
709                                 int fl, struct thandle *handle,
710                                 struct lustre_capa *capa)
711 {
712         struct dt_object *next = mdd_object_child(obj);
713         if (mdd_object_exists(obj) == 0) {
714                 CERROR("%s: object "DFID" not found: rc = -2\n",
715                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
716                 return -ENOENT;
717         }
718         return next->do_ops->do_xattr_set(env, next, buf, name, fl, handle,
719                                           capa);
720 }
721
722 static inline int mdo_declare_xattr_del(const struct lu_env *env,
723                                         struct mdd_object *obj,
724                                         const char *name,
725                                         struct thandle *handle)
726 {
727         struct dt_object *next = mdd_object_child(obj);
728         return dt_declare_xattr_del(env, next, name, handle);
729 }
730
731 static inline int mdo_xattr_del(const struct lu_env *env,struct mdd_object *obj,
732                                 const char *name, struct thandle *handle,
733                                 struct lustre_capa *capa)
734 {
735         struct dt_object *next = mdd_object_child(obj);
736         if (mdd_object_exists(obj) == 0) {
737                 CERROR("%s: object "DFID" not found: rc = -2\n",
738                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
739                 return -ENOENT;
740         }
741         return next->do_ops->do_xattr_del(env, next, name, handle, capa);
742 }
743
744 static inline
745 int mdo_xattr_list(const struct lu_env *env, struct mdd_object *obj,
746                    struct lu_buf *buf, struct lustre_capa *capa)
747 {
748         struct dt_object *next = mdd_object_child(obj);
749         if (mdd_object_exists(obj) == 0) {
750                 CERROR("%s: object "DFID" not found: rc = -2\n",
751                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
752                 return -ENOENT;
753         }
754         return next->do_ops->do_xattr_list(env, next, buf, capa);
755 }
756
757 static inline
758 int mdo_index_try(const struct lu_env *env, struct mdd_object *obj,
759                                  const struct dt_index_features *feat)
760 {
761         struct dt_object *next = mdd_object_child(obj);
762         return next->do_ops->do_index_try(env, next, feat);
763 }
764
765 static inline
766 int mdo_declare_index_insert(const struct lu_env *env, struct mdd_object *obj,
767                              const struct lu_fid *fid, const char *name,
768                              struct thandle *handle)
769 {
770         struct dt_object *next = mdd_object_child(obj);
771         int              rc = 0;
772
773         /*
774          * if the object doesn't exist yet, then it's supposed to be created
775          * and declaration of the creation should be enough to insert ./..
776          */
777          /* FIXME: remote object should not be awared by MDD layer, but local
778           * creation does not declare insert ./.. (comments above), which
779           * is required by remote directory creation.
780           * This remote check should be removed when mdd_object_exists check is
781           * removed.
782           */
783          if (mdd_object_exists(obj) || mdd_object_remote(obj)) {
784                 rc = -ENOTDIR;
785                 if (dt_try_as_dir(env, next))
786                         rc = dt_declare_insert(env, next,
787                                                (struct dt_rec *)fid,
788                                                (const struct dt_key *)name,
789                                                handle);
790         }
791
792         return rc;
793 }
794
795 static inline
796 int mdo_declare_index_delete(const struct lu_env *env, struct mdd_object *obj,
797                              const char *name, struct thandle *handle)
798 {
799         struct dt_object *next = mdd_object_child(obj);
800
801         if (!dt_try_as_dir(env, next))
802                 return -ENOTDIR;
803
804         return dt_declare_delete(env, next, (const struct dt_key *)name,
805                                  handle);
806 }
807
808 static inline int mdo_declare_ref_add(const struct lu_env *env,
809                                       struct mdd_object *obj,
810                                       struct thandle *handle)
811 {
812         struct dt_object *next = mdd_object_child(obj);
813         return dt_declare_ref_add(env, next, handle);
814 }
815
816 static inline int mdo_ref_add(const struct lu_env *env, struct mdd_object *obj,
817                               struct thandle *handle)
818 {
819         struct dt_object *next = mdd_object_child(obj);
820         if (mdd_object_exists(obj) == 0) {
821                 CERROR("%s: object "DFID" not found: rc = -2\n",
822                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
823                 return -ENOENT;
824         }
825         return next->do_ops->do_ref_add(env, next, handle);
826 }
827
828 static inline int mdo_declare_ref_del(const struct lu_env *env,
829                                       struct mdd_object *obj,
830                                       struct thandle *handle)
831 {
832         struct dt_object *next = mdd_object_child(obj);
833         return dt_declare_ref_del(env, next, handle);
834 }
835
836 static inline int mdo_ref_del(const struct lu_env *env, struct mdd_object *obj,
837                               struct thandle *handle)
838 {
839         struct dt_object *next = mdd_object_child(obj);
840         if (mdd_object_exists(obj) == 0) {
841                 CERROR("%s: object "DFID" not found: rc = -2\n",
842                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
843                 return -ENOENT;
844         }
845         return next->do_ops->do_ref_del(env, next, handle);
846 }
847
848 static inline
849 int mdo_declare_create_obj(const struct lu_env *env, struct mdd_object *o,
850                            struct lu_attr *attr,
851                            struct dt_allocation_hint *hint,
852                            struct dt_object_format *dof,
853                            struct thandle *handle)
854 {
855         struct dt_object *next = mdd_object_child(o);
856         return next->do_ops->do_declare_create(env, next, attr, hint,
857                                                dof, handle);
858 }
859
860 static inline
861 int mdo_create_obj(const struct lu_env *env, struct mdd_object *o,
862                    struct lu_attr *attr,
863                    struct dt_allocation_hint *hint,
864                    struct dt_object_format *dof,
865                    struct thandle *handle)
866 {
867         struct dt_object *next = mdd_object_child(o);
868         struct lu_ucred *uc = lu_ucred(env);
869         __u32 saved;
870         int rc;
871
872         /*
873          *  LU-974 enforce client umask in creation.
874          * TODO: CMD needs to handle this for remote object.
875          */
876         if (likely(uc != NULL))
877                 saved = xchg(&current->fs->umask, uc->uc_umask & S_IRWXUGO);
878
879         rc = next->do_ops->do_create(env, next, attr, hint, dof, handle);
880
881         /* restore previous umask value */
882         if (likely(uc != NULL))
883                 current->fs->umask = saved;
884
885         return rc;
886 }
887
888 static inline
889 int mdo_declare_destroy(const struct lu_env *env, struct mdd_object *o,
890                         struct thandle *handle)
891 {
892         struct dt_object *next = mdd_object_child(o);
893         return dt_declare_destroy(env, next, handle);
894 }
895
896 static inline
897 int mdo_destroy(const struct lu_env *env, struct mdd_object *o,
898                 struct thandle *handle)
899 {
900         struct dt_object *next = mdd_object_child(o);
901         return dt_destroy(env, next, handle);
902 }
903
904 static inline struct obd_capa *mdo_capa_get(const struct lu_env *env,
905                                             struct mdd_object *obj,
906                                             struct lustre_capa *old,
907                                             __u64 opc)
908 {
909         struct dt_object *next = mdd_object_child(obj);
910         if (mdd_object_exists(obj) == 0) {
911                 CERROR("%s: object "DFID" not found: rc = -2\n",
912                        mdd_obj_dev_name(obj), PFID(mdd_object_fid(obj)));
913                 return ERR_PTR(-ENOENT);
914         }
915         return next->do_ops->do_capa_get(env, next, old, opc);
916 }
917
918 #endif