blob: 5aa9a3e6dc958987907b955b41e67156ff7fefdd [file] [log] [blame]
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -08001/*
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#define LOG_TAG "Camera3-InputStream"
18#define ATRACE_TAG ATRACE_TAG_CAMERA
19//#define LOG_NDEBUG 0
20
21#include <utils/Log.h>
22#include <utils/Trace.h>
23#include "Camera3InputStream.h"
24
25namespace android {
26
27namespace camera3 {
28
29Camera3InputStream::Camera3InputStream(int id,
30 uint32_t width, uint32_t height, int format) :
Igor Murashkinae3d0ba2013-05-08 18:03:15 -070031 Camera3IOStreamBase(id, CAMERA3_STREAM_INPUT, width, height,
32 /*maxSize*/0, format) {
Igor Murashkin0776a142013-04-15 14:59:22 -070033
34 if (format == HAL_PIXEL_FORMAT_BLOB) {
35 ALOGE("%s: Bad format, BLOB not supported", __FUNCTION__);
36 mState = STATE_ERROR;
37 }
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -080038}
39
Igor Murashkin0776a142013-04-15 14:59:22 -070040Camera3InputStream::~Camera3InputStream() {
41 disconnectLocked();
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -080042}
43
Igor Murashkin0776a142013-04-15 14:59:22 -070044status_t Camera3InputStream::getInputBufferLocked(
45 camera3_stream_buffer *buffer) {
46 ATRACE_CALL();
47 status_t res;
48
49 // FIXME: will not work in (re-)registration
50 if (mState == STATE_IN_CONFIG || mState == STATE_IN_RECONFIG) {
51 ALOGE("%s: Stream %d: Buffer registration for input streams"
52 " not implemented (state %d)",
53 __FUNCTION__, mId, mState);
54 return INVALID_OPERATION;
55 }
56
Igor Murashkinae3d0ba2013-05-08 18:03:15 -070057 if ((res = getBufferPreconditionCheckLocked()) != OK) {
58 return res;
Igor Murashkin0776a142013-04-15 14:59:22 -070059 }
60
61 ANativeWindowBuffer* anb;
62 int fenceFd;
63
64 assert(mConsumer != 0);
65
66 BufferItem bufferItem;
67 res = mConsumer->acquireBuffer(&bufferItem, /*waitForFence*/false);
68
69 if (res != OK) {
70 ALOGE("%s: Stream %d: Can't acquire next output buffer: %s (%d)",
71 __FUNCTION__, mId, strerror(-res), res);
72 return res;
73 }
74
75 anb = bufferItem.mGraphicBuffer->getNativeBuffer();
76 assert(anb != NULL);
77 fenceFd = bufferItem.mFence->dup();
Igor Murashkinae3d0ba2013-05-08 18:03:15 -070078
Igor Murashkin0776a142013-04-15 14:59:22 -070079 /**
80 * FenceFD now owned by HAL except in case of error,
81 * in which case we reassign it to acquire_fence
82 */
Igor Murashkinae3d0ba2013-05-08 18:03:15 -070083 handoutBufferLocked(*buffer, &(anb->handle), /*acquireFence*/fenceFd,
84 /*releaseFence*/-1, CAMERA3_BUFFER_STATUS_OK);
Igor Murashkin0776a142013-04-15 14:59:22 -070085 mBuffersInFlight.push_back(bufferItem);
86
87 return OK;
88}
89
Igor Murashkinae3d0ba2013-05-08 18:03:15 -070090status_t Camera3InputStream::returnBufferCheckedLocked(
91 const camera3_stream_buffer &buffer,
92 nsecs_t timestamp,
93 bool output,
94 /*out*/
95 sp<Fence> *releaseFenceOut) {
96
97 (void)timestamp;
98 (void)output;
99 ALOG_ASSERT(!output, "Expected output to be false");
100
Igor Murashkin0776a142013-04-15 14:59:22 -0700101 status_t res;
102
Igor Murashkin0776a142013-04-15 14:59:22 -0700103 bool bufferFound = false;
104 BufferItem bufferItem;
105 {
106 // Find the buffer we are returning
107 Vector<BufferItem>::iterator it, end;
108 for (it = mBuffersInFlight.begin(), end = mBuffersInFlight.end();
109 it != end;
110 ++it) {
111
112 const BufferItem& tmp = *it;
113 ANativeWindowBuffer *anb = tmp.mGraphicBuffer->getNativeBuffer();
114 if (anb != NULL && &(anb->handle) == buffer.buffer) {
115 bufferFound = true;
116 bufferItem = tmp;
117 mBuffersInFlight.erase(it);
Igor Murashkin0776a142013-04-15 14:59:22 -0700118 }
119 }
120 }
121 if (!bufferFound) {
122 ALOGE("%s: Stream %d: Can't return buffer that wasn't sent to HAL",
123 __FUNCTION__, mId);
124 return INVALID_OPERATION;
125 }
126
127 if (buffer.status == CAMERA3_BUFFER_STATUS_ERROR) {
128 if (buffer.release_fence != -1) {
129 ALOGE("%s: Stream %d: HAL should not set release_fence(%d) when "
130 "there is an error", __FUNCTION__, mId, buffer.release_fence);
131 close(buffer.release_fence);
132 }
133
134 /**
135 * Reassign release fence as the acquire fence incase of error
136 */
137 const_cast<camera3_stream_buffer*>(&buffer)->release_fence =
138 buffer.acquire_fence;
139 }
140
141 /**
142 * Unconditionally return buffer to the buffer queue.
143 * - Fwk takes over the release_fence ownership
144 */
145 sp<Fence> releaseFence = new Fence(buffer.release_fence);
146 res = mConsumer->releaseBuffer(bufferItem, releaseFence);
147 if (res != OK) {
148 ALOGE("%s: Stream %d: Error releasing buffer back to buffer queue:"
149 " %s (%d)", __FUNCTION__, mId, strerror(-res), res);
Igor Murashkin0776a142013-04-15 14:59:22 -0700150 }
151
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700152 *releaseFenceOut = releaseFence;
Igor Murashkin0776a142013-04-15 14:59:22 -0700153
Eino-Ville Talvalaf1e98d82013-09-06 09:32:43 -0700154 return res;
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800155}
156
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700157status_t Camera3InputStream::returnInputBufferLocked(
158 const camera3_stream_buffer &buffer) {
159 ATRACE_CALL();
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800160
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700161 return returnAnyBufferLocked(buffer, /*timestamp*/0, /*output*/false);
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800162}
163
164status_t Camera3InputStream::disconnectLocked() {
Igor Murashkin0776a142013-04-15 14:59:22 -0700165
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700166 status_t res;
167
168 if ((res = Camera3IOStreamBase::disconnectLocked()) != OK) {
169 return res;
Igor Murashkin0776a142013-04-15 14:59:22 -0700170 }
171
172 assert(mBuffersInFlight.size() == 0);
173
174 /**
175 * no-op since we can't disconnect the producer from the consumer-side
176 */
177
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700178 mState = (mState == STATE_IN_RECONFIG) ? STATE_IN_CONFIG
179 : STATE_CONSTRUCTED;
Igor Murashkin0776a142013-04-15 14:59:22 -0700180 return OK;
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800181}
182
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800183void Camera3InputStream::dump(int fd, const Vector<String16> &args) const {
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800184 (void) args;
Igor Murashkin0776a142013-04-15 14:59:22 -0700185 String8 lines;
186 lines.appendFormat(" Stream[%d]: Input\n", mId);
Igor Murashkin0776a142013-04-15 14:59:22 -0700187 write(fd, lines.string(), lines.size());
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700188
189 Camera3IOStreamBase::dump(fd, args);
Igor Murashkin0776a142013-04-15 14:59:22 -0700190}
191
192status_t Camera3InputStream::configureQueueLocked() {
193 status_t res;
194
Igor Murashkinae3d0ba2013-05-08 18:03:15 -0700195 if ((res = Camera3IOStreamBase::configureQueueLocked()) != OK) {
196 return res;
Igor Murashkin0776a142013-04-15 14:59:22 -0700197 }
198
199 assert(mMaxSize == 0);
200 assert(camera3_stream::format != HAL_PIXEL_FORMAT_BLOB);
201
202 mTotalBufferCount = BufferQueue::MIN_UNDEQUEUED_BUFFERS +
203 camera3_stream::max_buffers;
204 mDequeuedBufferCount = 0;
205 mFrameCount = 0;
206
207 if (mConsumer.get() == 0) {
Mathias Agopian8d764bf2013-07-12 22:06:20 -0700208 sp<BufferQueue> bq = new BufferQueue();
209 mConsumer = new BufferItemConsumer(bq, camera3_stream::usage,
Mathias Agopian5e1f08b2013-07-16 22:54:39 -0700210 mTotalBufferCount);
Igor Murashkin0776a142013-04-15 14:59:22 -0700211 mConsumer->setName(String8::format("Camera3-InputStream-%d", mId));
212 }
213
214 res = mConsumer->setDefaultBufferSize(camera3_stream::width,
215 camera3_stream::height);
216 if (res != OK) {
217 ALOGE("%s: Stream %d: Could not set buffer dimensions %dx%d",
218 __FUNCTION__, mId, camera3_stream::width, camera3_stream::height);
219 return res;
220 }
221 res = mConsumer->setDefaultBufferFormat(camera3_stream::format);
222 if (res != OK) {
223 ALOGE("%s: Stream %d: Could not set buffer format %d",
224 __FUNCTION__, mId, camera3_stream::format);
225 return res;
226 }
227
228 return OK;
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800229}
230
Eino-Ville Talvalab2f5b192013-07-30 14:36:03 -0700231status_t Camera3InputStream::getEndpointUsage(uint32_t *usage) {
232 // Per HAL3 spec, input streams have 0 for their initial usage field.
233 *usage = 0;
234 return OK;
235}
236
Eino-Ville Talvala8be20f52013-03-06 16:20:06 -0800237}; // namespace camera3
238
239}; // namespace android