Merge "Camera: clear buffer cache when stream is reconfigured" into qt-dev (7906c289) · Commits · e / os / android_frameworks_av

services/camera/libcameraservice/device3/Camera3Device.cpp

+37 −22

Original line number	Diff line number	Diff line
		@@ -2522,6 +2522,9 @@ status_t Camera3Device::setConsumerSurfaces(int streamId,
		CLOGE("Stream %d is unknown", streamId);
		return BAD_VALUE;
		}

		// isConsumerConfigurationDeferred will be off after setConsumers
		bool isDeferred = stream->isConsumerConfigurationDeferred();
		status_t res = stream->setConsumers(consumers);
		if (res != OK) {
		CLOGE("Stream %d set consumer failed (error %d %s) ", streamId, res, strerror(-res));
		@@ -2537,7 +2540,7 @@ status_t Camera3Device::setConsumerSurfaces(int streamId,
		surfaceIds->push_back(id);
		}

		if (stream->isConsumerConfigurationDeferred()) {
		if (isDeferred) {
		if (!stream->isConfiguring()) {
		CLOGE("Stream %d was already fully configured.", streamId);
		return INVALID_OPERATION;
		@@ -2612,7 +2615,6 @@ status_t Camera3Device::dropStreamBuffers(bool dropping, int streamId) {
		sp<Camera3Device::CaptureRequest> Camera3Device::createCaptureRequest(
		const PhysicalCameraSettingsList &request, const SurfaceMap &surfaceMap) {
		ATRACE_CALL();
		status_t res;

		sp<CaptureRequest> newRequest = new CaptureRequest;
		newRequest->mSettingsList = request;
		@@ -2626,17 +2628,12 @@ sp<Camera3Device::CaptureRequest> Camera3Device::createCaptureRequest(
		inputStreams.data.u8[0]);
		return NULL;
		}
		// Lazy completion of stream configuration (allocation/registration)
		// on first use

		if (mInputStream->isConfiguring()) {
		res = mInputStream->finishConfiguration();
		if (res != OK) {
		SET_ERR_L("Unable to finish configuring input stream %d:"
		" %s (%d)",
		mInputStream->getId(), strerror(-res), res);
		SET_ERR_L("%s: input stream %d is not configured!",
		__FUNCTION__, mInputStream->getId());
		return NULL;
		}
		}
		// Check if stream prepare is blocking requests.
		if (mInputStream->isBlockedByPrepare()) {
		CLOGE("Request references an input stream that's being prepared!");
		@@ -2675,16 +2672,10 @@ sp<Camera3Device::CaptureRequest> Camera3Device::createCaptureRequest(
		newRequest->mOutputSurfaces[streams.data.i32[i]] = surfaces;
		}

		// Lazy completion of stream configuration (allocation/registration)
		// on first use
		if (stream->isConfiguring()) {
		res = stream->finishConfiguration();
		if (res != OK) {
		SET_ERR_L("Unable to finish configuring stream %d: %s (%d)",
		stream->getId(), strerror(-res), res);
		SET_ERR_L("%s: stream %d is not configured!", __FUNCTION__, stream->getId());
		return NULL;
		}
		}
		// Check if stream prepare is blocking requests.
		if (stream->isBlockedByPrepare()) {
		CLOGE("Request references an output stream that's being prepared!");
		@@ -2908,7 +2899,8 @@ status_t Camera3Device::configureStreamsLocked(int operatingMode,
		// faster

		if (mInputStream != NULL && mInputStream->isConfiguring()) {
		res = mInputStream->finishConfiguration();
		bool streamReConfigured = false;
		res = mInputStream->finishConfiguration(&streamReConfigured);
		if (res != OK) {
		CLOGE("Can't finish configuring input stream %d: %s (%d)",
		mInputStream->getId(), strerror(-res), res);
		@@ -2918,12 +2910,16 @@ status_t Camera3Device::configureStreamsLocked(int operatingMode,
		}
		return BAD_VALUE;
		}
		if (streamReConfigured) {
		mInterface->onStreamReConfigured(mInputStream->getId());
		}
		}

		for (size_t i = 0; i < mOutputStreams.size(); i++) {
		sp<Camera3OutputStreamInterface> outputStream = mOutputStreams[i];
		if (outputStream->isConfiguring() && !outputStream->isConsumerConfigurationDeferred()) {
		res = outputStream->finishConfiguration();
		bool streamReConfigured = false;
		res = outputStream->finishConfiguration(&streamReConfigured);
		if (res != OK) {
		CLOGE("Can't finish configuring output stream %d: %s (%d)",
		outputStream->getId(), strerror(-res), res);
		@@ -2933,6 +2929,9 @@ status_t Camera3Device::configureStreamsLocked(int operatingMode,
		}
		return BAD_VALUE;
		}
		if (streamReConfigured) {
		mInterface->onStreamReConfigured(outputStream->getId());
		}
		}
		}

		@@ -4788,6 +4787,22 @@ void Camera3Device::HalInterface::onBufferFreed(
		mFreedBuffers.push_back(std::make_pair(streamId, bufferId));
		}

		void Camera3Device::HalInterface::onStreamReConfigured(int streamId) {
		std::lock_guard<std::mutex> lock(mBufferIdMapLock);
		auto mapIt = mBufferIdMaps.find(streamId);
		if (mapIt == mBufferIdMaps.end()) {
		ALOGE("%s: streamId %d not found!", __FUNCTION__, streamId);
		return;
		}

		BufferIdMap& bIdMap = mapIt->second;
		for (const auto& it : bIdMap) {
		uint64_t bufferId = it.second;
		mFreedBuffers.push_back(std::make_pair(streamId, bufferId));
		}
		bIdMap.clear();
		}

		/**
		* RequestThread inner class methods
		*/

services/camera/libcameraservice/device3/Camera3Device.h

+2 −0

Original line number	Diff line number	Diff line
		@@ -336,6 +336,8 @@ class Camera3Device :
		// Get a vector of bufferId of currently inflight buffers
		void getInflightRequestBufferKeys(std::vector<uint64_t>* out);

		void onStreamReConfigured(int streamId);

		static const uint64_t BUFFER_ID_NO_BUFFER = 0;
		private:
		// Always valid

services/camera/libcameraservice/device3/Camera3Stream.cpp

+9 −2

Original line number	Diff line number	Diff line
		@@ -287,8 +287,11 @@ bool Camera3Stream::isConfiguring() const {
		return (mState == STATE_IN_CONFIG) \|\| (mState == STATE_IN_RECONFIG);
		}

		status_t Camera3Stream::finishConfiguration() {
		status_t Camera3Stream::finishConfiguration(/out/bool* streamReconfigured) {
		ATRACE_CALL();
		if (streamReconfigured != nullptr) {
		*streamReconfigured = false;
		}
		Mutex::Autolock l(mLock);
		switch (mState) {
		case STATE_ERROR:
		@@ -313,7 +316,7 @@ status_t Camera3Stream::finishConfiguration() {

		// Register for idle tracking
		sp<StatusTracker> statusTracker = mStatusTracker.promote();
		if (statusTracker != 0) {
		if (statusTracker != 0 && mStatusId == StatusTracker::NO_STATUS_ID) {
		mStatusId = statusTracker->addComponent();
		}

		@@ -332,6 +335,7 @@ status_t Camera3Stream::finishConfiguration() {
		mPrepareBlockRequest = true;
		mStreamUnpreparable = false;

		bool reconfiguring = (mState == STATE_IN_RECONFIG);
		status_t res;
		res = configureQueueLocked();
		// configureQueueLocked could return error in case of abandoned surface.
		@@ -348,6 +352,9 @@ status_t Camera3Stream::finishConfiguration() {
		return res;
		}

		if (reconfiguring && streamReconfigured != nullptr) {
		*streamReconfigured = true;
		}
		mState = STATE_CONFIGURED;

		return res;

services/camera/libcameraservice/device3/Camera3Stream.h

+3 −1

Original line number	Diff line number	Diff line
		@@ -197,6 +197,8 @@ class Camera3Stream :
		* after this call, but can still be read until the destruction of the
		* stream.
		*
		* streamReconfigured: set to true when a stream is being reconfigured.
		*
		* Returns:
		* OK on a successful configuration
		* NO_INIT in case of a serious error from the HAL device
		@@ -204,7 +206,7 @@ class Camera3Stream :
		* INVALID_OPERATION in case connecting to the consumer failed or consumer
		* doesn't exist yet.
		*/
		status_t finishConfiguration();
		status_t finishConfiguration(/out/bool* streamReconfigured = nullptr);

		/**
		* Cancels the stream configuration process. This returns the stream to the

services/camera/libcameraservice/device3/Camera3StreamInterface.h

+3 −1

Original line number	Diff line number	Diff line
		@@ -130,13 +130,15 @@ class Camera3StreamInterface : public virtual RefBase {
		* modified after this call, but can still be read until the destruction of
		* the stream.
		*
		* streamReconfigured: set to true when a stream is being reconfigured.
		*
		* Returns:
		* OK on a successful configuration
		* NO_INIT in case of a serious error from the HAL device
		* NO_MEMORY in case of an error registering buffers
		* INVALID_OPERATION in case connecting to the consumer failed
		*/
		virtual status_t finishConfiguration() = 0;
		virtual status_t finishConfiguration(/out/bool* streamReconfigured = nullptr) = 0;

		/**
		* Cancels the stream configuration process. This returns the stream to the