Searched refs:eos_marker (Results 1 – 3 of 3) sorted by relevance
143 if (new->eos_marker) { in record_merge_enqueue()290 record->eos_marker = B_FALSE; in redact_cb()320 record->eos_marker = B_FALSE; in redact_cb()377 data->eos_marker = B_TRUE; in redact_traverse_thread()420 if (rr1->eos_marker) in redact_node_compare_start()422 if (rr2->eos_marker) in redact_node_compare_start()446 if (srr1->eos_marker) in redact_node_compare_end()448 if (srr2->eos_marker) in redact_node_compare_end()774 record->eos_marker) { in perform_thread_merge()845 rec->eos_marker = B_TRUE; in redact_merge_thread()[all …]
814 record.eos_marker = B_FALSE; in dump_dnode()1092 range->eos_marker = eos; in range_alloc()1269 if (from->eos_marker == B_TRUE) in send_range_after()1271 if (to->eos_marker == B_TRUE) in send_range_after()1368 int64_t cmp = TREE_CMP(r1->eos_marker, r2->eos_marker); in send_range_start_compare()1434 if (ranges[idx]->eos_marker) { in find_next_range()1588 while (!front_ranges[i]->eos_marker) { in send_merge_thread()1594 range->eos_marker = B_TRUE; in send_merge_thread()1908 while (!range->eos_marker) in send_reader_thread()2552 while (err == 0 && !range->eos_marker) { in dmu_send_impl()[all …]
98 boolean_t eos_marker; /* Marks the end of the stream */ member3184 for (rrd = bqueue_dequeue(&rwa->q); !rrd->eos_marker; in receive_writer_thread()3417 drc->drc_rrd->eos_marker = B_TRUE; in dmu_recv_stream()