Blame view
fs/nfs/fscache.c
11.9 KB
147272813 NFS: Define and c... |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
/* NFS filesystem cache interface * * Copyright (C) 2008 Red Hat, Inc. All Rights Reserved. * Written by David Howells (dhowells@redhat.com) * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public Licence * as published by the Free Software Foundation; either version * 2 of the Licence, or (at your option) any later version. */ #include <linux/init.h> #include <linux/kernel.h> #include <linux/sched.h> #include <linux/mm.h> #include <linux/nfs_fs.h> #include <linux/nfs_fs_sb.h> #include <linux/in6.h> #include <linux/seq_file.h> |
5a0e3ad6a include cleanup: ... |
20 |
#include <linux/slab.h> |
147272813 NFS: Define and c... |
21 22 |
#include "internal.h" |
545db45f0 NFS: FS-Cache pag... |
23 |
#include "iostat.h" |
147272813 NFS: Define and c... |
24 25 26 |
#include "fscache.h" #define NFSDBG_FACILITY NFSDBG_FSCACHE |
08734048b NFS: Define and c... |
27 28 |
static struct rb_root nfs_fscache_keys = RB_ROOT; static DEFINE_SPINLOCK(nfs_fscache_keys_lock); |
147272813 NFS: Define and c... |
29 30 31 32 33 34 35 36 37 38 39 |
/* * Get the per-client index cookie for an NFS client if the appropriate mount * flag was set * - We always try and get an index cookie for the client, but get filehandle * cookies on a per-superblock basis, depending on the mount flags */ void nfs_fscache_get_client_cookie(struct nfs_client *clp) { /* create a cache index for looking up filehandles */ clp->fscache = fscache_acquire_cookie(nfs_fscache_netfs.primary_index, &nfs_fscache_server_index_def, |
94d30ae90 FS-Cache: Provide... |
40 |
clp, true); |
147272813 NFS: Define and c... |
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
dfprintk(FSCACHE, "NFS: get client cookie (0x%p/0x%p) ", clp, clp->fscache); } /* * Dispose of a per-client cookie */ void nfs_fscache_release_client_cookie(struct nfs_client *clp) { dfprintk(FSCACHE, "NFS: releasing client cookie (0x%p/0x%p) ", clp, clp->fscache); fscache_relinquish_cookie(clp->fscache, 0); clp->fscache = NULL; } |
08734048b NFS: Define and c... |
58 59 60 61 |
/* * Get the cache cookie for an NFS superblock. We have to handle * uniquification here because the cache doesn't do it for us. |
2df548063 NFS: Propagate 'f... |
62 63 64 65 |
* * The default uniquifier is just an empty string, but it may be overridden * either by the 'fsc=xxx' option to mount, or by inheriting it from the parent * superblock across an automount point of some nature. |
08734048b NFS: Define and c... |
66 |
*/ |
2311b9439 NFS: Don't pass m... |
67 |
void nfs_fscache_get_super_cookie(struct super_block *sb, const char *uniq, int ulen) |
08734048b NFS: Define and c... |
68 69 70 71 |
{ struct nfs_fscache_key *key, *xkey; struct nfs_server *nfss = NFS_SB(sb); struct rb_node **p, *parent; |
2311b9439 NFS: Don't pass m... |
72 |
int diff; |
2df548063 NFS: Propagate 'f... |
73 74 75 76 77 |
if (!uniq) { uniq = ""; ulen = 1; } |
08734048b NFS: Define and c... |
78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 |
key = kzalloc(sizeof(*key) + ulen, GFP_KERNEL); if (!key) return; key->nfs_client = nfss->nfs_client; key->key.super.s_flags = sb->s_flags & NFS_MS_MASK; key->key.nfs_server.flags = nfss->flags; key->key.nfs_server.rsize = nfss->rsize; key->key.nfs_server.wsize = nfss->wsize; key->key.nfs_server.acregmin = nfss->acregmin; key->key.nfs_server.acregmax = nfss->acregmax; key->key.nfs_server.acdirmin = nfss->acdirmin; key->key.nfs_server.acdirmax = nfss->acdirmax; key->key.nfs_server.fsid = nfss->fsid; key->key.rpc_auth.au_flavor = nfss->client->cl_auth->au_flavor; key->key.uniq_len = ulen; memcpy(key->key.uniquifier, uniq, ulen); spin_lock(&nfs_fscache_keys_lock); p = &nfs_fscache_keys.rb_node; parent = NULL; while (*p) { parent = *p; xkey = rb_entry(parent, struct nfs_fscache_key, node); if (key->nfs_client < xkey->nfs_client) goto go_left; if (key->nfs_client > xkey->nfs_client) goto go_right; diff = memcmp(&key->key, &xkey->key, sizeof(key->key)); if (diff < 0) goto go_left; if (diff > 0) goto go_right; if (key->key.uniq_len == 0) goto non_unique; diff = memcmp(key->key.uniquifier, xkey->key.uniquifier, key->key.uniq_len); if (diff < 0) goto go_left; if (diff > 0) goto go_right; goto non_unique; go_left: p = &(*p)->rb_left; continue; go_right: p = &(*p)->rb_right; } rb_link_node(&key->node, parent, p); rb_insert_color(&key->node, &nfs_fscache_keys); spin_unlock(&nfs_fscache_keys_lock); nfss->fscache_key = key; /* create a cache index for looking up filehandles */ nfss->fscache = fscache_acquire_cookie(nfss->nfs_client->fscache, &nfs_fscache_super_index_def, |
94d30ae90 FS-Cache: Provide... |
141 |
nfss, true); |
08734048b NFS: Define and c... |
142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 |
dfprintk(FSCACHE, "NFS: get superblock cookie (0x%p/0x%p) ", nfss, nfss->fscache); return; non_unique: spin_unlock(&nfs_fscache_keys_lock); kfree(key); nfss->fscache_key = NULL; nfss->fscache = NULL; printk(KERN_WARNING "NFS:" " Cache request denied due to non-unique superblock keys "); } /* * release a per-superblock cookie */ void nfs_fscache_release_super_cookie(struct super_block *sb) { struct nfs_server *nfss = NFS_SB(sb); dfprintk(FSCACHE, "NFS: releasing superblock cookie (0x%p/0x%p) ", nfss, nfss->fscache); fscache_relinquish_cookie(nfss->fscache, 0); nfss->fscache = NULL; if (nfss->fscache_key) { spin_lock(&nfs_fscache_keys_lock); rb_erase(&nfss->fscache_key->node, &nfs_fscache_keys); spin_unlock(&nfs_fscache_keys_lock); kfree(nfss->fscache_key); nfss->fscache_key = NULL; } } |
ef79c097b NFS: Use local di... |
179 180 181 182 |
/* * Initialise the per-inode cache cookie pointer for an NFS inode. */ |
f1fe29b4a NFS: Use i_writec... |
183 |
void nfs_fscache_init_inode(struct inode *inode) |
ef79c097b NFS: Use local di... |
184 |
{ |
ef79c097b NFS: Use local di... |
185 |
struct nfs_inode *nfsi = NFS_I(inode); |
f1fe29b4a NFS: Use i_writec... |
186 187 |
nfsi->fscache = NULL; if (!S_ISREG(inode->i_mode)) |
ef79c097b NFS: Use local di... |
188 |
return; |
f1fe29b4a NFS: Use i_writec... |
189 190 191 |
nfsi->fscache = fscache_acquire_cookie(NFS_SB(inode->i_sb)->fscache, &nfs_fscache_inode_object_def, nfsi, false); |
ef79c097b NFS: Use local di... |
192 193 194 195 196 |
} /* * Release a per-inode cookie. */ |
f1fe29b4a NFS: Use i_writec... |
197 |
void nfs_fscache_clear_inode(struct inode *inode) |
ef79c097b NFS: Use local di... |
198 199 |
{ struct nfs_inode *nfsi = NFS_I(inode); |
f1fe29b4a NFS: Use i_writec... |
200 |
struct fscache_cookie *cookie = nfs_i_fscache(inode); |
ef79c097b NFS: Use local di... |
201 |
|
f1fe29b4a NFS: Use i_writec... |
202 203 |
dfprintk(FSCACHE, "NFS: clear cookie (0x%p/0x%p) ", nfsi, cookie); |
ef79c097b NFS: Use local di... |
204 |
|
f1fe29b4a NFS: Use i_writec... |
205 |
fscache_relinquish_cookie(cookie, false); |
ef79c097b NFS: Use local di... |
206 207 |
nfsi->fscache = NULL; } |
f1fe29b4a NFS: Use i_writec... |
208 |
static bool nfs_fscache_can_enable(void *data) |
ef79c097b NFS: Use local di... |
209 |
{ |
f1fe29b4a NFS: Use i_writec... |
210 |
struct inode *inode = data; |
ef79c097b NFS: Use local di... |
211 |
|
f1fe29b4a NFS: Use i_writec... |
212 |
return !inode_is_open_for_write(inode); |
ef79c097b NFS: Use local di... |
213 214 215 |
} /* |
f1fe29b4a NFS: Use i_writec... |
216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 |
* Enable or disable caching for a file that is being opened as appropriate. * The cookie is allocated when the inode is initialised, but is not enabled at * that time. Enablement is deferred to file-open time to avoid stat() and * access() thrashing the cache. * * For now, with NFS, only regular files that are open read-only will be able * to use the cache. * * We enable the cache for an inode if we open it read-only and it isn't * currently open for writing. We disable the cache if the inode is open * write-only. * * The caller uses the file struct to pin i_writecount on the inode before * calling us when a file is opened for writing, so we can make use of that. * * Note that this may be invoked multiple times in parallel by parallel * nfs_open() functions. |
ef79c097b NFS: Use local di... |
233 |
*/ |
f1fe29b4a NFS: Use i_writec... |
234 |
void nfs_fscache_open_file(struct inode *inode, struct file *filp) |
ef79c097b NFS: Use local di... |
235 236 |
{ struct nfs_inode *nfsi = NFS_I(inode); |
f1fe29b4a NFS: Use i_writec... |
237 |
struct fscache_cookie *cookie = nfs_i_fscache(inode); |
ef79c097b NFS: Use local di... |
238 |
|
f1fe29b4a NFS: Use i_writec... |
239 240 |
if (!fscache_cookie_valid(cookie)) return; |
ef79c097b NFS: Use local di... |
241 |
|
f1fe29b4a NFS: Use i_writec... |
242 243 244 245 246 247 248 249 250 251 252 253 |
if (inode_is_open_for_write(inode)) { dfprintk(FSCACHE, "NFS: nfsi 0x%p disabling cache ", nfsi); clear_bit(NFS_INO_FSCACHE, &nfsi->flags); fscache_disable_cookie(cookie, true); fscache_uncache_all_inode_pages(cookie, inode); } else { dfprintk(FSCACHE, "NFS: nfsi 0x%p enabling cache ", nfsi); fscache_enable_cookie(cookie, nfs_fscache_can_enable, inode); if (fscache_cookie_enabled(cookie)) set_bit(NFS_INO_FSCACHE, &NFS_I(inode)->flags); |
ef79c097b NFS: Use local di... |
254 |
} |
ef79c097b NFS: Use local di... |
255 |
} |
f1fe29b4a NFS: Use i_writec... |
256 |
EXPORT_SYMBOL_GPL(nfs_fscache_open_file); |
545db45f0 NFS: FS-Cache pag... |
257 258 259 260 261 262 263 264 |
/* * Release the caching state associated with a page, if the page isn't busy * interacting with the cache. * - Returns true (can release page) or false (page busy). */ int nfs_fscache_release_page(struct page *page, gfp_t gfp) { |
545db45f0 NFS: FS-Cache pag... |
265 |
if (PageFsCache(page)) { |
f1fe29b4a NFS: Use i_writec... |
266 |
struct fscache_cookie *cookie = nfs_i_fscache(page->mapping->host); |
2c1740098 NFS: Fix a bug in... |
267 268 |
BUG_ON(!cookie); |
545db45f0 NFS: FS-Cache pag... |
269 270 |
dfprintk(FSCACHE, "NFS: fscache releasepage (0x%p/0x%p/0x%p) ", |
f1fe29b4a NFS: Use i_writec... |
271 |
cookie, page, NFS_I(page->mapping->host)); |
545db45f0 NFS: FS-Cache pag... |
272 |
|
201a15428 FS-Cache: Handle ... |
273 274 |
if (!fscache_maybe_release_page(cookie, page, gfp)) return 0; |
e9f456ca5 nfs: define nfs_i... |
275 276 |
nfs_inc_fscache_stats(page->mapping->host, NFSIOS_FSCACHE_PAGES_UNCACHED); |
545db45f0 NFS: FS-Cache pag... |
277 278 279 280 281 282 283 284 285 286 287 |
} return 1; } /* * Release the caching state associated with a page if undergoing complete page * invalidation. */ void __nfs_fscache_invalidate_page(struct page *page, struct inode *inode) { |
f1fe29b4a NFS: Use i_writec... |
288 |
struct fscache_cookie *cookie = nfs_i_fscache(inode); |
545db45f0 NFS: FS-Cache pag... |
289 290 291 292 293 |
BUG_ON(!cookie); dfprintk(FSCACHE, "NFS: fscache invalidatepage (0x%p/0x%p/0x%p) ", |
f1fe29b4a NFS: Use i_writec... |
294 |
cookie, page, NFS_I(inode)); |
545db45f0 NFS: FS-Cache pag... |
295 296 297 298 299 |
fscache_wait_on_page_write(cookie, page); BUG_ON(!PageLocked(page)); fscache_uncache_page(cookie, page); |
e9f456ca5 nfs: define nfs_i... |
300 301 |
nfs_inc_fscache_stats(page->mapping->host, NFSIOS_FSCACHE_PAGES_UNCACHED); |
545db45f0 NFS: FS-Cache pag... |
302 |
} |
9a9fc1c03 NFS: Read pages f... |
303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 |
/* * Handle completion of a page being read from the cache. * - Called in process (keventd) context. */ static void nfs_readpage_from_fscache_complete(struct page *page, void *context, int error) { dfprintk(FSCACHE, "NFS: readpage_from_fscache_complete (0x%p/0x%p/%d) ", page, context, error); /* if the read completes with an error, we just unlock the page and let * the VM reissue the readpage */ if (!error) { SetPageUptodate(page); unlock_page(page); } else { error = nfs_readpage_async(context, page->mapping->host, page); if (error) unlock_page(page); } } /* * Retrieve a page from fscache */ int __nfs_readpage_from_fscache(struct nfs_open_context *ctx, struct inode *inode, struct page *page) { int ret; dfprintk(FSCACHE, "NFS: readpage_from_fscache(fsc:%p/p:%p(i:%lx f:%lx)/0x%p) ", |
f1fe29b4a NFS: Use i_writec... |
340 |
nfs_i_fscache(inode), page, page->index, page->flags, inode); |
9a9fc1c03 NFS: Read pages f... |
341 |
|
f1fe29b4a NFS: Use i_writec... |
342 |
ret = fscache_read_or_alloc_page(nfs_i_fscache(inode), |
9a9fc1c03 NFS: Read pages f... |
343 344 345 346 347 348 349 350 351 352 |
page, nfs_readpage_from_fscache_complete, ctx, GFP_KERNEL); switch (ret) { case 0: /* read BIO submitted (page in fscache) */ dfprintk(FSCACHE, "NFS: readpage_from_fscache: BIO submitted "); |
e9f456ca5 nfs: define nfs_i... |
353 |
nfs_inc_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_READ_OK); |
9a9fc1c03 NFS: Read pages f... |
354 355 356 357 |
return ret; case -ENOBUFS: /* inode not in cache */ case -ENODATA: /* page not in cache */ |
e9f456ca5 nfs: define nfs_i... |
358 |
nfs_inc_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_READ_FAIL); |
9a9fc1c03 NFS: Read pages f... |
359 360 361 362 363 364 365 366 |
dfprintk(FSCACHE, "NFS: readpage_from_fscache %d ", ret); return 1; default: dfprintk(FSCACHE, "NFS: readpage_from_fscache %d ", ret); |
e9f456ca5 nfs: define nfs_i... |
367 |
nfs_inc_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_READ_FAIL); |
9a9fc1c03 NFS: Read pages f... |
368 369 370 371 372 373 374 375 376 377 378 379 380 |
} return ret; } /* * Retrieve a set of pages from fscache */ int __nfs_readpages_from_fscache(struct nfs_open_context *ctx, struct inode *inode, struct address_space *mapping, struct list_head *pages, unsigned *nr_pages) { |
0f15c53d5 NFS: Squelch comp... |
381 382 |
unsigned npages = *nr_pages; int ret; |
9a9fc1c03 NFS: Read pages f... |
383 384 385 |
dfprintk(FSCACHE, "NFS: nfs_getpages_from_fscache (0x%p/%u/0x%p) ", |
f1fe29b4a NFS: Use i_writec... |
386 |
nfs_i_fscache(inode), npages, inode); |
9a9fc1c03 NFS: Read pages f... |
387 |
|
f1fe29b4a NFS: Use i_writec... |
388 |
ret = fscache_read_or_alloc_pages(nfs_i_fscache(inode), |
9a9fc1c03 NFS: Read pages f... |
389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 |
mapping, pages, nr_pages, nfs_readpage_from_fscache_complete, ctx, mapping_gfp_mask(mapping)); if (*nr_pages < npages) nfs_add_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_READ_OK, npages); if (*nr_pages > 0) nfs_add_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_READ_FAIL, *nr_pages); switch (ret) { case 0: /* read submitted to the cache for all pages */ BUG_ON(!list_empty(pages)); BUG_ON(*nr_pages != 0); dfprintk(FSCACHE, "NFS: nfs_getpages_from_fscache: submitted "); return ret; case -ENOBUFS: /* some pages aren't cached and can't be */ case -ENODATA: /* some pages aren't cached */ dfprintk(FSCACHE, "NFS: nfs_getpages_from_fscache: no page: %d ", ret); return 1; default: dfprintk(FSCACHE, "NFS: nfs_getpages_from_fscache: ret %d ", ret); } return ret; } |
7f8e05f60 NFS: Store pages ... |
425 426 427 428 429 430 431 432 433 434 435 436 |
/* * Store a newly fetched page in fscache * - PG_fscache must be set on the page */ void __nfs_readpage_to_fscache(struct inode *inode, struct page *page, int sync) { int ret; dfprintk(FSCACHE, "NFS: readpage_to_fscache(fsc:%p/p:%p(i:%lx f:%lx)/%d) ", |
f1fe29b4a NFS: Use i_writec... |
437 |
nfs_i_fscache(inode), page, page->index, page->flags, sync); |
7f8e05f60 NFS: Store pages ... |
438 |
|
f1fe29b4a NFS: Use i_writec... |
439 |
ret = fscache_write_page(nfs_i_fscache(inode), page, GFP_KERNEL); |
7f8e05f60 NFS: Store pages ... |
440 441 442 443 444 445 |
dfprintk(FSCACHE, "NFS: readpage_to_fscache: p:%p(i:%lu f:%lx) ret %d ", page, page->index, page->flags, ret); if (ret != 0) { |
f1fe29b4a NFS: Use i_writec... |
446 |
fscache_uncache_page(nfs_i_fscache(inode), page); |
e9f456ca5 nfs: define nfs_i... |
447 448 449 |
nfs_inc_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_WRITTEN_FAIL); nfs_inc_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_UNCACHED); |
7f8e05f60 NFS: Store pages ... |
450 |
} else { |
e9f456ca5 nfs: define nfs_i... |
451 452 |
nfs_inc_fscache_stats(inode, NFSIOS_FSCACHE_PAGES_WRITTEN_OK); |
7f8e05f60 NFS: Store pages ... |
453 454 |
} } |