Method Poll

LibLemon/src/ipc/interface.cpp:44–104

    }

    long Interface::Poll(handle_t& client, Message& m){
        handle_t newIf;
        while((newIf = InterfaceAccept(interfaceHandle))){ // Accept any incoming connections
            if(newIf > 0){
                endpoints.push_back(newIf);

                for(Waiter* waiter : waiters){
                    waiter->RepopulateHandles(); // Repopulate handles
                }
            }
        }

        if(queue.size() > 0){ // Check for messages on the queue
            auto& front = queue.front();

            client = front.client;
            m.Set(front.data, front.length, front.id);

            queue.pop_front();
            return 1;
        }

        for(auto it = endpoints.begin(); !endpoints.empty() && it != endpoints.end(); it++){
            handle_t& endpoint = *it;
            InterfaceMessageInfo msg = {endpoint, 0, nullptr, 0};

            while(long ret = EndpointDequeue(endpoint, &msg.id, &msg.length, dataBuffer)){
                if(ret < 0){ // We have probably disconnected
                    if(ret == -ENOTCONN){
                        DestroyKObject(endpoint);
                    }

                    endpoints.erase(it);

                    queue.push_back({.client = endpoint, .id = MessagePeerDisconnect, .data = nullptr, .length = 0});

                    for(Waiter* waiter : waiters){
                        waiter->RepopulateHandles();
                    }
                    break;
                }

                msg.data = dataBuffer;
                queue.push_back(msg);

                dataBuffer = new uint8_t[msgSize];
            }
        }

        if(queue.size() > 0){
            auto& front = queue.front();

            client = front.client;
            m.Set(front.data, front.length, front.id);

            queue.pop_front();
            return 1;
        } else {