Method PollSync

LibLemon/src/ipc/interfaceuds.cpp:185–230

    }

    std::shared_ptr<LemonMessage> MessageClient::PollSync(){
    retry:
        if(queue.size() > 0){
            auto element = queue.front();
            queue.pop_front();
            return element;
        }

        LemonMessage msg;

        ssize_t len = recv(sock.fd, &msg, sizeof(LemonMessage), 0);
        
        if(len < (ssize_t)sizeof(LemonMessage)){
            //printf("invalid length: %d\n", len);
            
            return std::shared_ptr<LemonMessage>(nullptr);
        }

        if(msg.magic != LEMON_MESSAGE_MAGIC){
            printf("Invalid magic: %x, discarding data.\n", msg.magic);
            while(msg.magic != LEMON_MESSAGE_MAGIC && len >= static_cast<ssize_t>(sizeof(msg))){
                len = recv(sock.fd, &msg, sizeof(msg), MSG_DONTWAIT); // Discard everything until we find a message
            }
        }

        if(msg.magic != LEMON_MESSAGE_MAGIC){
            printf("invalid magic: %x\n", msg.magic);
            
            return std::shared_ptr<LemonMessage>(nullptr);
        }

        std::shared_ptr<LemonMessage> newMsg((LemonMessage*)malloc(sizeof(LemonMessage) + msg.length));
        *newMsg = msg;

        len = recv(sock.fd, newMsg->data, msg.length, 0);

        if(len < msg.length){
            printf("Warning: invalid message length %u. Only read %ld bytes\n", msg.length, len);
            
            return std::shared_ptr<LemonMessage>(nullptr);
        }

        queue.push_back(newMsg);

        goto retry;
    }

    void MessageClient::Wait(){
        char c;