what about the wayland parts? is it ok to have the wayland parts in the same file?

N

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

it's just calling 2 functions + a mutex for synchronization

M

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

I mean its all down to asthetic choice, but if its like, if the vibes are different then generally yes

M

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

Like if it feels like you have to switch your brain at all to thinking about a different thing, or thinking in a diff way then i put it in sepearte files

N

NovaOP•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

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

i just gotta populate

eventLoop

eventLoop

eventLoop

eventLoop now

M

Malek•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

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

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

M

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

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

N

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

k

M

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

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

N

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

keyboard isn't trivial either :S

M

Malek•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

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

:3

N

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

true haha

N

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

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

N

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

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

M

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

pat pat

N

NovaOP•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

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

this is just the start

N

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

i think

N

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

wait is it almost done?

N

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

i can't tell anymoreee

N

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

oh great

N

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

now the thing just... won't accept

N

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

the client tries to connect and it just instantly gets rejected

N

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

:/

N

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

wait it's an async connection

N

NovaOP•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

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

ok but like

N

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

examples of poll being used for this please???

N

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

got it working but guess what

N

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

turns out

N

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

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

N

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

adnfjlkadshnflkjsdanglkdsang;adsfs

N

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

wait maybe they are maybe they aren't

N

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

i seem to just be getting pure garbage now

N

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

:/

N

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

what in the hell

N

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

this is with blocking sockets btw

N

NovaOP•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

NovaOP•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

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

that's what i don't get at all

N

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

ahahahahahaha

N

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

N

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

yeeeess

N

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

it workssss

N

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

well... not fully @Turtle1331 :p

N

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

still WIP

M

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

Eyyy

what about the wayland parts? is it ok to have the wayland parts in the same file?

Similar Threads

Similar Threads

Similar Threads