Home
last modified time | relevance | path

Searched refs:ScriptExecutionTask (Results 1 – 7 of 7) sorted by relevance

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/databroker/
DDataBrokerTest.java125 private ScriptExecutionTask mHighPriorityTask;
126 private ScriptExecutionTask mLowPriorityTask;
177 mHighPriorityTask = new ScriptExecutionTask( in setUp()
183 mLowPriorityTask = new ScriptExecutionTask( in setUp()
270 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_whenTaskInProgress_shouldNotInvokeScriptExecutorAgain()
367 ScriptExecutionTask bypassTask = new ScriptExecutionTask( in testScheduleNextTask_whenScriptExecutorBypassed_shouldStoreFinalResult()
401 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_withLargeDataFlag_shouldPipeData()
418 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_withoutLargeDataFlag_doesNotPipeData()
435 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
436 taskQueue.add(new ScriptExecutionTask( in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
[all …]
DDataSubscriberTest.java71 ArgumentCaptor<ScriptExecutionTask> taskCaptor = in testPush_shouldAddTaskToQueue()
72 ArgumentCaptor.forClass(ScriptExecutionTask.class); in testPush_shouldAddTaskToQueue()
74 ScriptExecutionTask task = taskCaptor.getValue(); in testPush_shouldAddTaskToQueue()
/packages/services/Car/service/src/com/android/car/telemetry/databroker/
DScriptExecutionTask.java33 public class ScriptExecutionTask implements Comparable<ScriptExecutionTask> { class
42 ScriptExecutionTask( in ScriptExecutionTask() method in ScriptExecutionTask
55 ScriptExecutionTask( in ScriptExecutionTask() method in ScriptExecutionTask
131 public int compareTo(@NonNull ScriptExecutionTask other) { in compareTo()
DDataSubscriber.java85 ScriptExecutionTask task = new ScriptExecutionTask( in push()
99 ScriptExecutionTask task = new ScriptExecutionTask( in push()
DDataBrokerImpl.java102 private final PriorityBlockingQueue<ScriptExecutionTask> mTaskQueue =
359 Iterator<ScriptExecutionTask> it = mTaskQueue.iterator(); in removeMetricsConfig()
361 ScriptExecutionTask task = it.next(); in removeMetricsConfig()
380 public int addTaskToQueue(@NonNull ScriptExecutionTask task) { in addTaskToQueue()
443 PriorityBlockingQueue<ScriptExecutionTask> getTaskQueue() { in getTaskQueue()
460 ScriptExecutionTask task = mTaskQueue.peek(); in pollAndExecuteTask()
542 private void invokeScriptForLargeInput(@NonNull ScriptExecutionTask task) in invokeScriptForLargeInput()
573 private void invokeScriptForBundleList(@NonNull ScriptExecutionTask task) in invokeScriptForBundleList()
DDataBroker.java108 int addTaskToQueue(@NonNull ScriptExecutionTask task); in addTaskToQueue()
/packages/services/Car/service/src/com/android/car/telemetry/
DCarTelemetryService.java66 import com.android.car.telemetry.databroker.ScriptExecutionTask;