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