Support looper callbacks based on smart pointers.
Bug: 6559630
Change-Id: I5a667f219f431838638acefbc9fa6afa610971bd
diff --git a/libs/utils/Looper.cpp b/libs/utils/Looper.cpp
index 9894993..a5e6645 100644
--- a/libs/utils/Looper.cpp
+++ b/libs/utils/Looper.cpp
@@ -30,6 +30,9 @@
mHandler(handler) {
}
+WeakMessageHandler::~WeakMessageHandler() {
+}
+
void WeakMessageHandler::handleMessage(const Message& message) {
sp<MessageHandler> handler = mHandler.promote();
if (handler != NULL) {
@@ -38,6 +41,20 @@
}
+// --- SimpleLooperCallback ---
+
+SimpleLooperCallback::SimpleLooperCallback(ALooper_callbackFunc callback) :
+ mCallback(callback) {
+}
+
+SimpleLooperCallback::~SimpleLooperCallback() {
+}
+
+int SimpleLooperCallback::handleEvent(int fd, int events, void* data) {
+ return mCallback(fd, events, data);
+}
+
+
// --- Looper ---
// Hint for number of file descriptors to be associated with the epoll instance.
@@ -142,9 +159,8 @@
for (;;) {
while (mResponseIndex < mResponses.size()) {
const Response& response = mResponses.itemAt(mResponseIndex++);
- ALooper_callbackFunc callback = response.request.callback;
- if (!callback) {
- int ident = response.request.ident;
+ int ident = response.request.ident;
+ if (ident >= 0) {
int fd = response.request.fd;
int events = response.events;
void* data = response.request.data;
@@ -165,7 +181,7 @@
ALOGD("%p ~ pollOnce - returning result %d", this, result);
#endif
if (outFd != NULL) *outFd = 0;
- if (outEvents != NULL) *outEvents = NULL;
+ if (outEvents != NULL) *outEvents = 0;
if (outData != NULL) *outData = NULL;
return result;
}
@@ -293,20 +309,22 @@
// Invoke all response callbacks.
for (size_t i = 0; i < mResponses.size(); i++) {
- const Response& response = mResponses.itemAt(i);
- ALooper_callbackFunc callback = response.request.callback;
- if (callback) {
+ Response& response = mResponses.editItemAt(i);
+ if (response.request.ident == ALOOPER_POLL_CALLBACK) {
int fd = response.request.fd;
int events = response.events;
void* data = response.request.data;
#if DEBUG_POLL_AND_WAKE || DEBUG_CALLBACKS
ALOGD("%p ~ pollOnce - invoking fd event callback %p: fd=%d, events=0x%x, data=%p",
- this, callback, fd, events, data);
+ this, response.request.callback.get(), fd, events, data);
#endif
- int callbackResult = callback(fd, events, data);
+ int callbackResult = response.request.callback->handleEvent(fd, events, data);
if (callbackResult == 0) {
removeFd(fd);
}
+ // Clear the callback reference in the response structure promptly because we
+ // will not clear the response vector itself until the next poll.
+ response.request.callback.clear();
result = ALOOPER_POLL_CALLBACK;
}
}
@@ -376,21 +394,27 @@
}
int Looper::addFd(int fd, int ident, int events, ALooper_callbackFunc callback, void* data) {
+ return addFd(fd, ident, events, callback ? new SimpleLooperCallback(callback) : NULL, data);
+}
+
+int Looper::addFd(int fd, int ident, int events, const sp<LooperCallback>& callback, void* data) {
#if DEBUG_CALLBACKS
ALOGD("%p ~ addFd - fd=%d, ident=%d, events=0x%x, callback=%p, data=%p", this, fd, ident,
- events, callback, data);
+ events, callback.get(), data);
#endif
- if (! callback) {
+ if (!callback.get()) {
if (! mAllowNonCallbacks) {
ALOGE("Invalid attempt to set NULL callback but not allowed for this looper.");
return -1;
}
if (ident < 0) {
- ALOGE("Invalid attempt to set NULL callback with ident <= 0.");
+ ALOGE("Invalid attempt to set NULL callback with ident < 0.");
return -1;
}
+ } else {
+ ident = ALOOPER_POLL_CALLBACK;
}
int epollEvents = 0;