Home
last modified time | relevance | path

Searched refs:Stream (Results 1 – 25 of 48) sorted by relevance

12

/aosp14/frameworks/base/media/jni/soundpool/
H A DStream.cpp29 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 DStreamManager.h299 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 DStreamManager.cpp71 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 DSoundPool.cpp149 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 DStream.h57 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 DKeyStoreCryptoOperationChunkedStreamer.java55 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 DAndroidKeyStoreAuthenticatedAESCipherSpi.java27 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 DDreamOverlayTouchMonitorTest.java65 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 DRemoteInputNotificationRebuilder.java33 import java.util.stream.Stream;
110 ? Stream.concat( in rebuildWithRemoteInputInserted()
111 Stream.of(newItem), in rebuildWithRemoteInputInserted()
H A DAlertingNotificationManager.java33 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 DFiles.java30 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 DProgramSelector.java33 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 DProviderRegistryGetSession.java50 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 DBackupUtilsTest.java36 import java.util.stream.Stream;
186 return Stream.of(files) in paths()
/aosp14/frameworks/base/core/java/android/app/slice/
H A DSliceQuery.java26 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 DTransportManagerTest.java46 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 DBiometricFrameworkStatsLogger.java33 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 DTransportTestUtils.java48 import java.util.stream.Stream;
109 return Stream.of(transports) in setUpTransports()
/aosp14/frameworks/base/services/core/java/com/android/server/pm/
H A DPackageMetrics.java41 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 DEditUserInfoControllerTest.java54 import java.util.stream.Stream;
124 final String longName = Stream.generate( in userNameView_inputLongName_shouldBeConstrained()
/aosp14/frameworks/base/core/java/android/app/
H A DUiModeManager.java54 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 DPersistLogSection.java47 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 DNotificationVisitUrisTest.java80 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 DPeopleSpaceWidgetManager.java116 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 DPerformInitializeTaskTest.java69 import java.util.stream.Stream;
271 Stream.of(new TransportData[] {backupTransport(), d2dTransport(), localTransport()}) in testRun_withMultipleTransports()

12