Searched refs:eos_marker (Results 1 – 3 of 3) sorted by relevance
142 if (new->eos_marker) { in record_merge_enqueue()289 record->eos_marker = B_FALSE; in redact_cb()319 record->eos_marker = B_FALSE; in redact_cb()376 data->eos_marker = B_TRUE; in redact_traverse_thread()419 if (rr1->eos_marker) in redact_node_compare_start()421 if (rr2->eos_marker) in redact_node_compare_start()445 if (srr1->eos_marker) in redact_node_compare_end()447 if (srr2->eos_marker) in redact_node_compare_end()775 record->eos_marker) { in perform_thread_merge()845 rec->eos_marker = B_TRUE; in redact_merge_thread()[all …]
800 record.eos_marker = B_FALSE; in dump_dnode()1076 range->eos_marker = eos; in range_alloc()1254 if (from->eos_marker == B_TRUE) in send_range_after()1256 if (to->eos_marker == B_TRUE) in send_range_after()1353 int64_t cmp = TREE_CMP(r1->eos_marker, r2->eos_marker); in send_range_start_compare()1419 if (ranges[idx]->eos_marker) { in find_next_range()1573 while (!front_ranges[i]->eos_marker) { in send_merge_thread()1581 range->eos_marker = B_TRUE; in send_merge_thread()1891 while (!range->eos_marker) in send_reader_thread()2534 while (err == 0 && !range->eos_marker) { in dmu_send_impl()[all …]
88 boolean_t eos_marker; /* Marks the end of the stream */ member2797 for (rrd = bqueue_dequeue(&rwa->q); !rrd->eos_marker; in receive_writer_thread()3007 drc->drc_rrd->eos_marker = B_TRUE; in dmu_recv_stream()