1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
#pragma once
#include <sys/un.h>
#include <wayfire/object.hpp>
#include <wayland-server.h>
#include <wayfire/plugins/common/shared-core-data.hpp>
#include "wayfire/plugins/ipc/ipc-method-repository.hpp"
namespace wf
{
namespace ipc
{
/**
* Represents a single connected client to the IPC socket.
*/
class server_t;
class client_t : public client_interface_t
{
public:
client_t(server_t *server, int client_fd);
~client_t();
bool send_json(wf::json_t json) override;
private:
int fd;
wl_event_source *source;
server_t *ipc;
int current_buffer_valid = 0;
std::vector<char> buffer;
int read_up_to(int n, int *available);
/** Handle incoming data on the socket */
std::function<void(uint32_t)> handle_fd_activity;
void handle_fd_incoming(uint32_t);
};
/**
* The IPC server is a singleton object accessed via shared_data::ref_ptr_t.
* It represents the IPC socket used for communication with clients.
*/
class server_t
{
public:
server_t();
void init(std::string socket_path);
~server_t();
private:
friend class client_t;
wf::shared_data::ref_ptr_t<wf::ipc::method_repository_t> method_repository;
void handle_incoming_message(client_t *client, wf::json_t message);
void client_disappeared(client_t *client);
int fd = -1;
/**
* Setup a socket at the given address, and set it as CLOEXEC and non-blocking.
*/
int setup_socket(const char *address);
sockaddr_un saddr;
wl_event_source *source;
std::vector<std::unique_ptr<client_t>> clients;
std::function<void()> accept_new_client;
void do_accept_new_client();
};
}
}
|
