1 /* 2 * Copyright (C) 2019 The Android Open Source Project 3 * 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 17 #ifndef ANDROID_AUTOMOTIVE_EVS_V1_1_HALCAMERA_H 18 #define ANDROID_AUTOMOTIVE_EVS_V1_1_HALCAMERA_H 19 20 #include "stats/CameraUsageStats.h" 21 22 #include <deque> 23 #include <list> 24 #include <thread> 25 #include <unordered_map> 26 27 #include <android/hardware/automotive/evs/1.1/types.h> 28 #include <android/hardware/automotive/evs/1.1/IEvsCamera.h> 29 #include <android/hardware/automotive/evs/1.1/IEvsCameraStream.h> 30 #include <utils/Mutex.h> 31 #include <utils/SystemClock.h> 32 33 using namespace ::android::hardware::automotive::evs::V1_1; 34 using ::android::hardware::camera::device::V3_2::Stream; 35 using ::android::hardware::Return; 36 using ::android::hardware::hidl_handle; 37 using ::android::hardware::automotive::evs::V1_0::EvsResult; 38 using IEvsCamera_1_0 = ::android::hardware::automotive::evs::V1_0::IEvsCamera; 39 using IEvsCamera_1_1 = ::android::hardware::automotive::evs::V1_1::IEvsCamera; 40 using BufferDesc_1_0 = ::android::hardware::automotive::evs::V1_0::BufferDesc; 41 using BufferDesc_1_1 = ::android::hardware::automotive::evs::V1_1::BufferDesc; 42 using IEvsCameraStream_1_0 = ::android::hardware::automotive::evs::V1_0::IEvsCameraStream; 43 using IEvsCameraStream_1_1 = ::android::hardware::automotive::evs::V1_1::IEvsCameraStream; 44 45 namespace android { 46 namespace automotive { 47 namespace evs { 48 namespace V1_1 { 49 namespace implementation { 50 51 52 class VirtualCamera; // From VirtualCamera.h 53 54 55 // This class wraps the actual hardware IEvsCamera objects. There is a one to many 56 // relationship between instances of this class and instances of the VirtualCamera class. 57 // This class implements the IEvsCameraStream interface so that it can receive the video 58 // stream from the hardware camera and distribute it to the associated VirtualCamera objects. 59 class HalCamera : public IEvsCameraStream_1_1 { 60 public: 61 HalCamera(sp<IEvsCamera_1_1>& hwCamera, 62 std::string deviceId = "", 63 int32_t recordId = 0, 64 Stream cfg = {}) 65 : mHwCamera(hwCamera), 66 mId(deviceId), 67 mStreamConfig(cfg), 68 mTimeCreatedMs(android::uptimeMillis()), 69 mUsageStats(new CameraUsageStats(recordId)) { 70 mCurrentRequests = &mFrameRequests[0]; 71 mNextRequests = &mFrameRequests[1]; 72 } 73 74 virtual ~HalCamera(); 75 76 // Factory methods for client VirtualCameras 77 sp<VirtualCamera> makeVirtualCamera(); 78 bool ownVirtualCamera(sp<VirtualCamera>& virtualCamera); 79 void disownVirtualCamera(sp<VirtualCamera>& virtualCamera); 80 void disownVirtualCamera(const VirtualCamera* virtualCamera); 81 82 // Implementation details getHwCamera()83 sp<IEvsCamera_1_0> getHwCamera() { return mHwCamera; }; getClientCount()84 unsigned getClientCount() { return mClients.size(); }; getId()85 std::string getId() { return mId; } getStreamConfig()86 Stream& getStreamConfig() { return mStreamConfig; } 87 bool changeFramesInFlight(int delta); 88 bool changeFramesInFlight(const hardware::hidl_vec<BufferDesc_1_1>& buffers, 89 int* delta); 90 void requestNewFrame(sp<VirtualCamera> virtualCamera, 91 const int64_t timestamp); 92 93 Return<EvsResult> clientStreamStarting(); 94 void clientStreamEnding(const VirtualCamera* client); 95 Return<void> doneWithFrame(const BufferDesc_1_0& buffer); 96 Return<void> doneWithFrame(const BufferDesc_1_1& buffer); 97 Return<EvsResult> setMaster(sp<VirtualCamera> virtualCamera); 98 Return<EvsResult> forceMaster(sp<VirtualCamera> virtualCamera); 99 Return<EvsResult> unsetMaster(const VirtualCamera* virtualCamera); 100 Return<EvsResult> setParameter(sp<VirtualCamera> virtualCamera, 101 CameraParam id, int32_t& value); 102 Return<EvsResult> getParameter(CameraParam id, int32_t& value); 103 104 // Returns a snapshot of collected usage statistics 105 CameraUsageStatsRecord getStats() const; 106 107 // Returns active stream configuration 108 Stream getStreamConfiguration() const; 109 110 // Returns a string showing the current status 111 std::string toString(const char* indent = "") const; 112 113 // Returns a string showing current stream configuration 114 static std::string toString(Stream configuration, const char* indent = ""); 115 116 // Methods from ::android::hardware::automotive::evs::V1_0::IEvsCameraStream follow. 117 Return<void> deliverFrame(const BufferDesc_1_0& buffer) override; 118 119 // Methods from ::android::hardware::automotive::evs::V1_1::IEvsCameraStream follow. 120 Return<void> deliverFrame_1_1(const hardware::hidl_vec<BufferDesc_1_1>& buffer) override; 121 Return<void> notify(const EvsEventDesc& event) override; 122 123 private: 124 sp<IEvsCamera_1_1> mHwCamera; 125 std::list<wp<VirtualCamera>> mClients; // Weak pointers -> objects destruct if client dies 126 127 enum { 128 STOPPED, 129 RUNNING, 130 STOPPING, 131 } mStreamState = STOPPED; 132 133 struct FrameRecord { 134 uint32_t frameId; 135 uint32_t refCount; FrameRecordFrameRecord136 FrameRecord(uint32_t id) : frameId(id), refCount(0) {}; 137 }; 138 std::vector<FrameRecord> mFrames; 139 wp<VirtualCamera> mPrimaryClient = nullptr; 140 std::string mId; 141 Stream mStreamConfig; 142 143 struct FrameRequest { 144 wp<VirtualCamera> client = nullptr; 145 int64_t timestamp = -1; 146 }; 147 148 void cancelCaptureRequestFromClientLocked(std::deque<FrameRequest>* requests, 149 const VirtualCamera* client) REQUIRES(mFrameMutex); 150 151 // synchronization 152 mutable std::mutex mFrameMutex; 153 std::deque<FrameRequest> mFrameRequests[2] GUARDED_BY(mFrameMutex); 154 std::deque<FrameRequest>* mCurrentRequests PT_GUARDED_BY(mFrameMutex); 155 std::deque<FrameRequest>* mNextRequests PT_GUARDED_BY(mFrameMutex); 156 157 // Time this object was created 158 int64_t mTimeCreatedMs; 159 160 // usage statistics to collect 161 android::sp<CameraUsageStats> mUsageStats; 162 }; 163 164 } // namespace implementation 165 } // namespace V1_1 166 } // namespace evs 167 } // namespace automotive 168 } // namespace android 169 170 #endif // ANDROID_AUTOMOTIVE_EVS_V1_1_HALCAMERA_H 171