Method wait

source/kernel/kepoll.cpp:175–207

}

U32 KEPoll::wait(KThread* thread, U32 events, U32 maxevents, U32 timeout) {
    S32 result = 0;
    U32 pollCount=0;
    KMemory* memory = thread->memory;

    thread->pollData.clear();
    for( const auto& n : this->data ) {
        Data* next = n.value;
        KPollData pollData;
        
        pollData.events = next->events;
        pollData.fd = next->fd;
        pollData.data = next->data;
        thread->pollData.push_back(pollData);
        pollCount++;	
    }
    result = internal_poll(thread, thread->pollData.data(), pollCount, timeout);
    if (result >= 0) {
        result = 0;
        for (KPollData& data : thread->pollData) {
            if (data.revents!=0) {
                memory->writed(events + result * 12, data.revents);
                memory->writeq(events + result * 12 + 4, data.data);
                result++;
                if (result>=(S32)maxevents) {
                    kwarn("possible starvation in epoll, more events are ready than can be received.");
                    break;
                }
            }        
        }
    }
    return result;
}