Lines Matching refs:newStream

170         Stream *newStream = nullptr;  in queueForPlay()  local
179 newStream = stream; in queueForPlay()
184 if (newStream == nullptr) { in queueForPlay()
186 newStream = *mAvailableStreams.begin(); in queueForPlay()
188 newStream->setStopTimeNs(systemTime()); in queueForPlay()
193 if (newStream == nullptr || newStream->getSoundID() != soundID) { in queueForPlay()
198 newStream = stream; in queueForPlay()
201 } else if (newStream == nullptr) { in queueForPlay()
203 newStream = stream; in queueForPlay()
210 if (newStream == nullptr) { in queueForPlay()
213 if (newStream == nullptr in queueForPlay()
214 || newStream->getPriority() > stream->getPriority()) { in queueForPlay()
215 newStream = stream; in queueForPlay()
220 if (newStream != nullptr) { // we need to mute as it is still playing. in queueForPlay()
221 (void)newStream->requestStop(newStream->getStreamID()); in queueForPlay()
226 if (newStream == nullptr) { in queueForPlay()
230 newStream = stream; in queueForPlay()
238 if (newStream == nullptr) { in queueForPlay()
243 Stream *pairStream = newStream->getPairStream(); in queueForPlay()
246 __func__, newStream, pairStream, streamID); in queueForPlay()
250 removeFromQueues_l(newStream); in queueForPlay()
251 mProcessingStreams.emplace(newStream); in queueForPlay()
253 if (Stream* nextStream = newStream->playPairStream(garbage, playerIId)) { in queueForPlay()
259 mAvailableStreams.insert(newStream); in queueForPlay()
262 mProcessingStreams.erase(newStream); in queueForPlay()
264 launchThread = moveToRestartQueue_l(newStream) && needMoreThreads_l(); in queueForPlay()