Home
last modified time | relevance | path

Searched refs:streamId (Results 1 – 25 of 28) sorted by relevance

12

/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/
DFingerprint.java104 public static Fingerprint fromStreamId(String streamId) { in fromStreamId() argument
105 if ((streamId == null) in fromStreamId()
106 || !streamId.startsWith(STREAM_ID_CS_PREFIX) in fromStreamId()
107 || (streamId.length() != STREAM_ID_CS_01_LENGTH)) { in fromStreamId()
108 throw new IllegalArgumentException("bad streamId: " + streamId); in fromStreamId()
116 int value = (toDigit(streamId, idx) << 4) | toDigit(streamId, idx + 1); in fromStreamId()
129 for (String streamId : streamIdList) { in extractFingerprint()
130 if (streamId.startsWith(STREAM_ID_CS_PREFIX)) { in extractFingerprint()
131 return fromStreamId(streamId); in extractFingerprint()
144 StringBuilder streamId = new StringBuilder(STREAM_ID_CS_PREFIX); in toStreamId() local
[all …]
/packages/services/Car/computepipe/runner/engine/
DDefaultEngine.cpp194 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()
[all …]
DDefaultEngine.h102 Status freePacket(int bufferId, int streamId) override;
106 void DispatchPixelData(int streamId, int64_t timestamp, const InputFrame& frame) override;
108 void DispatchSerializedData(int streamId, int64_t timestamp, std::string&& output) override;
198 Status forwardOutputDataToClient(int streamId, std::shared_ptr<MemHandle>& handle);
319 Status dispatchInputFrame(int streamId, int64_t timestamp, const InputFrame& frame) override;
/packages/services/Car/computepipe/runner/client_interface/
DAidlClientImpl.cpp86 Status AidlClientImpl::DispatchSemanticData(int32_t streamId, in DispatchSemanticData() argument
90 if (mPacketHandlers.find(streamId) == mPacketHandlers.end()) { in DispatchSemanticData()
107 ScopedAStatus ret = mPacketHandlers[streamId]->deliverPacket(desc); in DispatchSemanticData()
114 Status AidlClientImpl::DispatchPixelData(int32_t streamId, in DispatchPixelData() argument
118 if (mPacketHandlers.find(streamId) == mPacketHandlers.end()) { in DispatchPixelData()
153 ScopedAStatus ret = mPacketHandlers[streamId]->deliverPacket(desc); in DispatchPixelData()
162 Status AidlClientImpl::dispatchPacketToClient(int32_t streamId, in dispatchPacketToClient() argument
172 return DispatchSemanticData(streamId, packetHandle); in dispatchPacketToClient()
174 return DispatchPixelData(streamId, packetHandle); in dispatchPacketToClient()
263 ScopedAStatus AidlClientImpl::setPipeOutputConfig(int32_t streamId, int32_t maxInFlightCount, in setPipeOutputConfig() argument
[all …]
DAidlClientImpl.h49 Status dispatchPacketToClient(int32_t streamId, const std::shared_ptr<MemHandle>& packetHandle);
66 int32_t streamId, int32_t maxInFlightCount,
73 ndk::ScopedAStatus doneWithPacket(int32_t bufferId, int32_t streamId) override;
86 Status DispatchSemanticData(int32_t streamId, const std::shared_ptr<MemHandle>& packetHandle);
90 Status DispatchPixelData(int32_t streamId, const std::shared_ptr<MemHandle>& packetHandle);
DAidlClient.cpp50 Status AidlClient::dispatchPacketToClient(int32_t streamId, in dispatchPacketToClient() argument
55 return mPipeRunner->dispatchPacketToClient(streamId, packet); in dispatchPacketToClient()
/packages/services/Car/computepipe/tests/runner/graph/
DGrpcGraphTest.cpp186 void DispatchPixelData(int streamId, int64_t timestamp, in DispatchPixelData() argument
188 ASSERT_EQ(streamId % 2, 0); in DispatchPixelData()
190 if (mNumPacketsPerStream.find(streamId) == mNumPacketsPerStream.end()) { in DispatchPixelData()
191 mNumPacketsPerStream[streamId] = 1; in DispatchPixelData()
193 mNumPacketsPerStream[streamId]++; in DispatchPixelData()
197 void DispatchSerializedData(int streamId, int64_t timestamp, std::string&& data) override { in DispatchSerializedData() argument
198 ASSERT_EQ(streamId % 2, 1); in DispatchSerializedData()
200 if (mNumPacketsPerStream.find(streamId) == mNumPacketsPerStream.end()) { in DispatchSerializedData()
201 mNumPacketsPerStream[streamId] = 1; in DispatchSerializedData()
203 mNumPacketsPerStream[streamId]++; in DispatchSerializedData()
[all …]
DLocalPrebuiltGraphTest.cpp53 void DispatchPixelData(int streamId, int64_t timestamp, in DispatchPixelData() argument
55 mPixelCallbackFn(streamId, timestamp, frame); in DispatchPixelData()
58 void DispatchSerializedData(int streamId, int64_t timestamp, std::string&& data) override { in DispatchSerializedData() argument
59 mSerializedStreamCallbackFn(streamId, timestamp, std::move(data)); in DispatchSerializedData()
/packages/services/Car/computepipe/tests/runner/stream_manager/
DPixelStreamManagerTest.cpp97 int streamId = 1; in TEST() local
99 PixelMemHandle memHandle(bufferId, streamId, AHARDWAREBUFFER_USAGE_CPU_READ_OFTEN); in TEST()
102 EXPECT_EQ(memHandle.getStreamId(), streamId); in TEST()
125 int streamId = 1; in TEST() local
127 PixelMemHandle memHandle(bufferId, streamId, AHARDWAREBUFFER_USAGE_CPU_READ_OFTEN); in TEST()
130 EXPECT_EQ(memHandle.getStreamId(), streamId); in TEST()
150 int streamId = 1; in TEST() local
152 PixelMemHandle memHandle(bufferId, streamId, AHARDWAREBUFFER_USAGE_CPU_READ_OFTEN); in TEST()
155 EXPECT_EQ(memHandle.getStreamId(), streamId); in TEST()
175 int streamId = 1; in TEST() local
[all …]
/packages/services/Car/computepipe/runner/graph/
DStreamSetObserver.h42 virtual void reportStreamClosed(int streamId) = 0;
49 virtual void dispatchPixelData(int streamId, int64_t timestamp_us,
52 virtual void dispatchSerializedData(int streamId, int64_t timestamp_us,
62 SingleStreamObserver(int streamId, EndOfStreamReporter* endOfStreamReporter,
88 void reportStreamClosed(int streamId) override;
DStreamSetObserver.cpp32 SingleStreamObserver::SingleStreamObserver(int streamId, EndOfStreamReporter* endOfStreamReporter, in SingleStreamObserver() argument
34 mStreamId(streamId), in SingleStreamObserver()
177 void StreamSetObserver::reportStreamClosed(int streamId) { in reportStreamClosed() argument
179 auto streamObserver = mStreamObservers.find(streamId); in reportStreamClosed()
DGrpcGraph.cpp421 void GrpcGraph::dispatchPixelData(int streamId, int64_t timestamp_us, in dispatchPixelData() argument
425 return engineInterface->DispatchPixelData(streamId, timestamp_us, frame); in dispatchPixelData()
429 void GrpcGraph::dispatchSerializedData(int streamId, int64_t timestamp_us, in dispatchSerializedData() argument
433 return engineInterface->DispatchSerializedData(streamId, timestamp_us, in dispatchSerializedData()
DGrpcGraph.h102 void dispatchPixelData(int streamId, int64_t timestamp_us,
105 void dispatchSerializedData(int streamId, int64_t timestamp_us,
/packages/services/Car/computepipe/runner/input_manager/
DEvsInputManager.cpp89 int streamId = mInputConfig.input_stream(i).stream_id(); in initializeCameras() local
90 auto [it, result] = mEvsUseCases.try_emplace(std::move(streamId), in initializeCameras()
117 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleExecutionPhase()
127 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleExecutionPhase()
158 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleStopImmediatePhase()
175 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleStopWithFlushPhase()
/packages/services/Car/evs/sampleDriver/
DEvsV4lCamera.cpp893 int32_t streamId = -1, area = INT_MIN; in Create() local
901 streamId = id; in Create()
906 streamId = id; in Create()
913 if (streamId >= 0) { in Create()
915 << "width: " << camInfo->streamConfigurations[streamId][1] in Create()
916 << ", height: " << camInfo->streamConfigurations[streamId][2] in Create()
917 << ", format: " << camInfo->streamConfigurations[streamId][3]; in Create()
920 camInfo->streamConfigurations[streamId][1], in Create()
921 camInfo->streamConfigurations[streamId][2]); in Create()
922 evsCamera->mFormat = static_cast<uint32_t>(camInfo->streamConfigurations[streamId][3]); in Create()
/packages/services/Car/computepipe/runner/stream_manager/
DSemanticManager.cpp47 Status SemanticHandle::setMemInfo(int streamId, const char* data, uint32_t size, uint64_t timestamp, in setMemInfo() argument
52 mStreamId = streamId; in setMemInfo()
174 SemanticManager::SemanticManager(std::string name, int streamId, const proto::PacketType& type) in SemanticManager() argument
175 : StreamManager(name, type), mStreamId(streamId) { in SemanticManager()
DPixelStreamManager.cpp31 PixelMemHandle::PixelMemHandle(int bufferId, int streamId, int additionalUsageFlags) in PixelMemHandle() argument
33 mStreamId(streamId), in PixelMemHandle()
324 PixelStreamManager::PixelStreamManager(std::string name, int streamId) in PixelStreamManager() argument
325 : StreamManager(name, proto::PacketType::PIXEL_DATA), mStreamId(streamId) { in PixelStreamManager()
DSemanticManager.h46 Status setMemInfo(int streamId, const char* data, uint32_t size, uint64_t timestamp,
79 explicit SemanticManager(std::string name, int streamId, const proto::PacketType& type);
DPixelStreamManager.h38 explicit PixelMemHandle(int bufferId, int streamId, int additionalUsageFlags = 0);
89 explicit PixelStreamManager(std::string name, int streamId);
/packages/services/Car/computepipe/runner/graph/include/
DPrebuiltEngineInterface.h31 virtual void DispatchPixelData(int streamId, int64_t timestamp,
34 virtual void DispatchSerializedData(int streamId, int64_t timestamp, std::string&&) = 0;
/packages/services/Car/computepipe/runner/input_manager/include/
DInputEngineInterface.h32 virtual Status dispatchInputFrame(int streamId, int64_t timestamp, const InputFrame& frame) = 0;
/packages/services/Car/computepipe/runner/client_interface/include/
DClientEngineInterface.h49 virtual Status freePacket(int bufferId, int streamId) = 0;
/packages/services/Car/computepipe/tests/runner/client_interface/
DMockEngine.h35 MOCK_METHOD2(freePacket, Status(int bufferId, int streamId));
/packages/services/Car/computepipe/aidl/aidl_api/android.automotive.computepipe.runner/1/android/automotive/computepipe/runner/
DIPipeRunner.aidl31 void doneWithPacket(in int bufferId, in int streamId); in doneWithPacket() argument
/packages/services/Car/computepipe/aidl/aidl_api/android.automotive.computepipe.runner/current/android/automotive/computepipe/runner/
DIPipeRunner.aidl31 void doneWithPacket(in int bufferId, in int streamId); in doneWithPacket() argument

12