Like if it feels like you have to switch your brain at all to thinking about a different thing, or t

N

Nova•4/18/22, 1:34 AM

#include "eventloop.hpp"
#include "../nodetypes/drawable/drawable.hpp"
#include "scenegraphpropagation.hpp"
#include <memory>
#include <mutex>
#include <vector>

namespace StardustXRServer {

EventLoop::EventLoop() :
eventThread(&EventLoop::eventLoop, this) {}

EventLoop::~EventLoop() {
    eventThread.join();
}

void EventLoop::callClientsDebug() {
    for(auto &client : clients) {
        client->scenegraphPropagate("", ScenegraphDebugFunction);
    }
}

void EventLoop::eventLoop() {

}

}

#include "eventloop.hpp"
#include "../nodetypes/drawable/drawable.hpp"
#include "scenegraphpropagation.hpp"
#include <memory>
#include <mutex>
#include <vector>

namespace StardustXRServer {

EventLoop::EventLoop() :
eventThread(&EventLoop::eventLoop, this) {}

EventLoop::~EventLoop() {
    eventThread.join();
}

void EventLoop::callClientsDebug() {
    for(auto &client : clients) {
        client->scenegraphPropagate("", ScenegraphDebugFunction);
    }
}

void EventLoop::eventLoop() {

}

}

#include "eventloop.hpp"
#include "../nodetypes/drawable/drawable.hpp"
#include "scenegraphpropagation.hpp"
#include <memory>
#include <mutex>
#include <vector>

namespace StardustXRServer {

EventLoop::EventLoop() :
eventThread(&EventLoop::eventLoop, this) {}

EventLoop::~EventLoop() {
    eventThread.join();
}

void EventLoop::callClientsDebug() {
    for(auto &client : clients) {
        client->scenegraphPropagate("", ScenegraphDebugFunction);
    }
}

void EventLoop::eventLoop() {

}

}

#include "eventloop.hpp"
#include "../nodetypes/drawable/drawable.hpp"
#include "scenegraphpropagation.hpp"
#include <memory>
#include <mutex>
#include <vector>

namespace StardustXRServer {

EventLoop::EventLoop() :
eventThread(&EventLoop::eventLoop, this) {}

EventLoop::~EventLoop() {
    eventThread.join();
}

void EventLoop::callClientsDebug() {
    for(auto &client : clients) {
        client->scenegraphPropagate("", ScenegraphDebugFunction);
    }
}

void EventLoop::eventLoop() {

}

}

N

Nova•4/18/22, 1:34 AM

i just gotta populate

eventLoop

eventLoop

eventLoop

eventLoop now

M

MalekOP•4/18/22, 1:35 AM

:vibecat:

MMalek Like if it feels like you have to switch your brain at all to thinking about a d...

N

Nova•4/18/22, 1:35 AM

i do have to.... somewhat but not much

M

MalekOP•4/18/22, 1:35 AM

then its totally up to you and i don't think anyone would complain either way then

N

Nova•4/18/22, 2:00 AM

k

M

MalekOP•4/18/22, 2:38 AM

After the event loop, its just the keyboard and then Stardust is actually useable, which is pog

N

Nova•4/18/22, 2:43 AM

keyboard isn't trivial either :S

M

MalekOP•4/18/22, 2:44 AM

Not saying it is, but having a stardust I can start actually working in, even if there are minimal features, within like, a few weeks is still poggers

M

MalekOP•4/18/22, 2:44 AM

:3

N

Nova•4/18/22, 2:48 AM

true haha

N

Nova•4/18/22, 2:56 AM

i swear to god just getting this vent loop set up is like twister

N

Nova•4/18/22, 2:56 AM

having to contort things around to get them to fit into the shape i want

M

MalekOP•4/18/22, 3:03 AM

pat pat

N

Nova•4/18/22, 3:22 AM

