Snap for 6279178 from 1e420429fd585309d5611919393defa639b564aa to rvc-release (b5b96382) · Commits · e / os / android_frameworks_av

media/codec2/components/vorbis/Android.bp

+1 −1

Original line number	Diff line number	Diff line
		@@ -7,5 +7,5 @@ cc_library_shared {

		srcs: ["C2SoftVorbisDec.cpp"],

		shared_libs: ["libvorbisidec"],
		static_libs: ["libvorbisidec"],
		}

media/libmedia/aidl/android/media/IResourceManagerService.aidl

+8 −0

Original line number	Diff line number	Diff line
		@@ -94,4 +94,12 @@ interface IResourceManagerService {
		* remove existing override on originalPid if newPid is -1.
		*/
		void overridePid(int originalPid, int newPid);

		/**
		* Mark a client for pending removal
		*
		* @param pid pid from which the client's resources will be removed.
		* @param clientId clientId within the pid that will be removed.
		*/
		void markClientForPendingRemoval(int pid, long clientId);
		}

media/libstagefright/MediaCodec.cpp

+26 −1

Original line number	Diff line number	Diff line
		@@ -199,6 +199,7 @@ struct MediaCodec::ResourceManagerServiceProxy : public RefBase {
		void addResource(const MediaResourceParcel &resource);
		void removeResource(const MediaResourceParcel &resource);
		void removeClient();
		void markClientForPendingRemoval();
		bool reclaimResource(const std::vector<MediaResourceParcel> &resources);

		private:
		@@ -280,6 +281,14 @@ void MediaCodec::ResourceManagerServiceProxy::removeClient() {
		mService->removeClient(mPid, getId(mClient));
		}

		void MediaCodec::ResourceManagerServiceProxy::markClientForPendingRemoval() {
		Mutex::Autolock _l(mLock);
		if (mService == nullptr) {
		return;
		}
		mService->markClientForPendingRemoval(mPid, getId(mClient));
		}

		bool MediaCodec::ResourceManagerServiceProxy::reclaimResource(
		const std::vector<MediaResourceParcel> &resources) {
		Mutex::Autolock _l(mLock);
		@@ -1432,7 +1441,13 @@ status_t MediaCodec::reclaim(bool force) {

		status_t MediaCodec::release() {
		sp<AMessage> msg = new AMessage(kWhatRelease, this);
		sp<AMessage> response;
		return PostAndAwaitResponse(msg, &response);
		}

		status_t MediaCodec::releaseAsync() {
		sp<AMessage> msg = new AMessage(kWhatRelease, this);
		msg->setInt32("async", 1);
		sp<AMessage> response;
		return PostAndAwaitResponse(msg, &response);
		}
		@@ -2600,7 +2615,9 @@ void MediaCodec::onMessageReceived(const sp<AMessage> &msg) {

		mResourceManagerProxy->removeClient();

		if (mReplyID != nullptr) {
		(new AMessage)->postReply(mReplyID);
		}
		break;
		}

		@@ -2999,6 +3016,14 @@ void MediaCodec::onMessageReceived(const sp<AMessage> &msg) {
		pushBlankBuffersToNativeWindow(mSurface.get());
		}

		int32_t async = 0;
		if (msg->findInt32("async", &async) && async) {
		mResourceManagerProxy->markClientForPendingRemoval();
		handleSetSurface(NULL);
		(new AMessage)->postReply(mReplyID);
		mReplyID = 0;
		}

		break;
		}

media/libstagefright/include/media/stagefright/MediaCodec.h

+2 −0

Original line number	Diff line number	Diff line
		@@ -139,6 +139,8 @@ struct MediaCodec : public AHandler {
		// object.
		status_t release();

		status_t releaseAsync();

		status_t flush();

		status_t queueInputBuffer(

services/mediaresourcemanager/ResourceManagerService.cpp

+42 −1

Original line number	Diff line number	Diff line
		@@ -114,6 +114,7 @@ static ResourceInfo& getResourceInfoForEdit(
		info.uid = uid;
		info.clientId = clientId;
		info.client = client;
		info.pendingRemoval = false;

		index = infos.add(clientId, info);
		}
		@@ -648,6 +649,36 @@ Status ResourceManagerService::overridePid(
		return Status::ok();
		}

		Status ResourceManagerService::markClientForPendingRemoval(int32_t pid, int64_t clientId) {
		String8 log = String8::format(
		"markClientForPendingRemoval(pid %d, clientId %lld)",
		pid, (long long) clientId);
		mServiceLog->add(log);

		Mutex::Autolock lock(mLock);
		if (!mProcessInfo->isValidPid(pid)) {
		ALOGE("Rejected markClientForPendingRemoval call with invalid pid.");
		return Status::fromServiceSpecificError(BAD_VALUE);
		}
		ssize_t index = mMap.indexOfKey(pid);
		if (index < 0) {
		ALOGV("markClientForPendingRemoval: didn't find pid %d for clientId %lld",
		pid, (long long)clientId);
		return Status::ok();
		}
		ResourceInfos &infos = mMap.editValueAt(index);

		index = infos.indexOfKey(clientId);
		if (index < 0) {
		ALOGV("markClientForPendingRemoval: didn't find clientId %lld", (long long) clientId);
		return Status::ok();
		}

		ResourceInfo &info = infos.editValueAt(index);
		info.pendingRemoval = true;
		return Status::ok();
		}

		bool ResourceManagerService::getPriority_l(int pid, int* priority) {
		int newPid = pid;

		@@ -693,6 +724,12 @@ bool ResourceManagerService::getLowestPriorityBiggestClient_l(
		int lowestPriorityPid;
		int lowestPriority;
		int callingPriority;

		// Before looking into other processes, check if we have clients marked for
		// pending removal in the same process.
		if (getBiggestClient_l(callingPid, type, client, true /* pendingRemovalOnly */)) {
		return true;
		}
		if (!getPriority_l(callingPid, &callingPriority)) {
		ALOGE("getLowestPriorityBiggestClient_l: can't get process priority for pid %d",
		callingPid);
		@@ -761,7 +798,8 @@ bool ResourceManagerService::isCallingPriorityHigher_l(int callingPid, int pid)
		}

		bool ResourceManagerService::getBiggestClient_l(
		int pid, MediaResource::Type type, std::shared_ptr<IResourceManagerClient> *client) {
		int pid, MediaResource::Type type, std::shared_ptr<IResourceManagerClient> *client,
		bool pendingRemovalOnly) {
		ssize_t index = mMap.indexOfKey(pid);
		if (index < 0) {
		ALOGE("getBiggestClient_l: can't find resource info for pid %d", pid);
		@@ -773,6 +811,9 @@ bool ResourceManagerService::getBiggestClient_l(
		const ResourceInfos &infos = mMap.valueAt(index);
		for (size_t i = 0; i < infos.size(); ++i) {
		const ResourceList &resources = infos[i].resources;
		if (pendingRemovalOnly && !infos[i].pendingRemoval) {
		continue;
		}
		for (auto it = resources.begin(); it != resources.end(); it++) {
		const MediaResourceParcel &resource = it->second;
		if (resource.type == type) {