Searched refs:min_queue_ts (Results 1 – 1 of 1) sorted by relevance
91 int64_t min_queue_ts[2]{kTsMax, kTsMax}; in SortAndExtractEventsBeyondWindow() local102 if (queue.min_ts_ < min_queue_ts[0]) { in SortAndExtractEventsBeyondWindow()103 min_queue_ts[1] = min_queue_ts[0]; in SortAndExtractEventsBeyondWindow()104 min_queue_ts[0] = queue.min_ts_; in SortAndExtractEventsBeyondWindow()107 } else if (queue.min_ts_ < min_queue_ts[1]) { in SortAndExtractEventsBeyondWindow()108 min_queue_ts[1] = queue.min_ts_; in SortAndExtractEventsBeyondWindow()127 int64_t extract_until_ts = std::min(extract_end_ts, min_queue_ts[1]); in SortAndExtractEventsBeyondWindow()162 global_min_ts_ = min_queue_ts[1]; in SortAndExtractEventsBeyondWindow()172 global_min_ts_ = std::min(queue.min_ts_, min_queue_ts[1]); in SortAndExtractEventsBeyondWindow()