Loading core/java/android/os/CombinedMessageQueue/MessageQueue.java +20 −7 Original line number Diff line number Diff line Loading @@ -426,6 +426,18 @@ public final class MessageQueue { // Update the file descriptor record if the listener changed the set of // events to watch and the listener itself hasn't been updated since. if (newWatchedEvents != oldWatchedEvents) { if (mUseConcurrent) { synchronized (mFileDescriptorRecordsLock) { int index = mFileDescriptorRecords.indexOfKey(fd); if (index >= 0 && mFileDescriptorRecords.valueAt(index) == record && record.mSeq == seq) { record.mEvents = newWatchedEvents; if (newWatchedEvents == 0) { mFileDescriptorRecords.removeAt(index); } } } } else { synchronized (this) { int index = mFileDescriptorRecords.indexOfKey(fd); if (index >= 0 && mFileDescriptorRecords.valueAt(index) == record Loading @@ -437,6 +449,7 @@ public final class MessageQueue { } } } } // Return the new set of events to watch for native code to take care of. return newWatchedEvents; Loading Loading
core/java/android/os/CombinedMessageQueue/MessageQueue.java +20 −7 Original line number Diff line number Diff line Loading @@ -426,6 +426,18 @@ public final class MessageQueue { // Update the file descriptor record if the listener changed the set of // events to watch and the listener itself hasn't been updated since. if (newWatchedEvents != oldWatchedEvents) { if (mUseConcurrent) { synchronized (mFileDescriptorRecordsLock) { int index = mFileDescriptorRecords.indexOfKey(fd); if (index >= 0 && mFileDescriptorRecords.valueAt(index) == record && record.mSeq == seq) { record.mEvents = newWatchedEvents; if (newWatchedEvents == 0) { mFileDescriptorRecords.removeAt(index); } } } } else { synchronized (this) { int index = mFileDescriptorRecords.indexOfKey(fd); if (index >= 0 && mFileDescriptorRecords.valueAt(index) == record Loading @@ -437,6 +449,7 @@ public final class MessageQueue { } } } } // Return the new set of events to watch for native code to take care of. return newWatchedEvents; Loading