Searched refs:min_queue_ts (Results 1 – 1 of 1) sorted by relevance
89 int64_t min_queue_ts[2]{kTsMax, kTsMax}; in SortAndExtractEventsBeyondWindow() local100 if (queue.min_ts_ < min_queue_ts[0]) { in SortAndExtractEventsBeyondWindow()101 min_queue_ts[1] = min_queue_ts[0]; in SortAndExtractEventsBeyondWindow()102 min_queue_ts[0] = queue.min_ts_; in SortAndExtractEventsBeyondWindow()105 } else if (queue.min_ts_ < min_queue_ts[1]) { in SortAndExtractEventsBeyondWindow()106 min_queue_ts[1] = queue.min_ts_; in SortAndExtractEventsBeyondWindow()125 int64_t extract_until_ts = std::min(extract_end_ts, min_queue_ts[1]); in SortAndExtractEventsBeyondWindow()160 global_min_ts_ = min_queue_ts[1]; in SortAndExtractEventsBeyondWindow()170 global_min_ts_ = std::min(queue.min_ts_, min_queue_ts[1]); in SortAndExtractEventsBeyondWindow()