Function kselect

source/kernel/kpoll.cpp:160–272

U32 kselect(KThread* thread, U32 nfds, U32 readfds, U32 writefds, U32 errorfds, U32 timeout, bool timeoutIsTimeVal, U32 sigmask, bool time64) {
    S32 result = 0;
    int count = 0;
    U32 pollCount = 0;
    KMemory* memory = thread->memory;

    if (timeout == 0)
        timeout = 0x7FFFFFFF;
    else {
        // timeval, 2nd part is microseconds
        // timespec, 2nd part is nanoseconds
        if (time64) {
            timeout = (U32)(memory->readq(timeout) * 1000 + memory->readd(timeout + 8) / (timeoutIsTimeVal?1000:1000000));
        } else {
            timeout = memory->readd(timeout) * 1000 + memory->readd(timeout + 4) / (timeoutIsTimeVal ? 1000 : 1000000);
        }
        if (timeout < NUMBER_OF_MILLIES_TO_SPIN_FOR_WAIT && nfds == 0) {
            return KThread::currentThread()->sleep(timeout);
        }
    }    

    KPollData* pollData = new KPollData[nfds];

    for (U32 i=0;i<nfds;) {
        U32 readbits = 0;
        U32 writebits = 0;
        U32 errorbits = 0;

        if (readfds!=0) {
            readbits = memory->readb(readfds + i / 8);
        }
        if (writefds!=0) {
            writebits = memory->readb(writefds + i / 8);
        }
        if (errorfds!=0) {
            errorbits = memory->readb(errorfds + i / 8);
        }
        for (U32 b = 0; b < 8 && i < nfds; b++, i++) {
            U32 mask = 1 << b;
            U32 r = readbits & mask;
            U32 w = writebits & mask;
            U32 e = errorbits & mask;
            if (r || w || e) {
                U32 events = 0;
                if (r)
                    events |= K_POLLIN;
                if (w)
                    events |= K_POLLHUP|K_POLLOUT;
                if (e)
                    events |= K_POLLERR;
                pollData[pollCount].events = events;
                pollData[pollCount].fd = i;
                pollCount++;
            }
        }
    }    
    if (sigmask) {
        U32 mask = thread->memory->readd(sigmask);