aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTony Crisci <tony@dubstepdish.com>2018-04-05 19:01:03 -0400
committerTony Crisci <tony@dubstepdish.com>2018-04-05 19:01:03 -0400
commit235798ff8e9e60d919cbb671f7c399ff97c164d5 (patch)
tree0f0f88fbbbce6c4c65cae47a34280cbd1539782f
parentbbfc5487bce982ad7ad782fe00e7ac7c8de4c9d2 (diff)
dont send ipc events when there are no listeners
-rw-r--r--sway/ipc-server.c31
1 files changed, 29 insertions, 2 deletions
diff --git a/sway/ipc-server.c b/sway/ipc-server.c
index df5fb699..5fe5c755 100644
--- a/sway/ipc-server.c
+++ b/sway/ipc-server.c
@@ -241,10 +241,25 @@ int ipc_client_handle_readable(int client_fd, uint32_t mask, void *data) {
return 0;
}
+static bool ipc_has_event_listeners(enum ipc_command_type event) {
+ bool has_listeners = false;
+
+ struct ipc_client *client;
+ for (int i = 0; i < ipc_client_list->length; i++) {
+ client = ipc_client_list->items[i];
+ if ((client->subscribed_events & event_mask(event)) == 0) {
+ continue;
+ }
+ has_listeners = true;
+ break;
+ }
+
+ return has_listeners;
+}
+
static void ipc_send_event(const char *json_string, enum ipc_command_type event) {
- int i;
struct ipc_client *client;
- for (i = 0; i < ipc_client_list->length; i++) {
+ for (int i = 0; i < ipc_client_list->length; i++) {
client = ipc_client_list->items[i];
if ((client->subscribed_events & event_mask(event)) == 0) {
continue;
@@ -259,6 +274,9 @@ static void ipc_send_event(const char *json_string, enum ipc_command_type event)
void ipc_event_workspace(struct sway_container *old,
struct sway_container *new, const char *change) {
+ if (!ipc_has_event_listeners(IPC_EVENT_WORKSPACE)) {
+ return;
+ }
wlr_log(L_DEBUG, "Sending workspace::%s event", change);
json_object *obj = json_object_new_object();
json_object_object_add(obj, "change", json_object_new_string(change));
@@ -284,6 +302,9 @@ void ipc_event_workspace(struct sway_container *old,
}
void ipc_event_window(struct sway_container *window, const char *change) {
+ if (!ipc_has_event_listeners(IPC_EVENT_WINDOW)) {
+ return;
+ }
wlr_log(L_DEBUG, "Sending window::%s event", change);
json_object *obj = json_object_new_object();
json_object_object_add(obj, "change", json_object_new_string(change));
@@ -295,6 +316,9 @@ void ipc_event_window(struct sway_container *window, const char *change) {
}
void ipc_event_barconfig_update(struct bar_config *bar) {
+ if (!ipc_has_event_listeners(IPC_EVENT_BARCONFIG_UPDATE)) {
+ return;
+ }
wlr_log(L_DEBUG, "Sending barconfig_update event");
json_object *json = ipc_json_describe_bar_config(bar);
@@ -304,6 +328,9 @@ void ipc_event_barconfig_update(struct bar_config *bar) {
}
void ipc_event_mode(const char *mode) {
+ if (!ipc_has_event_listeners(IPC_EVENT_MODE)) {
+ return;
+ }
wlr_log(L_DEBUG, "Sending mode::%s event", mode);
json_object *obj = json_object_new_object();
json_object_object_add(obj, "change", json_object_new_string(mode));