194 Status DefaultEngine::freePacket(int bufferId, int streamId) {  in freePacket()  argument
195     if (mStreamManagers.find(streamId) == mStreamManagers.end()) {  in freePacket()
200     return mStreamManagers[streamId]->freePacket(bufferId);  in freePacket()
206 void DefaultEngine::DispatchPixelData(int streamId, int64_t timestamp, const InputFrame& frame) {  in DispatchPixelData()  argument
207     LOG(DEBUG) << "Engine::Received data for pixel stream  " << streamId << " with timestamp "  in DispatchPixelData()
209     if (mStreamManagers.find(streamId) == mStreamManagers.end()) {  in DispatchPixelData()
213     mStreamManagers[streamId]->queuePacket(frame, timestamp);  in DispatchPixelData()
216 void DefaultEngine::DispatchSerializedData(int streamId, int64_t timestamp, std::string&& output) {  in DispatchSerializedData()  argument
217     LOG(DEBUG) << "Engine::Received data for stream  " << streamId << " with timestamp "  in DispatchSerializedData()
219     if (mStreamManagers.find(streamId) == mStreamManagers.end()) {  in DispatchSerializedData()
224     mStreamManagers[streamId]->queuePacket(data.c_str(), data.size(), timestamp);  in DispatchSerializedData()
511         int streamId = configIt.first;  in populateStreamManagers()  local
517             if (optionIt.stream_id() == streamId) {  in populateStreamManagers()
524             LOG(ERROR) << "no matching output config for requested id " << streamId;  in populateStreamManagers()
528             [this, streamId](std::shared_ptr<MemHandle> handle) -> Status {  in populateStreamManagers()
529             return this->forwardOutputDataToClient(streamId, handle);  in populateStreamManagers()
532         std::function<void(std::string)> errorCb = [this, streamId](std::string m) {  in populateStreamManagers()
533             std::string source = "StreamManager:" + std::to_string(streamId) + " : " + m;  in populateStreamManagers()
537         std::function<void()> eos = [this, streamId]() {  in populateStreamManagers()
538             std::string source = "StreamManager:" + std::to_string(streamId);  in populateStreamManagers()
547         if (mStreamManagers[streamId] == nullptr) {  in populateStreamManagers()
548             LOG(ERROR) << "unable to create stream manager for stream " << streamId;  in populateStreamManagers()
555 Status DefaultEngine::forwardOutputDataToClient(int streamId,  in forwardOutputDataToClient()  argument
557     if (streamId != mDisplayStream) {  in forwardOutputDataToClient()
558         return mClient->dispatchPacketToClient(streamId, dataHandle);  in forwardOutputDataToClient()
563         if (mStreamManagers.find(streamId) == mStreamManagers.end()) {  in forwardOutputDataToClient()
566             displayMgrPacket = mStreamManagers[streamId]->clonePacket(dataHandle);  in forwardOutputDataToClient()
568         Status status = mClient->dispatchPacketToClient(streamId, dataHandle);  in forwardOutputDataToClient()
598                 [this](int streamId, int64_t timestamp, const InputFrame& frame) {  in populateInputManagers()  argument
599                     return this->mGraph->SetInputStreamPixelData(streamId, timestamp, frame);  in populateInputManagers()
737 Status InputCallback::dispatchInputFrame(int streamId, int64_t timestamp, const InputFrame& frame) {  in dispatchInputFrame()  argument
738     return mPacketHandler(streamId, timestamp, frame);  in dispatchInputFrame()