Fix refresh rate callback fan-out for choreographer am: c080030e71 (864d4803) · Commits · e / os / platform_frameworks_native

libs/gui/BitTube.cpp

+16 −0

Original line number	Diff line number	Diff line
		@@ -86,6 +86,10 @@ void BitTube::setReceiveFd(base::unique_fd&& receiveFd) {
		mReceiveFd = std::move(receiveFd);
		}

		void BitTube::setSendFd(base::unique_fd&& sendFd) {
		mSendFd = std::move(sendFd);
		}

		ssize_t BitTube::write(void const* vaddr, size_t size) {
		ssize_t err, len;
		do {
		@@ -115,6 +119,11 @@ status_t BitTube::writeToParcel(Parcel* reply) const {

		status_t result = reply->writeDupFileDescriptor(mReceiveFd);
		mReceiveFd.reset();
		if (result != NO_ERROR) {
		return result;
		}
		result = reply->writeDupFileDescriptor(mSendFd);
		mSendFd.reset();
		return result;
		}

		@@ -126,6 +135,13 @@ status_t BitTube::readFromParcel(const Parcel* parcel) {
		ALOGE("BitTube::readFromParcel: can't dup file descriptor (%s)", strerror(error));
		return -error;
		}
		mSendFd.reset(dup(parcel->readFileDescriptor()));
		if (mSendFd < 0) {
		mSendFd.reset();
		int error = errno;
		ALOGE("BitTube::readFromParcel: can't dup file descriptor (%s)", strerror(error));
		return -error;
		}
		return NO_ERROR;
		}

+6 −6

Original line number	Diff line number	Diff line
		@@ -89,12 +89,8 @@ status_t DisplayEventDispatcher::scheduleVsync() {
		return OK;
		}

		void DisplayEventDispatcher::requestLatestConfig() {
		status_t status = mReceiver.requestLatestConfig();
		if (status) {
		ALOGW("Failed enable config events, status=%d", status);
		return;
		}
		void DisplayEventDispatcher::injectEvent(const DisplayEventReceiver::Event& event) {
		mReceiver.sendEvents(&event, 1);
		}

		int DisplayEventDispatcher::getFd() const {
		@@ -157,6 +153,9 @@ bool DisplayEventDispatcher::processPendingEvents(nsecs_t* outTimestamp,
		dispatchConfigChanged(ev.header.timestamp, ev.header.displayId,
		ev.config.configId, ev.config.vsyncPeriod);
		break;
		case DisplayEventReceiver::DISPLAY_EVENT_NULL:
		dispatchNullEvent(ev.header.timestamp, ev.header.displayId);
		break;
		default:
		ALOGW("dispatcher %p ~ ignoring unknown event type %#x", this, ev.header.type);
		break;
		@@ -168,4 +167,5 @@ bool DisplayEventDispatcher::processPendingEvents(nsecs_t* outTimestamp,
		}
		return gotVsync;
		}

		} // namespace android

+4 −8

Original line number	Diff line number	Diff line
		@@ -79,14 +79,6 @@ status_t DisplayEventReceiver::requestNextVsync() {
		return NO_INIT;
		}

		status_t DisplayEventReceiver::requestLatestConfig() {
		if (mEventConnection != nullptr) {
		mEventConnection->requestLatestConfig();
		return NO_ERROR;
		}
		return NO_INIT;
		}

		ssize_t DisplayEventReceiver::getEvents(DisplayEventReceiver::Event* events,
		size_t count) {
		return DisplayEventReceiver::getEvents(mDataChannel.get(), events, count);
		@@ -98,6 +90,10 @@ ssize_t DisplayEventReceiver::getEvents(gui::BitTube* dataChannel,
		return gui::BitTube::recvObjects(dataChannel, events, count);
		}

		ssize_t DisplayEventReceiver::sendEvents(Event const* events, size_t count) {
		return DisplayEventReceiver::sendEvents(mDataChannel.get(), events, count);
		}

		ssize_t DisplayEventReceiver::sendEvents(gui::BitTube* dataChannel,
		Event const* events, size_t count)
		{

+1 −9

Original line number	Diff line number	Diff line
		@@ -26,8 +26,7 @@ enum class Tag : uint32_t {
		STEAL_RECEIVE_CHANNEL = IBinder::FIRST_CALL_TRANSACTION,
		SET_VSYNC_RATE,
		REQUEST_NEXT_VSYNC,
		REQUEST_LATEST_CONFIG,
		LAST = REQUEST_LATEST_CONFIG,
		LAST = REQUEST_NEXT_VSYNC,
		};

		} // Anonymous namespace
		@@ -54,11 +53,6 @@ public:
		callRemoteAsync<decltype(&IDisplayEventConnection::requestNextVsync)>(
		Tag::REQUEST_NEXT_VSYNC);
		}

		void requestLatestConfig() override {
		callRemoteAsync<decltype(&IDisplayEventConnection::requestLatestConfig)>(
		Tag::REQUEST_LATEST_CONFIG);
		}
		};

		// Out-of-line virtual method definition to trigger vtable emission in this translation unit (see
		@@ -80,8 +74,6 @@ status_t BnDisplayEventConnection::onTransact(uint32_t code, const Parcel& data,
		return callLocal(data, reply, &IDisplayEventConnection::setVsyncRate);
		case Tag::REQUEST_NEXT_VSYNC:
		return callLocalAsync(data, reply, &IDisplayEventConnection::requestNextVsync);
		case Tag::REQUEST_LATEST_CONFIG:
		return callLocalAsync(data, reply, &IDisplayEventConnection::requestLatestConfig);
		}
		}

+4 −1

Original line number	Diff line number	Diff line
		@@ -31,7 +31,7 @@ public:
		status_t initialize();
		void dispose();
		status_t scheduleVsync();
		void requestLatestConfig();
		void injectEvent(const DisplayEventReceiver::Event& event);
		int getFd() const;
		virtual int handleEvent(int receiveFd, int events, void* data);

		@@ -48,6 +48,9 @@ private:
		bool connected) = 0;
		virtual void dispatchConfigChanged(nsecs_t timestamp, PhysicalDisplayId displayId,
		int32_t configId, nsecs_t vsyncPeriod) = 0;
		// AChoreographer-specific hook for processing null-events so that looper
		// can be properly poked.
		virtual void dispatchNullEvent(nsecs_t timestamp, PhysicalDisplayId displayId) = 0;

		bool processPendingEvents(nsecs_t* outTimestamp, PhysicalDisplayId* outDisplayId,
		uint32_t* outCount);