Lines Matching refs:Stream

66     mStreamPool = std::make_unique<Stream[]>(mStreamPoolSize); // create array of streams.  in StreamMap()
68 mPerfectHash = std::make_unique<PerfectHash<int32_t, Stream *>>(roundup(mStreamPoolSize * 2)); in StreamMap()
71 Stream* StreamMap::findStream(int32_t streamID) const in findStream()
73 Stream *stream = lookupStreamFromId(streamID); in findStream()
77 size_t StreamMap::streamPosition(const Stream* stream) const in streamPosition()
85 Stream* StreamMap::lookupStreamFromId(int32_t streamID) const in lookupStreamFromId()
90 int32_t StreamMap::getNextIdForStream(Stream* stream) const { in getNextIdForStream()
94 [] (Stream *stream) { in getNextIdForStream()
120 forEach([this](Stream *stream) { in __anon9ad9a1b00302()
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()