Searched refs:addTaskToQueue (Results 1 – 7 of 7) sorted by relevance
/packages/modules/AppSearch/testing/servicestests/src/com/android/server/appsearch/ |
D | RateLimitedExecutorTest.java | 54 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_addOk() 56 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_addOk() 58 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_addOk() 60 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_addOk() 78 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask() 84 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask() 86 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask() 88 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask() 90 assertThat(rateLimitedExecutor.addTaskToQueue(pkgName, in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask() 99 rateLimitedExecutor.addTaskToQueue(pkgName, CallStats.CALL_TYPE_SEARCH)).isFalse(); in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask() [all …]
|
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/databroker/ |
D | DataBrokerTest.java | 576 mDataBroker.addTaskToQueue(mHighPriorityTask); in testAddTaskToQueue_shouldInvokeScriptExecutor() 586 mDataBroker.addTaskToQueue(mHighPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount() 593 mDataBroker.addTaskToQueue(mHighPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount() 595 mDataBroker.addTaskToQueue(mLowPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount() 596 mDataBroker.addTaskToQueue(mLowPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount() 597 mDataBroker.addTaskToQueue(mLowPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount() 600 int statsTaskCount = mDataBroker.addTaskToQueue(mHighPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount() 602 int memoryTaskCount = mDataBroker.addTaskToQueue(mLowPriorityTask); in testAddTaskToQueue_shouldReturnCorrectCount()
|
D | DataSubscriberTest.java | 65 when(mMockDataBroker.addTaskToQueue(any())).thenReturn(expectedNumPendingTasks); in testPush_shouldAddTaskToQueue() 73 verify(mMockDataBroker).addTaskToQueue(taskCaptor.capture()); in testPush_shouldAddTaskToQueue()
|
/packages/services/Car/service/src/com/android/car/telemetry/databroker/ |
D | DataSubscriber.java | 87 return mDataBroker.addTaskToQueue(task); in push() 101 return mDataBroker.addTaskToQueue(task); in push()
|
D | DataBroker.java | 108 int addTaskToQueue(@NonNull ScriptExecutionTask task); in addTaskToQueue() method
|
D | DataBrokerImpl.java | 380 public int addTaskToQueue(@NonNull ScriptExecutionTask task) { in addTaskToQueue() method in DataBrokerImpl 524 addTaskToQueue(task); // will trigger scheduleNextTask() and re-binding scriptexecutor in pollAndExecuteTask()
|
/packages/modules/AppSearch/service/java/com/android/server/appsearch/util/ |
D | RateLimitedExecutor.java | 87 if (!addTaskToQueue(packageName, apiType)) { in execute() 133 public boolean addTaskToQueue(@NonNull String packageName, @CallStats.CallType int apiType) { in addTaskToQueue() method in RateLimitedExecutor
|