Home
last modified time | relevance | path

Searched refs:StreamState (Results 1 - 22 of 22) sorted by relevance

/third_party/skia/third_party/externals/oboe/tests/
H A DtestStreamStates.cpp66 ASSERT_EQ(mStream->getState(), StreamState::Closed) << "Stream state " << convertToText(mStream->getState()); in openAndCloseStream()
72 StreamState next = StreamState::Unknown; in checkStreamStateIsStartedAfterStartingTwice()
75 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkStreamStateIsStartedAfterStartingTwice()
77 EXPECT_EQ(next, StreamState::Started); in checkStreamStateIsStartedAfterStartingTwice()
79 next = StreamState::Unknown; in checkStreamStateIsStartedAfterStartingTwice()
83 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkStreamStateIsStartedAfterStartingTwice()
85 ASSERT_EQ(next, StreamState::Started); in checkStreamStateIsStartedAfterStartingTwice()
93 StreamState next = StreamState in checkStreamStateIsStoppedAfterStoppingTwice()
[all...]
H A DtestStreamWaitState.cpp59 StreamState next = StreamState::Unknown; in checkWaitZeroTimeout()
66 StreamState next = StreamState::Unknown; in checkStopWhileWaiting()
69 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkStopWhileWaiting()
71 EXPECT_EQ(next, StreamState::Started) << "next = " << convertToText(next); in checkStopWhileWaiting()
79 r = mStream->waitForStateChange(StreamState::Started, &next, 1000 * kNanosPerMillisecond); in checkStopWhileWaiting()
83 if (next == StreamState::Stopping) { in checkStopWhileWaiting()
84 r = mStream->waitForStateChange(StreamState::Stopping, &next, 1000 * kNanosPerMillisecond); in checkStopWhileWaiting()
87 ASSERT_EQ(next, StreamState in checkStopWhileWaiting()
[all...]
H A DtestStreamClosedMethods.cpp57 ASSERT_EQ(mStream->getState(), StreamState::Closed) << "Stream state " << convertToText(mStream->getState()); in openAndCloseStream()
182 ASSERT_EQ(mStream->getState(), StreamState::Closed); in TEST_F()
310 StreamState next; in TEST_F()
311 Result r = mStream->waitForStateChange(StreamState::Open, &next, 0); in TEST_F()
H A DtestXRunBehaviour.cpp60 ASSERT_EQ(mStream->getState(), StreamState::Closed); in openAndCloseStream()
/third_party/skia/third_party/externals/oboe/src/opensles/
H A DAudioOutputStreamOpenSLES.cpp233 setState(StreamState::Open); in open()
248 if (getState() == StreamState::Closed){ in close()
284 StreamState initialState = getState(); in requestStart()
286 case StreamState::Starting: in requestStart()
287 case StreamState::Started: in requestStart()
290 case StreamState::Closed: in requestStart()
301 setState(StreamState::Starting); in requestStart()
304 setState(StreamState::Started); in requestStart()
322 StreamState initialState = getState(); in requestPause()
324 case StreamState in requestPause()
[all...]
H A DAudioInputStreamOpenSLES.cpp208 setState(StreamState::Open); in open()
219 if (getState() == StreamState::Closed){ in close()
254 StreamState initialState = getState(); in requestStart()
256 case StreamState::Starting: in requestStart()
257 case StreamState::Started: in requestStart()
259 case StreamState::Closed: in requestStart()
269 setState(StreamState::Starting); in requestStart()
272 setState(StreamState::Started); in requestStart()
299 StreamState initialState = getState(); in requestStop()
301 case StreamState in requestStop()
[all...]
H A DAudioStreamOpenSLES.h60 StreamState getState() const override { return mState.load(); }
77 Result waitForStateChange(StreamState currentState,
78 StreamState *nextState,
111 void setState(StreamState state) { in setState()
126 std::atomic<StreamState> mState{StreamState::Uninitialized};
H A DAudioStreamOpenSLES.cpp270 if (mState == StreamState::Closed) { in close()
288 setState(StreamState::Closed); in close()
366 Result AudioStreamOpenSLES::waitForStateChange(StreamState currentState, in waitForStateChange()
367 StreamState *nextState, in waitForStateChange()
374 const StreamState state = getState(); // this does not require a lock in waitForStateChange()
H A DAudioStreamBuffered.cpp207 if (getState() == StreamState::Closed){ in write()
222 if (getState() == StreamState::Closed){ in read()
236 if (getState() == StreamState::Closed){ in setBufferSizeInFrames()
/third_party/skia/third_party/externals/oboe/src/common/
H A DUtilities.cpp143 const char *convertToText<StreamState>(StreamState state) { in convertToText()
145 case StreamState::Closed: return "Closed"; in convertToText()
146 case StreamState::Closing: return "Closing"; in convertToText()
147 case StreamState::Disconnected: return "Disconnected"; in convertToText()
148 case StreamState::Flushed: return "Flushed"; in convertToText()
149 case StreamState::Flushing: return "Flushing"; in convertToText()
150 case StreamState::Open: return "Open"; in convertToText()
151 case StreamState::Paused: return "Paused"; in convertToText()
152 case StreamState in convertToText()
[all...]
H A DAudioStream.cpp74 Result AudioStream::waitForStateTransition(StreamState startingState, in waitForStateTransition()
75 StreamState endingState, in waitForStateTransition()
78 StreamState state; in waitForStateTransition()
82 if (state == StreamState::Closed) { in waitForStateTransition()
84 } else if (state == StreamState::Disconnected) { in waitForStateTransition()
89 StreamState nextState = state; in waitForStateTransition()
110 return waitForStateTransition(StreamState::Starting, in start()
111 StreamState::Started, timeoutNanoseconds); in start()
119 return waitForStateTransition(StreamState::Pausing, in pause()
120 StreamState in pause()
[all...]
H A DFilterAudioStream.h112 StreamState getState() const override {
117 StreamState inputState,
118 StreamState *nextState,
/third_party/skia/third_party/externals/oboe/src/aaudio/
H A DAudioStreamAAudio.cpp349 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestStart()
350 if (state == StreamState::Starting || state == StreamState::Started) { in requestStart()
370 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestPause()
371 if (state == StreamState::Pausing || state == StreamState::Paused) { in requestPause()
387 StreamState state = static_cast<StreamState>(mLibLoade in requestFlush()
[all...]
H A DAAudioLoader.cpp254 static_assert((int32_t)StreamState::Uninitialized == AAUDIO_STREAM_STATE_UNINITIALIZED, ERRMSG);
255 static_assert((int32_t)StreamState::Unknown == AAUDIO_STREAM_STATE_UNKNOWN, ERRMSG);
256 static_assert((int32_t)StreamState::Open == AAUDIO_STREAM_STATE_OPEN, ERRMSG);
257 static_assert((int32_t)StreamState::Starting == AAUDIO_STREAM_STATE_STARTING, ERRMSG);
258 static_assert((int32_t)StreamState::Started == AAUDIO_STREAM_STATE_STARTED, ERRMSG);
259 static_assert((int32_t)StreamState::Pausing == AAUDIO_STREAM_STATE_PAUSING, ERRMSG);
260 static_assert((int32_t)StreamState::Paused == AAUDIO_STREAM_STATE_PAUSED, ERRMSG);
261 static_assert((int32_t)StreamState::Flushing == AAUDIO_STREAM_STATE_FLUSHING, ERRMSG);
262 static_assert((int32_t)StreamState::Flushed == AAUDIO_STREAM_STATE_FLUSHED, ERRMSG);
263 static_assert((int32_t)StreamState
[all...]
H A DAudioStreamAAudio.h76 Result waitForStateChange(StreamState currentState,
77 StreamState *nextState,
84 StreamState getState() const override;
/third_party/skia/third_party/externals/oboe/include/oboe/
H A DAudioStream.h129 * Query the current state, eg. StreamState::Pausing
133 virtual StreamState getState() const = 0;
145 * StreamState currentState = stream->getState();
146 * StreamState nextState = StreamState::Unknown;
147 * while (result == Result::OK && currentState != StreamState::Paused) {
162 virtual Result waitForStateChange(StreamState inputState,
163 StreamState *nextState,
443 virtual Result waitForStateTransition(StreamState startingState,
444 StreamState endingStat
[all...]
H A DDefinitions.h58 enum class StreamState : int32_t { // aaudio_stream_state_t class
/third_party/skia/third_party/externals/oboe/samples/iolib/src/main/cpp/player/
H A DSimpleMultiPlayer.cpp43 StreamState streamState = oboeStream->getState(); in onAudioReady()
44 if (streamState != StreamState::Open && streamState != StreamState::Started) { in onAudioReady()
47 if (streamState == StreamState::Disconnected) { in onAudioReady()
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/cpp/
H A Djni-bridge.cpp408 if (state != oboe::StreamState::Starting && state != oboe::StreamState::Started) { in Java_com_google_sample_oboe_manualtest_OboeAudioStream_getState()
410 oboe::StreamState::Uninitialized, in Java_com_google_sample_oboe_manualtest_OboeAudioStream_getState()
415 state = oboe::StreamState::Closed; in Java_com_google_sample_oboe_manualtest_OboeAudioStream_getState()
417 state = oboe::StreamState::Disconnected; in Java_com_google_sample_oboe_manualtest_OboeAudioStream_getState()
419 state = oboe::StreamState::Unknown; in Java_com_google_sample_oboe_manualtest_OboeAudioStream_getState()
/third_party/skia/third_party/externals/oboe/apps/fxlab/app/src/main/cpp/
H A DDuplexEngine.cpp78 auto nextState = oboe::StreamState::Unknown; in startStreams()
79 while (result == oboe::Result::OK && currentState != oboe::StreamState::Started) { in startStreams()
/third_party/rust/crates/rust-openssl/openssl/src/ssl/
H A Dbio.rs17 pub struct StreamState<S> { structure names
39 let state = Box::new(StreamState { in new()
66 let state = &*(BIO_get_data(bio) as *const StreamState<S>); in get_ref()
84 unsafe fn state<'a, S: 'a>(bio: *mut BIO) -> &'a mut StreamState<S> { in state()
186 let _ = Box::<StreamState<S>>::from_raw(data as *mut _);
/third_party/skia/third_party/externals/oboe/samples/MegaDrone/src/main/cpp/
H A DMegaDroneEngine.cpp86 if(mStream && mStream->getState() != oboe::StreamState::Closed) { in stop()

Completed in 30 milliseconds