Loading apex/appsearch/framework/java/android/app/appsearch/AppSearchSession.java +4 −1 Original line number Diff line number Diff line Loading @@ -90,6 +90,7 @@ public final class AppSearchSession implements Closeable { @NonNull Consumer<AppSearchResult<AppSearchSession>> callback) { try { mService.initialize( mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime(), new IAppSearchResultCallback.Stub() { Loading Loading @@ -685,7 +686,9 @@ public final class AppSearchSession implements Closeable { if (mIsMutated && !mIsClosed) { try { mService.persistToDisk( mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mIsClosed = true; } catch (RemoteException e) { Log.e(TAG, "Unable to close the AppSearchSession", e); Loading apex/appsearch/framework/java/android/app/appsearch/GlobalSearchSession.java +4 −1 Original line number Diff line number Diff line Loading @@ -73,6 +73,7 @@ public class GlobalSearchSession implements Closeable { @NonNull Consumer<AppSearchResult<GlobalSearchSession>> callback) { try { mService.initialize( mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime(), new IAppSearchResultCallback.Stub() { Loading Loading @@ -187,7 +188,9 @@ public class GlobalSearchSession implements Closeable { if (mIsMutated && !mIsClosed) { try { mService.persistToDisk( mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mIsClosed = true; } catch (RemoteException e) { Log.e(TAG, "Unable to close the GlobalSearchSession", e); Loading apex/appsearch/framework/java/android/app/appsearch/SearchResults.java +3 −2 Original line number Diff line number Diff line Loading @@ -124,7 +124,8 @@ public class SearchResults implements Closeable { wrapCallback(executor, callback)); } } else { mService.getNextPage(mNextPageToken, mUserHandle, wrapCallback(executor, callback)); mService.getNextPage(mPackageName, mNextPageToken, mUserHandle, wrapCallback(executor, callback)); } } catch (RemoteException e) { throw e.rethrowFromSystemServer(); Loading @@ -135,7 +136,7 @@ public class SearchResults implements Closeable { public void close() { if (!mIsClosed) { try { mService.invalidateNextPageToken(mNextPageToken, mUserHandle); mService.invalidateNextPageToken(mPackageName, mNextPageToken, mUserHandle); mIsClosed = true; } catch (RemoteException e) { Log.e(TAG, "Unable to close the SearchResults", e); Loading apex/appsearch/framework/java/android/app/appsearch/aidl/IAppSearchManager.aidl +18 −3 Original line number Diff line number Diff line Loading @@ -181,21 +181,30 @@ interface IAppSearchManager { * Fetches the next page of results of a previously executed query. Results can be empty if * next-page token is invalid or all pages have been returned. * * @param packageName The name of the package to persist to disk for. * @param nextPageToken The token of pre-loaded results of previously executed query. * @param userHandle Handle of the calling user * @param callback {@link AppSearchResult}<{@link Bundle}> of performing this * operation. */ void getNextPage(in long nextPageToken, in UserHandle userHandle, in IAppSearchResultCallback callback); void getNextPage( in String packageName, in long nextPageToken, in UserHandle userHandle, in IAppSearchResultCallback callback); /** * Invalidates the next-page token so that no more results of the related query can be returned. * * @param packageName The name of the package to persist to disk for. * @param nextPageToken The token of pre-loaded results of previously executed query to be * Invalidated. * @param userHandle Handle of the calling user */ void invalidateNextPageToken(in long nextPageToken, in UserHandle userHandle); void invalidateNextPageToken( in String packageName, in long nextPageToken, in UserHandle userHandle); /** * Searches a document based on a given specifications. Loading Loading @@ -336,20 +345,26 @@ interface IAppSearchManager { /** * Persists all update/delete requests to the disk. * * @param packageName The name of the package to persist to disk for. * @param userHandle Handle of the calling user * @param binderCallStartTimeMillis start timestamp of binder call in Millis */ void persistToDisk(in UserHandle userHandle, in long binderCallStartTimeMillis); void persistToDisk( in String packageName, in UserHandle userHandle, in long binderCallStartTimeMillis); /** * Creates and initializes AppSearchImpl for the calling app. * * @param packageName The name of the package to initialize for. * @param userHandle Handle of the calling user * @param binderCallStartTimeMillis start timestamp of binder call in Millis * @param callback {@link IAppSearchResultCallback#onResult} will be called with an * {@link AppSearchResult}<{@link Void}>. */ void initialize( in String packageName, in UserHandle userHandle, in long binderCallStartTimeMillis, in IAppSearchResultCallback callback); Loading apex/appsearch/framework/java/external/android/app/appsearch/AppSearchBatchResult.java +0 −11 Original line number Diff line number Diff line Loading @@ -96,17 +96,6 @@ public final class AppSearchBatchResult<KeyType, ValueType> { return Collections.unmodifiableMap(mAll); } /** * Asserts that this {@link AppSearchBatchResult} has no failures. * * @hide */ public void checkSuccess() { if (!isSuccess()) { throw new IllegalStateException("AppSearchBatchResult has failures: " + this); } } @Override @NonNull public String toString() { Loading Loading
apex/appsearch/framework/java/android/app/appsearch/AppSearchSession.java +4 −1 Original line number Diff line number Diff line Loading @@ -90,6 +90,7 @@ public final class AppSearchSession implements Closeable { @NonNull Consumer<AppSearchResult<AppSearchSession>> callback) { try { mService.initialize( mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime(), new IAppSearchResultCallback.Stub() { Loading Loading @@ -685,7 +686,9 @@ public final class AppSearchSession implements Closeable { if (mIsMutated && !mIsClosed) { try { mService.persistToDisk( mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mIsClosed = true; } catch (RemoteException e) { Log.e(TAG, "Unable to close the AppSearchSession", e); Loading
apex/appsearch/framework/java/android/app/appsearch/GlobalSearchSession.java +4 −1 Original line number Diff line number Diff line Loading @@ -73,6 +73,7 @@ public class GlobalSearchSession implements Closeable { @NonNull Consumer<AppSearchResult<GlobalSearchSession>> callback) { try { mService.initialize( mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime(), new IAppSearchResultCallback.Stub() { Loading Loading @@ -187,7 +188,9 @@ public class GlobalSearchSession implements Closeable { if (mIsMutated && !mIsClosed) { try { mService.persistToDisk( mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mPackageName, mUserHandle, /*binderCallStartTimeMillis=*/ SystemClock.elapsedRealtime()); mIsClosed = true; } catch (RemoteException e) { Log.e(TAG, "Unable to close the GlobalSearchSession", e); Loading
apex/appsearch/framework/java/android/app/appsearch/SearchResults.java +3 −2 Original line number Diff line number Diff line Loading @@ -124,7 +124,8 @@ public class SearchResults implements Closeable { wrapCallback(executor, callback)); } } else { mService.getNextPage(mNextPageToken, mUserHandle, wrapCallback(executor, callback)); mService.getNextPage(mPackageName, mNextPageToken, mUserHandle, wrapCallback(executor, callback)); } } catch (RemoteException e) { throw e.rethrowFromSystemServer(); Loading @@ -135,7 +136,7 @@ public class SearchResults implements Closeable { public void close() { if (!mIsClosed) { try { mService.invalidateNextPageToken(mNextPageToken, mUserHandle); mService.invalidateNextPageToken(mPackageName, mNextPageToken, mUserHandle); mIsClosed = true; } catch (RemoteException e) { Log.e(TAG, "Unable to close the SearchResults", e); Loading
apex/appsearch/framework/java/android/app/appsearch/aidl/IAppSearchManager.aidl +18 −3 Original line number Diff line number Diff line Loading @@ -181,21 +181,30 @@ interface IAppSearchManager { * Fetches the next page of results of a previously executed query. Results can be empty if * next-page token is invalid or all pages have been returned. * * @param packageName The name of the package to persist to disk for. * @param nextPageToken The token of pre-loaded results of previously executed query. * @param userHandle Handle of the calling user * @param callback {@link AppSearchResult}<{@link Bundle}> of performing this * operation. */ void getNextPage(in long nextPageToken, in UserHandle userHandle, in IAppSearchResultCallback callback); void getNextPage( in String packageName, in long nextPageToken, in UserHandle userHandle, in IAppSearchResultCallback callback); /** * Invalidates the next-page token so that no more results of the related query can be returned. * * @param packageName The name of the package to persist to disk for. * @param nextPageToken The token of pre-loaded results of previously executed query to be * Invalidated. * @param userHandle Handle of the calling user */ void invalidateNextPageToken(in long nextPageToken, in UserHandle userHandle); void invalidateNextPageToken( in String packageName, in long nextPageToken, in UserHandle userHandle); /** * Searches a document based on a given specifications. Loading Loading @@ -336,20 +345,26 @@ interface IAppSearchManager { /** * Persists all update/delete requests to the disk. * * @param packageName The name of the package to persist to disk for. * @param userHandle Handle of the calling user * @param binderCallStartTimeMillis start timestamp of binder call in Millis */ void persistToDisk(in UserHandle userHandle, in long binderCallStartTimeMillis); void persistToDisk( in String packageName, in UserHandle userHandle, in long binderCallStartTimeMillis); /** * Creates and initializes AppSearchImpl for the calling app. * * @param packageName The name of the package to initialize for. * @param userHandle Handle of the calling user * @param binderCallStartTimeMillis start timestamp of binder call in Millis * @param callback {@link IAppSearchResultCallback#onResult} will be called with an * {@link AppSearchResult}<{@link Void}>. */ void initialize( in String packageName, in UserHandle userHandle, in long binderCallStartTimeMillis, in IAppSearchResultCallback callback); Loading
apex/appsearch/framework/java/external/android/app/appsearch/AppSearchBatchResult.java +0 −11 Original line number Diff line number Diff line Loading @@ -96,17 +96,6 @@ public final class AppSearchBatchResult<KeyType, ValueType> { return Collections.unmodifiableMap(mAll); } /** * Asserts that this {@link AppSearchBatchResult} has no failures. * * @hide */ public void checkSuccess() { if (!isSuccess()) { throw new IllegalStateException("AppSearchBatchResult has failures: " + this); } } @Override @NonNull public String toString() { Loading