Home
last modified time | relevance | path

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

/aosp12/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/databroker/
H A DDataBrokerTest.java112 private ScriptExecutionTask mHighPriorityTask;
113 private ScriptExecutionTask mLowPriorityTask;
154 mHighPriorityTask = new ScriptExecutionTask( in setUp()
159 mLowPriorityTask = new ScriptExecutionTask( in setUp()
217 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_whenTaskInProgress_shouldNotInvokeScriptExecutorAgain()
236 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_whenTaskCompletes_shouldAutomaticallyScheduleNextTask()
324 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_withLargeDataFlag_shouldPipeData()
340 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_withoutLargeDataFlag_doesNotPipeData()
357 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
363 taskQueue.add(new ScriptExecutionTask( in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
[all …]
/aosp12/packages/services/Car/service/src/com/android/car/telemetry/databroker/
H A DScriptExecutionTask.java31 public class ScriptExecutionTask implements Comparable<ScriptExecutionTask> { class
37 ScriptExecutionTask(DataSubscriber subscriber, PersistableBundle data, in ScriptExecutionTask() method in ScriptExecutionTask
83 public int compareTo(ScriptExecutionTask other) { in compareTo()
H A DDataSubscriber.java63 ScriptExecutionTask task = new ScriptExecutionTask( in push()
H A DDataBrokerImpl.java83 private final PriorityBlockingQueue<ScriptExecutionTask> mTaskQueue =
281 public void addTaskToQueue(ScriptExecutionTask task) { in addTaskToQueue()
334 PriorityBlockingQueue<ScriptExecutionTask> getTaskQueue() { in getTaskQueue()
350 ScriptExecutionTask task = mTaskQueue.peek(); in pollAndExecuteTask()
398 private void invokeScriptForLargeInput(ScriptExecutionTask task) in invokeScriptForLargeInput()
H A DDataBroker.java67 void addTaskToQueue(ScriptExecutionTask task); in addTaskToQueue()