| /packages/modules/AppSearch/testing/appsindexertests/src/com/android/server/appsearch/appsindexer/ |
| D | AppsIndexerUserInstanceTest.java | 71 private ThreadPoolExecutor mSingleThreadedExecutor; field in AppsIndexerUserInstanceTest
84 mSingleThreadedExecutor = in setUp()
97 mContext, mAppsDir, mAppsIndexerConfig, mSingleThreadedExecutor); in setUp()
104 mSingleThreadedExecutor.shutdownNow(); in tearDown()
114 mSingleThreadedExecutor = in testFirstRun_schedulesUpdate()
129 mContext, mAppsDir, mAppsIndexerConfig, mSingleThreadedExecutor); in testFirstRun_schedulesUpdate()
138 long beforeFirstRun = mSingleThreadedExecutor.getCompletedTaskCount(); in testFirstRun_schedulesUpdate()
143 while (mSingleThreadedExecutor.getCompletedTaskCount() != beforeFirstRun + 1) { in testFirstRun_schedulesUpdate()
147 assertThat(mSingleThreadedExecutor.getCompletedTaskCount()).isEqualTo(beforeFirstRun + 1); in testFirstRun_schedulesUpdate()
165 mSingleThreadedExecutor = in testFirstRun_updateAlreadyRan_doesNotUpdate()
[all …]
|
| D | AppSearchHelperTest.java | 70 private final ExecutorService mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in AppSearchHelperTest
82 removeFakePackageDocuments(mContext, mSingleThreadedExecutor); in tearDown()
92 createFakeAppIndexerSession(mContext, mSingleThreadedExecutor); in testAppSearchHelper_permissionSetCorrectlyForMobileApplication()
117 removeFakePackageDocuments(mContext, mSingleThreadedExecutor); in testIndexManyApps()
130 createFakeAppIndexerSession(mContext, mSingleThreadedExecutor); in testIndexApps_compatibleSchemaChange()
147 createFakeAppIndexerSession(mContext, mSingleThreadedExecutor); in testIndexApps_incompatibleSchemaChange()
|
| D | AppsIndexerImplTest.java | 58 private final ExecutorService mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in AppsIndexerImplTest
68 removeFakePackageDocuments(mContext, mSingleThreadedExecutor); in tearDown()
|
| D | AppsIndexerManagerServiceTest.java | 82 private final ExecutorService mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in AppsIndexerManagerServiceTest
151 AppSearchSessionShim db = createFakeAppIndexerSession(mContext, mSingleThreadedExecutor); in tearDown()
|
| /packages/modules/AppSearch/testing/contactsindexertests/src/com/android/server/appsearch/contactsindexer/ |
| D | ContactsIndexerUserInstanceTest.java | 94 private final ExecutorService mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in ContactsIndexerUserInstanceTest
110 mConfigForTest, mSingleThreadedExecutor); in setUp()
226 boolean isDataDirectoryCreatedSynchronously = mSingleThreadedExecutor.submit(() -> { in testCreateInstance_dataDirectoryCreatedAsynchronously()
229 mSingleThreadedExecutor); in testCreateInstance_dataDirectoryCreatedAsynchronously()
234 boolean isDataDirectoryCreatedAsynchronously = mSingleThreadedExecutor.submit( in testCreateInstance_dataDirectoryCreatedAsynchronously()
245 mContactsDir, mConfigForTest, mSingleThreadedExecutor); in testStart_initialRun_schedulesFullUpdateJob()
266 mSingleThreadedExecutor, in testStart_initialRun_schedulesFullUpdateJob()
299 mSingleThreadedExecutor); in testStart_subsequentRunWithNoScheduledJob_schedulesFullUpdateJob() local
307 mContext, mContactsDir, mConfigForTest, mSingleThreadedExecutor); in testStart_subsequentRunWithNoScheduledJob_schedulesFullUpdateJob()
328 mSingleThreadedExecutor, in testStart_subsequentRunWithNoScheduledJob_schedulesFullUpdateJob()
[all …]
|
| D | AppSearchHelperTest.java | 69 private final Executor mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in AppSearchHelperTest
103 mAppSearchHelper = AppSearchHelper.createAppSearchHelper(mContext, mSingleThreadedExecutor, in setUp()
133 session.getSchema(mSingleThreadedExecutor, responseFuture::complete); in testAppSearchHelper_permissionIsSetCorrectlyForPerson()
270 mSingleThreadedExecutor, mConfigForTest); in testCreateAppSearchHelper_compatibleSchemaChange()
285 AppSearchHelper.createAppSearchHelper(mContext, mSingleThreadedExecutor, in testCreateAppSearchHelper_compatibleSchemaChange2()
301 AppSearchHelper.createAppSearchHelper(mContext, mSingleThreadedExecutor, in testCreateAppSearchHelper_incompatibleSchemaChange()
|
| D | ContactsIndexerManagerServiceTest.java | 68 private final ExecutorService mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in ContactsIndexerManagerServiceTest
103 mSingleThreadedExecutor).get(); in tearDown()
232 mSingleThreadedExecutor, in countDownAppSearchDocumentChanges()
|
| D | EnterpriseContactsTest.java | 130 private final Executor mSingleThreadedExecutor = Executors.newSingleThreadExecutor(); field in EnterpriseContactsTest
157 mAppSearchHelper = AppSearchHelper.createAppSearchHelper(mContext, mSingleThreadedExecutor, in setUp()
522 mSingleThreadedExecutor, callback); in testEnterpriseContactsInSystemPackage_transformPerson()
|
| /packages/modules/AppSearch/service/java/com/android/server/appsearch/appsindexer/ |
| D | AppsIndexerUserInstance.java | 76 private final ExecutorService mSingleThreadedExecutor; field in AppsIndexerUserInstance
139 mSingleThreadedExecutor = Objects.requireNonNull(singleThreadedExecutor); in AppsIndexerUserInstance()
149 synchronized (mSingleThreadedExecutor) { in shutdown()
150 mSingleThreadedExecutor.shutdown(); in shutdown()
152 boolean unused = mSingleThreadedExecutor.awaitTermination(30L, TimeUnit.SECONDS); in shutdown()
267 synchronized (mSingleThreadedExecutor) { in executeOnSingleThreadedExecutor()
268 if (mSingleThreadedExecutor.isShutdown()) { in executeOnSingleThreadedExecutor()
272 mSingleThreadedExecutor.execute( in executeOnSingleThreadedExecutor()
|
| /packages/modules/AppSearch/service/java/com/android/server/appsearch/contactsindexer/ |
| D | ContactsIndexerUserInstance.java | 98 private final ExecutorService mSingleThreadedExecutor; field in ContactsIndexerUserInstance
169 mSingleThreadedExecutor = Objects.requireNonNull(singleThreadedExecutor); in ContactsIndexerUserInstance()
215 synchronized (mSingleThreadedExecutor) { in shutdown()
216 mSingleThreadedExecutor.shutdown(); in shutdown()
218 boolean unused = mSingleThreadedExecutor.awaitTermination(30L, TimeUnit.SECONDS); in shutdown()
696 synchronized (mSingleThreadedExecutor) {
697 if (mSingleThreadedExecutor.isShutdown()) {
701 mSingleThreadedExecutor.execute(
|