void EventLoop::eventLoop() {
    while(running) {
        int socketAcceptFD = socketHandler.acceptNewClient();
        if(socketAcceptFD != -1) {
            addClient(socketAcceptFD);
        } else if(errno != EAGAIN && errno != EWOULDBLOCK) {
            running = false;
            return;
        }

        if(poll(pollFDs.data(), pollFDs.size(), 10) <= 0) continue;

        std::vector<pollfd> pollFDs = this->pollFDs;
        for(pollfd &pollFD : pollFDs) {
            auto clientIter = std::find_if(clients.begin(), clients.end(), [pollFD](std::unique_ptr<Client> &client) {
                return client->fd == pollFD.fd;
            });
            if(clientIter == clients.end()) {
                //Non-stardust client with fd in clientPollFDs like wayland for example
                continue;
            }

            if(pollFD.revents &= POLLERR | POLLHUP | POLLNVAL) {
                removeClient(pollFD.fd);
                continue;
            }

            if(pollFD.revents &= POLLIN) {
                Client *const client = clientIter->get();
                client->messenger.dispatch();
            }
        }
    }
}

void EventLoop::eventLoop() {
    while(running) {
        int socketAcceptFD = socketHandler.acceptNewClient();
        if(socketAcceptFD != -1) {
            addClient(socketAcceptFD);
        } else if(errno != EAGAIN && errno != EWOULDBLOCK) {
            running = false;
            return;
        }

        if(poll(pollFDs.data(), pollFDs.size(), 10) <= 0) continue;

        std::vector<pollfd> pollFDs = this->pollFDs;
        for(pollfd &pollFD : pollFDs) {
            auto clientIter = std::find_if(clients.begin(), clients.end(), [pollFD](std::unique_ptr<Client> &client) {
                return client->fd == pollFD.fd;
            });
            if(clientIter == clients.end()) {
                //Non-stardust client with fd in clientPollFDs like wayland for example
                continue;
            }

            if(pollFD.revents &= POLLERR | POLLHUP | POLLNVAL) {
                removeClient(pollFD.fd);
                continue;
            }

            if(pollFD.revents &= POLLIN) {
                Client *const client = clientIter->get();
                client->messenger.dispatch();
            }
        }
    }
}

void EventLoop::eventLoop() {
    while(running) {
        int socketAcceptFD = socketHandler.acceptNewClient();
        if(socketAcceptFD != -1) {
            addClient(socketAcceptFD);
        } else if(errno != EAGAIN && errno != EWOULDBLOCK) {
            running = false;
            return;
        }

        if(poll(pollFDs.data(), pollFDs.size(), 10) <= 0) continue;

        std::vector<pollfd> pollFDs = this->pollFDs;
        for(pollfd &pollFD : pollFDs) {
            auto clientIter = std::find_if(clients.begin(), clients.end(), [pollFD](std::unique_ptr<Client> &client) {
                return client->fd == pollFD.fd;
            });
            if(clientIter == clients.end()) {
                //Non-stardust client with fd in clientPollFDs like wayland for example
                continue;
            }

            if(pollFD.revents &= POLLERR | POLLHUP | POLLNVAL) {
                removeClient(pollFD.fd);
                continue;
            }

            if(pollFD.revents &= POLLIN) {
                Client *const client = clientIter->get();
                client->messenger.dispatch();
            }
        }
    }
}

void EventLoop::eventLoop() {
    while(running) {
        int socketAcceptFD = socketHandler.acceptNewClient();
        if(socketAcceptFD != -1) {
            addClient(socketAcceptFD);
        } else if(errno != EAGAIN && errno != EWOULDBLOCK) {
            running = false;
            return;
        }

        if(poll(pollFDs.data(), pollFDs.size(), 10) <= 0) continue;

        std::vector<pollfd> pollFDs = this->pollFDs;
        for(pollfd &pollFD : pollFDs) {
            auto clientIter = std::find_if(clients.begin(), clients.end(), [pollFD](std::unique_ptr<Client> &client) {
                return client->fd == pollFD.fd;
            });
            if(clientIter == clients.end()) {
                //Non-stardust client with fd in clientPollFDs like wayland for example
                continue;
            }

            if(pollFD.revents &= POLLERR | POLLHUP | POLLNVAL) {
                removeClient(pollFD.fd);
                continue;
            }

            if(pollFD.revents &= POLLIN) {
                Client *const client = clientIter->get();
                client->messenger.dispatch();
            }
        }
    }
}

