ZslProcessor3.h revision f0d962a6737eb8eec002d6804d9ffbe7bee672a0
1/* 2 * Copyright (C) 2013 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_SERVERS_CAMERA_CAMERA2_ZSLPROCESSOR3_H 18#define ANDROID_SERVERS_CAMERA_CAMERA2_ZSLPROCESSOR3_H 19 20#include <utils/Thread.h> 21#include <utils/String16.h> 22#include <utils/Vector.h> 23#include <utils/Mutex.h> 24#include <utils/Condition.h> 25#include <gui/BufferItemConsumer.h> 26#include <camera/CameraMetadata.h> 27 28#include "api1/client2/FrameProcessor.h" 29#include "api1/client2/ZslProcessorInterface.h" 30#include "device3/Camera3ZslStream.h" 31 32namespace android { 33 34class Camera2Client; 35 36namespace camera2 { 37 38class CaptureSequencer; 39class Parameters; 40 41/*** 42 * ZSL queue processing 43 */ 44class ZslProcessor3 : 45 public ZslProcessorInterface, 46 public camera3::Camera3StreamBufferListener, 47 virtual public Thread, 48 virtual public FrameProcessor::FilteredListener { 49 public: 50 ZslProcessor3(sp<Camera2Client> client, wp<CaptureSequencer> sequencer); 51 ~ZslProcessor3(); 52 53 // From FrameProcessor::FilteredListener 54 virtual void onResultAvailable(const CaptureResult &result); 55 56 /** 57 **************************************** 58 * ZslProcessorInterface implementation * 59 **************************************** 60 */ 61 62 virtual status_t updateStream(const Parameters ¶ms); 63 virtual status_t deleteStream(); 64 virtual int getStreamId() const; 65 66 virtual status_t pushToReprocess(int32_t requestId); 67 virtual status_t clearZslQueue(); 68 69 void dump(int fd, const Vector<String16>& args) const; 70 71 protected: 72 /** 73 ********************************************** 74 * Camera3StreamBufferListener implementation * 75 ********************************************** 76 */ 77 typedef camera3::Camera3StreamBufferListener::BufferInfo BufferInfo; 78 // Buffer was acquired by the HAL 79 virtual void onBufferAcquired(const BufferInfo& bufferInfo); 80 // Buffer was released by the HAL 81 virtual void onBufferReleased(const BufferInfo& bufferInfo); 82 83 private: 84 static const nsecs_t kWaitDuration = 10000000; // 10 ms 85 86 enum { 87 RUNNING, 88 LOCKED 89 } mState; 90 91 wp<Camera2Client> mClient; 92 wp<CaptureSequencer> mSequencer; 93 94 const int mId; 95 96 mutable Mutex mInputMutex; 97 98 enum { 99 NO_STREAM = -1 100 }; 101 102 int mZslStreamId; 103 sp<camera3::Camera3ZslStream> mZslStream; 104 105 struct ZslPair { 106 BufferItemConsumer::BufferItem buffer; 107 CameraMetadata frame; 108 }; 109 110 static const int32_t kDefaultMaxPipelineDepth = 4; 111 size_t mBufferQueueDepth; 112 size_t mFrameListDepth; 113 Vector<CameraMetadata> mFrameList; 114 size_t mFrameListHead; 115 116 ZslPair mNextPair; 117 118 Vector<ZslPair> mZslQueue; 119 size_t mZslQueueHead; 120 size_t mZslQueueTail; 121 122 CameraMetadata mLatestCapturedRequest; 123 124 virtual bool threadLoop(); 125 126 status_t clearZslQueueLocked(); 127 128 void clearZslResultQueueLocked(); 129 130 void dumpZslQueue(int id) const; 131 132 nsecs_t getCandidateTimestampLocked(size_t* metadataIdx) const; 133}; 134 135 136}; //namespace camera2 137}; //namespace android 138 139#endif 140