lustre/target/tgt_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, write to the
  18  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  19  * Boston, MA 021110-1307, USA
  20  *
  21  * GPL HEADER END
  22  */
  23 /*
  24  * Copyright (c) 2012, Intel Corporation.
  25  */
  26 /*
  27  * lustre/target/tgt_internal.h
  28  *
  29  * Lustre Unified Target header file
  30  *
  31  * Author: Mikhail Pershin <mike.pershin@intel.com>
  32  */
  33
  34 #ifndef _TG_INTERNAL_H
  35 #define _TG_INTERNAL_H
  36
  37 #include <lustre_net.h>
  38 #include <lustre/lustre_idl.h>
  39 #include <lu_target.h>
  40 #include <lustre_export.h>
  41 #include <lustre_fid.h>
  42 #include <lustre_fld.h>
  43 #include <lustre_req_layout.h>
  44 #include <lustre_sec.h>
  45
  46 struct tx_arg;
  47 typedef int (*tx_exec_func_t)(const struct lu_env *env, struct thandle *th,
  48                               struct tx_arg *ta);
  49
  50 struct tx_arg {
  51         tx_exec_func_t           exec_fn;
  52         tx_exec_func_t           undo_fn;
  53         struct dt_object        *object;
  54         char                    *file;
  55         struct update_reply     *reply;
  56         int                      line;
  57         int                      index;
  58         union {
  59                 struct {
  60                         const struct dt_rec     *rec;
  61                         const struct dt_key     *key;
  62                 } insert;
  63                 struct {
  64                 } ref;
  65                 struct {
  66                         struct lu_attr   attr;
  67                 } attr_set;
  68                 struct {
  69                         struct lu_buf    buf;
  70                         const char      *name;
  71                         int              flags;
  72                         __u32            csum;
  73                 } xattr_set;
  74                 struct {
  75                         struct lu_attr                  attr;
  76                         struct dt_allocation_hint       hint;
  77                         struct dt_object_format         dof;
  78                         struct lu_fid                   fid;
  79                 } create;
  80                 struct {
  81                         struct lu_buf   buf;
  82                         loff_t          pos;
  83                 } write;
  84                 struct {
  85                         struct ost_body     *body;
  86                 } destroy;
  87         } u;
  88 };
  89
  90 #define TX_MAX_OPS        10
  91 struct thandle_exec_args {
  92         struct thandle          *ta_handle;
  93         struct dt_device        *ta_dev;
  94         int                      ta_err;
  95         struct tx_arg            ta_args[TX_MAX_OPS];
  96         int                      ta_argno;   /* used args */
  97 };
  98
  99 /**
 100  * Common data shared by tg-level handlers. This is allocated per-thread to
 101  * reduce stack consumption.
 102  */
 103 struct tgt_thread_info {
 104         /* server and client data buffers */
 105         struct lr_server_data    tti_lsd;
 106         struct lsd_client_data   tti_lcd;
 107         struct lu_buf            tti_buf;
 108         loff_t                   tti_off;
 109
 110         struct lu_attr           tti_attr;
 111         struct lu_fid            tti_fid1;
 112
 113         /* transno storage during last_rcvd update */
 114         __u64                    tti_transno;
 115         __u32                    tti_has_trans:1,
 116                                  tti_mult_trans:1;
 117
 118         /* Updates data for OUT target */
 119         struct thandle_exec_args tti_tea;
 120         union {
 121                 struct {
 122                         /* for tgt_readpage()      */
 123                         struct lu_rdpg     tti_rdpg;
 124                         /* for tgt_sendpage()      */
 125                         struct l_wait_info tti_wait_info;
 126                 } rdpg;
 127                 struct {
 128                         struct dt_object_format  tti_update_dof;
 129                         struct update_reply     *tti_update_reply;
 130                         struct update           *tti_update;
 131                         int                      tti_update_reply_index;
 132                         struct obdo              tti_obdo;
 133                         struct dt_object        *tti_dt_object;
 134                 } update;
 135         } tti_u;
 136 };
 137
 138 extern struct lu_context_key tgt_thread_key;
 139
 140 static inline struct tgt_thread_info *tgt_th_info(const struct lu_env *env)
 141 {
 142         struct tgt_thread_info *tti;
 143
 144         tti = lu_context_key_get(&env->le_ctx, &tgt_thread_key);
 145         LASSERT(tti);
 146         return tti;
 147 }
 148
 149 #define MGS_SERVICE_WATCHDOG_FACTOR      (2)
 150
 151 int tgt_request_handle(struct ptlrpc_request *req);
 152
 153 /* check if request's xid is equal to last one or not*/
 154 static inline int req_xid_is_last(struct ptlrpc_request *req)
 155 {
 156         struct lsd_client_data *lcd = req->rq_export->exp_target_data.ted_lcd;
 157
 158         LASSERT(lcd != NULL);
 159         return (req->rq_xid == lcd->lcd_last_xid ||
 160                 req->rq_xid == lcd->lcd_last_close_xid);
 161 }
 162
 163 static inline char *dt_obd_name(struct dt_device *dt)
 164 {
 165         return dt->dd_lu_dev.ld_obd->obd_name;
 166 }
 167
 168 /* Update handlers */
 169 int out_handle(struct tgt_session_info *tsi);
 170
 171 #define out_tx_create(info, obj, attr, fid, dof, th, reply, idx) \
 172         __out_tx_create(info, obj, attr, fid, dof, th, reply, idx, \
 173                         __FILE__, __LINE__)
 174
 175 #define out_tx_attr_set(info, obj, attr, th, reply, idx) \
 176         __out_tx_attr_set(info, obj, attr, th, reply, idx, \
 177                           __FILE__, __LINE__)
 178
 179 #define out_tx_xattr_set(info, obj, buf, name, fl, th, reply, idx)      \
 180         __out_tx_xattr_set(info, obj, buf, name, fl, th, reply, idx,    \
 181                            __FILE__, __LINE__)
 182
 183 #define out_tx_ref_add(info, obj, th, reply, idx) \
 184         __out_tx_ref_add(info, obj, th, reply, idx, __FILE__, __LINE__)
 185
 186 #define out_tx_ref_del(info, obj, th, reply, idx) \
 187         __out_tx_ref_del(info, obj, th, reply, idx, __FILE__, __LINE__)
 188
 189 #define out_tx_index_insert(info, obj, th, name, fid, reply, idx) \
 190         __out_tx_index_insert(info, obj, th, name, fid, reply, idx, \
 191                               __FILE__, __LINE__)
 192
 193 #define out_tx_index_delete(info, obj, th, name, reply, idx) \
 194         __out_tx_index_delete(info, obj, th, name, reply, idx, \
 195                               __FILE__, __LINE__)
 196
 197 #define out_tx_destroy(info, obj, th, reply, idx) \
 198         __out_tx_destroy(info, obj, th, reply, idx, __FILE__, __LINE__)
 199
 200 extern struct page *tgt_page_to_corrupt;
 201
 202 struct tgt_thread_big_cache {
 203         struct niobuf_local     local[PTLRPC_MAX_BRW_PAGES];
 204 };
 205
 206 int tgt_server_data_init(const struct lu_env *env, struct lu_target *tgt);
 207 int tgt_txn_start_cb(const struct lu_env *env, struct thandle *th,
 208                      void *cookie);
 209 int tgt_txn_stop_cb(const struct lu_env *env, struct thandle *th,
 210                     void *cookie);
 211
 212 #endif /* _TG_INTERNAL_H */