Searched refs:eos_marker (Results 1 – 3 of 3) sorted by relevance
73 boolean_t eos_marker; /* Marks the end of the stream */ member143 if (new->eos_marker) { in record_merge_enqueue()292 record->eos_marker = B_FALSE; in redact_cb()322 record->eos_marker = B_FALSE; in redact_cb()379 data->eos_marker = B_TRUE; in redact_traverse_thread()422 if (rr1->eos_marker) in redact_node_compare_start()424 if (rr2->eos_marker) in redact_node_compare_start()448 if (srr1->eos_marker) in redact_node_compare_end()450 if (srr2->eos_marker) in redact_node_compare_end()471 if (from->eos_marker == B_TRUE) in redact_record_before()[all …]
150 boolean_t eos_marker; /* Marks the end of the stream */ member1050 range->eos_marker = eos; in range_alloc()1229 if (from->eos_marker == B_TRUE) in send_range_after()1231 if (to->eos_marker == B_TRUE) in send_range_after()1328 int64_t cmp = TREE_CMP(r1->eos_marker, r2->eos_marker); in send_range_start_compare()1394 if (ranges[idx]->eos_marker) { in find_next_range()1424 if (i == idx || ranges[i]->eos_marker || in find_next_range()1499 front_ranges[REDACT_IDX]->eos_marker = B_TRUE; in send_merge_thread()1514 !range->eos_marker && err == 0 && !smt_arg->cancel; in send_merge_thread()1548 while (!front_ranges[i]->eos_marker) { in send_merge_thread()[all …]
98 boolean_t eos_marker; /* Marks the end of the stream */ member3221 for (rrd = bqueue_dequeue(&rwa->q); !rrd->eos_marker; in receive_writer_thread()3454 drc->drc_rrd->eos_marker = B_TRUE; in dmu_recv_stream()