Home
last modified time | relevance | path

Searched refs:StreamState (Results 1 – 23 of 23) sorted by relevance

/third_party/skia/third_party/externals/oboe/tests/
DtestStreamStates.cpp66 …ASSERT_EQ(mStream->getState(), StreamState::Closed) << "Stream state " << convertToText(mStream->g… 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::Unknown; in checkStreamStateIsStoppedAfterStoppingTwice()
99 r = mStream->waitForStateChange(StreamState::Stopping, &next, kTimeoutInNanos); in checkStreamStateIsStoppedAfterStoppingTwice()
101 EXPECT_EQ(next, StreamState::Stopped); in checkStreamStateIsStoppedAfterStoppingTwice()
[all …]
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::Stopped) << "next = " << convertToText(next); in checkStopWhileWaiting()
91 StreamState next = StreamState::Unknown; in checkCloseWhileWaiting()
94 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkCloseWhileWaiting()
[all …]
DtestStreamClosedMethods.cpp57 …ASSERT_EQ(mStream->getState(), StreamState::Closed) << "Stream state " << convertToText(mStream->g… 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()
DtestXRunBehaviour.cpp60 ASSERT_EQ(mStream->getState(), StreamState::Closed); in openAndCloseStream()
/third_party/skia/third_party/externals/oboe/src/opensles/
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::Pausing: in requestPause()
[all …]
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::Stopping: in requestStop()
[all …]
DAudioStreamOpenSLES.h60 StreamState getState() const override { return mState.load(); } in getState()
77 Result waitForStateChange(StreamState currentState,
78 StreamState *nextState,
111 void setState(StreamState state) { in setState()
126 std::atomic<StreamState> mState{StreamState::Uninitialized};
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()
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/
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::Paused, timeoutNanoseconds); in pause()
[all …]
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::Pausing: return "Pausing"; in convertToText()
153 case StreamState::Started: return "Started"; in convertToText()
[all …]
DFilterAudioStream.h112 StreamState getState() const override { in getState()
117 StreamState inputState, in waitForStateChange()
118 StreamState *nextState, in waitForStateChange()
/third_party/skia/third_party/externals/oboe/src/aaudio/
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>(mLibLoader->stream_getState(stream)); in requestFlush()
388 if (state == StreamState::Flushing || state == StreamState::Flushed) { in requestFlush()
412 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestStop_l()
413 if (state == StreamState::Stopping || state == StreamState::Stopped) { in requestStop_l()
451 Result AudioStreamAAudio::waitForStateChange(StreamState currentState, in waitForStateChange()
452 StreamState *nextState, in waitForStateChange()
[all …]
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::Stopping == AAUDIO_STREAM_STATE_STOPPING, ERRMSG);
[all …]
DAudioStreamAAudio.h76 Result waitForStateChange(StreamState currentState,
77 StreamState *nextState,
84 StreamState getState() const override;
/third_party/skia/third_party/externals/oboe/include/oboe/
DAudioStream.h133 virtual StreamState getState() const = 0;
162 virtual Result waitForStateChange(StreamState inputState,
163 StreamState *nextState,
443 virtual Result waitForStateTransition(StreamState startingState,
444 StreamState endingState,
DDefinitions.h58 enum class StreamState : int32_t { // aaudio_stream_state_t enum
/third_party/skia/third_party/externals/oboe/samples/iolib/src/main/cpp/player/
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/rust/crates/rust-openssl/openssl/src/ssl/
Dbio.rs17 pub struct StreamState<S> { struct
39 let state = Box::new(StreamState { in new() argument
66 let state = &*(BIO_get_data(bio) as *const StreamState<S>); in get_ref() constant
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 _); in destroy()
/third_party/skia/third_party/externals/oboe/apps/fxlab/app/src/main/cpp/
DDuplexEngine.cpp78 auto nextState = oboe::StreamState::Unknown; in startStreams()
79 while (result == oboe::Result::OK && currentState != oboe::StreamState::Started) { in startStreams()
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/cpp/
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/samples/MegaDrone/src/main/cpp/
DMegaDroneEngine.cpp86 if(mStream && mStream->getState() != oboe::StreamState::Closed) { in stop()
/third_party/skia/third_party/externals/oboe/docs/
DFullGuide.md255 StreamState inputState = StreamState::Pausing;
256 StreamState nextState = StreamState::Uninitialized;