2 * linux/fs/nfsd/nfs4recover.c
4 * Copyright (c) 2004 The Regents of the University of Michigan.
7 * Andy Adamson <andros@citi.umich.edu>
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted provided that the following conditions
13 * 1. Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright
16 * notice, this list of conditions and the following disclaimer in the
17 * documentation and/or other materials provided with the distribution.
18 * 3. Neither the name of the University nor the names of its
19 * contributors may be used to endorse or promote products derived
20 * from this software without specific prior written permission.
22 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
23 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
24 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
25 * DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
27 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
28 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
29 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
30 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
31 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
32 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
36 #include <linux/err.h>
37 #include <linux/sunrpc/svc.h>
38 #include <linux/nfsd/nfsd.h>
39 #include <linux/nfs4.h>
40 #include <linux/nfsd/state.h>
41 #include <linux/nfsd/xdr4.h>
42 #include <linux/param.h>
43 #include <linux/file.h>
44 #include <linux/namei.h>
45 #include <asm/uaccess.h>
46 #include <linux/scatterlist.h>
47 #include <linux/crypto.h>
48 #include <linux/sched.h>
49 #include <linux/mount.h>
51 #define NFSDDBG_FACILITY NFSDDBG_PROC
54 static struct path rec_dir
;
55 static int rec_dir_init
= 0;
58 nfs4_save_creds(const struct cred
**original_creds
)
62 new = prepare_creds();
68 *original_creds
= override_creds(new);
74 nfs4_reset_creds(const struct cred
*original
)
76 revert_creds(original
);
80 md5_to_hex(char *out
, char *md5
)
84 for (i
=0; i
<16; i
++) {
85 unsigned char c
= md5
[i
];
87 *out
++ = '0' + ((c
&0xf0)>>4) + (c
>=0xa0)*('a'-'9'-1);
88 *out
++ = '0' + (c
&0x0f) + ((c
&0x0f)>=0x0a)*('a'-'9'-1);
94 nfs4_make_rec_clidname(char *dname
, struct xdr_netobj
*clname
)
96 struct xdr_netobj cksum
;
97 struct hash_desc desc
;
98 struct scatterlist sg
;
99 __be32 status
= nfserr_resource
;
101 dprintk("NFSD: nfs4_make_rec_clidname for %.*s\n",
102 clname
->len
, clname
->data
);
103 desc
.flags
= CRYPTO_TFM_REQ_MAY_SLEEP
;
104 desc
.tfm
= crypto_alloc_hash("md5", 0, CRYPTO_ALG_ASYNC
);
105 if (IS_ERR(desc
.tfm
))
107 cksum
.len
= crypto_hash_digestsize(desc
.tfm
);
108 cksum
.data
= kmalloc(cksum
.len
, GFP_KERNEL
);
109 if (cksum
.data
== NULL
)
112 sg_init_one(&sg
, clname
->data
, clname
->len
);
114 if (crypto_hash_digest(&desc
, &sg
, sg
.length
, cksum
.data
))
117 md5_to_hex(dname
, cksum
.data
);
122 crypto_free_hash(desc
.tfm
);
128 nfsd4_sync_rec_dir(void)
130 mutex_lock(&rec_dir
.dentry
->d_inode
->i_mutex
);
131 nfsd_sync_dir(rec_dir
.dentry
);
132 mutex_unlock(&rec_dir
.dentry
->d_inode
->i_mutex
);
136 nfsd4_create_clid_dir(struct nfs4_client
*clp
)
138 const struct cred
*original_cred
;
139 char *dname
= clp
->cl_recdir
;
140 struct dentry
*dentry
;
143 dprintk("NFSD: nfsd4_create_clid_dir for \"%s\"\n", dname
);
145 if (!rec_dir_init
|| clp
->cl_firststate
)
148 status
= nfs4_save_creds(&original_cred
);
152 /* lock the parent */
153 mutex_lock(&rec_dir
.dentry
->d_inode
->i_mutex
);
155 dentry
= lookup_one_len(dname
, rec_dir
.dentry
, HEXDIR_LEN
-1);
156 if (IS_ERR(dentry
)) {
157 status
= PTR_ERR(dentry
);
161 if (dentry
->d_inode
) {
162 dprintk("NFSD: nfsd4_create_clid_dir: DIRECTORY EXISTS\n");
165 status
= mnt_want_write(rec_dir
.mnt
);
168 status
= vfs_mkdir(rec_dir
.dentry
->d_inode
, dentry
, S_IRWXU
);
169 mnt_drop_write(rec_dir
.mnt
);
173 mutex_unlock(&rec_dir
.dentry
->d_inode
->i_mutex
);
175 clp
->cl_firststate
= 1;
176 nfsd4_sync_rec_dir();
178 nfs4_reset_creds(original_cred
);
179 dprintk("NFSD: nfsd4_create_clid_dir returns %d\n", status
);
183 typedef int (recdir_func
)(struct dentry
*, struct dentry
*);
186 char name
[HEXDIR_LEN
];
187 struct list_head list
;
191 nfsd4_build_namelist(void *arg
, const char *name
, int namlen
,
192 loff_t offset
, u64 ino
, unsigned int d_type
)
194 struct list_head
*names
= arg
;
195 struct name_list
*entry
;
197 if (namlen
!= HEXDIR_LEN
- 1)
199 entry
= kmalloc(sizeof(struct name_list
), GFP_KERNEL
);
202 memcpy(entry
->name
, name
, HEXDIR_LEN
- 1);
203 entry
->name
[HEXDIR_LEN
- 1] = '\0';
204 list_add(&entry
->list
, names
);
209 nfsd4_list_rec_dir(struct dentry
*dir
, recdir_func
*f
)
211 const struct cred
*original_cred
;
214 struct name_list
*entry
;
215 struct dentry
*dentry
;
221 status
= nfs4_save_creds(&original_cred
);
225 filp
= dentry_open(dget(dir
), mntget(rec_dir
.mnt
), O_RDONLY
,
227 status
= PTR_ERR(filp
);
230 status
= vfs_readdir(filp
, nfsd4_build_namelist
, &names
);
232 mutex_lock_nested(&dir
->d_inode
->i_mutex
, I_MUTEX_PARENT
);
233 while (!list_empty(&names
)) {
234 entry
= list_entry(names
.next
, struct name_list
, list
);
236 dentry
= lookup_one_len(entry
->name
, dir
, HEXDIR_LEN
-1);
237 if (IS_ERR(dentry
)) {
238 status
= PTR_ERR(dentry
);
241 status
= f(dir
, dentry
);
245 list_del(&entry
->list
);
248 mutex_unlock(&dir
->d_inode
->i_mutex
);
250 while (!list_empty(&names
)) {
251 entry
= list_entry(names
.next
, struct name_list
, list
);
252 list_del(&entry
->list
);
255 nfs4_reset_creds(original_cred
);
260 nfsd4_unlink_clid_dir(char *name
, int namlen
)
262 struct dentry
*dentry
;
265 dprintk("NFSD: nfsd4_unlink_clid_dir. name %.*s\n", namlen
, name
);
267 mutex_lock_nested(&rec_dir
.dentry
->d_inode
->i_mutex
, I_MUTEX_PARENT
);
268 dentry
= lookup_one_len(name
, rec_dir
.dentry
, namlen
);
269 if (IS_ERR(dentry
)) {
270 status
= PTR_ERR(dentry
);
274 if (!dentry
->d_inode
)
276 status
= vfs_rmdir(rec_dir
.dentry
->d_inode
, dentry
);
280 mutex_unlock(&rec_dir
.dentry
->d_inode
->i_mutex
);
285 nfsd4_remove_clid_dir(struct nfs4_client
*clp
)
287 const struct cred
*original_cred
;
290 if (!rec_dir_init
|| !clp
->cl_firststate
)
293 status
= mnt_want_write(rec_dir
.mnt
);
296 clp
->cl_firststate
= 0;
298 status
= nfs4_save_creds(&original_cred
);
302 status
= nfsd4_unlink_clid_dir(clp
->cl_recdir
, HEXDIR_LEN
-1);
303 nfs4_reset_creds(original_cred
);
305 nfsd4_sync_rec_dir();
306 mnt_drop_write(rec_dir
.mnt
);
309 printk("NFSD: Failed to remove expired client state directory"
310 " %.*s\n", HEXDIR_LEN
, clp
->cl_recdir
);
315 purge_old(struct dentry
*parent
, struct dentry
*child
)
319 /* note: we currently use this path only for minorversion 0 */
320 if (nfs4_has_reclaimed_state(child
->d_name
.name
, false))
323 status
= vfs_rmdir(parent
->d_inode
, child
);
325 printk("failed to remove client recovery directory %s\n",
327 /* Keep trying, success or failure: */
332 nfsd4_recdir_purge_old(void) {
337 status
= mnt_want_write(rec_dir
.mnt
);
340 status
= nfsd4_list_rec_dir(rec_dir
.dentry
, purge_old
);
342 nfsd4_sync_rec_dir();
343 mnt_drop_write(rec_dir
.mnt
);
346 printk("nfsd4: failed to purge old clients from recovery"
347 " directory %s\n", rec_dir
.dentry
->d_name
.name
);
351 load_recdir(struct dentry
*parent
, struct dentry
*child
)
353 if (child
->d_name
.len
!= HEXDIR_LEN
- 1) {
354 printk("nfsd4: illegal name %s in recovery directory\n",
356 /* Keep trying; maybe the others are OK: */
359 nfs4_client_to_reclaim(child
->d_name
.name
);
364 nfsd4_recdir_load(void) {
367 status
= nfsd4_list_rec_dir(rec_dir
.dentry
, load_recdir
);
369 printk("nfsd4: failed loading clients from recovery"
370 " directory %s\n", rec_dir
.dentry
->d_name
.name
);
375 * Hold reference to the recovery directory.
379 nfsd4_init_recdir(char *rec_dirname
)
381 const struct cred
*original_cred
;
384 printk("NFSD: Using %s as the NFSv4 state recovery directory\n",
387 BUG_ON(rec_dir_init
);
389 status
= nfs4_save_creds(&original_cred
);
391 printk("NFSD: Unable to change credentials to find recovery"
392 " directory: error %d\n",
397 status
= kern_path(rec_dirname
, LOOKUP_FOLLOW
| LOOKUP_DIRECTORY
,
400 printk("NFSD: unable to find recovery directory %s\n",
405 nfs4_reset_creds(original_cred
);
409 nfsd4_shutdown_recdir(void)
This page took 0.038553 seconds and 5 git commands to generate.