Lines Matching full:buckets

14 #include "buckets.h"
144 move_buckets *buckets) in bch2_copygc_get_buckets() argument
180 ret2 = darray_push(buckets, b); in bch2_copygc_get_buckets()
186 ret2 = buckets->nr >= nr_to_get; in bch2_copygc_get_buckets()
191 pr_debug("have: %zu (%zu) saw %zu in flight %zu not movable %zu got %zu (%zu)/%zu buckets ret %i", in bch2_copygc_get_buckets()
193 saw, in_flight, not_movable, buckets->nr, sectors, nr_to_get, ret); in bch2_copygc_get_buckets()
208 move_buckets buckets = { 0 }; in bch2_copygc() local
213 ret = bch2_copygc_get_buckets(ctxt, buckets_in_flight, &buckets); in bch2_copygc()
217 darray_for_each(buckets, i) { in bch2_copygc()
240 darray_exit(&buckets); in bch2_copygc()
313 struct buckets_in_flight *buckets; in bch2_copygc_thread() local
317 buckets = kzalloc(sizeof(struct buckets_in_flight), GFP_KERNEL); in bch2_copygc_thread()
318 if (!buckets) in bch2_copygc_thread()
320 ret = rhashtable_init(&buckets->table, &bch_move_bucket_params); in bch2_copygc_thread()
321 bch_err_msg(c, ret, "allocating copygc buckets in flight"); in bch2_copygc_thread()
323 kfree(buckets); in bch2_copygc_thread()
341 move_buckets_wait(&ctxt, buckets, true); in bch2_copygc_thread()
347 move_buckets_wait(&ctxt, buckets, true); in bch2_copygc_thread()
358 move_buckets_wait(&ctxt, buckets, true); in bch2_copygc_thread()
368 ret = bch2_copygc(&ctxt, buckets, &did_work); in bch2_copygc_thread()
385 move_buckets_wait(&ctxt, buckets, true); in bch2_copygc_thread()
387 rhashtable_destroy(&buckets->table); in bch2_copygc_thread()
388 kfree(buckets); in bch2_copygc_thread()