| /external/oboe/tests/ |
| D | testStreamStates.cpp | 65 StreamState next = StreamState::Unknown; in checkStreamStateIsStartedAfterStartingTwice()
68 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkStreamStateIsStartedAfterStartingTwice()
70 EXPECT_EQ(next, StreamState::Started); in checkStreamStateIsStartedAfterStartingTwice()
72 next = StreamState::Unknown; in checkStreamStateIsStartedAfterStartingTwice()
76 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkStreamStateIsStartedAfterStartingTwice()
78 ASSERT_EQ(next, StreamState::Started); in checkStreamStateIsStartedAfterStartingTwice()
86 StreamState next = StreamState::Unknown; in checkStreamStateIsStoppedAfterStoppingTwice()
92 r = mStream->waitForStateChange(StreamState::Stopping, &next, kTimeoutInNanos); in checkStreamStateIsStoppedAfterStoppingTwice()
94 EXPECT_EQ(next, StreamState::Stopped); in checkStreamStateIsStoppedAfterStoppingTwice()
98 next = StreamState::Unknown; in checkStreamStateIsStoppedAfterStoppingTwice()
[all …]
|
| D | testStreamWaitState.cpp | 62 StreamState next = StreamState::Unknown; in checkWaitForStateChangeTimeout()
68 StreamState next = StreamState::Unknown; in checkStopWhileWaiting()
71 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkStopWhileWaiting()
73 EXPECT_EQ(next, StreamState::Started) << "next = " << convertToText(next); in checkStopWhileWaiting()
81 r = mStream->waitForStateChange(StreamState::Started, &next, 1000 * kNanosPerMillisecond); in checkStopWhileWaiting()
85 if (next == StreamState::Stopping) { in checkStopWhileWaiting()
86 … r = mStream->waitForStateChange(StreamState::Stopping, &next, 1000 * kNanosPerMillisecond); in checkStopWhileWaiting()
89 ASSERT_EQ(next, StreamState::Stopped) << "next = " << convertToText(next); in checkStopWhileWaiting()
93 StreamState next = StreamState::Unknown; in checkCloseWhileWaiting()
96 r = mStream->waitForStateChange(StreamState::Starting, &next, kTimeoutInNanos); in checkCloseWhileWaiting()
[all …]
|
| D | testStreamClosedMethods.cpp | 48 StreamState s = mStream->getState(); in openAndCloseStream()
49 EXPECT_EQ(s, StreamState::Closed) << "Stream state " << convertToText(mStream->getState()); in openAndCloseStream()
50 return (s == StreamState::Closed); in openAndCloseStream()
175 ASSERT_EQ(mStream->getState(), StreamState::Closed); in TEST_F()
302 StreamState next; in TEST_F()
303 Result r = mStream->waitForStateChange(StreamState::Open, &next, 0); in TEST_F()
|
| /external/oboe/src/common/ |
| D | AudioStream.cpp | 74 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 …]
|
| D | Utilities.cpp | 143 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 …]
|
| D | FilterAudioStream.h | 116 StreamState getState() const override { in getState()
121 StreamState inputState, in waitForStateChange()
122 StreamState *nextState, in waitForStateChange()
|
| /external/oboe/src/opensles/ |
| D | AudioOutputStreamOpenSLES.cpp | 233 setState(StreamState::Open); in open()
249 if (getState() == StreamState::Closed){ in close()
282 StreamState initialState = getState(); in requestStart()
284 case StreamState::Starting: in requestStart()
285 case StreamState::Started: in requestStart()
288 case StreamState::Closed: in requestStart()
299 setState(StreamState::Starting); in requestStart()
302 setState(StreamState::Started); in requestStart()
324 StreamState initialState = getState(); in requestPause_l()
326 case StreamState::Pausing: in requestPause_l()
[all …]
|
| D | AudioInputStreamOpenSLES.cpp | 214 setState(StreamState::Open); in open()
225 if (getState() == StreamState::Closed){ in close()
257 StreamState initialState = getState(); in requestStart()
259 case StreamState::Starting: in requestStart()
260 case StreamState::Started: in requestStart()
262 case StreamState::Closed: in requestStart()
272 setState(StreamState::Starting); in requestStart()
275 setState(StreamState::Started); in requestStart()
306 StreamState initialState = getState(); in requestStop_l()
308 case StreamState::Stopping: in requestStop_l()
[all …]
|
| D | AudioStreamOpenSLES.h | 59 StreamState getState() const override { return mState.load(); } in getState()
76 Result waitForStateChange(StreamState currentState,
77 StreamState *nextState,
113 void setState(StreamState state) { in setState()
128 std::atomic<StreamState> mState{StreamState::Uninitialized};
|
| D | AudioStreamOpenSLES.cpp | 272 if (mState == StreamState::Closed) { in close_l()
290 setState(StreamState::Closed); in close_l()
368 Result AudioStreamOpenSLES::waitForStateChange(StreamState currentState, in waitForStateChange()
369 StreamState *nextState, in waitForStateChange()
376 const StreamState state = getState(); // this does not require a lock in waitForStateChange()
|
| /external/oboe/src/aaudio/ |
| D | AudioStreamAAudio.cpp | 374 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestStart()
375 if (state == StreamState::Starting || state == StreamState::Started) { in requestStart()
395 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestPause()
396 if (state == StreamState::Pausing || state == StreamState::Paused) { in requestPause()
412 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestFlush()
413 if (state == StreamState::Flushing || state == StreamState::Flushed) { in requestFlush()
437 StreamState state = static_cast<StreamState>(mLibLoader->stream_getState(stream)); in requestStop_l()
438 if (state == StreamState::Stopping || state == StreamState::Stopped) { in requestStop_l()
476 Result AudioStreamAAudio::waitForStateChange(StreamState currentState, in waitForStateChange()
477 StreamState *nextState, in waitForStateChange()
[all …]
|
| D | AAudioLoader.cpp | 259 static_assert((int32_t)StreamState::Uninitialized == AAUDIO_STREAM_STATE_UNINITIALIZED, ERRMSG);
260 static_assert((int32_t)StreamState::Unknown == AAUDIO_STREAM_STATE_UNKNOWN, ERRMSG);
261 static_assert((int32_t)StreamState::Open == AAUDIO_STREAM_STATE_OPEN, ERRMSG);
262 static_assert((int32_t)StreamState::Starting == AAUDIO_STREAM_STATE_STARTING, ERRMSG);
263 static_assert((int32_t)StreamState::Started == AAUDIO_STREAM_STATE_STARTED, ERRMSG);
264 static_assert((int32_t)StreamState::Pausing == AAUDIO_STREAM_STATE_PAUSING, ERRMSG);
265 static_assert((int32_t)StreamState::Paused == AAUDIO_STREAM_STATE_PAUSED, ERRMSG);
266 static_assert((int32_t)StreamState::Flushing == AAUDIO_STREAM_STATE_FLUSHING, ERRMSG);
267 static_assert((int32_t)StreamState::Flushed == AAUDIO_STREAM_STATE_FLUSHED, ERRMSG);
268 static_assert((int32_t)StreamState::Stopping == AAUDIO_STREAM_STATE_STOPPING, ERRMSG);
[all …]
|
| D | AudioStreamAAudio.h | 76 Result waitForStateChange(StreamState currentState,
77 StreamState *nextState,
84 StreamState getState() const override;
|
| /external/llvm-project/clang/lib/StaticAnalyzer/Checkers/ |
| D | SimpleStreamChecker.cpp | 30 struct StreamState { struct
33 StreamState(Kind InK) : K(InK) { } in StreamState() argument
39 static StreamState getOpened() { return StreamState(Opened); } in getOpened() argument
40 static StreamState getClosed() { return StreamState(Closed); } in getClosed() argument
42 bool operator==(const StreamState &X) const { in operator ==() argument
89 REGISTER_MAP_WITH_PROGRAMSTATE(StreamMap, SymbolRef, StreamState)
132 State = State->set<StreamMap>(FileDesc, StreamState::getOpened()); in checkPostCall()
151 const StreamState *SS = State->get<StreamMap>(FileDesc); in checkPreCall()
158 State = State->set<StreamMap>(FileDesc, StreamState::getClosed()); in checkPreCall()
162 static bool isLeaked(SymbolRef Sym, const StreamState &SS, in isLeaked()
|
| D | StreamChecker.cpp | 81 struct StreamState { struct
107 StreamState(const FnDescription *L, KindTy S, const StreamErrorState &ES, in StreamState() argument
121 bool operator==(const StreamState &X) const { in operator ==() argument
129 static StreamState getOpened(const FnDescription *L, in getOpened() argument
132 return StreamState{L, Opened, ES, IsFilePositionIndeterminate}; in getOpened()
134 static StreamState getClosed(const FnDescription *L) { in getClosed() argument
135 return StreamState{L, Closed, {}, false}; in getClosed()
137 static StreamState getOpenFailed(const FnDescription *L) { in getOpenFailed() argument
138 return StreamState{L, OpenFailed, {}, false}; in getOpenFailed()
393 REGISTER_MAP_WITH_PROGRAMSTATE(StreamMap, SymbolRef, StreamState) in REGISTER_MAP_WITH_PROGRAMSTATE() argument
[all …]
|
| /external/clang/lib/StaticAnalyzer/Checkers/ |
| D | SimpleStreamChecker.cpp | 31 struct StreamState { struct
34 StreamState(Kind InK) : K(InK) { } in StreamState() function
40 static StreamState getOpened() { return StreamState(Opened); } in getOpened() argument
41 static StreamState getClosed() { return StreamState(Closed); } in getClosed() argument
43 bool operator==(const StreamState &X) const { in operator ==() argument
90 REGISTER_MAP_WITH_PROGRAMSTATE(StreamMap, SymbolRef, StreamState)
133 State = State->set<StreamMap>(FileDesc, StreamState::getOpened()); in checkPostCall()
152 const StreamState *SS = State->get<StreamMap>(FileDesc); in checkPreCall()
159 State = State->set<StreamMap>(FileDesc, StreamState::getClosed()); in checkPreCall()
163 static bool isLeaked(SymbolRef Sym, const StreamState &SS, in isLeaked()
|
| D | StreamChecker.cpp | 29 struct StreamState { struct
33 StreamState(Kind k, const Stmt *s) : K(k), S(s) {} in StreamState() function
40 bool operator==(const StreamState &X) const { in operator ==() argument
44 static StreamState getOpened(const Stmt *s) { return StreamState(Opened, s); } in getOpened() argument
45 static StreamState getClosed(const Stmt *s) { return StreamState(Closed, s); } in getClosed() argument
46 static StreamState getOpenFailed(const Stmt *s) { in getOpenFailed() argument
47 return StreamState(OpenFailed, s); in getOpenFailed()
49 static StreamState getEscaped(const Stmt *s) { in getEscaped() argument
50 return StreamState(Escaped, s); in getEscaped()
105 REGISTER_MAP_WITH_PROGRAMSTATE(StreamMap, SymbolRef, StreamState) in REGISTER_MAP_WITH_PROGRAMSTATE() argument
[all …]
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | shm_vios.rs | 57 UnexpectedState(StreamState),
240 .filter(|s| s.state == StreamState::Available && s.direction == direction as u8) in get_unused_stream_id()
249 &[StreamState::Available, StreamState::Acquired], in set_stream_parameters()
254 self.streams.lock()[stream_id as usize].state = StreamState::Acquired; in set_stream_parameters()
262 &[StreamState::Available, StreamState::Acquired], in prepare_stream()
263 StreamState::Acquired, in prepare_stream()
272 &[StreamState::Acquired], in release_stream()
273 StreamState::Available, in release_stream()
282 &[StreamState::Acquired], in start_stream()
283 StreamState::Active, in start_stream()
[all …]
|
| /external/pdfium/core/fxcodec/jbig2/ |
| D | JBig2_ArithDecoder.cpp | 95 case StreamState::kDataAvailable: in BYTEIN()
97 m_State = StreamState::kDecodingFinished; in BYTEIN()
99 case StreamState::kDecodingFinished: in BYTEIN()
101 m_State = StreamState::kLooping; in BYTEIN()
103 case StreamState::kLooping: in BYTEIN()
|
| D | JBig2_ArithDecoder.h | 49 enum class StreamState : uint8_t { enum
59 StreamState m_State = StreamState::kDataAvailable;
|
| /external/oboe/include/oboe/ |
| D | AudioStream.h | 133 virtual StreamState getState() const = 0;
162 virtual Result waitForStateChange(StreamState inputState,
163 StreamState *nextState,
463 virtual Result waitForStateTransition(StreamState startingState,
464 StreamState endingState,
|
| /external/webrtc/test/fuzzers/utils/ |
| D | rtp_replayer.h | 44 struct StreamState { struct
59 std::unique_ptr<StreamState> stream_state, argument
73 StreamState* stream_state,
|
| /external/oboe/samples/iolib/src/main/cpp/player/ |
| D | SimpleMultiPlayer.cpp | 43 StreamState streamState = oboeStream->getState(); in onAudioReady()
44 if (streamState != StreamState::Open && streamState != StreamState::Started) { in onAudioReady()
47 if (streamState == StreamState::Disconnected) { in onAudioReady()
|
| /external/webrtc/rtc_base/ |
| D | stream.h | 37 enum StreamState { SS_CLOSED, SS_OPENING, SS_OPEN }; enum
62 virtual StreamState GetState() const = 0;
149 StreamState GetState() const override;
|
| /external/webrtc/rtc_tools/ |
| D | video_replay.cc | 273 std::unique_ptr<StreamState> stream_state; in Replay()
303 struct StreamState { struct in webrtc::RtpReplayer
311 static std::unique_ptr<StreamState> ConfigureFromFile( in ConfigureFromFile()
314 auto stream_state = std::make_unique<StreamState>(); in ConfigureFromFile()
354 static std::unique_ptr<StreamState> ConfigureFromFlags( in ConfigureFromFlags()
357 auto stream_state = std::make_unique<StreamState>(); in ConfigureFromFlags()
|