Lines Matching refs:Stream

299     Stream* findStream(int32_t streamID) const;
305     void forEach(std::function<void(const Stream *)>f) const {  in forEach()
311     void forEach(std::function<void(Stream *)>f) {  in forEach()
319     Stream* getPairStream(const Stream* stream) const {  in getPairStream()
325     size_t streamPosition(const Stream* stream) const; // no lock needed
332     int32_t getNextIdForStream(Stream* stream) const;
338     Stream* lookupStreamFromId(int32_t streamID) const;
357     std::unique_ptr<Stream[]>   mStreamPool;        // no lock needed for access.
376     std::unique_ptr<PerfectHash<int32_t, Stream *>> mPerfectHash;
411     void moveToRestartQueue(Stream* stream, int32_t activeStreamIDToMatch = 0);
429             Stream* stream, int32_t activeStreamIDToMatch = 0) REQUIRES(mStreamManagerLock);
434             Stream* stream, int32_t activeStreamIDToMatch = 0) REQUIRES(mStreamManagerLock);
435     void addToRestartQueue_l(Stream *stream) REQUIRES(mStreamManagerLock);
436     void addToActiveQueue_l(Stream *stream) REQUIRES(mStreamManagerLock);
469     std::multimap<int64_t /* stopTimeNs */, Stream*>
475     std::list<Stream*>          mActiveStreams GUARDED_BY(mStreamManagerLock);
480     std::unordered_set<Stream*> mAvailableStreams GUARDED_BY(mStreamManagerLock);
487     std::unordered_set<Stream*> mProcessingStreams GUARDED_BY(mStreamManagerLock);