Searched refs:intervals (Results 1 – 17 of 17) sorted by relevance
442 const LogEvent& event, vector<Interval>& intervals, in aggregateFields() argument459 Interval& interval = intervals[i]; in aggregateFields()611 long wholeBucketVal = intervals[0].aggregate.getValueOrDefault<int64_t>(0); in aggregateFields()625 int64_t bucketEndTimeNs, vector<Interval>& intervals) { in buildPartialBucket() argument632 if (intervals.empty() || (intervals[0].hasValue() && !valuePassesThreshold(intervals[0]))) { in buildPartialBucket()636 for (const Interval& interval : intervals) { in buildPartialBucket()687 currentBucket.intervals.empty()) { in appendToFullBucket()691 auto& interval = currentBucket.intervals[0]; in appendToFullBucket()709 if (tracker != nullptr && !currentBucket.intervals.empty()) { in appendToFullBucket()711 auto& interval = currentBucket.intervals[0]; in appendToFullBucket()[all …]
113 vector<Interval>& intervals, Empty& empty) { in aggregateFields() argument117 Interval& interval = intervals[i]; in aggregateFields()141 int64_t bucketEndTimeNs, vector<Interval>& intervals) { in buildPartialBucket() argument145 for (Interval& interval : intervals) { in buildPartialBucket()
292 CurrentBucket() : intervals(), conditionTimer(ConditionTimer(false, 0)) { in CurrentBucket()295 std::vector<Interval> intervals; member341 std::vector<Interval>& intervals) = 0;376 const LogEvent& event, std::vector<Interval>& intervals,
653 for (const Interval& interval : currentBucket.intervals) { in dumpStatesLocked()744 vector<Interval>& intervals = currentBucket.intervals; in onMatchedLogEventInternalLocked() local745 if (intervals.size() < mFieldMatchers.size()) { in onMatchedLogEventInternalLocked()747 intervals.resize(mFieldMatchers.size()); in onMatchedLogEventInternalLocked()753 dimensionsInWhatInfo.seenNewData |= aggregateFields(eventTimeNs, eventKey, event, intervals, in onMatchedLogEventInternalLocked()854 buildPartialBucket(bucketEndTimeNs, currentBucket.intervals); in closeCurrentBucket()909 for (auto& interval : it->second.intervals) { in initNextSlicedBucket()
99 int64_t bucketEndTime, std::vector<Interval>& intervals) override;109 const LogEvent& event, std::vector<Interval>& intervals,
110 std::vector<Interval>& intervals) override;133 const LogEvent& event, std::vector<Interval>& intervals,
23 # Below intervals are in seconds34 # Below intervals are in seconds45 # Below intervals are in seconds
630 valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()658 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()879 valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()888 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()937 valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()938 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()947 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()958 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()1205 valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()1278 valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()[all …]
250 kllProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()285 kllProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()
3067 List<Long> intervals = triggerPeriodicScansAndGetIntervals(0 /* triggerTimes */, in testInitialFastScanSchedulesMoreScans() local3072 verifyScanTimesAndIntervals(1 /* scanTimes */, intervals, in testInitialFastScanSchedulesMoreScans()3153 private void verifyScanTimesAndIntervals(int scanTimes, List<Long> intervals, in verifyScanTimesAndIntervals() argument3176 for (int i = 0; i < intervals.size(); i++) { in verifyScanTimesAndIntervals()3181 final long delta = Math.abs(expected - intervals.get(i).longValue()); in verifyScanTimesAndIntervals()3187 private void verifyScanTimesAndFirstInterval(int scanTimes, List<Long> intervals, in verifyScanTimesAndFirstInterval() argument3194 final long delta = Math.abs(expectedInterval * 1000L - intervals.get(0)); in verifyScanTimesAndFirstInterval()3240 List<Long> intervals = triggerPeriodicScansAndGetIntervals(SCAN_TRIGGER_TIMES, in checkWorkingWithDefaultScheduleWithMultiplier() local3247 verifyScanTimesAndIntervals(SCAN_TRIGGER_TIMES + 1, intervals, in checkWorkingWithDefaultScheduleWithMultiplier()3272 List<Long> intervals = triggerPeriodicScansAndGetIntervals(SCAN_TRIGGER_TIMES, in checkPeriodicScanIntervalWhenDisconnected() local[all …]
229 frame->intervals.emplace_back(ival); in getFrameIntervals()494 for (auto frameInterval : chosenFrame.intervals) { in setStreamingControl()502 reqFrameInterval = chosenFrame.intervals[chosenFrame.intervals.size() - 1]; in setStreamingControl()
55 std::vector<uint32_t> intervals; member
67 min and max intervals, the number of attempts and the timeout. The overall
1dictionary=main:en_gb,locale=en_GB,description=English (UK),date ...
1dictionary=main:en_us,locale=en_US,description=English (US),date ...
1dictionary=main:en,locale=en,description=English,date=1414726273, ...