37a84c5223
* socket2: fix events being reordered * remove WL_EVENT_READABLE * initialize eventSource in SClient * add more logs oopsie * replace unordered_map with vector * fix reordering when socket becomes writable before queue is flushed * ignore EAGAIN when accepting connection * use g_pEventManager
45 lines
1.1 KiB
C++
45 lines
1.1 KiB
C++
#pragma once
|
|
#include <deque>
|
|
#include <vector>
|
|
|
|
#include "../defines.hpp"
|
|
#include "../helpers/memory/SharedPtr.hpp"
|
|
|
|
struct SHyprIPCEvent {
|
|
std::string event;
|
|
std::string data;
|
|
};
|
|
|
|
class CEventManager {
|
|
public:
|
|
CEventManager();
|
|
~CEventManager();
|
|
|
|
void postEvent(const SHyprIPCEvent& event);
|
|
|
|
private:
|
|
std::string formatEvent(const SHyprIPCEvent& event) const;
|
|
|
|
static int onServerEvent(int fd, uint32_t mask, void* data);
|
|
static int onClientEvent(int fd, uint32_t mask, void* data);
|
|
|
|
int onServerEvent(int fd, uint32_t mask);
|
|
int onClientEvent(int fd, uint32_t mask);
|
|
|
|
struct SClient {
|
|
int fd = -1;
|
|
std::deque<SP<std::string>> events;
|
|
wl_event_source* eventSource = nullptr;
|
|
};
|
|
|
|
std::vector<SClient>::iterator findClientByFD(int fd);
|
|
std::vector<SClient>::iterator removeClientByFD(int fd);
|
|
|
|
private:
|
|
int m_iSocketFD = -1;
|
|
wl_event_source* m_pEventSource = nullptr;
|
|
|
|
std::vector<SClient> m_vClients;
|
|
};
|
|
|
|
inline std::unique_ptr<CEventManager> g_pEventManager;
|