• Home
  • Raw
  • Download

Lines Matching refs:bucket

63 pnfs_free_bucket_lseg(struct pnfs_commit_bucket *bucket)  in pnfs_free_bucket_lseg()  argument
65 if (list_empty(&bucket->committing) && list_empty(&bucket->written)) { in pnfs_free_bucket_lseg()
66 struct pnfs_layout_segment *freeme = bucket->lseg; in pnfs_free_bucket_lseg()
67 bucket->lseg = NULL; in pnfs_free_bucket_lseg()
81 struct pnfs_commit_bucket *bucket = NULL; in pnfs_generic_clear_request_commit() local
87 bucket = list_first_entry(&req->wb_list, in pnfs_generic_clear_request_commit()
91 if (bucket) in pnfs_generic_clear_request_commit()
92 pnfs_put_lseg(pnfs_free_bucket_lseg(bucket)); in pnfs_generic_clear_request_commit()
241 pnfs_bucket_scan_ds_commit_list(struct pnfs_commit_bucket *bucket, in pnfs_bucket_scan_ds_commit_list() argument
245 struct list_head *src = &bucket->written; in pnfs_bucket_scan_ds_commit_list()
246 struct list_head *dst = &bucket->committing; in pnfs_bucket_scan_ds_commit_list()
403 struct pnfs_commit_bucket *bucket, in pnfs_bucket_get_committing() argument
409 list_for_each(pos, &bucket->committing) in pnfs_bucket_get_committing()
411 list_splice_init(&bucket->committing, head); in pnfs_bucket_get_committing()
412 lseg = pnfs_free_bucket_lseg(bucket); in pnfs_bucket_get_committing()
414 lseg = pnfs_get_lseg(bucket->lseg); in pnfs_bucket_get_committing()
419 pnfs_bucket_fetch_commitdata(struct pnfs_commit_bucket *bucket, in pnfs_bucket_fetch_commitdata() argument
426 data->lseg = pnfs_bucket_get_committing(&data->pages, bucket, cinfo); in pnfs_bucket_fetch_commitdata()
435 struct pnfs_commit_bucket *bucket; in pnfs_generic_retry_commit() local
439 for (bucket = buckets; idx < nbuckets; bucket++, idx++) { in pnfs_generic_retry_commit()
440 if (list_empty(&bucket->committing)) in pnfs_generic_retry_commit()
443 freeme = pnfs_bucket_get_committing(&pages, bucket, cinfo); in pnfs_generic_retry_commit()
456 struct pnfs_commit_bucket *bucket; in pnfs_bucket_alloc_ds_commits() local
461 for (i = 0, bucket = buckets; i < nbuckets; i++, bucket++) { in pnfs_bucket_alloc_ds_commits()
462 if (list_empty(&bucket->committing)) in pnfs_bucket_alloc_ds_commits()
465 if (!list_empty(&bucket->committing)) { in pnfs_bucket_alloc_ds_commits()
466 data = pnfs_bucket_fetch_commitdata(bucket, cinfo); in pnfs_bucket_alloc_ds_commits()
1171 struct pnfs_commit_bucket *bucket; in pnfs_layout_mark_request_commit() local
1177 bucket = &array->buckets[ds_commit_idx]; in pnfs_layout_mark_request_commit()
1178 list = &bucket->written; in pnfs_layout_mark_request_commit()
1185 if (!bucket->lseg) in pnfs_layout_mark_request_commit()
1186 bucket->lseg = pnfs_get_lseg(lseg); in pnfs_layout_mark_request_commit()