blob: c2b0033a724b900c2b7cbdfecdcacdf0815aa585 [file] [log] [blame]
Boaz Harroshb14f8ab2008-10-27 18:27:55 +02001/*
2 * Copyright (C) 2005, 2006
Boaz Harrosh27d2e142009-06-14 17:23:09 +03003 * Avishay Traeger (avishay@gmail.com)
Boaz Harroshb14f8ab2008-10-27 18:27:55 +02004 * Copyright (C) 2008, 2009
5 * Boaz Harrosh <bharrosh@panasas.com>
6 *
7 * This file is part of exofs.
8 *
9 * exofs is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation. Since it is based on ext2, and the only
12 * valid version of GPL for the Linux kernel is version 2, the only valid
13 * version of GPL for exofs is version 2.
14 *
15 * exofs is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
19 *
20 * You should have received a copy of the GNU General Public License
21 * along with exofs; if not, write to the Free Software
22 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
23 */
24
Tejun Heo5a0e3ad2010-03-24 17:04:11 +090025#include <linux/slab.h>
Boaz Harrosh5d952b82010-02-01 13:35:51 +020026#include <asm/div64.h>
Boaz Harroshb14f8ab2008-10-27 18:27:55 +020027
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070028#include <scsi/osd_ore.h>
Boaz Harroshb14f8ab2008-10-27 18:27:55 +020029
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070030#define ORE_ERR(fmt, a...) printk(KERN_ERR "ore: " fmt, ##a)
Boaz Harrosh34ce4e7c2009-12-15 19:34:17 +020031
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070032#ifdef CONFIG_EXOFS_DEBUG
33#define ORE_DBGMSG(fmt, a...) \
34 printk(KERN_NOTICE "ore @%s:%d: " fmt, __func__, __LINE__, ##a)
35#else
36#define ORE_DBGMSG(fmt, a...) \
37 do { if (0) printk(fmt, ##a); } while (0)
38#endif
39
40/* u64 has problems with printk this will cast it to unsigned long long */
41#define _LLU(x) (unsigned long long)(x)
42
43#define ORE_DBGMSG2(M...) do {} while (0)
44/* #define ORE_DBGMSG2 ORE_DBGMSG */
45
Boaz Harroshcf283ad2011-08-06 19:22:06 -070046MODULE_AUTHOR("Boaz Harrosh <bharrosh@panasas.com>");
47MODULE_DESCRIPTION("Objects Raid Engine ore.ko");
48MODULE_LICENSE("GPL");
49
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070050static u8 *_ios_cred(struct ore_io_state *ios, unsigned index)
Boaz Harrosh9e9db452011-08-05 15:06:04 -070051{
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030052 return ios->oc->comps[index & ios->oc->single_comp].cred;
Boaz Harrosh9e9db452011-08-05 15:06:04 -070053}
54
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070055static struct osd_obj_id *_ios_obj(struct ore_io_state *ios, unsigned index)
Boaz Harrosh9e9db452011-08-05 15:06:04 -070056{
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030057 return &ios->oc->comps[index & ios->oc->single_comp].obj;
Boaz Harrosh9e9db452011-08-05 15:06:04 -070058}
59
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070060static struct osd_dev *_ios_od(struct ore_io_state *ios, unsigned index)
Boaz Harrosh9e9db452011-08-05 15:06:04 -070061{
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030062 return ios->oc->ods[index];
Boaz Harrosh9e9db452011-08-05 15:06:04 -070063}
64
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030065int ore_get_rw_state(struct ore_layout *layout, struct ore_components *oc,
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070066 bool is_reading, u64 offset, u64 length,
67 struct ore_io_state **pios)
Boaz Harroshb14f8ab2008-10-27 18:27:55 +020068{
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070069 struct ore_io_state *ios;
Boaz Harroshb14f8ab2008-10-27 18:27:55 +020070
Boaz Harrosh06886a52009-11-08 14:54:08 +020071 /*TODO: Maybe use kmem_cach per sbi of size
Boaz Harrosh45d3abc2010-01-28 11:46:16 +020072 * exofs_io_state_size(layout->s_numdevs)
Boaz Harrosh06886a52009-11-08 14:54:08 +020073 */
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030074 ios = kzalloc(ore_io_state_size(oc->numdevs), GFP_KERNEL);
Boaz Harrosh06886a52009-11-08 14:54:08 +020075 if (unlikely(!ios)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070076 ORE_DBGMSG("Failed kzalloc bytes=%d\n",
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030077 ore_io_state_size(oc->numdevs));
Boaz Harrosh06886a52009-11-08 14:54:08 +020078 *pios = NULL;
79 return -ENOMEM;
Boaz Harroshb14f8ab2008-10-27 18:27:55 +020080 }
81
Boaz Harrosh45d3abc2010-01-28 11:46:16 +020082 ios->layout = layout;
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030083 ios->oc = oc;
Boaz Harroshe1042ba2010-11-16 20:09:58 +020084 ios->offset = offset;
85 ios->length = length;
86 ios->reading = is_reading;
87
Boaz Harrosh06886a52009-11-08 14:54:08 +020088 *pios = ios;
89 return 0;
90}
Boaz Harroshcf283ad2011-08-06 19:22:06 -070091EXPORT_SYMBOL(ore_get_rw_state);
Boaz Harroshb14f8ab2008-10-27 18:27:55 +020092
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030093int ore_get_io_state(struct ore_layout *layout, struct ore_components *oc,
Boaz Harrosh8ff660a2011-08-06 19:26:31 -070094 struct ore_io_state **ios)
Boaz Harroshe1042ba2010-11-16 20:09:58 +020095{
Boaz Harrosh5bf696d2011-09-28 11:39:59 +030096 return ore_get_rw_state(layout, oc, true, 0, 0, ios);
Boaz Harroshe1042ba2010-11-16 20:09:58 +020097}
Boaz Harroshcf283ad2011-08-06 19:22:06 -070098EXPORT_SYMBOL(ore_get_io_state);
Boaz Harroshe1042ba2010-11-16 20:09:58 +020099
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700100void ore_put_io_state(struct ore_io_state *ios)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200101{
102 if (ios) {
103 unsigned i;
104
105 for (i = 0; i < ios->numdevs; i++) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700106 struct ore_per_dev_state *per_dev = &ios->per_dev[i];
Boaz Harrosh06886a52009-11-08 14:54:08 +0200107
108 if (per_dev->or)
109 osd_end_request(per_dev->or);
110 if (per_dev->bio)
111 bio_put(per_dev->bio);
112 }
113
114 kfree(ios);
115 }
116}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700117EXPORT_SYMBOL(ore_put_io_state);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200118
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700119static void _sync_done(struct ore_io_state *ios, void *p)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200120{
121 struct completion *waiting = p;
122
123 complete(waiting);
124}
125
126static void _last_io(struct kref *kref)
127{
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700128 struct ore_io_state *ios = container_of(
129 kref, struct ore_io_state, kref);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200130
131 ios->done(ios, ios->private);
132}
133
134static void _done_io(struct osd_request *or, void *p)
135{
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700136 struct ore_io_state *ios = p;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200137
138 kref_put(&ios->kref, _last_io);
139}
140
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700141static int ore_io_execute(struct ore_io_state *ios)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200142{
143 DECLARE_COMPLETION_ONSTACK(wait);
144 bool sync = (ios->done == NULL);
145 int i, ret;
146
147 if (sync) {
148 ios->done = _sync_done;
149 ios->private = &wait;
150 }
151
152 for (i = 0; i < ios->numdevs; i++) {
153 struct osd_request *or = ios->per_dev[i].or;
154 if (unlikely(!or))
155 continue;
156
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700157 ret = osd_finalize_request(or, 0, _ios_cred(ios, i), NULL);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200158 if (unlikely(ret)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700159 ORE_DBGMSG("Failed to osd_finalize_request() => %d\n",
Boaz Harrosh06886a52009-11-08 14:54:08 +0200160 ret);
161 return ret;
162 }
163 }
164
165 kref_init(&ios->kref);
166
167 for (i = 0; i < ios->numdevs; i++) {
168 struct osd_request *or = ios->per_dev[i].or;
169 if (unlikely(!or))
170 continue;
171
172 kref_get(&ios->kref);
173 osd_execute_request_async(or, _done_io, ios);
174 }
175
176 kref_put(&ios->kref, _last_io);
177 ret = 0;
178
179 if (sync) {
180 wait_for_completion(&wait);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700181 ret = ore_check_io(ios, NULL);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200182 }
Boaz Harroshb14f8ab2008-10-27 18:27:55 +0200183 return ret;
184}
185
Boaz Harrosh22ddc552010-01-19 19:24:45 +0200186static void _clear_bio(struct bio *bio)
187{
188 struct bio_vec *bv;
189 unsigned i;
190
191 __bio_for_each_segment(bv, bio, i, 0) {
192 unsigned this_count = bv->bv_len;
193
194 if (likely(PAGE_SIZE == this_count))
195 clear_highpage(bv->bv_page);
196 else
197 zero_user(bv->bv_page, bv->bv_offset, this_count);
198 }
199}
200
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700201int ore_check_io(struct ore_io_state *ios, u64 *resid)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200202{
203 enum osd_err_priority acumulated_osd_err = 0;
204 int acumulated_lin_err = 0;
205 int i;
206
207 for (i = 0; i < ios->numdevs; i++) {
208 struct osd_sense_info osi;
Boaz Harrosh22ddc552010-01-19 19:24:45 +0200209 struct osd_request *or = ios->per_dev[i].or;
210 int ret;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200211
Boaz Harrosh22ddc552010-01-19 19:24:45 +0200212 if (unlikely(!or))
213 continue;
214
215 ret = osd_req_decode_sense(or, &osi);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200216 if (likely(!ret))
217 continue;
218
Boaz Harrosh22ddc552010-01-19 19:24:45 +0200219 if (OSD_ERR_PRI_CLEAR_PAGES == osi.osd_err_pri) {
220 /* start read offset passed endof file */
221 _clear_bio(ios->per_dev[i].bio);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700222 ORE_DBGMSG("start read offset passed end of file "
Boaz Harrosh22ddc552010-01-19 19:24:45 +0200223 "offset=0x%llx, length=0x%llx\n",
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200224 _LLU(ios->per_dev[i].offset),
225 _LLU(ios->per_dev[i].length));
Boaz Harrosh22ddc552010-01-19 19:24:45 +0200226
227 continue; /* we recovered */
Boaz Harrosh06886a52009-11-08 14:54:08 +0200228 }
229
230 if (osi.osd_err_pri >= acumulated_osd_err) {
231 acumulated_osd_err = osi.osd_err_pri;
232 acumulated_lin_err = ret;
233 }
234 }
235
236 /* TODO: raid specific residual calculations */
237 if (resid) {
238 if (likely(!acumulated_lin_err))
239 *resid = 0;
240 else
241 *resid = ios->length;
242 }
243
244 return acumulated_lin_err;
245}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700246EXPORT_SYMBOL(ore_check_io);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200247
Boaz Harroshb367e782010-02-07 19:18:58 +0200248/*
249 * L - logical offset into the file
250 *
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200251 * U - The number of bytes in a stripe within a group
Boaz Harroshb367e782010-02-07 19:18:58 +0200252 *
253 * U = stripe_unit * group_width
254 *
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200255 * T - The number of bytes striped within a group of component objects
256 * (before advancing to the next group)
Boaz Harroshb367e782010-02-07 19:18:58 +0200257 *
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200258 * T = stripe_unit * group_width * group_depth
259 *
260 * S - The number of bytes striped across all component objects
261 * before the pattern repeats
262 *
263 * S = stripe_unit * group_width * group_depth * group_count
264 *
265 * M - The "major" (i.e., across all components) stripe number
266 *
267 * M = L / S
268 *
269 * G - Counts the groups from the beginning of the major stripe
270 *
271 * G = (L - (M * S)) / T [or (L % S) / T]
272 *
273 * H - The byte offset within the group
274 *
275 * H = (L - (M * S)) % T [or (L % S) % T]
276 *
277 * N - The "minor" (i.e., across the group) stripe number
278 *
279 * N = H / U
Boaz Harroshb367e782010-02-07 19:18:58 +0200280 *
281 * C - The component index coresponding to L
282 *
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200283 * C = (H - (N * U)) / stripe_unit + G * group_width
284 * [or (L % U) / stripe_unit + G * group_width]
Boaz Harroshb367e782010-02-07 19:18:58 +0200285 *
286 * O - The component offset coresponding to L
287 *
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200288 * O = L % stripe_unit + N * stripe_unit + M * group_depth * stripe_unit
Boaz Harroshb367e782010-02-07 19:18:58 +0200289 */
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700290static void ore_calc_stripe_info(struct ore_layout *layout, u64 file_offset,
291 struct ore_striping_info *si)
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200292{
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700293 u32 stripe_unit = layout->stripe_unit;
294 u32 group_width = layout->group_width;
295 u64 group_depth = layout->group_depth;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200296
Boaz Harroshb367e782010-02-07 19:18:58 +0200297 u32 U = stripe_unit * group_width;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200298 u64 T = U * group_depth;
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700299 u64 S = T * layout->group_count;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200300 u64 M = div64_u64(file_offset, S);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200301
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200302 /*
303 G = (L - (M * S)) / T
304 H = (L - (M * S)) % T
305 */
306 u64 LmodS = file_offset - M * S;
307 u32 G = div64_u64(LmodS, T);
308 u64 H = LmodS - G * T;
Boaz Harroshb367e782010-02-07 19:18:58 +0200309
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200310 u32 N = div_u64(H, U);
311
312 /* "H - (N * U)" is just "H % U" so it's bound to u32 */
313 si->dev = (u32)(H - (N * U)) / stripe_unit + G * group_width;
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700314 si->dev *= layout->mirrors_p1;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200315
316 div_u64_rem(file_offset, stripe_unit, &si->unit_off);
317
318 si->obj_offset = si->unit_off + (N * stripe_unit) +
319 (M * group_depth * stripe_unit);
320
321 si->group_length = T - H;
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700322 si->M = M;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200323}
324
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700325static int _add_stripe_unit(struct ore_io_state *ios, unsigned *cur_pg,
326 unsigned pgbase, struct ore_per_dev_state *per_dev,
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200327 int cur_len)
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200328{
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200329 unsigned pg = *cur_pg;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200330 struct request_queue *q =
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700331 osd_request_queue(_ios_od(ios, per_dev->dev));
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200332
333 per_dev->length += cur_len;
334
335 if (per_dev->bio == NULL) {
336 unsigned pages_in_stripe = ios->layout->group_width *
337 (ios->layout->stripe_unit / PAGE_SIZE);
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200338 unsigned bio_size = (ios->nr_pages + pages_in_stripe) /
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200339 ios->layout->group_width;
340
341 per_dev->bio = bio_kmalloc(GFP_KERNEL, bio_size);
342 if (unlikely(!per_dev->bio)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700343 ORE_DBGMSG("Failed to allocate BIO size=%u\n",
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200344 bio_size);
345 return -ENOMEM;
346 }
347 }
348
349 while (cur_len > 0) {
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200350 unsigned pglen = min_t(unsigned, PAGE_SIZE - pgbase, cur_len);
351 unsigned added_len;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200352
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200353 BUG_ON(ios->nr_pages <= pg);
354 cur_len -= pglen;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200355
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200356 added_len = bio_add_pc_page(q, per_dev->bio, ios->pages[pg],
357 pglen, pgbase);
358 if (unlikely(pglen != added_len))
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200359 return -ENOMEM;
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200360 pgbase = 0;
361 ++pg;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200362 }
363 BUG_ON(cur_len);
364
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200365 *cur_pg = pg;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200366 return 0;
367}
368
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700369static int _prepare_one_group(struct ore_io_state *ios, u64 length,
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700370 struct ore_striping_info *si)
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200371{
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200372 unsigned stripe_unit = ios->layout->stripe_unit;
Boaz Harroshb367e782010-02-07 19:18:58 +0200373 unsigned mirrors_p1 = ios->layout->mirrors_p1;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200374 unsigned devs_in_group = ios->layout->group_width * mirrors_p1;
Boaz Harroshb367e782010-02-07 19:18:58 +0200375 unsigned dev = si->dev;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200376 unsigned first_dev = dev - (dev % devs_in_group);
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200377 unsigned max_comp = ios->numdevs ? ios->numdevs - mirrors_p1 : 0;
378 unsigned cur_pg = ios->pages_consumed;
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200379 int ret = 0;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200380
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200381 while (length) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700382 struct ore_per_dev_state *per_dev = &ios->per_dev[dev];
Boaz Harroshb367e782010-02-07 19:18:58 +0200383 unsigned cur_len, page_off = 0;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200384
385 if (!per_dev->length) {
Boaz Harroshb367e782010-02-07 19:18:58 +0200386 per_dev->dev = dev;
387 if (dev < si->dev) {
388 per_dev->offset = si->obj_offset + stripe_unit -
389 si->unit_off;
390 cur_len = stripe_unit;
391 } else if (dev == si->dev) {
392 per_dev->offset = si->obj_offset;
393 cur_len = stripe_unit - si->unit_off;
394 page_off = si->unit_off & ~PAGE_MASK;
395 BUG_ON(page_off && (page_off != ios->pgbase));
396 } else { /* dev > si->dev */
397 per_dev->offset = si->obj_offset - si->unit_off;
398 cur_len = stripe_unit;
399 }
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200400
Boaz Harrosh6e316092010-07-29 17:08:13 +0300401 if (max_comp < dev)
402 max_comp = dev;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200403 } else {
Boaz Harroshb367e782010-02-07 19:18:58 +0200404 cur_len = stripe_unit;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200405 }
Boaz Harroshb367e782010-02-07 19:18:58 +0200406 if (cur_len >= length)
407 cur_len = length;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200408
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200409 ret = _add_stripe_unit(ios, &cur_pg, page_off , per_dev,
410 cur_len);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200411 if (unlikely(ret))
412 goto out;
413
Boaz Harrosh6e316092010-07-29 17:08:13 +0300414 dev += mirrors_p1;
415 dev = (dev % devs_in_group) + first_dev;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200416
417 length -= cur_len;
418 }
419out:
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200420 ios->numdevs = max_comp + mirrors_p1;
421 ios->pages_consumed = cur_pg;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200422 return ret;
423}
424
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700425static int _prepare_for_striping(struct ore_io_state *ios)
Boaz Harroshb367e782010-02-07 19:18:58 +0200426{
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200427 u64 length = ios->length;
Boaz Harrosh5002dd12010-08-02 20:06:46 +0300428 u64 offset = ios->offset;
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700429 struct ore_striping_info si;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200430 int ret = 0;
Boaz Harroshb367e782010-02-07 19:18:58 +0200431
Boaz Harroshb367e782010-02-07 19:18:58 +0200432 if (!ios->pages) {
433 if (ios->kern_buff) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700434 struct ore_per_dev_state *per_dev = &ios->per_dev[0];
Boaz Harroshb367e782010-02-07 19:18:58 +0200435
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700436 ore_calc_stripe_info(ios->layout, ios->offset, &si);
Boaz Harroshb367e782010-02-07 19:18:58 +0200437 per_dev->offset = si.obj_offset;
438 per_dev->dev = si.dev;
439
440 /* no cross device without page array */
441 BUG_ON((ios->layout->group_width > 1) &&
442 (si.unit_off + ios->length >
443 ios->layout->stripe_unit));
444 }
445 ios->numdevs = ios->layout->mirrors_p1;
446 return 0;
447 }
448
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200449 while (length) {
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700450 ore_calc_stripe_info(ios->layout, offset, &si);
Boaz Harrosh5002dd12010-08-02 20:06:46 +0300451
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200452 if (length < si.group_length)
453 si.group_length = length;
454
Boaz Harrosh6e316092010-07-29 17:08:13 +0300455 ret = _prepare_one_group(ios, si.group_length, &si);
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200456 if (unlikely(ret))
457 goto out;
458
Boaz Harrosh5002dd12010-08-02 20:06:46 +0300459 offset += si.group_length;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200460 length -= si.group_length;
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200461 }
462
463out:
464 return ret;
Boaz Harroshb367e782010-02-07 19:18:58 +0200465}
466
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700467int ore_create(struct ore_io_state *ios)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200468{
469 int i, ret;
470
Boaz Harrosh5bf696d2011-09-28 11:39:59 +0300471 for (i = 0; i < ios->oc->numdevs; i++) {
Boaz Harrosh06886a52009-11-08 14:54:08 +0200472 struct osd_request *or;
473
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700474 or = osd_start_request(_ios_od(ios, i), GFP_KERNEL);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200475 if (unlikely(!or)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700476 ORE_ERR("%s: osd_start_request failed\n", __func__);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200477 ret = -ENOMEM;
478 goto out;
479 }
480 ios->per_dev[i].or = or;
481 ios->numdevs++;
482
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700483 osd_req_create_object(or, _ios_obj(ios, i));
Boaz Harrosh06886a52009-11-08 14:54:08 +0200484 }
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700485 ret = ore_io_execute(ios);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200486
487out:
488 return ret;
489}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700490EXPORT_SYMBOL(ore_create);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200491
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700492int ore_remove(struct ore_io_state *ios)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200493{
494 int i, ret;
495
Boaz Harrosh5bf696d2011-09-28 11:39:59 +0300496 for (i = 0; i < ios->oc->numdevs; i++) {
Boaz Harrosh06886a52009-11-08 14:54:08 +0200497 struct osd_request *or;
498
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700499 or = osd_start_request(_ios_od(ios, i), GFP_KERNEL);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200500 if (unlikely(!or)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700501 ORE_ERR("%s: osd_start_request failed\n", __func__);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200502 ret = -ENOMEM;
503 goto out;
504 }
505 ios->per_dev[i].or = or;
506 ios->numdevs++;
507
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700508 osd_req_remove_object(or, _ios_obj(ios, i));
Boaz Harrosh06886a52009-11-08 14:54:08 +0200509 }
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700510 ret = ore_io_execute(ios);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200511
512out:
513 return ret;
514}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700515EXPORT_SYMBOL(ore_remove);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200516
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700517static int _write_mirror(struct ore_io_state *ios, int cur_comp)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200518{
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700519 struct ore_per_dev_state *master_dev = &ios->per_dev[cur_comp];
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200520 unsigned dev = ios->per_dev[cur_comp].dev;
521 unsigned last_comp = cur_comp + ios->layout->mirrors_p1;
522 int ret = 0;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200523
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200524 if (ios->pages && !master_dev->length)
525 return 0; /* Just an empty slot */
526
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200527 for (; cur_comp < last_comp; ++cur_comp, ++dev) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700528 struct ore_per_dev_state *per_dev = &ios->per_dev[cur_comp];
Boaz Harrosh06886a52009-11-08 14:54:08 +0200529 struct osd_request *or;
530
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700531 or = osd_start_request(_ios_od(ios, dev), GFP_KERNEL);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200532 if (unlikely(!or)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700533 ORE_ERR("%s: osd_start_request failed\n", __func__);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200534 ret = -ENOMEM;
535 goto out;
536 }
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200537 per_dev->or = or;
538 per_dev->offset = master_dev->offset;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200539
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200540 if (ios->pages) {
Boaz Harrosh06886a52009-11-08 14:54:08 +0200541 struct bio *bio;
542
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200543 if (per_dev != master_dev) {
Boaz Harrosh04dc1e82009-11-16 16:03:05 +0200544 bio = bio_kmalloc(GFP_KERNEL,
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200545 master_dev->bio->bi_max_vecs);
Boaz Harrosh04dc1e82009-11-16 16:03:05 +0200546 if (unlikely(!bio)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700547 ORE_DBGMSG(
Paul Bolle426d3102010-08-07 12:30:03 +0200548 "Failed to allocate BIO size=%u\n",
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200549 master_dev->bio->bi_max_vecs);
Boaz Harrosh04dc1e82009-11-16 16:03:05 +0200550 ret = -ENOMEM;
551 goto out;
552 }
553
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200554 __bio_clone(bio, master_dev->bio);
Boaz Harrosh04dc1e82009-11-16 16:03:05 +0200555 bio->bi_bdev = NULL;
556 bio->bi_next = NULL;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200557 per_dev->length = master_dev->length;
558 per_dev->bio = bio;
559 per_dev->dev = dev;
Boaz Harrosh04dc1e82009-11-16 16:03:05 +0200560 } else {
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200561 bio = master_dev->bio;
562 /* FIXME: bio_set_dir() */
Christoph Hellwig7b6d91d2010-08-07 18:20:39 +0200563 bio->bi_rw |= REQ_WRITE;
Boaz Harrosh04dc1e82009-11-16 16:03:05 +0200564 }
Boaz Harrosh06886a52009-11-08 14:54:08 +0200565
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700566 osd_req_write(or, _ios_obj(ios, dev), per_dev->offset,
567 bio, per_dev->length);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700568 ORE_DBGMSG("write(0x%llx) offset=0x%llx "
Boaz Harrosh34ce4e7c2009-12-15 19:34:17 +0200569 "length=0x%llx dev=%d\n",
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700570 _LLU(_ios_obj(ios, dev)->id),
571 _LLU(per_dev->offset),
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200572 _LLU(per_dev->length), dev);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200573 } else if (ios->kern_buff) {
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700574 ret = osd_req_write_kern(or, _ios_obj(ios, dev),
575 per_dev->offset,
576 ios->kern_buff, ios->length);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200577 if (unlikely(ret))
578 goto out;
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700579 ORE_DBGMSG2("write_kern(0x%llx) offset=0x%llx "
Boaz Harrosh34ce4e7c2009-12-15 19:34:17 +0200580 "length=0x%llx dev=%d\n",
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700581 _LLU(_ios_obj(ios, dev)->id),
582 _LLU(per_dev->offset),
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200583 _LLU(ios->length), dev);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200584 } else {
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700585 osd_req_set_attributes(or, _ios_obj(ios, dev));
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700586 ORE_DBGMSG2("obj(0x%llx) set_attributes=%d dev=%d\n",
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700587 _LLU(_ios_obj(ios, dev)->id),
588 ios->out_attr_len, dev);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200589 }
590
591 if (ios->out_attr)
592 osd_req_add_set_attr_list(or, ios->out_attr,
593 ios->out_attr_len);
594
595 if (ios->in_attr)
596 osd_req_add_get_attr_list(or, ios->in_attr,
597 ios->in_attr_len);
598 }
Boaz Harrosh06886a52009-11-08 14:54:08 +0200599
600out:
601 return ret;
602}
603
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700604int ore_write(struct ore_io_state *ios)
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200605{
606 int i;
607 int ret;
608
609 ret = _prepare_for_striping(ios);
610 if (unlikely(ret))
611 return ret;
612
613 for (i = 0; i < ios->numdevs; i += ios->layout->mirrors_p1) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700614 ret = _write_mirror(ios, i);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200615 if (unlikely(ret))
616 return ret;
617 }
618
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700619 ret = ore_io_execute(ios);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200620 return ret;
621}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700622EXPORT_SYMBOL(ore_write);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200623
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700624static int _read_mirror(struct ore_io_state *ios, unsigned cur_comp)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200625{
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200626 struct osd_request *or;
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700627 struct ore_per_dev_state *per_dev = &ios->per_dev[cur_comp];
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700628 struct osd_obj_id *obj = _ios_obj(ios, cur_comp);
629 unsigned first_dev = (unsigned)obj->id;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200630
Boaz Harrosh50a76fd2010-02-11 13:01:39 +0200631 if (ios->pages && !per_dev->length)
632 return 0; /* Just an empty slot */
633
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200634 first_dev = per_dev->dev + first_dev % ios->layout->mirrors_p1;
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700635 or = osd_start_request(_ios_od(ios, first_dev), GFP_KERNEL);
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200636 if (unlikely(!or)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700637 ORE_ERR("%s: osd_start_request failed\n", __func__);
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200638 return -ENOMEM;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200639 }
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200640 per_dev->or = or;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200641
Boaz Harrosh86093aa2010-01-28 18:24:06 +0200642 if (ios->pages) {
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700643 osd_req_read(or, obj, per_dev->offset,
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200644 per_dev->bio, per_dev->length);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700645 ORE_DBGMSG("read(0x%llx) offset=0x%llx length=0x%llx"
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700646 " dev=%d\n", _LLU(obj->id),
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200647 _LLU(per_dev->offset), _LLU(per_dev->length),
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200648 first_dev);
649 } else if (ios->kern_buff) {
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700650 int ret = osd_req_read_kern(or, obj, per_dev->offset,
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200651 ios->kern_buff, ios->length);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700652 ORE_DBGMSG2("read_kern(0x%llx) offset=0x%llx "
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200653 "length=0x%llx dev=%d ret=>%d\n",
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700654 _LLU(obj->id), _LLU(per_dev->offset),
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200655 _LLU(ios->length), first_dev, ret);
656 if (unlikely(ret))
657 return ret;
658 } else {
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700659 osd_req_get_attributes(or, obj);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700660 ORE_DBGMSG2("obj(0x%llx) get_attributes=%d dev=%d\n",
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700661 _LLU(obj->id),
662 ios->in_attr_len, first_dev);
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200663 }
Boaz Harrosh46f4d972010-02-01 11:37:30 +0200664 if (ios->out_attr)
665 osd_req_add_set_attr_list(or, ios->out_attr, ios->out_attr_len);
666
667 if (ios->in_attr)
668 osd_req_add_get_attr_list(or, ios->in_attr, ios->in_attr_len);
669
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200670 return 0;
671}
672
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700673int ore_read(struct ore_io_state *ios)
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200674{
675 int i;
676 int ret;
677
678 ret = _prepare_for_striping(ios);
679 if (unlikely(ret))
680 return ret;
681
682 for (i = 0; i < ios->numdevs; i += ios->layout->mirrors_p1) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700683 ret = _read_mirror(ios, i);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200684 if (unlikely(ret))
685 return ret;
686 }
687
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700688 ret = ore_io_execute(ios);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200689 return ret;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200690}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700691EXPORT_SYMBOL(ore_read);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200692
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700693int extract_attr_from_ios(struct ore_io_state *ios, struct osd_attr *attr)
Boaz Harroshb14f8ab2008-10-27 18:27:55 +0200694{
695 struct osd_attr cur_attr = {.attr_page = 0}; /* start with zeros */
696 void *iter = NULL;
697 int nelem;
698
699 do {
700 nelem = 1;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200701 osd_req_decode_get_attr_list(ios->per_dev[0].or,
702 &cur_attr, &nelem, &iter);
Boaz Harroshb14f8ab2008-10-27 18:27:55 +0200703 if ((cur_attr.attr_page == attr->attr_page) &&
704 (cur_attr.attr_id == attr->attr_id)) {
705 attr->len = cur_attr.len;
706 attr->val_ptr = cur_attr.val_ptr;
707 return 0;
708 }
709 } while (iter);
710
711 return -EIO;
712}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700713EXPORT_SYMBOL(extract_attr_from_ios);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200714
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700715static int _truncate_mirrors(struct ore_io_state *ios, unsigned cur_comp,
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200716 struct osd_attr *attr)
717{
718 int last_comp = cur_comp + ios->layout->mirrors_p1;
719
720 for (; cur_comp < last_comp; ++cur_comp) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700721 struct ore_per_dev_state *per_dev = &ios->per_dev[cur_comp];
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200722 struct osd_request *or;
723
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700724 or = osd_start_request(_ios_od(ios, cur_comp), GFP_KERNEL);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200725 if (unlikely(!or)) {
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700726 ORE_ERR("%s: osd_start_request failed\n", __func__);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200727 return -ENOMEM;
728 }
729 per_dev->or = or;
730
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700731 osd_req_set_attributes(or, _ios_obj(ios, cur_comp));
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200732 osd_req_add_set_attr_list(or, attr, 1);
733 }
734
735 return 0;
736}
737
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700738struct _trunc_info {
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700739 struct ore_striping_info si;
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700740 u64 prev_group_obj_off;
741 u64 next_group_obj_off;
742
743 unsigned first_group_dev;
744 unsigned nex_group_dev;
745 unsigned max_devs;
746};
747
H Hartley Sweeten1958c7c22011-09-23 13:42:43 -0700748static void _calc_trunk_info(struct ore_layout *layout, u64 file_offset,
749 struct _trunc_info *ti)
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700750{
751 unsigned stripe_unit = layout->stripe_unit;
752
Boaz Harrosheb507bc2011-08-10 14:17:28 -0700753 ore_calc_stripe_info(layout, file_offset, &ti->si);
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700754
755 ti->prev_group_obj_off = ti->si.M * stripe_unit;
756 ti->next_group_obj_off = ti->si.M ? (ti->si.M - 1) * stripe_unit : 0;
757
758 ti->first_group_dev = ti->si.dev - (ti->si.dev % layout->group_width);
759 ti->nex_group_dev = ti->first_group_dev + layout->group_width;
760 ti->max_devs = layout->group_width * layout->group_count;
761}
762
Boaz Harrosh5bf696d2011-09-28 11:39:59 +0300763int ore_truncate(struct ore_layout *layout, struct ore_components *oc,
Boaz Harrosh9e9db452011-08-05 15:06:04 -0700764 u64 size)
Boaz Harrosh06886a52009-11-08 14:54:08 +0200765{
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700766 struct ore_io_state *ios;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200767 struct exofs_trunc_attr {
768 struct osd_attr attr;
769 __be64 newsize;
770 } *size_attrs;
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700771 struct _trunc_info ti;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200772 int i, ret;
773
Boaz Harrosh5bf696d2011-09-28 11:39:59 +0300774 ret = ore_get_io_state(layout, oc, &ios);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200775 if (unlikely(ret))
776 return ret;
777
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700778 _calc_trunk_info(ios->layout, size, &ti);
779
780 size_attrs = kcalloc(ti.max_devs, sizeof(*size_attrs),
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200781 GFP_KERNEL);
782 if (unlikely(!size_attrs)) {
783 ret = -ENOMEM;
784 goto out;
785 }
Boaz Harrosh06886a52009-11-08 14:54:08 +0200786
Boaz Harrosh5bf696d2011-09-28 11:39:59 +0300787 ios->numdevs = ios->oc->numdevs;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200788
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700789 for (i = 0; i < ti.max_devs; ++i) {
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200790 struct exofs_trunc_attr *size_attr = &size_attrs[i];
791 u64 obj_size;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200792
Boaz Harrosh16f75bb2011-08-03 20:44:16 -0700793 if (i < ti.first_group_dev)
794 obj_size = ti.prev_group_obj_off;
795 else if (i >= ti.nex_group_dev)
796 obj_size = ti.next_group_obj_off;
797 else if (i < ti.si.dev) /* dev within this group */
798 obj_size = ti.si.obj_offset +
799 ios->layout->stripe_unit - ti.si.unit_off;
800 else if (i == ti.si.dev)
801 obj_size = ti.si.obj_offset;
802 else /* i > ti.dev */
803 obj_size = ti.si.obj_offset - ti.si.unit_off;
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200804
805 size_attr->newsize = cpu_to_be64(obj_size);
806 size_attr->attr = g_attr_logical_length;
807 size_attr->attr.val_ptr = &size_attr->newsize;
808
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700809 ORE_DBGMSG("trunc(0x%llx) obj_offset=0x%llx dev=%d\n",
Boaz Harrosh5bf696d2011-09-28 11:39:59 +0300810 _LLU(oc->comps->obj.id), _LLU(obj_size), i);
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200811 ret = _truncate_mirrors(ios, i * ios->layout->mirrors_p1,
812 &size_attr->attr);
813 if (unlikely(ret))
Boaz Harrosh06886a52009-11-08 14:54:08 +0200814 goto out;
Boaz Harrosh06886a52009-11-08 14:54:08 +0200815 }
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700816 ret = ore_io_execute(ios);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200817
818out:
Boaz Harrosh5d952b82010-02-01 13:35:51 +0200819 kfree(size_attrs);
Boaz Harrosh8ff660a2011-08-06 19:26:31 -0700820 ore_put_io_state(ios);
Boaz Harrosh06886a52009-11-08 14:54:08 +0200821 return ret;
822}
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700823EXPORT_SYMBOL(ore_truncate);
Boaz Harrosh85e44df2011-05-16 15:26:47 +0300824
825const struct osd_attr g_attr_logical_length = ATTR_DEF(
826 OSD_APAGE_OBJECT_INFORMATION, OSD_ATTR_OI_LOGICAL_LENGTH, 8);
Boaz Harroshcf283ad2011-08-06 19:22:06 -0700827EXPORT_SYMBOL(g_attr_logical_length);