Lines Matching full:bucket

64 pnfs_free_bucket_lseg(struct pnfs_commit_bucket *bucket)  in pnfs_free_bucket_lseg()  argument
66 if (list_empty(&bucket->committing) && list_empty(&bucket->written)) { in pnfs_free_bucket_lseg()
67 struct pnfs_layout_segment *freeme = bucket->lseg; in pnfs_free_bucket_lseg()
68 bucket->lseg = NULL; in pnfs_free_bucket_lseg()
75 * If this will make the bucket empty, it will need to put the lseg reference.
82 struct pnfs_commit_bucket *bucket = NULL; in pnfs_generic_clear_request_commit() local
88 bucket = list_first_entry(&req->wb_list, in pnfs_generic_clear_request_commit()
92 if (bucket) in pnfs_generic_clear_request_commit()
93 pnfs_put_lseg(pnfs_free_bucket_lseg(bucket)); in pnfs_generic_clear_request_commit()
239 * @bucket->committing.
242 pnfs_bucket_scan_ds_commit_list(struct pnfs_commit_bucket *bucket, in pnfs_bucket_scan_ds_commit_list() argument
246 struct list_head *src = &bucket->written; in pnfs_bucket_scan_ds_commit_list()
247 struct list_head *dst = &bucket->committing; in pnfs_bucket_scan_ds_commit_list()
357 struct pnfs_commit_bucket *bucket, in pnfs_bucket_get_committing() argument
363 list_for_each(pos, &bucket->committing) in pnfs_bucket_get_committing()
365 list_splice_init(&bucket->committing, head); in pnfs_bucket_get_committing()
366 lseg = pnfs_free_bucket_lseg(bucket); in pnfs_bucket_get_committing()
368 lseg = pnfs_get_lseg(bucket->lseg); in pnfs_bucket_get_committing()
373 pnfs_bucket_fetch_commitdata(struct pnfs_commit_bucket *bucket, in pnfs_bucket_fetch_commitdata() argument
380 data->lseg = pnfs_bucket_get_committing(&data->pages, bucket, cinfo); in pnfs_bucket_fetch_commitdata()
389 struct pnfs_commit_bucket *bucket; in pnfs_generic_retry_commit() local
393 for (bucket = buckets; idx < nbuckets; bucket++, idx++) { in pnfs_generic_retry_commit()
394 if (list_empty(&bucket->committing)) in pnfs_generic_retry_commit()
397 freeme = pnfs_bucket_get_committing(&pages, bucket, cinfo); in pnfs_generic_retry_commit()
410 struct pnfs_commit_bucket *bucket; in pnfs_bucket_alloc_ds_commits() local
415 for (i = 0, bucket = buckets; i < nbuckets; i++, bucket++) { in pnfs_bucket_alloc_ds_commits()
416 if (list_empty(&bucket->committing)) in pnfs_bucket_alloc_ds_commits()
419 if (!list_empty(&bucket->committing)) { in pnfs_bucket_alloc_ds_commits()
420 data = pnfs_bucket_fetch_commitdata(bucket, cinfo); in pnfs_bucket_alloc_ds_commits()
1164 struct pnfs_commit_bucket *bucket; in pnfs_layout_mark_request_commit() local
1170 bucket = &array->buckets[ds_commit_idx]; in pnfs_layout_mark_request_commit()
1171 list = &bucket->written; in pnfs_layout_mark_request_commit()
1178 if (!bucket->lseg) in pnfs_layout_mark_request_commit()
1179 bucket->lseg = pnfs_get_lseg(lseg); in pnfs_layout_mark_request_commit()