1 /* SPDX-License-Identifier: GPL-2.0-or-later */ 2 /* Internal definitions for network filesystem support 3 * 4 * Copyright (C) 2021 Red Hat, Inc. All Rights Reserved. 5 * Written by David Howells (dhowells@redhat.com) 6 */ 7 8 #include <linux/slab.h> 9 #include <linux/seq_file.h> 10 #include <linux/folio_queue.h> 11 #include <linux/netfs.h> 12 #include <linux/fscache.h> 13 #include <linux/fscache-cache.h> 14 #include <trace/events/netfs.h> 15 #include <trace/events/fscache.h> 16 17 #ifdef pr_fmt 18 #undef pr_fmt 19 #endif 20 21 #define pr_fmt(fmt) "netfs: " fmt 22 23 /* 24 * buffered_read.c 25 */ 26 void netfs_queue_read(struct netfs_io_request *rreq, 27 struct netfs_io_subrequest *subreq); 28 void netfs_cache_read_terminated(void *priv, ssize_t transferred_or_error); 29 int netfs_prefetch_for_write(struct file *file, struct folio *folio, 30 size_t offset, size_t len); 31 32 /* 33 * buffered_write.c 34 */ 35 void netfs_update_i_size(struct netfs_inode *ctx, struct inode *inode, 36 loff_t pos, size_t copied); 37 38 /* 39 * main.c 40 */ 41 extern unsigned int netfs_debug; 42 extern struct list_head netfs_io_requests; 43 extern spinlock_t netfs_proc_lock; 44 extern mempool_t netfs_request_pool; 45 extern mempool_t netfs_subrequest_pool; 46 47 #ifdef CONFIG_PROC_FS 48 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) 49 { 50 spin_lock(&netfs_proc_lock); 51 list_add_tail_rcu(&rreq->proc_link, &netfs_io_requests); 52 spin_unlock(&netfs_proc_lock); 53 } 54 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) 55 { 56 if (!list_empty(&rreq->proc_link)) { 57 spin_lock(&netfs_proc_lock); 58 list_del_rcu(&rreq->proc_link); 59 spin_unlock(&netfs_proc_lock); 60 } 61 } 62 #else 63 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) {} 64 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) {} 65 #endif 66 67 /* 68 * misc.c 69 */ 70 struct folio_queue *netfs_buffer_make_space(struct netfs_io_request *rreq, 71 enum netfs_folioq_trace trace); 72 void netfs_reset_iter(struct netfs_io_subrequest *subreq); 73 void netfs_wake_collector(struct netfs_io_request *rreq); 74 void netfs_subreq_clear_in_progress(struct netfs_io_subrequest *subreq); 75 void netfs_wait_for_in_progress_stream(struct netfs_io_request *rreq, 76 struct netfs_io_stream *stream); 77 ssize_t netfs_wait_for_read(struct netfs_io_request *rreq); 78 ssize_t netfs_wait_for_write(struct netfs_io_request *rreq); 79 void netfs_wait_for_paused_read(struct netfs_io_request *rreq); 80 void netfs_wait_for_paused_write(struct netfs_io_request *rreq); 81 82 /* 83 * objects.c 84 */ 85 struct netfs_io_request *netfs_alloc_request(struct address_space *mapping, 86 struct file *file, 87 loff_t start, size_t len, 88 enum netfs_io_origin origin); 89 void netfs_get_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what); 90 void netfs_clear_subrequests(struct netfs_io_request *rreq); 91 void netfs_put_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what); 92 void netfs_put_failed_request(struct netfs_io_request *rreq); 93 struct netfs_io_subrequest *netfs_alloc_subrequest(struct netfs_io_request *rreq); 94 95 static inline void netfs_see_request(struct netfs_io_request *rreq, 96 enum netfs_rreq_ref_trace what) 97 { 98 trace_netfs_rreq_ref(rreq->debug_id, refcount_read(&rreq->ref), what); 99 } 100 101 static inline void netfs_see_subrequest(struct netfs_io_subrequest *subreq, 102 enum netfs_sreq_ref_trace what) 103 { 104 trace_netfs_sreq_ref(subreq->rreq->debug_id, subreq->debug_index, 105 refcount_read(&subreq->ref), what); 106 } 107 108 /* 109 * read_collect.c 110 */ 111 bool netfs_read_collection(struct netfs_io_request *rreq); 112 void netfs_read_collection_worker(struct work_struct *work); 113 void netfs_cancel_read(struct netfs_io_subrequest *subreq, int error); 114 void netfs_cache_read_terminated(void *priv, ssize_t transferred_or_error); 115 116 /* 117 * read_pgpriv2.c 118 */ 119 void netfs_pgpriv2_copy_to_cache(struct netfs_io_request *rreq, struct folio *folio); 120 void netfs_pgpriv2_end_copy_to_cache(struct netfs_io_request *rreq); 121 bool netfs_pgpriv2_unlock_copied_folios(struct netfs_io_request *wreq); 122 123 /* 124 * read_retry.c 125 */ 126 void netfs_retry_reads(struct netfs_io_request *rreq); 127 void netfs_unlock_abandoned_read_pages(struct netfs_io_request *rreq); 128 129 /* 130 * stats.c 131 */ 132 #ifdef CONFIG_NETFS_STATS 133 extern atomic_t netfs_n_rh_dio_read; 134 extern atomic_t netfs_n_rh_readahead; 135 extern atomic_t netfs_n_rh_read_folio; 136 extern atomic_t netfs_n_rh_read_single; 137 extern atomic_t netfs_n_rh_rreq; 138 extern atomic_t netfs_n_rh_sreq; 139 extern atomic_t netfs_n_rh_download; 140 extern atomic_t netfs_n_rh_download_done; 141 extern atomic_t netfs_n_rh_download_failed; 142 extern atomic_t netfs_n_rh_download_instead; 143 extern atomic_t netfs_n_rh_read; 144 extern atomic_t netfs_n_rh_read_done; 145 extern atomic_t netfs_n_rh_read_failed; 146 extern atomic_t netfs_n_rh_zero; 147 extern atomic_t netfs_n_rh_short_read; 148 extern atomic_t netfs_n_rh_write; 149 extern atomic_t netfs_n_rh_write_begin; 150 extern atomic_t netfs_n_rh_write_done; 151 extern atomic_t netfs_n_rh_write_failed; 152 extern atomic_t netfs_n_rh_write_zskip; 153 extern atomic_t netfs_n_rh_retry_read_req; 154 extern atomic_t netfs_n_rh_retry_read_subreq; 155 extern atomic_t netfs_n_wh_buffered_write; 156 extern atomic_t netfs_n_wh_writethrough; 157 extern atomic_t netfs_n_wh_dio_write; 158 extern atomic_t netfs_n_wh_writepages; 159 extern atomic_t netfs_n_wh_copy_to_cache; 160 extern atomic_t netfs_n_wh_wstream_conflict; 161 extern atomic_t netfs_n_wh_upload; 162 extern atomic_t netfs_n_wh_upload_done; 163 extern atomic_t netfs_n_wh_upload_failed; 164 extern atomic_t netfs_n_wh_write; 165 extern atomic_t netfs_n_wh_write_done; 166 extern atomic_t netfs_n_wh_write_failed; 167 extern atomic_t netfs_n_wh_retry_write_req; 168 extern atomic_t netfs_n_wh_retry_write_subreq; 169 extern atomic_t netfs_n_wb_lock_skip; 170 extern atomic_t netfs_n_wb_lock_wait; 171 extern atomic_t netfs_n_folioq; 172 173 int netfs_stats_show(struct seq_file *m, void *v); 174 175 static inline void netfs_stat(atomic_t *stat) 176 { 177 atomic_inc(stat); 178 } 179 180 static inline void netfs_stat_d(atomic_t *stat) 181 { 182 atomic_dec(stat); 183 } 184 185 #else 186 #define netfs_stat(x) do {} while(0) 187 #define netfs_stat_d(x) do {} while(0) 188 #endif 189 190 /* 191 * write_collect.c 192 */ 193 int netfs_folio_written_back(struct folio *folio); 194 bool netfs_write_collection(struct netfs_io_request *wreq); 195 void netfs_write_collection_worker(struct work_struct *work); 196 197 /* 198 * write_issue.c 199 */ 200 struct netfs_io_request *netfs_create_write_req(struct address_space *mapping, 201 struct file *file, 202 loff_t start, 203 enum netfs_io_origin origin); 204 void netfs_prepare_write(struct netfs_io_request *wreq, 205 struct netfs_io_stream *stream, 206 loff_t start); 207 void netfs_reissue_write(struct netfs_io_stream *stream, 208 struct netfs_io_subrequest *subreq, 209 struct iov_iter *source); 210 void netfs_issue_write(struct netfs_io_request *wreq, 211 struct netfs_io_stream *stream); 212 size_t netfs_advance_write(struct netfs_io_request *wreq, 213 struct netfs_io_stream *stream, 214 loff_t start, size_t len, bool to_eof); 215 struct netfs_io_request *netfs_begin_writethrough(struct kiocb *iocb, size_t len); 216 int netfs_advance_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc, 217 struct folio *folio, size_t copied, bool to_page_end, 218 struct folio **writethrough_cache); 219 ssize_t netfs_end_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc, 220 struct folio *writethrough_cache); 221 222 /* 223 * write_retry.c 224 */ 225 void netfs_retry_writes(struct netfs_io_request *wreq); 226 227 /* 228 * Miscellaneous functions. 229 */ 230 static inline bool netfs_is_cache_enabled(struct netfs_inode *ctx) 231 { 232 #if IS_ENABLED(CONFIG_FSCACHE) 233 struct fscache_cookie *cookie = ctx->cache; 234 235 return fscache_cookie_valid(cookie) && cookie->cache_priv && 236 fscache_cookie_enabled(cookie); 237 #else 238 return false; 239 #endif 240 } 241 242 static inline bool netfs_is_cache_maybe_enabled(struct netfs_inode *ctx) 243 { 244 #if IS_ENABLED(CONFIG_FSCACHE) 245 struct fscache_cookie *cookie = ctx->cache; 246 247 return fscache_cookie_valid(cookie) && 248 test_bit(FSCACHE_COOKIE_IS_CACHING, &cookie->flags); 249 #else 250 return false; 251 #endif 252 } 253 254 /* 255 * Get a ref on a netfs group attached to a dirty page (e.g. a ceph snap). 256 */ 257 static inline struct netfs_group *netfs_get_group(struct netfs_group *netfs_group) 258 { 259 if (netfs_group && netfs_group != NETFS_FOLIO_COPY_TO_CACHE) 260 refcount_inc(&netfs_group->ref); 261 return netfs_group; 262 } 263 264 /* 265 * Dispose of a netfs group attached to a dirty page (e.g. a ceph snap). 266 */ 267 static inline void netfs_put_group(struct netfs_group *netfs_group) 268 { 269 if (netfs_group && 270 netfs_group != NETFS_FOLIO_COPY_TO_CACHE && 271 refcount_dec_and_test(&netfs_group->ref)) 272 netfs_group->free(netfs_group); 273 } 274 275 /* 276 * Dispose of a netfs group attached to a dirty page (e.g. a ceph snap). 277 */ 278 static inline void netfs_put_group_many(struct netfs_group *netfs_group, int nr) 279 { 280 if (netfs_group && 281 netfs_group != NETFS_FOLIO_COPY_TO_CACHE && 282 refcount_sub_and_test(nr, &netfs_group->ref)) 283 netfs_group->free(netfs_group); 284 } 285 286 /* 287 * Clear and wake up a NETFS_RREQ_* flag bit on a request. 288 */ 289 static inline void netfs_wake_rreq_flag(struct netfs_io_request *rreq, 290 unsigned int rreq_flag, 291 enum netfs_rreq_trace trace) 292 { 293 if (test_bit(rreq_flag, &rreq->flags)) { 294 clear_bit_unlock(rreq_flag, &rreq->flags); 295 smp_mb__after_atomic(); /* Set flag before task state */ 296 trace_netfs_rreq(rreq, trace); 297 wake_up(&rreq->waitq); 298 } 299 } 300 301 /* 302 * Test the NETFS_RREQ_IN_PROGRESS flag, inserting an appropriate barrier. 303 */ 304 static inline bool netfs_check_rreq_in_progress(const struct netfs_io_request *rreq) 305 { 306 /* Order read of flags before read of anything else, such as error. */ 307 return test_bit_acquire(NETFS_RREQ_IN_PROGRESS, &rreq->flags); 308 } 309 310 /* 311 * Test the NETFS_SREQ_IN_PROGRESS flag, inserting an appropriate barrier. 312 */ 313 static inline bool netfs_check_subreq_in_progress(const struct netfs_io_subrequest *subreq) 314 { 315 /* Order read of flags before read of anything else, such as error. */ 316 return test_bit_acquire(NETFS_SREQ_IN_PROGRESS, &subreq->flags); 317 } 318 319 /* 320 * fscache-cache.c 321 */ 322 #ifdef CONFIG_PROC_FS 323 extern const struct seq_operations fscache_caches_seq_ops; 324 #endif 325 bool fscache_begin_cache_access(struct fscache_cache *cache, enum fscache_access_trace why); 326 void fscache_end_cache_access(struct fscache_cache *cache, enum fscache_access_trace why); 327 struct fscache_cache *fscache_lookup_cache(const char *name, bool is_cache); 328 void fscache_put_cache(struct fscache_cache *cache, enum fscache_cache_trace where); 329 330 static inline enum fscache_cache_state fscache_cache_state(const struct fscache_cache *cache) 331 { 332 return smp_load_acquire(&cache->state); 333 } 334 335 static inline bool fscache_cache_is_live(const struct fscache_cache *cache) 336 { 337 return fscache_cache_state(cache) == FSCACHE_CACHE_IS_ACTIVE; 338 } 339 340 static inline void fscache_set_cache_state(struct fscache_cache *cache, 341 enum fscache_cache_state new_state) 342 { 343 smp_store_release(&cache->state, new_state); 344 345 } 346 347 static inline bool fscache_set_cache_state_maybe(struct fscache_cache *cache, 348 enum fscache_cache_state old_state, 349 enum fscache_cache_state new_state) 350 { 351 return try_cmpxchg_release(&cache->state, &old_state, new_state); 352 } 353 354 /* 355 * fscache-cookie.c 356 */ 357 extern struct kmem_cache *fscache_cookie_jar; 358 #ifdef CONFIG_PROC_FS 359 extern const struct seq_operations fscache_cookies_seq_ops; 360 #endif 361 extern struct timer_list fscache_cookie_lru_timer; 362 363 extern void fscache_print_cookie(struct fscache_cookie *cookie, char prefix); 364 extern bool fscache_begin_cookie_access(struct fscache_cookie *cookie, 365 enum fscache_access_trace why); 366 367 static inline void fscache_see_cookie(struct fscache_cookie *cookie, 368 enum fscache_cookie_trace where) 369 { 370 trace_fscache_cookie(cookie->debug_id, refcount_read(&cookie->ref), 371 where); 372 } 373 374 /* 375 * fscache-main.c 376 */ 377 extern unsigned int fscache_hash(unsigned int salt, const void *data, size_t len); 378 #ifdef CONFIG_FSCACHE 379 int __init fscache_init(void); 380 void __exit fscache_exit(void); 381 #else 382 static inline int fscache_init(void) { return 0; } 383 static inline void fscache_exit(void) {} 384 #endif 385 386 /* 387 * fscache-proc.c 388 */ 389 #ifdef CONFIG_PROC_FS 390 extern int __init fscache_proc_init(void); 391 extern void fscache_proc_cleanup(void); 392 #else 393 #define fscache_proc_init() (0) 394 #define fscache_proc_cleanup() do {} while (0) 395 #endif 396 397 /* 398 * fscache-stats.c 399 */ 400 #ifdef CONFIG_FSCACHE_STATS 401 extern atomic_t fscache_n_volumes; 402 extern atomic_t fscache_n_volumes_collision; 403 extern atomic_t fscache_n_volumes_nomem; 404 extern atomic_t fscache_n_cookies; 405 extern atomic_t fscache_n_cookies_lru; 406 extern atomic_t fscache_n_cookies_lru_expired; 407 extern atomic_t fscache_n_cookies_lru_removed; 408 extern atomic_t fscache_n_cookies_lru_dropped; 409 410 extern atomic_t fscache_n_acquires; 411 extern atomic_t fscache_n_acquires_ok; 412 extern atomic_t fscache_n_acquires_oom; 413 414 extern atomic_t fscache_n_invalidates; 415 416 extern atomic_t fscache_n_relinquishes; 417 extern atomic_t fscache_n_relinquishes_retire; 418 extern atomic_t fscache_n_relinquishes_dropped; 419 420 extern atomic_t fscache_n_resizes; 421 extern atomic_t fscache_n_resizes_null; 422 423 static inline void fscache_stat(atomic_t *stat) 424 { 425 atomic_inc(stat); 426 } 427 428 static inline void fscache_stat_d(atomic_t *stat) 429 { 430 atomic_dec(stat); 431 } 432 433 #define __fscache_stat(stat) (stat) 434 435 int fscache_stats_show(struct seq_file *m); 436 #else 437 438 #define __fscache_stat(stat) (NULL) 439 #define fscache_stat(stat) do {} while (0) 440 #define fscache_stat_d(stat) do {} while (0) 441 442 static inline int fscache_stats_show(struct seq_file *m) { return 0; } 443 #endif 444 445 /* 446 * fscache-volume.c 447 */ 448 #ifdef CONFIG_PROC_FS 449 extern const struct seq_operations fscache_volumes_seq_ops; 450 #endif 451 452 struct fscache_volume *fscache_get_volume(struct fscache_volume *volume, 453 enum fscache_volume_trace where); 454 bool fscache_begin_volume_access(struct fscache_volume *volume, 455 struct fscache_cookie *cookie, 456 enum fscache_access_trace why); 457 void fscache_create_volume(struct fscache_volume *volume, bool wait); 458 459 /*****************************************************************************/ 460 /* 461 * debug tracing 462 */ 463 #define dbgprintk(FMT, ...) \ 464 printk("[%-6.6s] "FMT"\n", current->comm, ##__VA_ARGS__) 465 466 #define kenter(FMT, ...) dbgprintk("==> %s("FMT")", __func__, ##__VA_ARGS__) 467 #define kleave(FMT, ...) dbgprintk("<== %s()"FMT"", __func__, ##__VA_ARGS__) 468 #define kdebug(FMT, ...) dbgprintk(FMT, ##__VA_ARGS__) 469 470 #ifdef __KDEBUG 471 #define _enter(FMT, ...) kenter(FMT, ##__VA_ARGS__) 472 #define _leave(FMT, ...) kleave(FMT, ##__VA_ARGS__) 473 #define _debug(FMT, ...) kdebug(FMT, ##__VA_ARGS__) 474 475 #elif defined(CONFIG_NETFS_DEBUG) 476 #define _enter(FMT, ...) \ 477 do { \ 478 if (netfs_debug) \ 479 kenter(FMT, ##__VA_ARGS__); \ 480 } while (0) 481 482 #define _leave(FMT, ...) \ 483 do { \ 484 if (netfs_debug) \ 485 kleave(FMT, ##__VA_ARGS__); \ 486 } while (0) 487 488 #define _debug(FMT, ...) \ 489 do { \ 490 if (netfs_debug) \ 491 kdebug(FMT, ##__VA_ARGS__); \ 492 } while (0) 493 494 #else 495 #define _enter(FMT, ...) no_printk("==> %s("FMT")", __func__, ##__VA_ARGS__) 496 #define _leave(FMT, ...) no_printk("<== %s()"FMT"", __func__, ##__VA_ARGS__) 497 #define _debug(FMT, ...) no_printk(FMT, ##__VA_ARGS__) 498 #endif 499 500 /* 501 * assertions 502 */ 503 #if 1 /* defined(__KDEBUGALL) */ 504 505 #define ASSERT(X) \ 506 do { \ 507 if (unlikely(!(X))) { \ 508 pr_err("\n"); \ 509 pr_err("Assertion failed\n"); \ 510 BUG(); \ 511 } \ 512 } while (0) 513 514 #define ASSERTCMP(X, OP, Y) \ 515 do { \ 516 if (unlikely(!((X) OP (Y)))) { \ 517 pr_err("\n"); \ 518 pr_err("Assertion failed\n"); \ 519 pr_err("%lx " #OP " %lx is false\n", \ 520 (unsigned long)(X), (unsigned long)(Y)); \ 521 BUG(); \ 522 } \ 523 } while (0) 524 525 #define ASSERTIF(C, X) \ 526 do { \ 527 if (unlikely((C) && !(X))) { \ 528 pr_err("\n"); \ 529 pr_err("Assertion failed\n"); \ 530 BUG(); \ 531 } \ 532 } while (0) 533 534 #define ASSERTIFCMP(C, X, OP, Y) \ 535 do { \ 536 if (unlikely((C) && !((X) OP (Y)))) { \ 537 pr_err("\n"); \ 538 pr_err("Assertion failed\n"); \ 539 pr_err("%lx " #OP " %lx is false\n", \ 540 (unsigned long)(X), (unsigned long)(Y)); \ 541 BUG(); \ 542 } \ 543 } while (0) 544 545 #else 546 547 #define ASSERT(X) do {} while (0) 548 #define ASSERTCMP(X, OP, Y) do {} while (0) 549 #define ASSERTIF(C, X) do {} while (0) 550 #define ASSERTIFCMP(C, X, OP, Y) do {} while (0) 551 552 #endif /* assert or not */ 553