Home
last modified time | relevance | path

Searched refs:streamId (Results 1 – 25 of 33) 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/cpp/computepipe/runner/client_interface/
DAidlClientImpl.cpp86 Status AidlClientImpl::DispatchSemanticData(int32_t streamId, in DispatchSemanticData() argument
90 if (mPacketHandlers.find(streamId) == mPacketHandlers.end()) { in DispatchSemanticData()
108 ScopedAStatus ret = mPacketHandlers[streamId]->deliverPacket(desc); in DispatchSemanticData()
115 Status AidlClientImpl::DispatchPixelData(int32_t streamId, in DispatchPixelData() argument
119 if (mPacketHandlers.find(streamId) == mPacketHandlers.end()) { in DispatchPixelData()
154 ScopedAStatus ret = mPacketHandlers[streamId]->deliverPacket(desc); in DispatchPixelData()
163 Status AidlClientImpl::dispatchPacketToClient(int32_t streamId, in dispatchPacketToClient() argument
173 return DispatchSemanticData(streamId, packetHandle); in dispatchPacketToClient()
175 return DispatchPixelData(streamId, packetHandle); in dispatchPacketToClient()
264 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/cpp/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);
323 Status dispatchInputFrame(int streamId, int64_t timestamp, const InputFrame& frame) override;
/packages/services/Car/cpp/computepipe/tests/runner/graph/includes/
DGrpcGraphServerImpl.h183 void DispatchPixelData(int streamId, int64_t timestamp, in DispatchPixelData() argument
185 ASSERT_EQ(streamId % 2, 0); in DispatchPixelData()
187 if (mNumPacketsPerStream.find(streamId) == mNumPacketsPerStream.end()) { in DispatchPixelData()
188 mNumPacketsPerStream[streamId] = 1; in DispatchPixelData()
190 mNumPacketsPerStream[streamId]++; in DispatchPixelData()
194 void DispatchSerializedData(int streamId, int64_t timestamp, std::string&& data) override { in DispatchSerializedData() argument
195 ASSERT_EQ(streamId % 2, 1); in DispatchSerializedData()
197 if (mNumPacketsPerStream.find(streamId) == mNumPacketsPerStream.end()) { in DispatchSerializedData()
198 mNumPacketsPerStream[streamId] = 1; in DispatchSerializedData()
200 mNumPacketsPerStream[streamId]++; in DispatchSerializedData()
[all …]
DPrebuiltEngineInterfaceImpl.h51 void DispatchPixelData(int streamId, int64_t timestamp, in DispatchPixelData() argument
53 mPixelCallbackFn(streamId, timestamp, frame); in DispatchPixelData()
56 void DispatchSerializedData(int streamId, int64_t timestamp, std::string&& data) override { in DispatchSerializedData() argument
57 mSerializedStreamCallbackFn(streamId, timestamp, std::move(data)); in DispatchSerializedData()
/packages/services/Car/cpp/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,
90 void reportStreamClosed(int streamId) override;
DStreamSetObserver.cpp32 SingleStreamObserver::SingleStreamObserver(int streamId, EndOfStreamReporter* endOfStreamReporter, in SingleStreamObserver() argument
34 mStreamId(streamId), in SingleStreamObserver()
179 void StreamSetObserver::reportStreamClosed(int streamId) { in reportStreamClosed() argument
181 auto streamObserver = mStreamObservers.find(streamId); in reportStreamClosed()
DGrpcGraph.h102 void dispatchPixelData(int streamId, int64_t timestamp_us,
105 void dispatchSerializedData(int streamId, int64_t timestamp_us,
DGrpcGraph.cpp425 void GrpcGraph::dispatchPixelData(int streamId, int64_t timestamp_us, in dispatchPixelData() argument
429 return engineInterface->DispatchPixelData(streamId, timestamp_us, frame); in dispatchPixelData()
433 void GrpcGraph::dispatchSerializedData(int streamId, int64_t timestamp_us, in dispatchSerializedData() argument
437 return engineInterface->DispatchSerializedData(streamId, timestamp_us, in dispatchSerializedData()
/packages/services/Car/cpp/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/cpp/computepipe/runner/input_manager/
DEvsInputManager.cpp90 int streamId = mInputConfig.input_stream(i).stream_id(); in initializeCameras() local
91 auto [it, result] = mEvsUseCases.try_emplace(std::move(streamId), in initializeCameras()
118 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleExecutionPhase()
128 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleExecutionPhase()
159 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleStopImmediatePhase()
176 for (auto& [streamId, evsUseCase] : mEvsUseCases) { in handleStopWithFlushPhase()
/packages/services/Car/cpp/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/apps/Car/DebuggingRestrictionController/libs/
Dokhttp-3.12.1.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/proguard/ okhttp3/ ...
/packages/services/Car/cpp/evs/sampleDriver/hidl/
DEvsV4lCamera.cpp885 int32_t streamId = -1, area = INT_MIN; in Create() local
892 streamId = id; in Create()
896 streamId = id; in Create()
902 if (streamId >= 0) { in Create()
904 << "width: " << camInfo->streamConfigurations[streamId][1] in Create()
905 << ", height: " << camInfo->streamConfigurations[streamId][2] in Create()
906 << ", format: " << camInfo->streamConfigurations[streamId][3]; in Create()
907 success = evsCamera->mVideo.open(deviceName, camInfo->streamConfigurations[streamId][1], in Create()
908 camInfo->streamConfigurations[streamId][2]); in Create()
909 evsCamera->mFormat = static_cast<uint32_t>(camInfo->streamConfigurations[streamId][3]); in Create()
/packages/services/Car/cpp/evs/sampleDriver/aidl/src/
DEvsV4lCamera.cpp865 int32_t streamId = -1, area = INT_MIN; in Create() local
871 streamId = id; in Create()
876 streamId = id; in Create()
882 if (streamId >= 0) { in Create()
884 LOG(INFO) << " width = " << camInfo->streamConfigurations[streamId].width; in Create()
885 LOG(INFO) << " height = " << camInfo->streamConfigurations[streamId].height; in Create()
887 << static_cast<int>(camInfo->streamConfigurations[streamId].format); in Create()
889 camInfo->streamConfigurations[streamId].width, in Create()
890 camInfo->streamConfigurations[streamId].height); in Create()
895 static_cast<uint32_t>(camInfo->streamConfigurations[streamId].format); in Create()
/packages/services/Car/cpp/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/cpp/computepipe/tests/fuzz/
DPixelMemHandleFuzzer.cpp46 int streamId = 1; in setFrameDataTest() local
49 PixelMemHandle memHandle(bufferId, streamId, AHARDWAREBUFFER_USAGE_CPU_READ_OFTEN); in setFrameDataTest()
/packages/services/Car/cpp/computepipe/tests/runner/graph/
DGrpcGraphTest.cpp74 int numPacketsForStream(int streamId) { return mEngine->numPacketsForStream(streamId); } in numPacketsForStream() argument
/packages/services/Car/cpp/computepipe/runner/input_manager/include/
DInputEngineInterface.h32 virtual Status dispatchInputFrame(int streamId, int64_t timestamp, const InputFrame& frame) = 0;

12