Lines Matching refs:Stream
65 mStreamPool = std::make_unique<Stream[]>(mStreamPoolSize); // create array of streams. in StreamMap()
67 mPerfectHash = std::make_unique<PerfectHash<int32_t, Stream *>>(roundup(mStreamPoolSize * 2)); in StreamMap()
70 Stream* StreamMap::findStream(int32_t streamID) const in findStream()
72 Stream *stream = lookupStreamFromId(streamID); in findStream()
76 size_t StreamMap::streamPosition(const Stream* stream) const in streamPosition()
84 Stream* StreamMap::lookupStreamFromId(int32_t streamID) const in lookupStreamFromId()
89 int32_t StreamMap::getNextIdForStream(Stream* stream) const { in getNextIdForStream()
93 [] (Stream *stream) { in getNextIdForStream()
119 forEach([this](Stream *stream) { in __anon2eef97d60302()
146 forEach([](Stream *stream) { stream->stop(); }); in ~StreamManager()
151 forEach([](Stream *stream) { stream->clearAudioTrack(); }); in ~StreamManager()
170 Stream *newStream = nullptr; in queueForPlay()
243 Stream *pairStream = newStream->getPairStream(); in queueForPlay()
253 if (Stream* nextStream = newStream->playPairStream(garbage, playerIId)) { 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()
354 void StreamManager::addToRestartQueue_l(Stream *stream) { in addToRestartQueue_l()
358 void StreamManager::addToActiveQueue_l(Stream *stream) { in addToActiveQueue_l()
389 Stream* const stream = it->second; in run()
400 if (Stream* nextStream = stream->playPairStream(garbage)) { in run()
430 forEach([](const Stream *stream) { stream->dump(); }); in dump()