Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 903d0981 authored by Bart Van Assche's avatar Bart Van Assche Committed by Automerger Merge Worker
Browse files

libhealthloop: Handle netlink receive buffer overflows am: 0cfcfac1

parents 78e3718e 0cfcfac1
Loading
Loading
Loading
Loading
+11 −6
Original line number Diff line number Diff line
@@ -57,14 +57,13 @@ int HealthLoop::RegisterEvent(int fd, BoundFunction func, EventWakeup wakeup) {
                                          EventHandler{this, fd, std::move(func)}))
                                  .get();

    struct epoll_event ev;

    ev.events = EPOLLIN;
    struct epoll_event ev = {
            .events = EPOLLIN | EPOLLERR,
            .data.ptr = reinterpret_cast<void*>(event_handler),
    };

    if (wakeup == EVENT_WAKEUP_FD) ev.events |= EPOLLWAKEUP;

    ev.data.ptr = reinterpret_cast<void*>(event_handler);

    if (epoll_ctl(epollfd_, EPOLL_CTL_ADD, fd, &ev) == -1) {
        KLOG_ERROR(LOG_TAG, "epoll_ctl failed; errno=%d\n", errno);
        return -1;
@@ -119,9 +118,15 @@ void HealthLoop::PeriodicChores() {

// TODO(b/140330870): Use BPF instead.
#define UEVENT_MSG_LEN 2048
void HealthLoop::UeventEvent(uint32_t /*epevents*/) {
void HealthLoop::UeventEvent(uint32_t epevents) {
    // No need to lock because uevent_fd_ is guaranteed to be initialized.

    if (epevents & EPOLLERR) {
        // The netlink receive buffer overflowed.
        ScheduleBatteryUpdate();
        return;
    }

    char msg[UEVENT_MSG_LEN + 2];
    char* cp;
    int n;