Lines Matching refs:cl
210 struct closure *cl) in __try_alloc_bucket() argument
225 if (cl) in __try_alloc_bucket()
226 closure_wait(&c->open_buckets_wait, cl); in __try_alloc_bucket()
263 struct closure *cl) in try_alloc_bucket() argument
278 return __try_alloc_bucket(c, req, b, gen, cl); in try_alloc_bucket()
287 struct closure *cl) in bch2_bucket_alloc_early() argument
351 ? __try_alloc_bucket(c, req, k.k->p.offset, a->gen, cl) in bch2_bucket_alloc_early()
378 struct closure *cl) in bch2_bucket_alloc_freelist() argument
420 ob = try_alloc_bucket(trans, req, &iter, cl); in bch2_bucket_alloc_freelist()
453 struct closure *cl, in trace_bucket_alloc2() argument
463 prt_printf(&buf, "blocking\t%u\n", cl != NULL); in trace_bucket_alloc2()
498 struct closure *cl, in bch2_bucket_alloc_trans() argument
529 if (cl && !waiting) { in bch2_bucket_alloc_trans()
530 closure_wait(&c->freelist_wait, cl); in bch2_bucket_alloc_trans()
545 ? bch2_bucket_alloc_freelist(trans, req, cl) in bch2_bucket_alloc_trans()
546 : bch2_bucket_alloc_early(trans, req, cl); in bch2_bucket_alloc_trans()
575 trace_bucket_alloc2(c, req, cl, ob); in bch2_bucket_alloc_trans()
583 struct closure *cl) in bch2_bucket_alloc() argument
593 PTR_ERR_OR_ZERO(ob = bch2_bucket_alloc_trans(trans, &req, cl, false))); in bch2_bucket_alloc()
710 struct closure *cl) in bch2_bucket_alloc_set_trans() argument
729 struct open_bucket *ob = bch2_bucket_alloc_trans(trans, req, cl, in bch2_bucket_alloc_set_trans()
737 if (bch2_err_matches(ret, BCH_ERR_transaction_restart) || cl) in bch2_bucket_alloc_set_trans()
764 struct closure *cl) in bucket_alloc_from_stripe() argument
776 bch2_ec_stripe_head_get(trans, req, 0, cl); in bucket_alloc_from_stripe()
897 struct closure *cl = NULL; in __open_bucket_add_buckets() local
926 ret = bch2_bucket_alloc_set_trans(trans, req, &req->wp->stripe, cl); in __open_bucket_add_buckets()
930 !cl && _cl) { in __open_bucket_add_buckets()
931 cl = _cl; in __open_bucket_add_buckets()
941 struct closure *cl) in open_bucket_add_buckets() argument
946 ret = __open_bucket_add_buckets(trans, req, cl); in open_bucket_add_buckets()
958 ret = __open_bucket_add_buckets(trans, req, cl); in open_bucket_add_buckets()
1243 struct closure *cl, in bch2_alloc_sectors_start_trans() argument
1293 int ret2 = open_bucket_add_buckets(trans, req, cl); in bch2_alloc_sectors_start_trans()
1309 ret = open_bucket_add_buckets(trans, req, cl); in bch2_alloc_sectors_start_trans()
1311 ret = open_bucket_add_buckets(trans, req, cl); in bch2_alloc_sectors_start_trans()
1379 if (cl && bch2_err_matches(ret, BCH_ERR_open_buckets_empty)) in bch2_alloc_sectors_start_trans()
1382 if (cl && !(flags & BCH_WRITE_alloc_nowait) && in bch2_alloc_sectors_start_trans()
1673 void __bch2_wait_on_allocator(struct bch_fs *c, struct closure *cl) in __bch2_wait_on_allocator() argument
1677 if (t && closure_sync_timeout(cl, t)) { in __bch2_wait_on_allocator()
1682 closure_sync(cl); in __bch2_wait_on_allocator()