udf_strat_sequential.c revision 1.5 1 /* $NetBSD: udf_strat_sequential.c,v 1.5 2008/08/29 15:04:18 reinoud Exp $ */
2
3 /*
4 * Copyright (c) 2006, 2008 Reinoud Zandijk
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 *
27 */
28
29 #include <sys/cdefs.h>
30 #ifndef lint
31 __KERNEL_RCSID(0, "$NetBSD: udf_strat_sequential.c,v 1.5 2008/08/29 15:04:18 reinoud Exp $");
32 #endif /* not lint */
33
34
35 #if defined(_KERNEL_OPT)
36 #include "opt_quota.h"
37 #include "opt_compat_netbsd.h"
38 #endif
39
40 #include <sys/param.h>
41 #include <sys/systm.h>
42 #include <sys/sysctl.h>
43 #include <sys/namei.h>
44 #include <sys/proc.h>
45 #include <sys/kernel.h>
46 #include <sys/vnode.h>
47 #include <miscfs/genfs/genfs_node.h>
48 #include <sys/mount.h>
49 #include <sys/buf.h>
50 #include <sys/file.h>
51 #include <sys/device.h>
52 #include <sys/disklabel.h>
53 #include <sys/ioctl.h>
54 #include <sys/malloc.h>
55 #include <sys/dirent.h>
56 #include <sys/stat.h>
57 #include <sys/conf.h>
58 #include <sys/kauth.h>
59 #include <sys/kthread.h>
60 #include <dev/clock_subr.h>
61
62 #include <fs/udf/ecma167-udf.h>
63 #include <fs/udf/udf_mount.h>
64
65 #include "udf.h"
66 #include "udf_subr.h"
67 #include "udf_bswap.h"
68
69
70 #define VTOI(vnode) ((struct udf_node *) vnode->v_data)
71 #define PRIV(ump) ((struct strat_private *) ump->strategy_private)
72
73 /* --------------------------------------------------------------------- */
74
75 /* BUFQ's */
76 #define UDF_SHED_MAX 3
77
78 #define UDF_SHED_READING 0
79 #define UDF_SHED_WRITING 1
80 #define UDF_SHED_SEQWRITING 2
81
82 struct strat_private {
83 struct pool desc_pool; /* node descriptors */
84
85 lwp_t *queue_lwp;
86 kcondvar_t discstrat_cv; /* to wait on */
87 kmutex_t discstrat_mutex; /* disc strategy */
88
89 int run_thread; /* thread control */
90 int cur_queue;
91
92 struct disk_strategy old_strategy_setting;
93 struct bufq_state *queues[UDF_SHED_MAX];
94 struct timespec last_queued[UDF_SHED_MAX];
95 };
96
97
98 /* --------------------------------------------------------------------- */
99
100 static void
101 udf_wr_nodedscr_callback(struct buf *buf)
102 {
103 struct udf_node *udf_node;
104
105 KASSERT(buf);
106 KASSERT(buf->b_data);
107
108 /* called when write action is done */
109 DPRINTF(WRITE, ("udf_wr_nodedscr_callback(): node written out\n"));
110
111 udf_node = VTOI(buf->b_vp);
112 if (udf_node == NULL) {
113 putiobuf(buf);
114 printf("udf_wr_node_callback: NULL node?\n");
115 return;
116 }
117
118 /* XXX right flags to mark dirty again on error? */
119 if (buf->b_error) {
120 udf_node->i_flags |= IN_MODIFIED | IN_ACCESSED;
121 /* XXX TODO reshedule on error */
122 }
123
124 /* decrement outstanding_nodedscr */
125 KASSERT(udf_node->outstanding_nodedscr >= 1);
126 udf_node->outstanding_nodedscr--;
127 if (udf_node->outstanding_nodedscr == 0) {
128 /* first unlock the node */
129 KASSERT(udf_node->i_flags & IN_CALLBACK_ULK);
130 UDF_UNLOCK_NODE(udf_node, IN_CALLBACK_ULK);
131
132 wakeup(&udf_node->outstanding_nodedscr);
133 }
134
135 /* unreference the vnode so it can be recycled */
136 holdrele(udf_node->vnode);
137
138 putiobuf(buf);
139 }
140
141 /* --------------------------------------------------------------------- */
142
143 static int
144 udf_create_logvol_dscr_seq(struct udf_strat_args *args)
145 {
146 union dscrptr **dscrptr = &args->dscr;
147 struct udf_mount *ump = args->ump;
148 struct strat_private *priv = PRIV(ump);
149 uint32_t lb_size;
150
151 lb_size = udf_rw32(ump->logical_vol->lb_size);
152 *dscrptr = pool_get(&priv->desc_pool, PR_WAITOK);
153 memset(*dscrptr, 0, lb_size);
154
155 return 0;
156 }
157
158
159 static void
160 udf_free_logvol_dscr_seq(struct udf_strat_args *args)
161 {
162 union dscrptr *dscr = args->dscr;
163 struct udf_mount *ump = args->ump;
164 struct strat_private *priv = PRIV(ump);
165
166 pool_put(&priv->desc_pool, dscr);
167 }
168
169
170 static int
171 udf_read_logvol_dscr_seq(struct udf_strat_args *args)
172 {
173 union dscrptr **dscrptr = &args->dscr;
174 union dscrptr *tmpdscr;
175 struct udf_mount *ump = args->ump;
176 struct long_ad *icb = args->icb;
177 struct strat_private *priv = PRIV(ump);
178 uint32_t lb_size;
179 uint32_t sector, dummy;
180 int error;
181
182 lb_size = udf_rw32(ump->logical_vol->lb_size);
183
184 error = udf_translate_vtop(ump, icb, §or, &dummy);
185 if (error)
186 return error;
187
188 /* try to read in fe/efe */
189 error = udf_read_phys_dscr(ump, sector, M_UDFTEMP, &tmpdscr);
190 if (error)
191 return error;
192
193 *dscrptr = pool_get(&priv->desc_pool, PR_WAITOK);
194 memcpy(*dscrptr, tmpdscr, lb_size);
195 free(tmpdscr, M_UDFTEMP);
196
197 return 0;
198 }
199
200
201 static int
202 udf_write_logvol_dscr_seq(struct udf_strat_args *args)
203 {
204 union dscrptr *dscr = args->dscr;
205 struct udf_mount *ump = args->ump;
206 struct udf_node *udf_node = args->udf_node;
207 struct long_ad *icb = args->icb;
208 int waitfor = args->waitfor;
209 uint32_t logsectornr, sectornr, dummy;
210 int error, vpart;
211
212 /*
213 * we have to decide if we write it out sequential or at its fixed
214 * position by examining the partition its (to be) written on.
215 */
216 vpart = udf_rw16(udf_node->loc.loc.part_num);
217 logsectornr = udf_rw32(icb->loc.lb_num);
218 sectornr = 0;
219 if (ump->vtop_tp[vpart] != UDF_VTOP_TYPE_VIRT) {
220 error = udf_translate_vtop(ump, icb, §ornr, &dummy);
221 if (error)
222 goto out;
223 }
224
225 /* add reference to the vnode to prevent recycling */
226 vhold(udf_node->vnode);
227
228 if (waitfor) {
229 DPRINTF(WRITE, ("udf_write_logvol_dscr: sync write\n"));
230
231 error = udf_write_phys_dscr_sync(ump, udf_node, UDF_C_NODE,
232 dscr, sectornr, logsectornr);
233 } else {
234 DPRINTF(WRITE, ("udf_write_logvol_dscr: no wait, async write\n"));
235
236 error = udf_write_phys_dscr_async(ump, udf_node, UDF_C_NODE,
237 dscr, sectornr, logsectornr, udf_wr_nodedscr_callback);
238 /* will be UNLOCKED in call back */
239 return error;
240 }
241
242 holdrele(udf_node->vnode);
243 out:
244 udf_node->outstanding_nodedscr--;
245 if (udf_node->outstanding_nodedscr == 0) {
246 UDF_UNLOCK_NODE(udf_node, 0);
247 wakeup(&udf_node->outstanding_nodedscr);
248 }
249
250 return error;
251 }
252
253 /* --------------------------------------------------------------------- */
254
255 /*
256 * Main file-system specific sheduler. Due to the nature of optical media
257 * sheduling can't be performed in the traditional way. Most OS
258 * implementations i've seen thus read or write a file atomically giving all
259 * kinds of side effects.
260 *
261 * This implementation uses a kernel thread to shedule the queued requests in
262 * such a way that is semi-optimal for optical media; this means aproximately
263 * (R*|(Wr*|Ws*))* since switching between reading and writing is expensive in
264 * time.
265 */
266
267 static void
268 udf_queuebuf_seq(struct udf_strat_args *args)
269 {
270 struct udf_mount *ump = args->ump;
271 struct buf *nestbuf = args->nestbuf;
272 struct strat_private *priv = PRIV(ump);
273 int queue;
274 int what;
275
276 KASSERT(ump);
277 KASSERT(nestbuf);
278 KASSERT(nestbuf->b_iodone == nestiobuf_iodone);
279
280 what = nestbuf->b_udf_c_type;
281 queue = UDF_SHED_READING;
282 if ((nestbuf->b_flags & B_READ) == 0) {
283 /* writing */
284 queue = UDF_SHED_SEQWRITING;
285 if (what == UDF_C_DSCR)
286 queue = UDF_SHED_WRITING;
287 #if 0
288 if (queue == UDF_SHED_SEQWRITING) {
289 /* TODO do add sector to uncommitted space */
290 }
291 #endif
292 }
293
294 /* use our own sheduler lists for more complex sheduling */
295 mutex_enter(&priv->discstrat_mutex);
296 BUFQ_PUT(priv->queues[queue], nestbuf);
297 vfs_timestamp(&priv->last_queued[queue]);
298 mutex_exit(&priv->discstrat_mutex);
299
300 /* signal our thread that there might be something to do */
301 cv_signal(&priv->discstrat_cv);
302 }
303
304 /* --------------------------------------------------------------------- */
305
306 /* TODO convert to lb_size */
307 static void
308 udf_VAT_mapping_update(struct udf_mount *ump, struct buf *buf, uint32_t lb_map)
309 {
310 union dscrptr *fdscr = (union dscrptr *) buf->b_data;
311 struct vnode *vp = buf->b_vp;
312 struct udf_node *udf_node = VTOI(vp);
313 uint32_t lb_size, blks;
314 uint32_t lb_num;
315 uint32_t udf_rw32_lbmap;
316 int c_type = buf->b_udf_c_type;
317 int error;
318
319 /* only interested when we're using a VAT */
320 KASSERT(ump->vat_node);
321 KASSERT(ump->vtop_alloc[ump->node_part] == UDF_ALLOC_VAT);
322
323 /* only nodes are recorded in the VAT */
324 /* NOTE: and the fileset descriptor (FIXME ?) */
325 if (c_type != UDF_C_NODE)
326 return;
327
328 /* we now have an UDF FE/EFE node on media with VAT (or VAT itself) */
329 lb_size = udf_rw32(ump->logical_vol->lb_size);
330 blks = lb_size / DEV_BSIZE;
331
332 udf_rw32_lbmap = udf_rw32(lb_map);
333
334 /* if we're the VAT itself, only update our assigned sector number */
335 if (udf_node == ump->vat_node) {
336 fdscr->tag.tag_loc = udf_rw32_lbmap;
337 udf_validate_tag_sum(fdscr);
338 DPRINTF(TRANSLATE, ("VAT assigned to sector %u\n",
339 udf_rw32(udf_rw32_lbmap)));
340 /* no use mapping the VAT node in the VAT */
341 return;
342 }
343
344 /* record new position in VAT file */
345 lb_num = udf_rw32(fdscr->tag.tag_loc);
346
347 /* lb_num = udf_rw32(udf_node->write_loc.loc.lb_num); */
348
349 DPRINTF(TRANSLATE, ("VAT entry change (log %u -> phys %u)\n",
350 lb_num, lb_map));
351
352 /* VAT should be the longer than this write, can't go wrong */
353 KASSERT(lb_num <= ump->vat_entries);
354
355 mutex_enter(&ump->allocate_mutex);
356 error = udf_vat_write(ump->vat_node,
357 (uint8_t *) &udf_rw32_lbmap, 4,
358 ump->vat_offset + lb_num * 4);
359 mutex_exit(&ump->allocate_mutex);
360
361 if (error)
362 panic( "udf_VAT_mapping_update: HELP! i couldn't "
363 "write in the VAT file ?\n");
364 }
365
366
367 static void
368 udf_issue_buf(struct udf_mount *ump, int queue, struct buf *buf)
369 {
370 struct long_ad *node_ad_cpy;
371 struct part_desc *pdesc;
372 uint64_t *lmapping, *lmappos, blknr;
373 uint32_t our_sectornr, sectornr, bpos;
374 uint32_t ptov;
375 uint16_t vpart_num;
376 uint8_t *fidblk;
377 int sector_size = ump->discinfo.sector_size;
378 int blks = sector_size / DEV_BSIZE;
379 int len, buf_len;
380
381 /* if reading, just pass to the device's STRATEGY */
382 if (queue == UDF_SHED_READING) {
383 DPRINTF(SHEDULE, ("\nudf_issue_buf READ %p : sector %d type %d,"
384 "b_resid %d, b_bcount %d, b_bufsize %d\n",
385 buf, (uint32_t) buf->b_blkno / blks, buf->b_udf_c_type,
386 buf->b_resid, buf->b_bcount, buf->b_bufsize));
387 VOP_STRATEGY(ump->devvp, buf);
388 return;
389 }
390
391 blknr = buf->b_blkno;
392 our_sectornr = blknr / blks;
393
394 if (queue == UDF_SHED_WRITING) {
395 DPRINTF(SHEDULE, ("\nudf_issue_buf WRITE %p : sector %d "
396 "type %d, b_resid %d, b_bcount %d, b_bufsize %d\n",
397 buf, (uint32_t) buf->b_blkno / blks, buf->b_udf_c_type,
398 buf->b_resid, buf->b_bcount, buf->b_bufsize));
399 /* if we have FIDs fixup using buffer's sector number(s) */
400 if (buf->b_udf_c_type == UDF_C_FIDS) {
401 panic("UDF_C_FIDS in SHED_WRITING!\n");
402 buf_len = buf->b_bcount;
403 sectornr = our_sectornr;
404 bpos = 0;
405 while (buf_len) {
406 len = MIN(buf_len, sector_size);
407 fidblk = (uint8_t *) buf->b_data + bpos;
408 udf_fixup_fid_block(fidblk, sector_size,
409 0, len, sectornr);
410 sectornr++;
411 bpos += len;
412 buf_len -= len;
413 }
414 }
415 udf_fixup_node_internals(ump, buf->b_data, buf->b_udf_c_type);
416 VOP_STRATEGY(ump->devvp, buf);
417 return;
418 }
419
420 KASSERT(queue == UDF_SHED_SEQWRITING);
421 DPRINTF(SHEDULE, ("\nudf_issue_buf SEQWRITE %p : sector XXXX "
422 "type %d, b_resid %d, b_bcount %d, b_bufsize %d\n",
423 buf, buf->b_udf_c_type, buf->b_resid, buf->b_bcount,
424 buf->b_bufsize));
425
426 /*
427 * Buffers should not have been allocated to disc addresses yet on
428 * this queue. Note that a buffer can get multiple extents allocated.
429 *
430 * lmapping contains lb_num relative to base partition.
431 */
432 lmapping = ump->la_lmapping;
433 node_ad_cpy = ump->la_node_ad_cpy;
434
435 /* logically allocate buf and map it in the file */
436 udf_late_allocate_buf(ump, buf, lmapping, node_ad_cpy, &vpart_num);
437
438 /* update mapping in the VAT */
439 udf_VAT_mapping_update(ump, buf, *lmapping);
440
441 /*
442 * NOTE We are using the knowledge here that sequential media will
443 * always be mapped linearly. Thus no use to explicitly translate the
444 * lmapping list.
445 */
446
447 /* calculate offset from physical base partition */
448 pdesc = ump->partitions[ump->vtop[vpart_num]];
449 ptov = udf_rw32(pdesc->start_loc);
450
451 /* set buffers blkno to the physical block number */
452 buf->b_blkno = (*lmapping + ptov) * blks;
453
454 /* if we have FIDs, fixup using the new allocation table */
455 if (buf->b_udf_c_type == UDF_C_FIDS) {
456 buf_len = buf->b_bcount;
457 bpos = 0;
458 lmappos = lmapping;
459 while (buf_len) {
460 sectornr = *lmappos++;
461 len = MIN(buf_len, sector_size);
462 fidblk = (uint8_t *) buf->b_data + bpos;
463 udf_fixup_fid_block(fidblk, sector_size,
464 0, len, sectornr);
465 bpos += len;
466 buf_len -= len;
467 }
468 }
469
470 /* NOTE we can't have metadata space bitmap descriptors here */
471
472 udf_fixup_node_internals(ump, buf->b_data, buf->b_udf_c_type);
473 VOP_STRATEGY(ump->devvp, buf);
474 }
475
476
477 static void
478 udf_doshedule(struct udf_mount *ump)
479 {
480 struct buf *buf;
481 struct timespec now, *last;
482 struct strat_private *priv = PRIV(ump);
483 void (*b_callback)(struct buf *);
484 int new_queue;
485 int error;
486
487 buf = BUFQ_GET(priv->queues[priv->cur_queue]);
488 if (buf) {
489 /* transfer from the current queue to the device queue */
490 mutex_exit(&priv->discstrat_mutex);
491
492 /* transform buffer to synchronous; XXX needed? */
493 b_callback = buf->b_iodone;
494 buf->b_iodone = NULL;
495 CLR(buf->b_flags, B_ASYNC);
496
497 /* issue and wait on completion */
498 udf_issue_buf(ump, priv->cur_queue, buf);
499 biowait(buf);
500
501 mutex_enter(&priv->discstrat_mutex);
502
503 /* if there is an error, repair this error, otherwise propagate */
504 if (buf->b_error && ((buf->b_flags & B_READ) == 0)) {
505 /* check what we need to do */
506 panic("UDF write error, can't handle yet!\n");
507 }
508
509 /* propagate result to higher layers */
510 if (b_callback) {
511 buf->b_iodone = b_callback;
512 (*buf->b_iodone)(buf);
513 }
514
515 return;
516 }
517
518 /* Check if we're idling in this state */
519 vfs_timestamp(&now);
520 last = &priv->last_queued[priv->cur_queue];
521 if (ump->discinfo.mmc_class == MMC_CLASS_CD) {
522 /* dont switch too fast for CD media; its expensive in time */
523 if (now.tv_sec - last->tv_sec < 3)
524 return;
525 }
526
527 /* check if we can/should switch */
528 new_queue = priv->cur_queue;
529
530 if (BUFQ_PEEK(priv->queues[UDF_SHED_READING]))
531 new_queue = UDF_SHED_READING;
532 if (BUFQ_PEEK(priv->queues[UDF_SHED_SEQWRITING]))
533 new_queue = UDF_SHED_SEQWRITING;
534 if (BUFQ_PEEK(priv->queues[UDF_SHED_WRITING])) /* only for unmount */
535 new_queue = UDF_SHED_WRITING;
536 if (priv->cur_queue == UDF_SHED_READING) {
537 if (new_queue == UDF_SHED_SEQWRITING) {
538 /* TODO use flag to signal if this is needed */
539 mutex_exit(&priv->discstrat_mutex);
540
541 /* update trackinfo for data and metadata */
542 error = udf_update_trackinfo(ump,
543 &ump->data_track);
544 assert(error == 0);
545 error = udf_update_trackinfo(ump,
546 &ump->metadata_track);
547 assert(error == 0);
548 mutex_enter(&priv->discstrat_mutex);
549 }
550 }
551
552 if (new_queue != priv->cur_queue) {
553 DPRINTF(SHEDULE, ("switching from %d to %d\n",
554 priv->cur_queue, new_queue));
555 }
556
557 priv->cur_queue = new_queue;
558 }
559
560
561 static void
562 udf_discstrat_thread(void *arg)
563 {
564 struct udf_mount *ump = (struct udf_mount *) arg;
565 struct strat_private *priv = PRIV(ump);
566 int empty;
567
568 empty = 1;
569 mutex_enter(&priv->discstrat_mutex);
570 while (priv->run_thread || !empty) {
571 /* process the current selected queue */
572 udf_doshedule(ump);
573 empty = (BUFQ_PEEK(priv->queues[UDF_SHED_READING]) == NULL);
574 empty &= (BUFQ_PEEK(priv->queues[UDF_SHED_WRITING]) == NULL);
575 empty &= (BUFQ_PEEK(priv->queues[UDF_SHED_SEQWRITING]) == NULL);
576
577 /* wait for more if needed */
578 if (empty)
579 cv_timedwait(&priv->discstrat_cv,
580 &priv->discstrat_mutex, hz/8);
581 }
582 mutex_exit(&priv->discstrat_mutex);
583
584 wakeup(&priv->run_thread);
585 kthread_exit(0);
586 /* not reached */
587 }
588
589 /* --------------------------------------------------------------------- */
590
591 static void
592 udf_discstrat_init_seq(struct udf_strat_args *args)
593 {
594 struct udf_mount *ump = args->ump;
595 struct strat_private *priv = PRIV(ump);
596 struct disk_strategy dkstrat;
597 uint32_t lb_size;
598
599 KASSERT(ump);
600 KASSERT(ump->logical_vol);
601 KASSERT(priv == NULL);
602
603 lb_size = udf_rw32(ump->logical_vol->lb_size);
604 KASSERT(lb_size > 0);
605
606 /* initialise our memory space */
607 ump->strategy_private = malloc(sizeof(struct strat_private),
608 M_UDFTEMP, M_WAITOK);
609 priv = ump->strategy_private;
610 memset(priv, 0 , sizeof(struct strat_private));
611
612 /* initialise locks */
613 cv_init(&priv->discstrat_cv, "udfstrat");
614 mutex_init(&priv->discstrat_mutex, MUTEX_DEFAULT, IPL_NONE);
615
616 /*
617 * Initialise pool for descriptors associated with nodes. This is done
618 * in lb_size units though currently lb_size is dictated to be
619 * sector_size.
620 */
621 pool_init(&priv->desc_pool, lb_size, 0, 0, 0, "udf_desc_pool", NULL,
622 IPL_NONE);
623
624 /*
625 * remember old device strategy method and explicit set method
626 * `discsort' since we have our own more complex strategy that is not
627 * implementable on the CD device and other strategies will get in the
628 * way.
629 */
630 memset(&priv->old_strategy_setting, 0,
631 sizeof(struct disk_strategy));
632 VOP_IOCTL(ump->devvp, DIOCGSTRATEGY, &priv->old_strategy_setting,
633 FREAD | FKIOCTL, NOCRED);
634 memset(&dkstrat, 0, sizeof(struct disk_strategy));
635 strcpy(dkstrat.dks_name, "discsort");
636 VOP_IOCTL(ump->devvp, DIOCSSTRATEGY, &dkstrat, FWRITE | FKIOCTL,
637 NOCRED);
638
639 /* initialise our internal sheduler */
640 priv->cur_queue = UDF_SHED_READING;
641 bufq_alloc(&priv->queues[UDF_SHED_READING], "disksort",
642 BUFQ_SORT_RAWBLOCK);
643 bufq_alloc(&priv->queues[UDF_SHED_WRITING], "disksort",
644 BUFQ_SORT_RAWBLOCK);
645 bufq_alloc(&priv->queues[UDF_SHED_SEQWRITING], "fcfs", 0);
646 vfs_timestamp(&priv->last_queued[UDF_SHED_READING]);
647 vfs_timestamp(&priv->last_queued[UDF_SHED_WRITING]);
648 vfs_timestamp(&priv->last_queued[UDF_SHED_SEQWRITING]);
649
650 /* create our disk strategy thread */
651 priv->run_thread = 1;
652 if (kthread_create(PRI_NONE, 0 /* KTHREAD_MPSAFE*/, NULL /* cpu_info*/,
653 udf_discstrat_thread, ump, &priv->queue_lwp,
654 "%s", "udf_rw")) {
655 panic("fork udf_rw");
656 }
657 }
658
659
660 static void
661 udf_discstrat_finish_seq(struct udf_strat_args *args)
662 {
663 struct udf_mount *ump = args->ump;
664 struct strat_private *priv = PRIV(ump);
665 int error;
666
667 if (ump == NULL)
668 return;
669
670 /* stop our sheduling thread */
671 KASSERT(priv->run_thread == 1);
672 priv->run_thread = 0;
673 wakeup(priv->queue_lwp);
674 do {
675 error = tsleep(&priv->run_thread, PRIBIO+1,
676 "udfshedfin", hz);
677 } while (error);
678 /* kthread should be finished now */
679
680 /* set back old device strategy method */
681 VOP_IOCTL(ump->devvp, DIOCSSTRATEGY, &priv->old_strategy_setting,
682 FWRITE, NOCRED);
683
684 /* destroy our pool */
685 pool_destroy(&priv->desc_pool);
686
687 /* free our private space */
688 free(ump->strategy_private, M_UDFTEMP);
689 ump->strategy_private = NULL;
690 }
691
692 /* --------------------------------------------------------------------- */
693
694 struct udf_strategy udf_strat_sequential =
695 {
696 udf_create_logvol_dscr_seq,
697 udf_free_logvol_dscr_seq,
698 udf_read_logvol_dscr_seq,
699 udf_write_logvol_dscr_seq,
700 udf_queuebuf_seq,
701 udf_discstrat_init_seq,
702 udf_discstrat_finish_seq
703 };
704
705
706