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;
182 mHighPriorityTask = new ScriptExecutionTask( in setUp()
188 mLowPriorityTask = new ScriptExecutionTask( in setUp()
275 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_whenTaskInProgress_shouldNotInvokeScriptExecutorAgain()
372 ScriptExecutionTask bypassTask = new ScriptExecutionTask( in testScheduleNextTask_whenScriptExecutorBypassed_shouldStoreFinalResult()
406 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_withLargeDataFlag_shouldPipeData()
423 ScriptExecutionTask highPriorityTask = new ScriptExecutionTask( in testScheduleNextTask_withoutLargeDataFlag_doesNotPipeData()
440 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
441 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 =
353 Iterator<ScriptExecutionTask> it = mTaskQueue.iterator(); in removeMetricsConfig()
355 ScriptExecutionTask task = it.next(); in removeMetricsConfig()
374 public int addTaskToQueue(@NonNull ScriptExecutionTask task) { in addTaskToQueue()
437 PriorityBlockingQueue<ScriptExecutionTask> getTaskQueue() { in getTaskQueue()
454 ScriptExecutionTask task = mTaskQueue.peek(); in pollAndExecuteTask()
536 private void invokeScriptForLargeInput(@NonNull ScriptExecutionTask task) in invokeScriptForLargeInput()
567 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.java67 import com.android.car.telemetry.databroker.ScriptExecutionTask;