N

Nova•4/18/22, 3:22 AM

this is just the start

N

Nova•4/18/22, 3:22 AM

i think

N

Nova•4/18/22, 3:22 AM

wait is it almost done?

N

Nova•4/18/22, 3:22 AM

i can't tell anymoreee

N

Nova•4/18/22, 3:38 AM

oh great

N

Nova•4/18/22, 3:38 AM

now the thing just... won't accept

N

Nova•4/18/22, 3:38 AM

the client tries to connect and it just instantly gets rejected

N

Nova•4/18/22, 3:38 AM

:/

N

Nova•4/18/22, 3:52 AM

wait it's an async connection

N

Nova•4/18/22, 3:52 AM

If the connection cannot be established immediately and O_NONBLOCK is set for the file descriptor for the socket, connect() shall fail and set errno to [EINPROGRESS], but the connection request shall not be aborted, and the connection shall be established asynchronously. Subsequent calls to connect() for the same socket, before the connection is established, shall fail and set errno to [EALREADY].

When the connection has been established asynchronously, select() and poll() shall indicate that the file descriptor for the socket is ready for writing.

N

Nova•4/18/22, 3:52 AM

ok but like

N

Nova•4/18/22, 3:53 AM

examples of poll being used for this please???

N

Nova•4/18/22, 4:02 AM

got it working but guess what

N

Nova•4/18/22, 4:02 AM

turns out

N

Nova•4/18/22, 4:02 AM

the darn fd is nonblocking so all my read calls are nonblocking too

N

Nova•4/18/22, 4:02 AM

adnfjlkadshnflkjsdanglkdsang;adsfs

N

Nova•4/18/22, 5:04 AM

wait maybe they are maybe they aren't

N

Nova•4/18/22, 5:04 AM

i seem to just be getting pure garbage now

N

Nova•4/18/22, 5:04 AM

:/

N

Nova•4/18/22, 5:04 AM

what in the hell

N

Nova•4/18/22, 5:07 AM

this is with blocking sockets btw

N

Nova•4/18/22, 5:07 AM

it's like... everything borken

TTurtle1331 obligatory post <https://journal.stuffwithstuff.com/2015/02/01/what-color-is-you...

T

Turtle1331•4/18/22, 6:40 AM

yeah, nonblocking-ness does behave like that :P

N

Nova•4/18/22, 11:18 AM

no but that's the weird part, this is happening even when I never make the function nonblocking

N

Nova•4/18/22, 12:27 PM

that's what i don't get at all

N

Nova•4/18/22, 1:00 PM

ahahahahahaha

N

Nova•4/18/22, 1:00 PM

N

Nova•4/18/22, 1:00 PM

yeeeess

N

Nova•4/18/22, 1:03 PM

it workssss

N

Nova•4/18/22, 3:29 PM

well... not fully @Turtle1331 :p

N

Nova•4/18/22, 3:29 PM

still WIP

M

MalekOP•4/18/22, 5:08 PM

Eyyy

M

MalekOP•4/18/22, 6:05 PM

Were you up for like, 14 hours doing this??

M

MalekOP•4/18/22, 6:05 PM

Danggg

M

MalekOP•4/18/22, 8:31 PM

Wish this was a company so I could work for it while still like, staying alive :pensivebread:

Like if it feels like you have to switch your brain at all to thinking about a different thing, or t

Similar Threads

Similar Threads

Similar Threads