Searched refs:getMetricsConfig (Results 1 – 7 of 7) sorted by relevance
55 public TelemetryProto.MetricsConfig getMetricsConfig() { in getMetricsConfig() method in ScriptExecutionTask56 return mSubscriber.getMetricsConfig(); in getMetricsConfig()71 return mSubscriber.getMetricsConfig().getName().equals(key.getName()) in isAssociatedWithMetricsConfig()72 && mSubscriber.getMetricsConfig().getVersion() == key.getVersion(); in isAssociatedWithMetricsConfig()
77 public TelemetryProto.MetricsConfig getMetricsConfig() { in getMetricsConfig() method in DataSubscriber97 return mMetricsConfig.getName().equals(other.getMetricsConfig().getName()) in equals()98 && mMetricsConfig.getVersion() == other.getMetricsConfig().getVersion() in equals()
363 mCurrentMetricsConfigKey = new MetricsConfigKey(task.getMetricsConfig().getName(), in pollAndExecuteTask()364 task.getMetricsConfig().getVersion()); in pollAndExecuteTask()372 task.getMetricsConfig().getScript(), in pollAndExecuteTask()405 task.getMetricsConfig().getScript(), in invokeScriptForLargeInput()
327 failedConfigs.add(mConfigKeyToSubscribers.get(stats.getId()).getMetricsConfig()); in processStatsMetadata()446 uniqueConfigs.add(mConfigKeyToSubscribers.valueAt(i).getMetricsConfig()); in getMetricsConfigs()456 return BUNDLE_CONFIG_KEY_PREFIX + subscriber.getMetricsConfig().getName() + "-" in buildBundleConfigKey()478 if (currentVersion >= subscriber.getMetricsConfig().getVersion()) { in addStatsConfig()489 mSavedStatsConfigs.putInt(bundleVersion, subscriber.getMetricsConfig().getVersion()); in addStatsConfig()533 String metricConfigName = subscriber.getMetricsConfig().getName(); in buildConfigKey()
129 return new ArrayList<>(mSubscribers.stream().map(DataSubscriber::getMetricsConfig).collect( in getMetricsConfigs()
265 eq(mHighPriorityTask.getMetricsConfig().getName()), eq(mData)); in testScheduleNextTask_onScriptSuccess_shouldStoreInterimResult()302 eq(mHighPriorityTask.getMetricsConfig().getName()), eq(mData)); in testScheduleNextTask_whenScriptFinishes_shouldStoreFinalResult()311 when(mMockResultStore.getInterimResult(mHighPriorityTask.getMetricsConfig().getName())) in testScheduleNextTask_whenInterimDataExists_shouldPassToScriptExecutor()
441 when(subscriber1.getMetricsConfig()).thenReturn(METRICS_CONFIG); in testPullStatsdReport_correctlyPushesBundlesToSubscribers()446 when(subscriber2.getMetricsConfig()).thenReturn(METRICS_CONFIG); in testPullStatsdReport_correctlyPushesBundlesToSubscribers()