Commit | Line | Data |
---|---|---|
025a70ed JR |
1 | /* |
2 | * linux/fs/nfs/blocklayout/blocklayoutdm.c | |
3 | * | |
4 | * Module for the NFSv4.1 pNFS block layout driver. | |
5 | * | |
6 | * Copyright (c) 2007 The Regents of the University of Michigan. | |
7 | * All rights reserved. | |
8 | * | |
9 | * Fred Isaman <iisaman@umich.edu> | |
10 | * Andy Adamson <andros@citi.umich.edu> | |
11 | * | |
12 | * permission is granted to use, copy, create derivative works and | |
13 | * redistribute this software and such derivative works for any purpose, | |
14 | * so long as the name of the university of michigan is not used in | |
15 | * any advertising or publicity pertaining to the use or distribution | |
16 | * of this software without specific, written prior authorization. if | |
17 | * the above copyright notice or any other identification of the | |
18 | * university of michigan is included in any copy of any portion of | |
19 | * this software, then the disclaimer below must also be included. | |
20 | * | |
21 | * this software is provided as is, without representation from the | |
22 | * university of michigan as to its fitness for any purpose, and without | |
23 | * warranty by the university of michigan of any kind, either express | |
24 | * or implied, including without limitation the implied warranties of | |
25 | * merchantability and fitness for a particular purpose. the regents | |
26 | * of the university of michigan shall not be liable for any damages, | |
27 | * including special, indirect, incidental, or consequential damages, | |
28 | * with respect to any claim arising out or in connection with the use | |
29 | * of the software, even if it has been or is hereafter advised of the | |
30 | * possibility of such damages. | |
31 | */ | |
32 | ||
33 | #include <linux/genhd.h> /* gendisk - used in a dprintk*/ | |
34 | #include <linux/sched.h> | |
35 | #include <linux/hash.h> | |
36 | ||
37 | #include "blocklayout.h" | |
38 | ||
39 | #define NFSDBG_FACILITY NFSDBG_PNFS_LD | |
40 | ||
9e2e74db | 41 | static void dev_remove(struct net *net, dev_t dev) |
025a70ed JR |
42 | { |
43 | struct rpc_pipe_msg msg; | |
44 | struct bl_dev_msg bl_umount_request; | |
45 | struct bl_msg_hdr bl_msg = { | |
46 | .type = BL_DEVICE_UMOUNT, | |
47 | .totallen = sizeof(bl_umount_request), | |
48 | }; | |
49 | uint8_t *dataptr; | |
50 | DECLARE_WAITQUEUE(wq, current); | |
9e2e74db | 51 | struct nfs_net *nn = net_generic(net, nfs_net_id); |
025a70ed JR |
52 | |
53 | dprintk("Entering %s\n", __func__); | |
54 | ||
55 | memset(&msg, 0, sizeof(msg)); | |
56 | msg.data = kzalloc(1 + sizeof(bl_umount_request), GFP_NOFS); | |
57 | if (!msg.data) | |
58 | goto out; | |
59 | ||
60 | memset(&bl_umount_request, 0, sizeof(bl_umount_request)); | |
61 | bl_umount_request.major = MAJOR(dev); | |
62 | bl_umount_request.minor = MINOR(dev); | |
63 | ||
64 | memcpy(msg.data, &bl_msg, sizeof(bl_msg)); | |
65 | dataptr = (uint8_t *) msg.data; | |
66 | memcpy(&dataptr[sizeof(bl_msg)], &bl_umount_request, sizeof(bl_umount_request)); | |
67 | msg.len = sizeof(bl_msg) + bl_msg.totallen; | |
68 | ||
69 | add_wait_queue(&bl_wq, &wq); | |
9e2e74db | 70 | if (rpc_queue_upcall(nn->bl_device_pipe, &msg) < 0) { |
025a70ed JR |
71 | remove_wait_queue(&bl_wq, &wq); |
72 | goto out; | |
73 | } | |
74 | ||
75 | set_current_state(TASK_UNINTERRUPTIBLE); | |
76 | schedule(); | |
77 | __set_current_state(TASK_RUNNING); | |
78 | remove_wait_queue(&bl_wq, &wq); | |
79 | ||
80 | out: | |
81 | kfree(msg.data); | |
82 | } | |
83 | ||
84 | /* | |
85 | * Release meta device | |
86 | */ | |
87 | static void nfs4_blk_metadev_release(struct pnfs_block_dev *bdev) | |
88 | { | |
89 | int rv; | |
90 | ||
91 | dprintk("%s Releasing\n", __func__); | |
92 | rv = nfs4_blkdev_put(bdev->bm_mdev); | |
93 | if (rv) | |
a030889a | 94 | printk(KERN_ERR "NFS: %s nfs4_blkdev_put returns %d\n", |
025a70ed JR |
95 | __func__, rv); |
96 | ||
9e2e74db | 97 | dev_remove(bdev->net, bdev->bm_mdev->bd_dev); |
025a70ed JR |
98 | } |
99 | ||
100 | void bl_free_block_dev(struct pnfs_block_dev *bdev) | |
101 | { | |
102 | if (bdev) { | |
103 | if (bdev->bm_mdev) { | |
104 | dprintk("%s Removing DM device: %d:%d\n", | |
105 | __func__, | |
106 | MAJOR(bdev->bm_mdev->bd_dev), | |
107 | MINOR(bdev->bm_mdev->bd_dev)); | |
108 | nfs4_blk_metadev_release(bdev); | |
109 | } | |
110 | kfree(bdev); | |
111 | } | |
112 | } |