• Home
  • Raw
  • Download

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()
117 forEach([this](Stream *stream) { in StreamManager()
143 forEach([](Stream *stream) { stream->stop(); }); in ~StreamManager()
148 forEach([](Stream *stream) { stream->clearAudioTrack(); }); in ~StreamManager()
163 Stream *newStream = nullptr; in queueForPlay()
236 Stream *pairStream = newStream->getPairStream(); in queueForPlay()
246 if (Stream* nextStream = newStream->playPairStream()) { in queueForPlay()
273 Stream* stream, int32_t activeStreamIDToMatch) in moveToRestartQueue()
300 Stream* stream, int32_t activeStreamIDToMatch) in moveToRestartQueue_l()
318 Stream* stream, int32_t activeStreamIDToMatch) { in removeFromQueues_l()
346 void StreamManager::addToRestartQueue_l(Stream *stream) { in addToRestartQueue_l()
350 void StreamManager::addToActiveQueue_l(Stream *stream) { in addToActiveQueue_l()
380 Stream* const stream = it->second; in run()
391 if (Stream* nextStream = stream->playPairStream()) { in run()
415 forEach([](const Stream *stream) { stream->dump(); }); in dump()