/aosp14/frameworks/base/media/jni/soundpool/ |
H A D | Stream.cpp | 29 Stream::~Stream() in ~Stream() 34 void Stream::autoPause() in autoPause() 47 void Stream::autoResume() in autoResume() 62 void Stream::mute(bool muting) in mute() 155 void Stream::setPlay( in setPlay() 199 void Stream::stop() in stop() 205 void Stream::stop_l() in stop_l() 217 void Stream::clearAudioTrack() in clearAudioTrack() 227 Stream* Stream::getPairStream() const in getPairStream() 232 Stream* Stream::playPairStream(std::vector<std::any>& garbage, int32_t playerIId) { in playPairStream() [all …]
|
H A D | StreamManager.h | 299 Stream* findStream(int32_t streamID) const; 305 void forEach(std::function<void(const Stream *)>f) const { in forEach() 311 void forEach(std::function<void(Stream *)>f) { in forEach() 319 Stream* getPairStream(const Stream* stream) const { in getPairStream() 325 size_t streamPosition(const Stream* stream) const; // no lock needed 332 int32_t getNextIdForStream(Stream* stream) const; 338 Stream* lookupStreamFromId(int32_t streamID) const; 376 std::unique_ptr<PerfectHash<int32_t, Stream *>> mPerfectHash; 435 void addToRestartQueue_l(Stream *stream) REQUIRES(mStreamManagerLock); 436 void addToActiveQueue_l(Stream *stream) REQUIRES(mStreamManagerLock); [all …]
|
H A D | StreamManager.cpp | 71 Stream* StreamMap::findStream(int32_t streamID) const in findStream() 73 Stream *stream = lookupStreamFromId(streamID); in findStream() 94 [] (Stream *stream) { in getNextIdForStream() 120 forEach([this](Stream *stream) { in __anon9ad9a1b00302() 146 forEach([](Stream *stream) { stream->stop(); }); in ~StreamManager() 170 Stream *newStream = nullptr; in queueForPlay() 243 Stream *pairStream = newStream->getPairStream(); in queueForPlay() 281 Stream* stream, int32_t activeStreamIDToMatch) in moveToRestartQueue() 308 Stream* stream, int32_t activeStreamIDToMatch) in moveToRestartQueue_l() 326 Stream* stream, int32_t activeStreamIDToMatch) { in removeFromQueues_l() [all …]
|
H A D | SoundPool.cpp | 149 mStreamManager.forEach([](soundpool::Stream *stream) { stream->autoPause(); }); in autoPause() 156 mStreamManager.forEach([](soundpool::Stream *stream) { stream->autoResume(); }); in autoResume() 163 mStreamManager.forEach([=](soundpool::Stream *stream) { stream->mute(muting); }); in mute() 170 if (soundpool::Stream* stream = mStreamManager.findStream(streamID)) { in pause() 179 if (soundpool::Stream* stream = mStreamManager.findStream(streamID)) { in resume() 188 soundpool::Stream* stream = mStreamManager.findStream(streamID); in stop() 199 if (soundpool::Stream* stream = mStreamManager.findStream(streamID)) { in setVolume() 209 if (soundpool::Stream* stream = mStreamManager.findStream(streamID)) { in setPriority() 219 if (soundpool::Stream* stream = mStreamManager.findStream(streamID)) { in setLoop() 229 if (soundpool::Stream* stream = mStreamManager.findStream(streamID)) { in setRate()
|
H A D | Stream.h | 57 class alignas(kCacheLineSize) Stream { in alignas() 72 ~Stream(); in alignas() 96 Stream* playPairStream(std::vector<std::any>& garbage, in alignas() 126 Stream* getPairStream() const; in alignas() 135 StreamCallback(Stream * stream, bool toggle) : mStream(stream), mToggle(toggle) {} in alignas() 152 Stream * const mStream; in alignas()
|
/aosp14/frameworks/base/keystore/java/android/security/keystore2/ |
H A D | KeyStoreCryptoOperationChunkedStreamer.java | 55 interface Stream { interface in KeyStoreCryptoOperationChunkedStreamer 90 private final Stream mKeyStoreStream; 98 KeyStoreCryptoOperationChunkedStreamer(Stream operation) { in KeyStoreCryptoOperationChunkedStreamer() 102 KeyStoreCryptoOperationChunkedStreamer(Stream operation, int chunkSizeThreshold) { in KeyStoreCryptoOperationChunkedStreamer() 106 KeyStoreCryptoOperationChunkedStreamer(Stream operation, int chunkSizeThreshold, in KeyStoreCryptoOperationChunkedStreamer() 212 public static class MainDataStream implements Stream {
|
H A D | AndroidKeyStoreAuthenticatedAESCipherSpi.java | 27 import android.security.keystore2.KeyStoreCryptoOperationChunkedStreamer.Stream; 425 private static class AdditionalAuthenticationDataStream implements Stream {
|
/aosp14/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/dreams/touch/ |
H A D | DreamOverlayTouchMonitorTest.java | 65 import java.util.stream.Stream; 157 final Environment environment = new Environment(Stream.of(touchHandler) in testReportedDisplayBounds() 187 final Environment environment = new Environment(Stream.of(touchHandler) in testEntryTouchZone() 255 final Environment environment = new Environment(Stream.of(touchHandler) in testInputEventPropagation() 275 final Environment environment = new Environment(Stream.of(touchHandler) in testInputEventPropagationAfterRemoval() 299 final Environment environment = new Environment(Stream.of(touchHandler) in testInputGesturePropagation() 318 final Environment environment = new Environment(Stream.of(touchHandler) in testGestureConsumption() 366 final Environment environment = new Environment(Stream.of(touchHandler) in testPush() 411 final Environment environment = new Environment(Stream.of(touchHandler) in testPop() 429 final Environment environment = new Environment(Stream.of(touchHandler) in testPauseWithNoActiveSessions() [all …]
|
/aosp14/frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/ |
H A D | RemoteInputNotificationRebuilder.java | 33 import java.util.stream.Stream; 110 ? Stream.concat( in rebuildWithRemoteInputInserted() 111 Stream.of(newItem), in rebuildWithRemoteInputInserted()
|
H A D | AlertingNotificationManager.java | 33 import java.util.stream.Stream; 141 public Stream<NotificationEntry> getAllEntries() { in getAllEntries()
|
/aosp14/frameworks/base/packages/SystemUI/src/com/android/systemui/util/io/ |
H A D | Files.java | 30 import java.util.stream.Stream; 48 public Stream<String> lines(Path path) throws IOException { in lines()
|
/aosp14/frameworks/base/core/java/android/hardware/radio/ |
H A D | ProgramSelector.java | 33 import java.util.stream.Stream; 330 if (Stream.of(secondaryIds).anyMatch(id -> id == null)) { in ProgramSelector() 439 Identifier[] secondaryIds = Stream.concat( in withSecondaryPreferred() 443 Stream.of(preferred)).toArray(Identifier[]::new); in withSecondaryPreferred() 591 if (Stream.of(mSecondaryIds).anyMatch(id -> id == null)) { in ProgramSelector()
|
/aosp14/frameworks/base/services/credentials/java/com/android/server/credentials/ |
H A D | ProviderRegistryGetSession.java | 50 import java.util.stream.Stream; 192 Stream<CredentialEntry>>) filterResult -> in prepareUiData() 271 Stream<CredentialEntry>>) in invokeSession()
|
/aosp14/frameworks/base/services/robotests/backup/src/android/app/backup/ |
H A D | BackupUtilsTest.java | 36 import java.util.stream.Stream; 186 return Stream.of(files) in paths()
|
/aosp14/frameworks/base/core/java/android/app/slice/ |
H A D | SliceQuery.java | 26 import java.util.stream.Stream; 152 public static Stream<SliceItem> stream(SliceItem slice) { in stream()
|
/aosp14/frameworks/base/services/robotests/backup/src/com/android/server/backup/ |
H A D | TransportManagerTest.java | 46 import static java.util.stream.Stream.concat; 83 import java.util.stream.Stream; 727 Stream.of(mTransportA1, mTransportA2, mTransportB1) in testGetRegisteredTransportNames() 743 Stream.of(mTransportA1, mTransportA2, mTransportB1) in testGetRegisteredTransportComponents() 832 return concat(Stream.of(selectedTransport), Stream.of(transports)) in merge()
|
/aosp14/frameworks/base/services/core/java/com/android/server/biometrics/log/ |
H A D | BiometricFrameworkStatsLogger.java | 33 import java.util.stream.Stream; 156 return Stream.of(toProtoWakeReasonDetails(ctx.authenticateReason)) in toProtoWakeReasonDetails()
|
/aosp14/frameworks/base/services/robotests/backup/src/com/android/server/backup/testing/ |
H A D | TransportTestUtils.java | 48 import java.util.stream.Stream; 109 return Stream.of(transports) in setUpTransports()
|
/aosp14/frameworks/base/services/core/java/com/android/server/pm/ |
H A D | PackageMetrics.java | 41 import java.util.stream.Stream; 158 try (Stream<Path> walkStream = Files.walk(apkDir.toPath())) { in getApksSize()
|
/aosp14/frameworks/base/packages/SettingsLib/tests/robotests/src/com/android/settingslib/users/ |
H A D | EditUserInfoControllerTest.java | 54 import java.util.stream.Stream; 124 final String longName = Stream.generate( in userNameView_inputLongName_shouldBeConstrained()
|
/aosp14/frameworks/base/core/java/android/app/ |
H A D | UiModeManager.java | 54 import java.util.stream.Stream; 438 private static Stream<Integer> allContrastLevels() { in allContrastLevels() 439 return Stream.of(CONTRAST_LEVEL_STANDARD, CONTRAST_LEVEL_MEDIUM, CONTRAST_LEVEL_HIGH); in allContrastLevels()
|
/aosp14/frameworks/base/cmds/incident_helper/java/com/android/commands/incident/sections/ |
H A D | PersistLogSection.java | 47 import java.util.stream.Stream; 107 try (Stream<File> stream = Files.list(logDirPath).map(Path::toFile) in run()
|
/aosp14/frameworks/base/services/tests/uiservicestests/src/com/android/server/notification/ |
H A D | NotificationVisitUrisTest.java | 80 import java.util.stream.Stream; 310 Stream<Class<?>> maybeBuilders = in generateObject() 311 Stream.concat(Arrays.stream(clazz.getDeclaredClasses()), in generateObject() 314 : Stream.empty()); in generateObject()
|
/aosp14/frameworks/base/packages/SystemUI/src/com/android/systemui/people/widget/ |
H A D | PeopleSpaceWidgetManager.java | 116 import java.util.stream.Stream; 997 Stream<ShortcutInfo> priorityConversations = conversations.stream() in getPriorityTiles() 1014 Stream<ShortcutInfo> nonPriorityConversations = conversations.stream() in getRecentTiles() 1021 Stream<ShortcutInfo> recentConversations = recentConversationsList in getRecentTiles() 1025 Stream<ShortcutInfo> mergedStream = Stream.concat(nonPriorityConversations, in getRecentTiles()
|
/aosp14/frameworks/base/services/robotests/backup/src/com/android/server/backup/internal/ |
H A D | PerformInitializeTaskTest.java | 69 import java.util.stream.Stream; 271 Stream.of(new TransportData[] {backupTransport(), d2dTransport(), localTransport()}) in testRun_withMultipleTransports()
|