Lines Matching refs:send_range
150 struct send_range { struct
185 struct send_range *spill_range;
228 static int do_dump(dmu_send_cookie_t *dscp, struct send_range *range);
231 range_free(struct send_range *range) in range_free()
883 do_dump(dmu_send_cookie_t *dscp, struct send_range *range) in do_dump()
1042 static struct send_range *
1046 struct send_range *range = kmem_alloc(sizeof (*range), KM_SLEEP); in range_alloc()
1076 struct send_range *record; in send_cb()
1184 struct send_range *data = range_alloc(REDACT, rb->rbp_object, in redact_list_cb()
1208 struct send_range *data; in send_traverse_thread()
1228 send_range_after(const struct send_range *from, const struct send_range *to) in send_range_after()
1273 static struct send_range *
1274 get_next_range_nofree(bqueue_t *bq, struct send_range *prev) in get_next_range_nofree()
1276 struct send_range *next = bqueue_dequeue(bq); in get_next_range_nofree()
1285 static struct send_range *
1286 get_next_range(bqueue_t *bq, struct send_range *prev) in get_next_range()
1288 struct send_range *next = get_next_range_nofree(bq, prev); in get_next_range()
1297 struct send_range *record; in redact_list_thread()
1323 send_range_start_compare(struct send_range *r1, struct send_range *r2) in send_range_start_compare()
1385 static struct send_range *
1386 find_next_range(struct send_range **ranges, bqueue_t **qs, uint64_t *out_mask) in find_next_range()
1396 struct send_range *ret = range_alloc(DATA, 0, 0, 0, B_TRUE); in find_next_range()
1416 struct send_range *ret = ranges[idx]; in find_next_range()
1458 struct send_range *ret = ranges[idx]; in find_next_range()
1467 struct send_range *ret = kmem_alloc(sizeof (*ret), KM_SLEEP); in find_next_range()
1492 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread()
1499 kmem_zalloc(sizeof (struct send_range), KM_SLEEP); in send_merge_thread()
1513 struct send_range *range; in send_merge_thread()
1573 struct send_range *range = zio->io_private; in dmu_send_read_done()
1589 issue_data_read(struct send_reader_thread_arg *srta, struct send_range *range) in issue_data_read()
1678 struct send_range *range = range_alloc(range_type, dn->dn_object, in enqueue_range()
1720 struct send_range *range) in piggyback_unmodified_spill()
1733 struct send_range *spill_range = range_alloc(DATA, range->object, in piggyback_unmodified_spill()
1761 struct send_range *range = bqueue_dequeue(inq); in send_reader_thread()
2083 offsetof(struct send_range, ln))); in setup_to_thread()
2104 offsetof(struct send_range, ln))); in setup_from_thread()
2128 offsetof(struct send_range, ln))); in setup_redact_list_thread()
2146 offsetof(struct send_range, ln))); in setup_merge_thread()
2166 offsetof(struct send_range, ln))); in setup_reader_thread()
2377 struct send_range *range; in dmu_send_impl()