blob: 6b8601fbb043bb59c85af47653cb255acceec4f8 [file] [log] [blame]
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -08001/*
Shuzhen Wangc28189a2017-11-27 23:05:10 -08002 * Copyright (C) 2013-2018 The Android Open Source Project
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -08003 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -080017#ifndef ANDROID_SERVERS_CAMERA3DEVICE_H
18#define ANDROID_SERVERS_CAMERA3DEVICE_H
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080019
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080020#include <utility>
21#include <unordered_map>
Shuzhen Wang5c22c152017-12-31 17:12:25 -080022#include <set>
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080023
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080024#include <utils/Condition.h>
25#include <utils/Errors.h>
26#include <utils/List.h>
27#include <utils/Mutex.h>
28#include <utils/Thread.h>
Eino-Ville Talvala7b82efe2013-07-25 17:12:35 -070029#include <utils/KeyedVector.h>
Shuzhen Wangc28dccc2016-02-11 23:48:46 -080030#include <utils/Timers.h>
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080031
32#include <android/hardware/camera/device/3.2/ICameraDevice.h>
33#include <android/hardware/camera/device/3.2/ICameraDeviceSession.h>
Eino-Ville Talvala91cd3f82017-08-21 16:12:50 -070034#include <android/hardware/camera/device/3.3/ICameraDeviceSession.h>
Eino-Ville Talvala1a86df52018-01-17 16:00:35 -080035#include <android/hardware/camera/device/3.4/ICameraDeviceSession.h>
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -070036#include <android/hardware/camera/device/3.5/ICameraDeviceSession.h>
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080037#include <android/hardware/camera/device/3.2/ICameraDeviceCallback.h>
Shuzhen Wang5c22c152017-12-31 17:12:25 -080038#include <android/hardware/camera/device/3.4/ICameraDeviceCallback.h>
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -070039#include <android/hardware/camera/device/3.5/ICameraDeviceCallback.h>
Yifan Hongf79b5542017-04-11 14:44:25 -070040#include <fmq/MessageQueue.h>
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080041
Jianing Weicb0652e2014-03-12 18:29:36 -070042#include <camera/CaptureResult.h>
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080043
Eino-Ville Talvala7b82efe2013-07-25 17:12:35 -070044#include "common/CameraDeviceBase.h"
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -070045#include "device3/StatusTracker.h"
Zhijun He125684a2015-12-26 15:07:30 -080046#include "device3/Camera3BufferManager.h"
Eino-Ville Talvala7b8a1fd2018-05-22 15:30:35 -070047#include "device3/DistortionMapper.h"
Eino-Ville Talvala4d453832016-07-15 11:56:53 -070048#include "utils/TagMonitor.h"
Shuzhen Wang686f6442017-06-20 16:16:04 -070049#include "utils/LatencyHistogram.h"
Emilian Peev71c73a22017-03-21 16:35:51 +000050#include <camera_metadata_hidden.h>
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080051
Emilian Peev40ead602017-09-26 15:46:36 +010052using android::camera3::OutputStreamInfo;
53
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080054namespace android {
55
Eino-Ville Talvala7b82efe2013-07-25 17:12:35 -070056namespace camera3 {
57
58class Camera3Stream;
59class Camera3ZslStream;
60class Camera3OutputStreamInterface;
61class Camera3StreamInterface;
62
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080063} // namespace camera3
Eino-Ville Talvala7b82efe2013-07-25 17:12:35 -070064
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080065/**
Zhijun He95dd5ba2014-03-26 18:18:00 -070066 * CameraDevice for HAL devices with version CAMERA_DEVICE_API_VERSION_3_0 or higher.
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080067 */
68class Camera3Device :
69 public CameraDeviceBase,
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -070070 virtual public hardware::camera::device::V3_5::ICameraDeviceCallback {
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080071 public:
Ruben Brunkc78ac262015-08-13 17:58:46 -070072
Eino-Ville Talvala2f09bac2016-12-13 11:29:54 -080073 explicit Camera3Device(const String8& id);
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080074
75 virtual ~Camera3Device();
76
77 /**
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -080078 * CameraDeviceBase interface
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -080079 */
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -080080
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080081 const String8& getId() const override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -080082
Emilian Peev00420d22018-02-05 21:33:13 +000083 metadata_vendor_id_t getVendorTagId() const override { return mVendorTagId; }
84
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -080085 // Transitions to idle state on success.
Emilian Peevbd8c5032018-02-14 23:05:40 +000086 status_t initialize(sp<CameraProviderManager> manager, const String8& monitorTags) override;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080087 status_t disconnect() override;
88 status_t dump(int fd, const Vector<String16> &args) override;
89 const CameraMetadata& info() const override;
Shuzhen Wang2e7f58f2018-07-11 14:00:29 -070090 const CameraMetadata& info(const String8& physicalId) const override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -080091
92 // Capture and setStreamingRequest will configure streams if currently in
93 // idle state
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080094 status_t capture(CameraMetadata &request, int64_t *lastFrameNumber = NULL) override;
Emilian Peevaebbe412018-01-15 13:53:24 +000095 status_t captureList(const List<const PhysicalCameraSettingsList> &requestsList,
Shuzhen Wang0129d522016-10-30 22:43:41 -070096 const std::list<const SurfaceMap> &surfaceMaps,
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -080097 int64_t *lastFrameNumber = NULL) override;
98 status_t setStreamingRequest(const CameraMetadata &request,
99 int64_t *lastFrameNumber = NULL) override;
Emilian Peevaebbe412018-01-15 13:53:24 +0000100 status_t setStreamingRequestList(const List<const PhysicalCameraSettingsList> &requestsList,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700101 const std::list<const SurfaceMap> &surfaceMaps,
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800102 int64_t *lastFrameNumber = NULL) override;
103 status_t clearStreamingRequest(int64_t *lastFrameNumber = NULL) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800104
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800105 status_t waitUntilRequestReceived(int32_t requestId, nsecs_t timeout) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800106
107 // Actual stream creation/deletion is delayed until first request is submitted
108 // If adding streams while actively capturing, will pause device before adding
Zhijun He5d677d12016-05-29 16:52:39 -0700109 // stream, reconfiguring device, and unpausing. If the client create a stream
Shuzhen Wang758c2152017-01-10 18:26:18 -0800110 // with nullptr consumer surface, the client must then call setConsumers()
Zhijun He5d677d12016-05-29 16:52:39 -0700111 // and finish the stream configuration before starting output streaming.
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800112 status_t createStream(sp<Surface> consumer,
Eino-Ville Talvala3d82c0d2015-02-23 15:19:19 -0800113 uint32_t width, uint32_t height, int format,
Zhijun He125684a2015-12-26 15:07:30 -0800114 android_dataspace dataSpace, camera3_stream_rotation_t rotation, int *id,
Shuzhen Wangc28189a2017-11-27 23:05:10 -0800115 const String8& physicalCameraId,
Emilian Peev40ead602017-09-26 15:46:36 +0100116 std::vector<int> *surfaceIds = nullptr,
Zhijun He5d677d12016-05-29 16:52:39 -0700117 int streamSetId = camera3::CAMERA3_STREAM_SET_ID_INVALID,
Emilian Peev050f5dc2017-05-18 14:43:56 +0100118 bool isShared = false, uint64_t consumerUsage = 0) override;
Shuzhen Wang0129d522016-10-30 22:43:41 -0700119 status_t createStream(const std::vector<sp<Surface>>& consumers,
120 bool hasDeferredConsumer, uint32_t width, uint32_t height, int format,
121 android_dataspace dataSpace, camera3_stream_rotation_t rotation, int *id,
Shuzhen Wangc28189a2017-11-27 23:05:10 -0800122 const String8& physicalCameraId,
Emilian Peev40ead602017-09-26 15:46:36 +0100123 std::vector<int> *surfaceIds = nullptr,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700124 int streamSetId = camera3::CAMERA3_STREAM_SET_ID_INVALID,
Emilian Peev050f5dc2017-05-18 14:43:56 +0100125 bool isShared = false, uint64_t consumerUsage = 0) override;
Shuzhen Wang0129d522016-10-30 22:43:41 -0700126
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800127 status_t createInputStream(
Igor Murashkin5a269fa2013-04-15 14:59:22 -0700128 uint32_t width, uint32_t height, int format,
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800129 int *id) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800130
Emilian Peev710c1422017-08-30 11:19:38 +0100131 status_t getStreamInfo(int id, StreamInfo *streamInfo) override;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800132 status_t setStreamTransform(int id, int transform) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800133
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800134 status_t deleteStream(int id) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800135
Emilian Peev5fbe0ba2017-10-20 15:45:45 +0100136 status_t configureStreams(const CameraMetadata& sessionParams,
137 int operatingMode =
Eino-Ville Talvalabbbbe842017-02-28 17:50:56 -0800138 static_cast<int>(hardware::camera::device::V3_2::StreamConfigurationMode::NORMAL_MODE))
139 override;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800140 status_t getInputBufferProducer(
141 sp<IGraphicBufferProducer> *producer) override;
Igor Murashkine2d167e2014-08-19 16:19:59 -0700142
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800143 status_t createDefaultRequest(int templateId, CameraMetadata *request) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800144
145 // Transitions to the idle state on success
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800146 status_t waitUntilDrained() override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800147
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800148 status_t setNotifyCallback(wp<NotificationListener> listener) override;
149 bool willNotify3A() override;
150 status_t waitForNextFrame(nsecs_t timeout) override;
151 status_t getNextResult(CaptureResult *frame) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800152
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800153 status_t triggerAutofocus(uint32_t id) override;
154 status_t triggerCancelAutofocus(uint32_t id) override;
155 status_t triggerPrecaptureMetering(uint32_t id) override;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800156
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800157 status_t flush(int64_t *lastFrameNumber = NULL) override;
Eino-Ville Talvalaabaa51d2013-08-14 11:37:00 -0700158
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800159 status_t prepare(int streamId) override;
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -0700160
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800161 status_t tearDown(int streamId) override;
Eino-Ville Talvalab25e3c82015-07-15 16:04:27 -0700162
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800163 status_t addBufferListenerForStream(int streamId,
164 wp<camera3::Camera3StreamBufferListener> listener) override;
Shuzhen Wangb0fdc1e2016-03-20 23:21:39 -0700165
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800166 status_t prepare(int maxCount, int streamId) override;
Ruben Brunkc78ac262015-08-13 17:58:46 -0700167
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800168 ssize_t getJpegBufferSize(uint32_t width, uint32_t height) const override;
Eino-Ville Talvala95a1d0f2015-08-11 15:08:53 -0700169 ssize_t getPointCloudBufferSize() const;
Eino-Ville Talvalad56db1d2015-12-17 16:50:35 -0800170 ssize_t getRawOpaqueBufferSize(int32_t width, int32_t height) const;
Zhijun He28c9b6f2014-08-08 12:00:47 -0700171
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700172 // Methods called by subclasses
173 void notifyStatus(bool idle); // updates from StatusTracker
174
Zhijun He5d677d12016-05-29 16:52:39 -0700175 /**
Shuzhen Wang758c2152017-01-10 18:26:18 -0800176 * Set the deferred consumer surfaces to the output stream and finish the deferred
Zhijun He5d677d12016-05-29 16:52:39 -0700177 * consumer configuration.
178 */
Emilian Peev40ead602017-09-26 15:46:36 +0100179 status_t setConsumerSurfaces(
180 int streamId, const std::vector<sp<Surface>>& consumers,
181 std::vector<int> *surfaceIds /*out*/) override;
182
183 /**
184 * Update a given stream.
185 */
186 status_t updateStream(int streamId, const std::vector<sp<Surface>> &newSurfaces,
187 const std::vector<OutputStreamInfo> &outputInfo,
188 const std::vector<size_t> &removedSurfaceIds,
189 KeyedVector<sp<Surface>, size_t> *outputMap/*out*/);
Zhijun He5d677d12016-05-29 16:52:39 -0700190
Chien-Yu Chena936ac22017-10-23 15:59:49 -0700191 /**
192 * Drop buffers for stream of streamId if dropping is true. If dropping is false, do not
193 * drop buffers for stream of streamId.
194 */
195 status_t dropStreamBuffers(bool dropping, int streamId) override;
196
Emilian Peev35ae8262018-11-08 13:11:32 +0000197 /**
198 * Helper functions to map between framework and HIDL values
199 */
200 static hardware::graphics::common::V1_0::PixelFormat mapToPixelFormat(int frameworkFormat);
201 static hardware::camera::device::V3_2::DataspaceFlags mapToHidlDataspace(
202 android_dataspace dataSpace);
203 static hardware::camera::device::V3_2::BufferUsageFlags mapToConsumerUsage(uint64_t usage);
204 static hardware::camera::device::V3_2::StreamRotation mapToStreamRotation(
205 camera3_stream_rotation_t rotation);
206 // Returns a negative error code if the passed-in operation mode is not valid.
207 static status_t mapToStreamConfigurationMode(camera3_stream_configuration_mode_t operationMode,
208 /*out*/ hardware::camera::device::V3_2::StreamConfigurationMode *mode);
209 static camera3_buffer_status_t mapHidlBufferStatus(
210 hardware::camera::device::V3_2::BufferStatus status);
211 static int mapToFrameworkFormat(hardware::graphics::common::V1_0::PixelFormat pixelFormat);
212 static android_dataspace mapToFrameworkDataspace(
213 hardware::camera::device::V3_2::DataspaceFlags);
214 static uint64_t mapConsumerToFrameworkUsage(
215 hardware::camera::device::V3_2::BufferUsageFlags usage);
216 static uint64_t mapProducerToFrameworkUsage(
217 hardware::camera::device::V3_2::BufferUsageFlags usage);
218
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800219 private:
Yifan Hongf79b5542017-04-11 14:44:25 -0700220
Yin-Chia Yehc5248132018-08-15 12:19:20 -0700221 status_t disconnectImpl();
222
Yifan Hongf79b5542017-04-11 14:44:25 -0700223 // internal typedefs
224 using RequestMetadataQueue = hardware::MessageQueue<uint8_t, hardware::kSynchronizedReadWrite>;
Yifan Honga640c5a2017-04-12 16:30:31 -0700225 using ResultMetadataQueue = hardware::MessageQueue<uint8_t, hardware::kSynchronizedReadWrite>;
Yifan Hongf79b5542017-04-11 14:44:25 -0700226
Igor Murashkin1e479c02013-09-06 16:55:14 -0700227 static const size_t kDumpLockAttempts = 10;
228 static const size_t kDumpSleepDuration = 100000; // 0.10 sec
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700229 static const nsecs_t kActiveTimeout = 500000000; // 500 ms
Yin-Chia Yeh99fd0972019-06-27 14:22:44 -0700230 static const nsecs_t kMinWarnInflightDuration = 5000000000; // 5 s
Yin-Chia Yeh90c0fdf2017-06-29 13:22:12 -0700231 static const size_t kInFlightWarnLimit = 30;
Chien-Yu Chenc96ac8d2015-08-12 16:46:24 -0700232 static const size_t kInFlightWarnLimitHighSpeed = 256; // batch size 32 * pipe depth 8
Eino-Ville Talvala10bd57e2017-06-23 16:22:44 -0700233 static const nsecs_t kDefaultExpectedDuration = 100000000; // 100 ms
234 static const nsecs_t kMinInflightDuration = 5000000000; // 5 s
Yin-Chia Yehb3a80b12018-09-04 12:13:05 -0700235 static const nsecs_t kBaseGetBufferWait = 3000000000; // 3 sec.
Eino-Ville Talvalaf99498e2015-09-25 16:52:55 -0700236 // SCHED_FIFO priority for request submission thread in HFR mode
Zhijun He7ee4c072016-07-25 13:52:28 -0700237 static const int kRequestThreadPriority = 1;
Chien-Yu Chenc96ac8d2015-08-12 16:46:24 -0700238
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700239 struct RequestTrigger;
Zhijun Hef7da0962014-04-24 13:27:56 -0700240 // minimal jpeg buffer size: 256KB + blob header
241 static const ssize_t kMinJpegBufferSize = 256 * 1024 + sizeof(camera3_jpeg_blob);
Eino-Ville Talvala16a2ada2014-08-27 14:41:33 -0700242 // Constant to use for stream ID when one doesn't exist
243 static const int NO_STREAM = -1;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800244
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700245 // A lock to enforce serialization on the input/configure side
246 // of the public interface.
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700247 // Not locked by methods guarded by mOutputLock, since they may act
248 // concurrently to the input/configure side of the interface.
249 // Must be locked before mLock if both will be locked by a method
250 Mutex mInterfaceLock;
251
252 // The main lock on internal state
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800253 Mutex mLock;
254
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700255 // Camera device ID
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800256 const String8 mId;
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700257
Eino-Ville Talvalabbbbe842017-02-28 17:50:56 -0800258 // Current stream configuration mode;
259 int mOperatingMode;
Emilian Peev5fbe0ba2017-10-20 15:45:45 +0100260 // Current session wide parameters
261 hardware::camera2::impl::CameraMetadataNative mSessionParams;
262
Eino-Ville Talvalabbbbe842017-02-28 17:50:56 -0800263 // Constant to use for no set operating mode
264 static const int NO_MODE = -1;
265
Zhijun He1fa89992015-06-01 15:44:31 -0700266 // Flag indicating is the current active stream configuration is constrained high speed.
267 bool mIsConstrainedHighSpeedConfiguration;
268
Yifan Honga640c5a2017-04-12 16:30:31 -0700269 // FMQ to write result on. Must be guarded by mProcessCaptureResultLock.
270 std::unique_ptr<ResultMetadataQueue> mResultMetadataQueue;
271
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800272 /**** Scope for mLock ****/
273
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800274 /**
275 * Adapter for legacy HAL / HIDL HAL interface calls; calls either into legacy HALv3 or the
276 * HIDL HALv3 interfaces.
277 */
Yin-Chia Yehbe83fa72017-03-30 13:35:36 -0700278 class HalInterface : public camera3::Camera3StreamBufferFreedListener {
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800279 public:
Yifan Hongf79b5542017-04-11 14:44:25 -0700280 HalInterface(sp<hardware::camera::device::V3_2::ICameraDeviceSession> &session,
Yin-Chia Yeh651fe2e2018-11-13 11:49:31 -0800281 std::shared_ptr<RequestMetadataQueue> queue,
282 bool useHalBufManager);
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800283 HalInterface(const HalInterface &other);
284 HalInterface();
285
286 // Returns true if constructed with a valid device or session, and not yet cleared
287 bool valid();
288
289 // Reset this HalInterface object (does not call close())
290 void clear();
291
292 // Calls into the HAL interface
293
294 // Caller takes ownership of requestTemplate
295 status_t constructDefaultRequestSettings(camera3_request_template_t templateId,
296 /*out*/ camera_metadata_t **requestTemplate);
Emilian Peev5fbe0ba2017-10-20 15:45:45 +0100297 status_t configureStreams(const camera_metadata_t *sessionParams,
Yin-Chia Yehfb6e55b2018-01-25 10:50:26 -0800298 /*inout*/ camera3_stream_configuration *config,
Emilian Peev192ee832018-01-31 14:46:47 +0000299 const std::vector<uint32_t>& bufferSizes);
Yin-Chia Yeh11648852019-05-16 10:42:54 -0700300
301 // When the call succeeds, the ownership of acquire fences in requests is transferred to
302 // HalInterface. More specifically, the current implementation will send the fence to
303 // HAL process and close the FD in cameraserver process. When the call fails, the ownership
304 // of the acquire fence still belongs to the caller.
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800305 status_t processBatchCaptureRequests(
306 std::vector<camera3_capture_request_t*>& requests,
307 /*out*/uint32_t* numRequestProcessed);
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800308 status_t flush();
309 status_t dump(int fd);
310 status_t close();
311
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700312 void signalPipelineDrain(const std::vector<int>& streamIds);
Emilian Peev4ec17882019-01-24 17:16:58 -0800313 bool isReconfigurationRequired(CameraMetadata& oldSessionParams,
314 CameraMetadata& newSessionParams);
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700315
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700316 // method to extract buffer's unique ID
317 // return pair of (newlySeenBuffer?, bufferId)
318 std::pair<bool, uint64_t> getBufferId(const buffer_handle_t& buf, int streamId);
319
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800320 // Find a buffer_handle_t based on frame number and stream ID
321 status_t popInflightBuffer(int32_t frameNumber, int32_t streamId,
322 /*out*/ buffer_handle_t **buffer);
323
Yin-Chia Yeh84be5782019-03-01 11:47:02 -0800324 // Register a bufId (streamId, buffer_handle_t) to inflight request buffer
325 status_t pushInflightRequestBuffer(
326 uint64_t bufferId, buffer_handle_t* buf, int32_t streamId);
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700327
328 // Find a buffer_handle_t based on bufferId
Yin-Chia Yeh84be5782019-03-01 11:47:02 -0800329 status_t popInflightRequestBuffer(uint64_t bufferId,
330 /*out*/ buffer_handle_t** buffer,
331 /*optional out*/ int32_t* streamId = nullptr);
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700332
Yin-Chia Yehf3fe36f2017-07-07 18:23:18 -0700333 // Get a vector of (frameNumber, streamId) pair of currently inflight
334 // buffers
335 void getInflightBufferKeys(std::vector<std::pair<int32_t, int32_t>>* out);
336
Yin-Chia Yeh84be5782019-03-01 11:47:02 -0800337 // Get a vector of bufferId of currently inflight buffers
338 void getInflightRequestBufferKeys(std::vector<uint64_t>* out);
339
Yin-Chia Yeh573a2702019-04-17 10:08:55 -0700340 void onStreamReConfigured(int streamId);
341
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700342 static const uint64_t BUFFER_ID_NO_BUFFER = 0;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800343 private:
Eino-Ville Talvala1a86df52018-01-17 16:00:35 -0800344 // Always valid
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800345 sp<hardware::camera::device::V3_2::ICameraDeviceSession> mHidlSession;
Eino-Ville Talvala1a86df52018-01-17 16:00:35 -0800346 // Valid if ICameraDeviceSession is @3.3 or newer
347 sp<hardware::camera::device::V3_3::ICameraDeviceSession> mHidlSession_3_3;
348 // Valid if ICameraDeviceSession is @3.4 or newer
349 sp<hardware::camera::device::V3_4::ICameraDeviceSession> mHidlSession_3_4;
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700350 // Valid if ICameraDeviceSession is @3.5 or newer
351 sp<hardware::camera::device::V3_5::ICameraDeviceSession> mHidlSession_3_5;
Eino-Ville Talvala1a86df52018-01-17 16:00:35 -0800352
Yifan Hongf79b5542017-04-11 14:44:25 -0700353 std::shared_ptr<RequestMetadataQueue> mRequestMetadataQueue;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800354
355 std::mutex mInflightLock;
356
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800357 // The output HIDL request still depends on input camera3_capture_request_t
358 // Do not free input camera3_capture_request_t before output HIDL request
Yin-Chia Yeh651fe2e2018-11-13 11:49:31 -0800359 status_t wrapAsHidlRequest(camera3_capture_request_t* in,
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800360 /*out*/hardware::camera::device::V3_2::CaptureRequest* out,
Yin-Chia Yehf8e28fb2019-05-16 11:46:54 -0700361 /*out*/std::vector<native_handle_t*>* handlesCreated,
362 /*out*/std::vector<std::pair<int32_t, int32_t>>* inflightBuffers);
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800363
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800364 status_t pushInflightBufferLocked(int32_t frameNumber, int32_t streamId,
Yin-Chia Yehf8e28fb2019-05-16 11:46:54 -0700365 buffer_handle_t *buffer);
366
367 // Pop inflight buffers based on pairs of (frameNumber,streamId)
368 void popInflightBuffers(const std::vector<std::pair<int32_t, int32_t>>& buffers);
369
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800370 // Cache of buffer handles keyed off (frameNumber << 32 | streamId)
Yin-Chia Yehf8e28fb2019-05-16 11:46:54 -0700371 std::unordered_map<uint64_t, buffer_handle_t*> mInflightBufferMap;
372
373 // Delete and optionally close native handles and clear the input vector afterward
374 static void cleanupNativeHandles(
375 std::vector<native_handle_t*> *handles, bool closeFd = false);
Yin-Chia Yeh77327052017-01-09 18:23:07 -0800376
377 struct BufferHasher {
378 size_t operator()(const buffer_handle_t& buf) const {
379 if (buf == nullptr)
380 return 0;
381
382 size_t result = 1;
383 result = 31 * result + buf->numFds;
Emilian Peev2a6a4682017-04-20 10:58:51 +0100384 for (int i = 0; i < buf->numFds; i++) {
Yin-Chia Yeh77327052017-01-09 18:23:07 -0800385 result = 31 * result + buf->data[i];
386 }
387 return result;
388 }
389 };
390
391 struct BufferComparator {
392 bool operator()(const buffer_handle_t& buf1, const buffer_handle_t& buf2) const {
Emilian Peev2a6a4682017-04-20 10:58:51 +0100393 if (buf1->numFds == buf2->numFds) {
394 for (int i = 0; i < buf1->numFds; i++) {
Yin-Chia Yeh77327052017-01-09 18:23:07 -0800395 if (buf1->data[i] != buf2->data[i]) {
396 return false;
397 }
398 }
399 return true;
400 }
401 return false;
402 }
403 };
404
405 std::mutex mBufferIdMapLock; // protecting mBufferIdMaps and mNextBufferId
406 typedef std::unordered_map<const buffer_handle_t, uint64_t,
407 BufferHasher, BufferComparator> BufferIdMap;
408 // stream ID -> per stream buffer ID map
409 std::unordered_map<int, BufferIdMap> mBufferIdMaps;
410 uint64_t mNextBufferId = 1; // 0 means no buffer
Yin-Chia Yehbe83fa72017-03-30 13:35:36 -0700411
412 virtual void onBufferFreed(int streamId, const native_handle_t* handle) override;
413
414 std::vector<std::pair<int, uint64_t>> mFreedBuffers;
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700415
416 // Buffers given to HAL through requestStreamBuffer API
417 std::mutex mRequestedBuffersLock;
Yin-Chia Yeh84be5782019-03-01 11:47:02 -0800418 std::unordered_map<uint64_t, std::pair<int32_t, buffer_handle_t*>> mRequestedBuffers;
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700419
420 uint32_t mNextStreamConfigCounter = 1;
Yin-Chia Yeh651fe2e2018-11-13 11:49:31 -0800421
422 const bool mUseHalBufManager;
Emilian Peev4ec17882019-01-24 17:16:58 -0800423 bool mIsReconfigurationQuerySupported;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800424 };
425
Yin-Chia Yehdb1e8642017-07-14 15:19:30 -0700426 sp<HalInterface> mInterface;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800427
428 CameraMetadata mDeviceInfo;
Shuzhen Wang2e7f58f2018-07-11 14:00:29 -0700429 std::unordered_map<std::string, CameraMetadata> mPhysicalDeviceInfoMap;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800430
Zhijun Hea1530f12014-09-14 12:44:20 -0700431 CameraMetadata mRequestTemplateCache[CAMERA3_TEMPLATE_COUNT];
432
Chien-Yu Chen618ff8a2015-03-13 11:27:17 -0700433 struct Size {
434 uint32_t width;
435 uint32_t height;
Chih-Hung Hsieh8b0b9712016-08-09 14:25:53 -0700436 explicit Size(uint32_t w = 0, uint32_t h = 0) : width(w), height(h){}
Chien-Yu Chen618ff8a2015-03-13 11:27:17 -0700437 };
438 // Map from format to size.
439 Vector<Size> mSupportedOpaqueInputSizes;
440
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700441 enum Status {
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800442 STATUS_ERROR,
443 STATUS_UNINITIALIZED,
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700444 STATUS_UNCONFIGURED,
445 STATUS_CONFIGURED,
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800446 STATUS_ACTIVE
447 } mStatus;
Ruben Brunk183f0562015-08-12 12:55:02 -0700448
449 // Only clear mRecentStatusUpdates, mStatusWaiters from waitUntilStateThenRelock
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700450 Vector<Status> mRecentStatusUpdates;
Ruben Brunk183f0562015-08-12 12:55:02 -0700451 int mStatusWaiters;
452
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700453 Condition mStatusChanged;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800454
Eino-Ville Talvalab2058d12013-04-09 13:49:56 -0700455 // Tracking cause of fatal errors when in STATUS_ERROR
456 String8 mErrorCause;
457
Yin-Chia Yeh4ee35432018-10-10 13:52:31 -0700458 // Synchronized mapping of stream IDs to stream instances
459 class StreamSet {
460 public:
461 status_t add(int streamId, sp<camera3::Camera3OutputStreamInterface>);
462 ssize_t remove(int streamId);
463 sp<camera3::Camera3OutputStreamInterface> get(int streamId);
464 // get by (underlying) vector index
465 sp<camera3::Camera3OutputStreamInterface> operator[] (size_t index);
466 size_t size() const;
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700467 std::vector<int> getStreamIds();
Yin-Chia Yeh4ee35432018-10-10 13:52:31 -0700468 void clear();
469
470 private:
471 mutable std::mutex mLock;
472 KeyedVector<int, sp<camera3::Camera3OutputStreamInterface>> mData;
473 };
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800474
475 StreamSet mOutputStreams;
476 sp<camera3::Camera3Stream> mInputStream;
477 int mNextStreamId;
Eino-Ville Talvalaea26c772013-06-11 16:04:06 -0700478 bool mNeedConfig;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800479
Eino-Ville Talvala16a2ada2014-08-27 14:41:33 -0700480 int mDummyStreamId;
481
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700482 // Whether to send state updates upstream
483 // Pause when doing transparent reconfiguration
484 bool mPauseStateNotify;
485
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800486 // Need to hold on to stream references until configure completes.
Igor Murashkin2fba5842013-04-22 14:03:54 -0700487 Vector<sp<camera3::Camera3StreamInterface> > mDeletedStreams;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800488
Zhijun He204e3292014-07-14 17:09:23 -0700489 // Whether the HAL will send partial result
490 bool mUsePartialResult;
491
492 // Number of partial results that will be delivered by the HAL.
493 uint32_t mNumPartialResults;
Eino-Ville Talvalafd6ecdd2013-10-11 09:51:09 -0700494
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800495 /**** End scope for mLock ****/
496
Shuzhen Wangc28dccc2016-02-11 23:48:46 -0800497 // The offset converting from clock domain of other subsystem
498 // (video/hardware composer) to that of camera. Assumption is that this
499 // offset won't change during the life cycle of the camera device. In other
500 // words, camera device shouldn't be open during CPU suspend.
501 nsecs_t mTimestampOffset;
502
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800503 class CaptureRequest : public LightRefBase<CaptureRequest> {
504 public:
Emilian Peevaebbe412018-01-15 13:53:24 +0000505 PhysicalCameraSettingsList mSettingsList;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800506 sp<camera3::Camera3Stream> mInputStream;
Chien-Yu Chenc2adf482015-05-27 14:27:49 -0700507 camera3_stream_buffer_t mInputBuffer;
Igor Murashkin2fba5842013-04-22 14:03:54 -0700508 Vector<sp<camera3::Camera3OutputStreamInterface> >
509 mOutputStreams;
Shuzhen Wang0129d522016-10-30 22:43:41 -0700510 SurfaceMap mOutputSurfaces;
Jianing Weicb0652e2014-03-12 18:29:36 -0700511 CaptureResultExtras mResultExtras;
Chien-Yu Chen85a64552015-08-28 15:46:12 -0700512 // The number of requests that should be submitted to HAL at a time.
513 // For example, if batch size is 8, this request and the following 7
514 // requests will be submitted to HAL at a time. The batch size for
515 // the following 7 requests will be ignored by the request thread.
516 int mBatchSize;
Shuzhen Wang9d066012016-09-30 11:30:20 -0700517 // Whether this request is from a repeating or repeating burst.
518 bool mRepeating;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800519 };
520 typedef List<sp<CaptureRequest> > RequestList;
521
Jianing Wei90e59c92014-03-12 18:29:36 -0700522 status_t checkStatusOkToCaptureLocked();
523
524 status_t convertMetadataListToRequestListLocked(
Emilian Peevaebbe412018-01-15 13:53:24 +0000525 const List<const PhysicalCameraSettingsList> &metadataList,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700526 const std::list<const SurfaceMap> &surfaceMaps,
Shuzhen Wang9d066012016-09-30 11:30:20 -0700527 bool repeating,
Jianing Wei2d6bb3f2014-04-11 10:00:31 -0700528 /*out*/
529 RequestList *requestList);
Jianing Wei90e59c92014-03-12 18:29:36 -0700530
Emilian Peevaebbe412018-01-15 13:53:24 +0000531 void convertToRequestList(List<const PhysicalCameraSettingsList>& requestsList,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700532 std::list<const SurfaceMap>& surfaceMaps,
533 const CameraMetadata& request);
534
Emilian Peevaebbe412018-01-15 13:53:24 +0000535 status_t submitRequestsHelper(const List<const PhysicalCameraSettingsList> &requestsList,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700536 const std::list<const SurfaceMap> &surfaceMaps,
537 bool repeating,
Jianing Weicb0652e2014-03-12 18:29:36 -0700538 int64_t *lastFrameNumber = NULL);
Jianing Wei90e59c92014-03-12 18:29:36 -0700539
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800540
541 /**
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700542 * Implementation of android::hardware::camera::device::V3_5::ICameraDeviceCallback
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800543 */
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700544
Shuzhen Wang5c22c152017-12-31 17:12:25 -0800545 hardware::Return<void> processCaptureResult_3_4(
546 const hardware::hidl_vec<
547 hardware::camera::device::V3_4::CaptureResult>& results) override;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800548 hardware::Return<void> processCaptureResult(
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800549 const hardware::hidl_vec<
550 hardware::camera::device::V3_2::CaptureResult>& results) override;
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800551 hardware::Return<void> notify(
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800552 const hardware::hidl_vec<
553 hardware::camera::device::V3_2::NotifyMsg>& msgs) override;
554
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700555 hardware::Return<void> requestStreamBuffers(
556 const hardware::hidl_vec<
557 hardware::camera::device::V3_5::BufferRequest>& bufReqs,
558 requestStreamBuffers_cb _hidl_cb) override;
559
560 hardware::Return<void> returnStreamBuffers(
561 const hardware::hidl_vec<
562 hardware::camera::device::V3_2::StreamBuffer>& buffers) override;
563
Yifan Honga640c5a2017-04-12 16:30:31 -0700564 // Handle one capture result. Assume that mProcessCaptureResultLock is held.
565 void processOneCaptureResultLocked(
Shuzhen Wang5c22c152017-12-31 17:12:25 -0800566 const hardware::camera::device::V3_2::CaptureResult& result,
567 const hardware::hidl_vec<
Shuzhen Wangc2cba122018-05-17 18:10:24 -0700568 hardware::camera::device::V3_4::PhysicalCameraMetadata> physicalCameraMetadata);
Shuzhen Wang5c22c152017-12-31 17:12:25 -0800569 status_t readOneCameraMetadataLocked(uint64_t fmqResultSize,
570 hardware::camera::device::V3_2::CameraMetadata& resultMetadata,
571 const hardware::camera::device::V3_2::CameraMetadata& result);
572
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800573 // Handle one notify message
574 void notify(const hardware::camera::device::V3_2::NotifyMsg& msg);
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800575
Yifan Honga640c5a2017-04-12 16:30:31 -0700576 // lock to ensure only one processCaptureResult is called at a time.
577 Mutex mProcessCaptureResultLock;
578
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800579 /**
580 * Common initialization code shared by both HAL paths
581 *
582 * Must be called with mLock and mInterfaceLock held.
583 */
584 status_t initializeCommonLocked();
585
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800586 /**
Igor Murashkin1e479c02013-09-06 16:55:14 -0700587 * Get the last request submitted to the hal by the request thread.
588 *
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800589 * Must be called with mLock held.
Igor Murashkin1e479c02013-09-06 16:55:14 -0700590 */
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700591 virtual CameraMetadata getLatestRequestLocked();
Igor Murashkin1e479c02013-09-06 16:55:14 -0700592
593 /**
Ruben Brunk183f0562015-08-12 12:55:02 -0700594 * Update the current device status and wake all waiting threads.
595 *
596 * Must be called with mLock held.
597 */
598 void internalUpdateStatusLocked(Status status);
599
600 /**
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700601 * Pause processing and flush everything, but don't tell the clients.
602 * This is for reconfiguring outputs transparently when according to the
603 * CameraDeviceBase interface we shouldn't need to.
604 * Must be called with mLock and mInterfaceLock both held.
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800605 */
Yin-Chia Yeh598fc602017-07-24 11:37:23 -0700606 status_t internalPauseAndWaitLocked(nsecs_t maxExpectedDuration);
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700607
608 /**
609 * Resume work after internalPauseAndWaitLocked()
610 * Must be called with mLock and mInterfaceLock both held.
611 */
612 status_t internalResumeLocked();
613
614 /**
615 * Wait until status tracker tells us we've transitioned to the target state
616 * set, which is either ACTIVE when active==true or IDLE (which is any
617 * non-ACTIVE state) when active==false.
618 *
619 * Needs to be called with mLock and mInterfaceLock held. This means there
620 * can ever only be one waiter at most.
621 *
622 * During the wait mLock is released.
623 *
624 */
625 status_t waitUntilStateThenRelock(bool active, nsecs_t timeout);
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800626
627 /**
Zhijun He69a37482014-03-23 18:44:49 -0700628 * Implementation of waitUntilDrained. On success, will transition to IDLE state.
629 *
630 * Need to be called with mLock and mInterfaceLock held.
631 */
Yin-Chia Yeh598fc602017-07-24 11:37:23 -0700632 status_t waitUntilDrainedLocked(nsecs_t maxExpectedDuration);
Zhijun He69a37482014-03-23 18:44:49 -0700633
634 /**
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800635 * Do common work for setting up a streaming or single capture request.
636 * On success, will transition to ACTIVE if in IDLE.
637 */
Emilian Peevaebbe412018-01-15 13:53:24 +0000638 sp<CaptureRequest> setUpRequestLocked(const PhysicalCameraSettingsList &request,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700639 const SurfaceMap &surfaceMap);
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800640
641 /**
642 * Build a CaptureRequest request from the CameraDeviceBase request
643 * settings.
644 */
Emilian Peevaebbe412018-01-15 13:53:24 +0000645 sp<CaptureRequest> createCaptureRequest(const PhysicalCameraSettingsList &request,
Shuzhen Wang0129d522016-10-30 22:43:41 -0700646 const SurfaceMap &surfaceMap);
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800647
648 /**
Eino-Ville Talvala002001b2018-01-23 16:53:50 -0800649 * Pause state updates to the client application. Needed to mask out idle/active
650 * transitions during internal reconfigure
651 */
652 void pauseStateNotify(bool enable);
653
654 /**
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000655 * Internally re-configure camera device using new session parameters.
Eino-Ville Talvala002001b2018-01-23 16:53:50 -0800656 * This will get triggered by the request thread. Be sure to call
657 * pauseStateNotify(true) before going idle in the requesting location.
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000658 */
659 bool reconfigureCamera(const CameraMetadata& sessionParams);
660
661 /**
662 * Filter stream session parameters and configure camera HAL.
663 */
664 status_t filterParamsAndConfigureLocked(const CameraMetadata& sessionParams,
665 int operatingMode);
666
667 /**
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800668 * Take the currently-defined set of streams and configure the HAL to use
669 * them. This is a long-running operation (may be several hundered ms).
670 */
Emilian Peev5fbe0ba2017-10-20 15:45:45 +0100671 status_t configureStreamsLocked(int operatingMode,
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000672 const CameraMetadata& sessionParams, bool notifyRequestThread = true);
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800673
Eino-Ville Talvalab2058d12013-04-09 13:49:56 -0700674 /**
Chien-Yu Chen9b5860b2016-06-10 13:39:09 -0700675 * Cancel stream configuration that did not finish successfully.
676 */
677 void cancelStreamsConfigurationLocked();
678
679 /**
Eino-Ville Talvala16a2ada2014-08-27 14:41:33 -0700680 * Add a dummy stream to the current stream set as a workaround for
681 * not allowing 0 streams in the camera HAL spec.
682 */
683 status_t addDummyStreamLocked();
684
685 /**
686 * Remove a dummy stream if the current config includes real streams.
687 */
688 status_t tryRemoveDummyStreamLocked();
689
690 /**
Eino-Ville Talvalab2058d12013-04-09 13:49:56 -0700691 * Set device into an error state due to some fatal failure, and set an
692 * error message to indicate why. Only the first call's message will be
693 * used. The message is also sent to the log.
694 */
695 void setErrorState(const char *fmt, ...);
696 void setErrorStateV(const char *fmt, va_list args);
697 void setErrorStateLocked(const char *fmt, ...);
698 void setErrorStateLockedV(const char *fmt, va_list args);
699
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700700 /**
701 * Debugging trylock/spin method
702 * Try to acquire a lock a few times with sleeps between before giving up.
703 */
704 bool tryLockSpinRightRound(Mutex& lock);
705
Chien-Yu Chen618ff8a2015-03-13 11:27:17 -0700706 /**
707 * Helper function to determine if an input size for implementation defined
708 * format is supported.
709 */
710 bool isOpaqueInputSizeSupported(uint32_t width, uint32_t height);
Yin-Chia Yehcd8fce82014-06-18 10:51:34 -0700711
712 /**
713 * Helper function to get the largest Jpeg resolution (in area)
714 * Return Size(0, 0) if static metatdata is invalid
715 */
716 Size getMaxJpegResolution() const;
717
Shuzhen Wangc28dccc2016-02-11 23:48:46 -0800718 /**
719 * Helper function to get the offset between MONOTONIC and BOOTTIME
720 * timestamp.
721 */
722 static nsecs_t getMonoToBoottimeOffset();
723
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700724 struct RequestTrigger {
725 // Metadata tag number, e.g. android.control.aePrecaptureTrigger
726 uint32_t metadataTag;
727 // Metadata value, e.g. 'START' or the trigger ID
728 int32_t entryValue;
729
730 // The last part of the fully qualified path, e.g. afTrigger
731 const char *getTagName() const {
732 return get_camera_metadata_tag_name(metadataTag) ?: "NULL";
733 }
734
735 // e.g. TYPE_BYTE, TYPE_INT32, etc.
736 int getTagType() const {
737 return get_camera_metadata_tag_type(metadataTag);
738 }
739 };
740
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800741 /**
742 * Thread for managing capture request submission to HAL device.
743 */
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800744 class RequestThread : public Thread {
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800745
746 public:
747
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800748 RequestThread(wp<Camera3Device> parent,
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700749 sp<camera3::StatusTracker> statusTracker,
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700750 sp<HalInterface> interface,
751 const Vector<int32_t>& sessionParamKeys,
752 bool useHalBufManager);
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800753 ~RequestThread();
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800754
Yin-Chia Yehe1c80632016-08-08 14:48:05 -0700755 void setNotificationListener(wp<NotificationListener> listener);
Eino-Ville Talvala17543512014-08-06 14:32:02 -0700756
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800757 /**
758 * Call after stream (re)-configuration is completed.
759 */
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000760 void configurationComplete(bool isConstrainedHighSpeed,
761 const CameraMetadata& sessionParams);
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800762
763 /**
764 * Set or clear the list of repeating requests. Does not block
765 * on either. Use waitUntilPaused to wait until request queue
766 * has emptied out.
767 */
Jianing Wei2d6bb3f2014-04-11 10:00:31 -0700768 status_t setRepeatingRequests(const RequestList& requests,
769 /*out*/
770 int64_t *lastFrameNumber = NULL);
771 status_t clearRepeatingRequests(/*out*/
772 int64_t *lastFrameNumber = NULL);
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800773
Jianing Wei2d6bb3f2014-04-11 10:00:31 -0700774 status_t queueRequestList(List<sp<CaptureRequest> > &requests,
775 /*out*/
776 int64_t *lastFrameNumber = NULL);
Jianing Wei90e59c92014-03-12 18:29:36 -0700777
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800778 /**
Eino-Ville Talvalaabaa51d2013-08-14 11:37:00 -0700779 * Remove all queued and repeating requests, and pending triggers
780 */
Yin-Chia Yehe1c80632016-08-08 14:48:05 -0700781 status_t clear(/*out*/int64_t *lastFrameNumber = NULL);
Eino-Ville Talvalaabaa51d2013-08-14 11:37:00 -0700782
783 /**
Chien-Yu Chen85a64552015-08-28 15:46:12 -0700784 * Flush all pending requests in HAL.
785 */
786 status_t flush();
787
788 /**
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700789 * Queue a trigger to be dispatched with the next outgoing
790 * process_capture_request. The settings for that request only
791 * will be temporarily rewritten to add the trigger tag/value.
792 * Subsequent requests will not be rewritten (for this tag).
793 */
794 status_t queueTrigger(RequestTrigger trigger[], size_t count);
795
796 /**
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800797 * Pause/unpause the capture thread. Doesn't block, so use
798 * waitUntilPaused to wait until the thread is paused.
799 */
800 void setPaused(bool paused);
801
802 /**
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700803 * Wait until thread processes the capture request with settings'
804 * android.request.id == requestId.
805 *
806 * Returns TIMED_OUT in case the thread does not process the request
807 * within the timeout.
808 */
809 status_t waitUntilRequestProcessed(int32_t requestId, nsecs_t timeout);
810
Igor Murashkin1e479c02013-09-06 16:55:14 -0700811 /**
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700812 * Shut down the thread. Shutdown is asynchronous, so thread may
813 * still be running once this method returns.
814 */
815 virtual void requestExit();
816
817 /**
Igor Murashkin1e479c02013-09-06 16:55:14 -0700818 * Get the latest request that was sent to the HAL
819 * with process_capture_request.
820 */
821 CameraMetadata getLatestRequest() const;
822
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -0700823 /**
824 * Returns true if the stream is a target of any queued or repeating
825 * capture request
826 */
827 bool isStreamPending(sp<camera3::Camera3StreamInterface>& stream);
828
Emilian Peev40ead602017-09-26 15:46:36 +0100829 /**
830 * Returns true if the surface is a target of any queued or repeating
831 * capture request
832 */
833 bool isOutputSurfacePending(int streamId, size_t surfaceId);
834
Shuzhen Wang686f6442017-06-20 16:16:04 -0700835 // dump processCaptureRequest latency
836 void dumpCaptureRequestLatency(int fd, const char* name) {
837 mRequestLatency.dump(fd, name);
838 }
839
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700840 void signalPipelineDrain(const std::vector<int>& streamIds);
Yin-Chia Yehfe70f2d2020-07-28 00:17:58 -0700841 void resetPipelineDrain();
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700842
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800843 protected:
844
845 virtual bool threadLoop();
846
847 private:
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800848 static const String8& getId(const wp<Camera3Device> &device);
Eino-Ville Talvala42368d92013-04-09 14:13:50 -0700849
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700850 status_t queueTriggerLocked(RequestTrigger trigger);
851 // Mix-in queued triggers into this request
852 int32_t insertTriggers(const sp<CaptureRequest> &request);
853 // Purge the queued triggers from this request,
854 // restoring the old field values for those tags.
855 status_t removeTriggers(const sp<CaptureRequest> &request);
856
Eino-Ville Talvala2f876f92013-09-13 11:39:24 -0700857 // HAL workaround: Make sure a trigger ID always exists if
858 // a trigger does
859 status_t addDummyTriggerIds(const sp<CaptureRequest> &request);
860
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800861 static const nsecs_t kRequestTimeout = 50e6; // 50 ms
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800862
Chien-Yu Chen85a64552015-08-28 15:46:12 -0700863 // Used to prepare a batch of requests.
864 struct NextRequest {
865 sp<CaptureRequest> captureRequest;
866 camera3_capture_request_t halRequest;
867 Vector<camera3_stream_buffer_t> outputBuffers;
868 bool submitted;
869 };
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800870
Chien-Yu Chen57ea2922015-09-04 12:58:56 -0700871 // Wait for the next batch of requests and put them in mNextRequests. mNextRequests will
872 // be empty if it times out.
873 void waitForNextRequestBatch();
Chien-Yu Chen85a64552015-08-28 15:46:12 -0700874
875 // Waits for a request, or returns NULL if times out. Must be called with mRequestLock hold.
876 sp<CaptureRequest> waitForNextRequestLocked();
877
Chien-Yu Chen57ea2922015-09-04 12:58:56 -0700878 // Prepare HAL requests and output buffers in mNextRequests. Return TIMED_OUT if getting any
879 // output buffer timed out. If an error is returned, the caller should clean up the pending
880 // request batch.
881 status_t prepareHalRequests();
Chien-Yu Chen85a64552015-08-28 15:46:12 -0700882
Chien-Yu Chen57ea2922015-09-04 12:58:56 -0700883 // Return buffers, etc, for requests in mNextRequests that couldn't be fully constructed and
884 // send request errors if sendRequestError is true. The buffers will be returned in the
885 // ERROR state to mark them as not having valid data. mNextRequests will be cleared.
886 void cleanUpFailedRequests(bool sendRequestError);
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800887
Chien-Yu Chene8c535e2016-04-14 12:18:26 -0700888 // Stop the repeating request if any of its output streams is abandoned.
889 void checkAndStopRepeatingRequest();
890
Emilian Peevaebbe412018-01-15 13:53:24 +0000891 // Release physical camera settings and camera id resources.
892 void cleanupPhysicalSettings(sp<CaptureRequest> request,
893 /*out*/camera3_capture_request_t *halRequest);
894
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800895 // Pause handling
896 bool waitIfPaused();
Eino-Ville Talvala26fe6c72013-08-29 12:46:18 -0700897 void unpauseForNewRequests();
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800898
Eino-Ville Talvalab2058d12013-04-09 13:49:56 -0700899 // Relay error to parent device object setErrorState
900 void setErrorState(const char *fmt, ...);
901
Yin-Chia Yeh8684b7f2014-06-13 14:53:05 -0700902 // If the input request is in mRepeatingRequests. Must be called with mRequestLock hold
Chih-Hung Hsieh8b0b9712016-08-09 14:25:53 -0700903 bool isRepeatingRequestLocked(const sp<CaptureRequest>&);
Yin-Chia Yeh8684b7f2014-06-13 14:53:05 -0700904
Chien-Yu Chene8c535e2016-04-14 12:18:26 -0700905 // Clear repeating requests. Must be called with mRequestLock held.
906 status_t clearRepeatingRequestsLocked(/*out*/ int64_t *lastFrameNumber = NULL);
907
Yin-Chia Yeh94c68e02017-03-06 14:09:44 -0800908 // send request in mNextRequests to HAL in a batch. Return true = sucssess
909 bool sendRequestsBatch();
910
Eino-Ville Talvala10bd57e2017-06-23 16:22:44 -0700911 // Calculate the expected maximum duration for a request
912 nsecs_t calculateMaxExpectedDuration(const camera_metadata_t *request);
913
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000914 // Check and update latest session parameters based on the current request settings.
915 bool updateSessionParameters(const CameraMetadata& settings);
916
Emilian Peeva14b4dd2018-05-15 11:00:31 +0100917 // Check whether FPS range session parameter re-configuration is needed in constrained
918 // high speed recording camera sessions.
919 bool skipHFRTargetFPSUpdate(int32_t tag, const camera_metadata_ro_entry_t& newEntry,
920 const camera_metadata_entry_t& currentEntry);
921
Shuzhen Wangc2cba122018-05-17 18:10:24 -0700922 // Update next request sent to HAL
923 void updateNextRequest(NextRequest& nextRequest);
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000924
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800925 wp<Camera3Device> mParent;
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700926 wp<camera3::StatusTracker> mStatusTracker;
Yin-Chia Yehdb1e8642017-07-14 15:19:30 -0700927 sp<HalInterface> mInterface;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800928
Yin-Chia Yehe1c80632016-08-08 14:48:05 -0700929 wp<NotificationListener> mListener;
Eino-Ville Talvala17543512014-08-06 14:32:02 -0700930
Eino-Ville Talvala0b1cb142016-12-19 16:29:17 -0800931 const String8& mId; // The camera ID
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700932 int mStatusId; // The RequestThread's component ID for
933 // status tracking
Eino-Ville Talvala42368d92013-04-09 14:13:50 -0700934
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800935 Mutex mRequestLock;
936 Condition mRequestSignal;
937 RequestList mRequestQueue;
938 RequestList mRepeatingRequests;
Chien-Yu Chen57ea2922015-09-04 12:58:56 -0700939 // The next batch of requests being prepped for submission to the HAL, no longer
Eino-Ville Talvalae74c2282015-05-27 14:46:23 -0700940 // on the request queue. Read-only even with mRequestLock held, outside
941 // of threadLoop
Chien-Yu Chen57ea2922015-09-04 12:58:56 -0700942 Vector<NextRequest> mNextRequests;
Chien-Yu Chen85a64552015-08-28 15:46:12 -0700943
944 // To protect flush() and sending a request batch to HAL.
945 Mutex mFlushLock;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800946
947 bool mReconfigured;
948
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700949 // Used by waitIfPaused, waitForNextRequest, waitUntilPaused, and signalPipelineDrain
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800950 Mutex mPauseLock;
951 bool mDoPause;
952 Condition mDoPauseSignal;
953 bool mPaused;
Yin-Chia Yeh7447f0f2018-10-11 15:28:12 -0700954 bool mNotifyPipelineDrain;
955 std::vector<int> mStreamIdsToBeDrained;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800956
957 sp<CaptureRequest> mPrevRequest;
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700958 int32_t mPrevTriggers;
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800959
Eino-Ville Talvala42368d92013-04-09 14:13:50 -0700960 uint32_t mFrameNumber;
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700961
Igor Murashkin1e479c02013-09-06 16:55:14 -0700962 mutable Mutex mLatestRequestMutex;
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700963 Condition mLatestRequestSignal;
964 // android.request.id for latest process_capture_request
965 int32_t mLatestRequestId;
Igor Murashkin1e479c02013-09-06 16:55:14 -0700966 CameraMetadata mLatestRequest;
Shuzhen Wangc2cba122018-05-17 18:10:24 -0700967 std::unordered_map<std::string, CameraMetadata> mLatestPhysicalRequest;
Igor Murashkin4d2f2e82013-04-01 17:29:07 -0700968
969 typedef KeyedVector<uint32_t/*tag*/, RequestTrigger> TriggerMap;
970 Mutex mTriggerMutex;
971 TriggerMap mTriggerMap;
972 TriggerMap mTriggerRemovedMap;
973 TriggerMap mTriggerReplacedMap;
Yin-Chia Yehc00a25c2014-08-21 14:27:44 -0700974 uint32_t mCurrentAfTriggerId;
975 uint32_t mCurrentPreCaptureTriggerId;
Jianing Weicb0652e2014-03-12 18:29:36 -0700976
Jianing Wei2d6bb3f2014-04-11 10:00:31 -0700977 int64_t mRepeatingLastFrameNumber;
Chien-Yu Chend196d612015-06-22 19:49:01 -0700978
Chien-Yu Chenc66969b2016-05-19 16:37:51 -0700979 // Flag indicating if we should prepare video stream for video requests.
980 bool mPrepareVideoStream;
Shuzhen Wang686f6442017-06-20 16:16:04 -0700981
Emilian Peeva14b4dd2018-05-15 11:00:31 +0100982 bool mConstrainedMode;
983
Shuzhen Wang686f6442017-06-20 16:16:04 -0700984 static const int32_t kRequestLatencyBinSize = 40; // in ms
985 CameraLatencyHistogram mRequestLatency;
Emilian Peevac3ce6c2017-12-12 15:27:02 +0000986
987 Vector<int32_t> mSessionParamKeys;
988 CameraMetadata mLatestSessionParams;
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -0700989
990 const bool mUseHalBufManager;
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800991 };
Eino-Ville Talvalaf76e0272013-02-27 18:02:26 -0800992 sp<RequestThread> mRequestThread;
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -0800993
994 /**
Eino-Ville Talvala42368d92013-04-09 14:13:50 -0700995 * In-flight queue for tracking completion of capture requests.
996 */
997
998 struct InFlightRequest {
999 // Set by notify() SHUTTER call.
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001000 nsecs_t shutterTimestamp;
1001 // Set by process_capture_result().
1002 nsecs_t sensorTimestamp;
Zhijun He1d1f8462013-10-02 16:29:51 -07001003 int requestStatus;
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001004 // Set by process_capture_result call with valid metadata
1005 bool haveResultMetadata;
1006 // Decremented by calls to process_capture_result with valid output
Zhijun Hef0d962a2014-06-30 10:24:11 -07001007 // and input buffers
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001008 int numBuffersLeft;
Jianing Weicb0652e2014-03-12 18:29:36 -07001009 CaptureResultExtras resultExtras;
Zhijun Hec98bd8d2014-07-07 12:44:10 -07001010 // If this request has any input buffer
1011 bool hasInputBuffer;
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001012
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001013 // The last metadata that framework receives from HAL and
1014 // not yet send out because the shutter event hasn't arrived.
1015 // It's added by process_capture_result and sent when framework
1016 // receives the shutter event.
1017 CameraMetadata pendingMetadata;
1018
Chien-Yu Chen5cd8d642016-03-08 14:46:58 -08001019 // The metadata of the partial results that framework receives from HAL so far
1020 // and has sent out.
1021 CameraMetadata collectedPartialResult;
1022
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001023 // Buffers are added by process_capture_result when output buffers
1024 // return from HAL but framework has not yet received the shutter
1025 // event. They will be returned to the streams when framework receives
1026 // the shutter event.
1027 Vector<camera3_stream_buffer_t> pendingOutputBuffers;
1028
Shuzhen Wang4a472662017-02-26 23:29:04 -08001029 // Whether this inflight request's shutter and result callback are to be
1030 // called. The policy is that if the request is the last one in the constrained
1031 // high speed recording request list, this flag will be true. If the request list
1032 // is not for constrained high speed recording, this flag will also be true.
1033 bool hasCallback;
1034
Eino-Ville Talvala10bd57e2017-06-23 16:22:44 -07001035 // Maximum expected frame duration for this request.
1036 // For manual captures, equal to the max of requested exposure time and frame duration
1037 // For auto-exposure modes, equal to 1/(lower end of target FPS range)
1038 nsecs_t maxExpectedDuration;
1039
Shuzhen Wang20f57342017-08-24 15:39:05 -07001040 // Whether the result metadata for this request is to be skipped. The
1041 // result metadata should be skipped in the case of
1042 // REQUEST/RESULT error.
1043 bool skipResultMetadata;
1044
Shuzhen Wang5c22c152017-12-31 17:12:25 -08001045 // The physical camera ids being requested.
1046 std::set<String8> physicalCameraIds;
1047
1048 // Map of physicalCameraId <-> Metadata
1049 std::vector<PhysicalCaptureResultInfo> physicalMetadatas;
1050
Emilian Peev9dd21f42018-08-03 13:39:29 +01001051 // Indicates a still capture request.
1052 bool stillCapture;
1053
Shuzhen Wang26abaf42018-08-28 15:41:20 -07001054 // Indicates a ZSL capture request
1055 bool zslCapture;
1056
Yin-Chia Yeh58b1b4e2018-10-15 12:18:36 -07001057 // What shared surfaces an output should go to
1058 SurfaceMap outputSurfaces;
1059
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -07001060 // Default constructor needed by KeyedVector
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001061 InFlightRequest() :
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001062 shutterTimestamp(0),
1063 sensorTimestamp(0),
Zhijun He1d1f8462013-10-02 16:29:51 -07001064 requestStatus(OK),
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001065 haveResultMetadata(false),
Zhijun Hec98bd8d2014-07-07 12:44:10 -07001066 numBuffersLeft(0),
Chien-Yu Chend196d612015-06-22 19:49:01 -07001067 hasInputBuffer(false),
Eino-Ville Talvala10bd57e2017-06-23 16:22:44 -07001068 hasCallback(true),
Shuzhen Wang20f57342017-08-24 15:39:05 -07001069 maxExpectedDuration(kDefaultExpectedDuration),
Emilian Peev9dd21f42018-08-03 13:39:29 +01001070 skipResultMetadata(false),
Shuzhen Wang26abaf42018-08-28 15:41:20 -07001071 stillCapture(false),
1072 zslCapture(false) {
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001073 }
1074
Chien-Yu Chend196d612015-06-22 19:49:01 -07001075 InFlightRequest(int numBuffers, CaptureResultExtras extras, bool hasInput,
Shuzhen Wang5c22c152017-12-31 17:12:25 -08001076 bool hasAppCallback, nsecs_t maxDuration,
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -07001077 const std::set<String8>& physicalCameraIdSet, bool isStillCapture,
Yin-Chia Yeh58b1b4e2018-10-15 12:18:36 -07001078 bool isZslCapture,
1079 const SurfaceMap& outSurfaces = SurfaceMap{}) :
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001080 shutterTimestamp(0),
1081 sensorTimestamp(0),
Jianing Weicb0652e2014-03-12 18:29:36 -07001082 requestStatus(OK),
1083 haveResultMetadata(false),
1084 numBuffersLeft(numBuffers),
Zhijun Hec98bd8d2014-07-07 12:44:10 -07001085 resultExtras(extras),
Chien-Yu Chend196d612015-06-22 19:49:01 -07001086 hasInputBuffer(hasInput),
Eino-Ville Talvala10bd57e2017-06-23 16:22:44 -07001087 hasCallback(hasAppCallback),
Shuzhen Wang20f57342017-08-24 15:39:05 -07001088 maxExpectedDuration(maxDuration),
Shuzhen Wang5c22c152017-12-31 17:12:25 -08001089 skipResultMetadata(false),
Emilian Peev9dd21f42018-08-03 13:39:29 +01001090 physicalCameraIds(physicalCameraIdSet),
Shuzhen Wang26abaf42018-08-28 15:41:20 -07001091 stillCapture(isStillCapture),
Yin-Chia Yeh58b1b4e2018-10-15 12:18:36 -07001092 zslCapture(isZslCapture),
1093 outputSurfaces(outSurfaces) {
Zhijun Hec98bd8d2014-07-07 12:44:10 -07001094 }
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001095 };
1096
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001097 // Map from frame number to the in-flight request state
1098 typedef KeyedVector<uint32_t, InFlightRequest> InFlightMap;
1099
Yin-Chia Yeh598fc602017-07-24 11:37:23 -07001100
1101 Mutex mInFlightLock; // Protects mInFlightMap and
1102 // mExpectedInflightDuration
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001103 InFlightMap mInFlightMap;
Yin-Chia Yeh598fc602017-07-24 11:37:23 -07001104 nsecs_t mExpectedInflightDuration = 0;
Eino-Ville Talvala24b366e2016-07-21 12:53:07 -07001105 int mInFlightStatusId;
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001106
Jianing Weicb0652e2014-03-12 18:29:36 -07001107 status_t registerInFlight(uint32_t frameNumber,
Chien-Yu Chend196d612015-06-22 19:49:01 -07001108 int32_t numBuffers, CaptureResultExtras resultExtras, bool hasInput,
Emilian Peev9dd21f42018-08-03 13:39:29 +01001109 bool callback, nsecs_t maxExpectedDuration, std::set<String8>& physicalCameraIds,
Yin-Chia Yeh58b1b4e2018-10-15 12:18:36 -07001110 bool isStillCapture, bool isZslCapture,
1111 const SurfaceMap& outputSurfaces);
Eino-Ville Talvala10bd57e2017-06-23 16:22:44 -07001112
1113 /**
1114 * Returns the maximum expected time it'll take for all currently in-flight
1115 * requests to complete, based on their settings
1116 */
Yin-Chia Yeh598fc602017-07-24 11:37:23 -07001117 nsecs_t getExpectedInFlightDuration();
Chien-Yu Chend196d612015-06-22 19:49:01 -07001118
Eino-Ville Talvalafd6ecdd2013-10-11 09:51:09 -07001119 /**
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -07001120 * Tracking for idle detection
1121 */
1122 sp<camera3::StatusTracker> mStatusTracker;
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001123
1124 /**
Zhijun He125684a2015-12-26 15:07:30 -08001125 * Graphic buffer manager for output streams. Each device has a buffer manager, which is used
1126 * by the output streams to get and return buffers if these streams are registered to this
1127 * buffer manager.
1128 */
1129 sp<camera3::Camera3BufferManager> mBufferManager;
1130
1131 /**
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001132 * Thread for preparing streams
1133 */
1134 class PreparerThread : private Thread, public virtual RefBase {
1135 public:
1136 PreparerThread();
1137 ~PreparerThread();
1138
Yin-Chia Yehe1c80632016-08-08 14:48:05 -07001139 void setNotificationListener(wp<NotificationListener> listener);
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001140
1141 /**
Ruben Brunkc78ac262015-08-13 17:58:46 -07001142 * Queue up a stream to be prepared. Streams are processed by a background thread in FIFO
1143 * order. Pre-allocate up to maxCount buffers for the stream, or the maximum number needed
1144 * for the pipeline if maxCount is ALLOCATE_PIPELINE_MAX.
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001145 */
Ruben Brunkc78ac262015-08-13 17:58:46 -07001146 status_t prepare(int maxCount, sp<camera3::Camera3StreamInterface>& stream);
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001147
1148 /**
1149 * Cancel all current and pending stream preparation
1150 */
1151 status_t clear();
1152
Emilian Peevac3ce6c2017-12-12 15:27:02 +00001153 /**
1154 * Pause all preparation activities
1155 */
1156 void pause();
1157
1158 /**
1159 * Resume preparation activities
1160 */
1161 status_t resume();
1162
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001163 private:
1164 Mutex mLock;
Emilian Peevac3ce6c2017-12-12 15:27:02 +00001165 Condition mThreadActiveSignal;
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001166
1167 virtual bool threadLoop();
1168
1169 // Guarded by mLock
1170
Yin-Chia Yehe1c80632016-08-08 14:48:05 -07001171 wp<NotificationListener> mListener;
Emilian Peevac3ce6c2017-12-12 15:27:02 +00001172 std::unordered_map<int, sp<camera3::Camera3StreamInterface> > mPendingStreams;
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001173 bool mActive;
1174 bool mCancelNow;
1175
1176 // Only accessed by threadLoop and the destructor
1177
1178 sp<camera3::Camera3StreamInterface> mCurrentStream;
Emilian Peevac3ce6c2017-12-12 15:27:02 +00001179 int mCurrentMaxCount;
1180 bool mCurrentPrepareComplete;
Eino-Ville Talvala4d44cad2015-04-11 13:15:45 -07001181 };
1182 sp<PreparerThread> mPreparerThread;
1183
1184 /**
Eino-Ville Talvala7d346fa2013-03-11 14:13:50 -07001185 * Output result queue and current HAL device 3A state
1186 */
1187
1188 // Lock for output side of device
1189 Mutex mOutputLock;
1190
1191 /**** Scope for mOutputLock ****/
Chien-Yu Chen618ff8a2015-03-13 11:27:17 -07001192 // the minimal frame number of the next non-reprocess result
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001193 uint32_t mNextResultFrameNumber;
Chien-Yu Chen618ff8a2015-03-13 11:27:17 -07001194 // the minimal frame number of the next reprocess result
1195 uint32_t mNextReprocessResultFrameNumber;
Shuzhen Wang5ee99842019-04-12 11:55:48 -07001196 // the minimal frame number of the next ZSL still capture result
1197 uint32_t mNextZslStillResultFrameNumber;
Chien-Yu Chen3df11ce2015-09-30 14:13:30 -07001198 // the minimal frame number of the next non-reprocess shutter
Eino-Ville Talvala42368d92013-04-09 14:13:50 -07001199 uint32_t mNextShutterFrameNumber;
Chien-Yu Chen3df11ce2015-09-30 14:13:30 -07001200 // the minimal frame number of the next reprocess shutter
1201 uint32_t mNextReprocessShutterFrameNumber;
Shuzhen Wang5ee99842019-04-12 11:55:48 -07001202 // the minimal frame number of the next ZSL still capture shutter
1203 uint32_t mNextZslStillShutterFrameNumber;
Jianing Weicb0652e2014-03-12 18:29:36 -07001204 List<CaptureResult> mResultQueue;
Eino-Ville Talvala7d346fa2013-03-11 14:13:50 -07001205 Condition mResultSignal;
Yin-Chia Yehe1c80632016-08-08 14:48:05 -07001206 wp<NotificationListener> mListener;
Eino-Ville Talvala7d346fa2013-03-11 14:13:50 -07001207
Eino-Ville Talvala7d346fa2013-03-11 14:13:50 -07001208 /**** End scope for mOutputLock ****/
1209
1210 /**
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -08001211 * Callback functions from HAL device
1212 */
1213 void processCaptureResult(const camera3_capture_result *result);
1214
1215 void notify(const camera3_notify_msg *msg);
1216
Eino-Ville Talvala17543512014-08-06 14:32:02 -07001217 // Specific notify handlers
1218 void notifyError(const camera3_error_msg_t &msg,
Yin-Chia Yehe1c80632016-08-08 14:48:05 -07001219 sp<NotificationListener> listener);
Eino-Ville Talvala17543512014-08-06 14:32:02 -07001220 void notifyShutter(const camera3_shutter_msg_t &msg,
Yin-Chia Yehe1c80632016-08-08 14:48:05 -07001221 sp<NotificationListener> listener);
Eino-Ville Talvala17543512014-08-06 14:32:02 -07001222
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001223 // helper function to return the output buffers to the streams.
1224 void returnOutputBuffers(const camera3_stream_buffer_t *outputBuffers,
Yin-Chia Yeh58b1b4e2018-10-15 12:18:36 -07001225 size_t numBuffers, nsecs_t timestamp, bool timestampIncreasing = true,
1226 // The following arguments are only meant for surface sharing use case
1227 const SurfaceMap& outputSurfaces = SurfaceMap{},
1228 // Used to send buffer error callback when failing to return buffer
1229 const CaptureResultExtras &resultExtras = CaptureResultExtras{});
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001230
Chien-Yu Chen5cd8d642016-03-08 14:46:58 -08001231 // Send a partial capture result.
1232 void sendPartialCaptureResult(const camera_metadata_t * partialResult,
Emilian Peev7e25e5e2017-04-07 15:48:49 +01001233 const CaptureResultExtras &resultExtras, uint32_t frameNumber);
Chien-Yu Chen5cd8d642016-03-08 14:46:58 -08001234
1235 // Send a total capture result given the pending metadata and result extras,
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001236 // partial results, and the frame number to the result queue.
1237 void sendCaptureResult(CameraMetadata &pendingMetadata,
1238 CaptureResultExtras &resultExtras,
Chien-Yu Chen618ff8a2015-03-13 11:27:17 -07001239 CameraMetadata &collectedPartialResult, uint32_t frameNumber,
Shuzhen Wang5ee99842019-04-12 11:55:48 -07001240 bool reprocess, bool zslStillCapture,
1241 const std::vector<PhysicalCaptureResultInfo>& physicalMetadatas);
Shuzhen Wang5c22c152017-12-31 17:12:25 -08001242
1243 bool isLastFullResult(const InFlightRequest& inFlightRequest);
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001244
Chien-Yu Chen5cd8d642016-03-08 14:46:58 -08001245 // Insert the result to the result queue after updating frame number and overriding AE
1246 // trigger cancel.
1247 // mOutputLock must be held when calling this function.
Emilian Peev7e25e5e2017-04-07 15:48:49 +01001248 void insertResultLocked(CaptureResult *result, uint32_t frameNumber);
Chien-Yu Chen5cd8d642016-03-08 14:46:58 -08001249
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001250 /**** Scope for mInFlightLock ****/
1251
Shuzhen Wangcadb3302016-11-04 14:17:56 -07001252 // Remove the in-flight map entry of the given index from mInFlightMap.
1253 // It must only be called with mInFlightLock held.
1254 void removeInFlightMapEntryLocked(int idx);
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001255 // Remove the in-flight request of the given index from mInFlightMap
1256 // if it's no longer needed. It must only be called with mInFlightLock held.
1257 void removeInFlightRequestIfReadyLocked(int idx);
Yin-Chia Yehf3fe36f2017-07-07 18:23:18 -07001258 // Remove all in-flight requests and return all buffers.
1259 // This is used after HAL interface is closed to cleanup any request/buffers
1260 // not returned by HAL.
1261 void flushInflightRequests();
Chien-Yu Chen43e69a62014-11-25 16:38:33 -08001262
1263 /**** End scope for mInFlightLock ****/
1264
Eino-Ville Talvala7b8a1fd2018-05-22 15:30:35 -07001265 /**
1266 * Distortion correction support
1267 */
Shuzhen Wang4f6fa9d2019-03-29 10:40:35 -07001268 // Map from camera IDs to its corresponding distortion mapper. Only contains
1269 // 1 ID if the device isn't a logical multi-camera. Otherwise contains both
1270 // logical camera and its physical subcameras.
1271 std::unordered_map<std::string, camera3::DistortionMapper> mDistortionMappers;
Eino-Ville Talvala7b8a1fd2018-05-22 15:30:35 -07001272
Eino-Ville Talvala4d453832016-07-15 11:56:53 -07001273 // Debug tracker for metadata tag value changes
1274 // - Enabled with the -m <taglist> option to dumpsys, such as
1275 // dumpsys -m android.control.aeState,android.control.aeMode
1276 // - Disabled with -m off
1277 // - dumpsys -m 3a is a shortcut for ae/af/awbMode, State, and Triggers
1278 TagMonitor mTagMonitor;
1279
1280 void monitorMetadata(TagMonitor::eventSource source, int64_t frameNumber,
Shuzhen Wangc2cba122018-05-17 18:10:24 -07001281 nsecs_t timestamp, const CameraMetadata& metadata,
1282 const std::unordered_map<std::string, CameraMetadata>& physicalMetadata);
Eino-Ville Talvala4d453832016-07-15 11:56:53 -07001283
Emilian Peev71c73a22017-03-21 16:35:51 +00001284 metadata_vendor_id_t mVendorTagId;
1285
Emilian Peev811d2952018-05-25 11:08:40 +01001286 // Cached last requested template id
1287 int mLastTemplateId;
1288
Emilian Peev26d975d2018-07-05 14:52:57 +01001289 // Synchronizes access to status tracker between inflight updates and disconnect.
1290 // b/79972865
1291 Mutex mTrackerLock;
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -07001292
Yin-Chia Yeh30ab5ed2018-10-12 15:57:04 -07001293 // Whether HAL request buffers through requestStreamBuffers API
Yin-Chia Yehd5cd5ff2018-10-01 14:43:04 -07001294 bool mUseHalBufManager = false;
1295
1296 // Lock to ensure requestStreamBuffers() callbacks are serialized
1297 std::mutex mRequestBufferInterfaceLock;
1298
Yin-Chia Yeh30ab5ed2018-10-12 15:57:04 -07001299 // The state machine to control when requestStreamBuffers should allow
1300 // HAL to request buffers.
1301 enum RequestBufferState {
1302 /**
1303 * This is the initial state.
1304 * requestStreamBuffers call will return FAILED_CONFIGURING in this state.
1305 * Will switch to RB_STATUS_READY after a successful configureStreams or
1306 * processCaptureRequest call.
1307 */
1308 RB_STATUS_STOPPED,
1309
1310 /**
1311 * requestStreamBuffers call will proceed in this state.
1312 * When device is asked to stay idle via waitUntilStateThenRelock() call:
1313 * - Switch to RB_STATUS_STOPPED if there is no inflight requests and
1314 * request thread is paused.
1315 * - Switch to RB_STATUS_PENDING_STOP otherwise
1316 */
1317 RB_STATUS_READY,
1318
1319 /**
1320 * requestStreamBuffers call will proceed in this state.
1321 * Switch to RB_STATUS_STOPPED when all inflight requests are fulfilled
1322 * and request thread is paused
1323 */
1324 RB_STATUS_PENDING_STOP,
1325 };
1326
1327 class RequestBufferStateMachine {
1328 public:
1329 status_t initialize(sp<camera3::StatusTracker> statusTracker);
1330
1331 // Return if the state machine currently allows for requestBuffers
1332 // If the state allows for it, mRequestBufferOngoing will be set to true
1333 // and caller must call endRequestBuffer() later to unset the flag
1334 bool startRequestBuffer();
1335 void endRequestBuffer();
1336
1337 // Events triggered by application API call
1338 void onStreamsConfigured();
1339 void onWaitUntilIdle();
1340
1341 // Events usually triggered by hwBinder processCaptureResult callback thread
1342 // But can also be triggered on request thread for failed request, or on
1343 // hwbinder notify callback thread for shutter/error callbacks
1344 void onInflightMapEmpty();
1345
1346 // Events triggered by RequestThread
Yin-Chia Yehcd333fe2019-02-08 13:45:41 -08001347 void onSubmittingRequest();
Yin-Chia Yeh30ab5ed2018-10-12 15:57:04 -07001348 void onRequestThreadPaused();
1349
1350 private:
1351 void notifyTrackerLocked(bool active);
1352
1353 // Switch to STOPPED state and return true if all conditions allows for it.
1354 // Otherwise do nothing and return false.
1355 bool checkSwitchToStopLocked();
1356
1357 std::mutex mLock;
1358 RequestBufferState mStatus = RB_STATUS_STOPPED;
1359
1360 bool mRequestThreadPaused = true;
1361 bool mInflightMapEmpty = true;
1362 bool mRequestBufferOngoing = false;
1363
1364 wp<camera3::StatusTracker> mStatusTracker;
1365 int mRequestBufferStatusId;
1366 } mRequestBufferSM;
1367
Shuzhen Wang268a1362018-10-16 16:32:59 -07001368 // Fix up result metadata for monochrome camera.
1369 bool mNeedFixupMonochromeTags;
1370 status_t fixupMonochromeTags(const CameraMetadata& deviceInfo, CameraMetadata& resultMetadata);
Eino-Ville Talvala7fa43f32013-02-06 17:20:07 -08001371}; // class Camera3Device
1372
1373}; // namespace android
1374
1375#endif