aboutsummaryrefslogtreecommitdiff
path: root/connection.c
diff options
context:
space:
mode:
authorFederico Angelilli <code@fedang.net>2023-11-17 15:42:49 +0100
committerFederico Angelilli <code@fedang.net>2023-11-17 15:42:49 +0100
commitab92cac18652f72be12f68b5a96095ba8eb5afdf (patch)
treee52a5f295c7cda59e67a341fa87d25983bd56745 /connection.c
parentf8363e89257e8b0a4ff71accbd7b6be22935274f (diff)
Reorganize project structure
Diffstat (limited to 'connection.c')
-rw-r--r--connection.c297
1 files changed, 0 insertions, 297 deletions
diff --git a/connection.c b/connection.c
deleted file mode 100644
index d3eedda..0000000
--- a/connection.c
+++ /dev/null
@@ -1,297 +0,0 @@
-#include <glib.h>
-#include <xcb/xcb.h>
-#include <xcb/xcb_aux.h>
-#include <xcb/xcb_ewmh.h>
-#include <xcb/xcb_xrm.h>
-#include <xcb/xcb_errors.h>
-#include <xcb/randr.h>
-
-#include "log.h"
-#include "connection.h"
-#include "state.h"
-
-static bool query_xrm(Connection *con, const char *res, char **value)
-{
- if (xcb_xrm_resource_get_string(con->database, res, res, value) >= 0) {
- log_debug("Xrm query '%s' found '%s'", res, *value);
- return true;
- }
-
- log_debug("Xrm query '%s' not found", res);
- return false;
-}
-
-static void update_xrm(Connection *con)
-{
- xcb_flush(con->connection);
- xcb_xrm_database_t *database = xcb_xrm_database_from_default(con->connection);
-
- if (database == NULL) {
- log_warning("Xrm database couldn't be updated");
- return;
- }
-
- xcb_xrm_database_free(con->database);
- con->database = database;
- log_debug("Xrm database updated");
-}
-
-static void update_scale(Connection *con)
-{
- char *dpi_value;
- if (query_xrm(con, "Xft.dpi", &dpi_value)) {
- con->screen_dpi = strtod(dpi_value, NULL);
- g_free(dpi_value);
- } else {
- con->screen_dpi = (double)con->screen_size->height * 25.4 / (double)con->screen_size->mheight;
- log_debug("Fallback dpi value '%.2lf'", con->screen_dpi);
- }
-}
-
-typedef struct {
- GSource source;
- Connection *con;
- gpointer fd_tag;
- xcb_generic_event_t *event;
-} EventSource;
-
-static gboolean source_check(GSource *source)
-{
- EventSource *xsource = (EventSource *)source;
- xcb_flush(xsource->con->connection);
- g_assert_null(xsource->event);
-
- GIOCondition flags = g_source_query_unix_fd(source, xsource->fd_tag);
- if (flags & G_IO_IN) {
- g_assert_false(xcb_connection_has_error(xsource->con->connection));
- xsource->event = xcb_poll_for_event(xsource->con->connection);
- }
-
- return xsource->event != NULL;
-}
-
-static void redraw_window(Connection *con, xcb_window_t id)
-{
- for (int i = 0; i < con->states->len; ++i) {
- State *state = con->states->pdata[i];
-
- // Redraw matching window
- if (state->win->window == id) {
- log_debug("Redrawing window [id=%d]", id);
- draw_paint(state->draw, state->win);
- break;
- }
- }
-}
-
-static gboolean source_dispatch(GSource *source, GSourceFunc callback, gpointer data)
-{
- EventSource *xsource = (EventSource *)source;
- g_assert_nonnull(xsource->event);
-
- do {
- switch (xsource->event->response_type & ~0x80) {
- case 0: {
- xcb_generic_error_t *error = (xcb_generic_error_t *)xsource->event;
-
- const char *extension;
- const char *name = xcb_errors_get_name_for_error(xsource->con->errors, error->error_code, &extension);
- const char *major = xcb_errors_get_name_for_major_code(xsource->con->errors, error->major_code);
- const char *minor = xcb_errors_get_name_for_minor_code(xsource->con->errors, error->major_code, error->minor_code);
-
- // TODO: Handle errors instead of aborting
- log_error("Xcb error '%s' [extension=%s, major=%s, minor=%s, resource=%u, sequence=%u]",
- name,
- extension ? extension : "none",
- major,
- minor ? minor : "none",
- (unsigned int)error->resource_id,
- (unsigned int)error->sequence);
- break;
- }
-
- case XCB_EXPOSE: {
- xcb_expose_event_t *expose = (xcb_expose_event_t *)xsource->event;
- log_debug("Processing event 'Expose' [type=%d]", XCB_EXPOSE);
- redraw_window(xsource->con, expose->window);
- break;
- }
-
- case XCB_CREATE_NOTIFY: {
- xcb_create_notify_event_t *create = (xcb_create_notify_event_t *)xsource->event;
- log_debug("Processing event 'CreateNotify' [type=%d]", XCB_CREATE_NOTIFY);
-
- // TODO: Circulate top the window if override_redirect == 0
-
- break;
- }
-
- case XCB_BUTTON_RELEASE: {
- log_debug("Mouse event");
-
- // TODO: Handle click generically by translating the button code
- break;
- }
-
- case XCB_PROPERTY_NOTIFY: {
- xcb_property_notify_event_t *property = (xcb_property_notify_event_t *)xsource->event;
- log_debug("Processing event 'PropertyNotify' [type=%d]", XCB_PROPERTY_NOTIFY);
-
- if (property->atom == XCB_ATOM_RESOURCE_MANAGER) {
- update_xrm(xsource->con);
- update_scale(xsource->con);
- redraw_window(xsource->con, property->window);
- }
- break;
- }
-
- default: {
- const char *extension;
- const char *name = xcb_errors_get_name_for_xcb_event(xsource->con->errors, xsource->event, &extension);
-
- // TODO: Handle XCB_RANDR_SCREEN_CHANGE_NOTIFY
-
- log_debug("Ignoring event '%s' [type=%d, extension=%s]",
- name,
- xsource->event->response_type & 0x7f,
- extension ? extension : "none");
- }
- }
- } while ((xsource->event = xcb_poll_for_event(xsource->con->connection)) != NULL);
-
- return G_SOURCE_CONTINUE;
-}
-
-static GSourceFuncs source_fns = {
- NULL,
- source_check,
- source_dispatch,
- NULL,
-};
-
-static void attach_source(Connection *con)
-{
- EventSource *source = (EventSource *)g_source_new(&source_fns, sizeof(EventSource));
- con->source = (GSource *)source;
- g_source_set_static_name(con->source, "EventSource");
-
- source->con = con;
- source->event = NULL;
- source->fd_tag = g_source_add_unix_fd(con->source, xcb_get_file_descriptor(con->connection), G_IO_IN | G_IO_HUP | G_IO_ERR);
-
- g_source_attach(con->source, NULL);
-}
-
-Connection *connection_create()
-{
- Connection *con = g_malloc0(sizeof(Connection));
- g_assert_nonnull(con);
-
- int preferred_screen = 0;
- con->connection = xcb_connect(NULL, &preferred_screen);
- g_assert_true(con->connection != NULL && !xcb_connection_has_error(con->connection));
- log_debug("Xcb connection established");
-
- log_debug("Default screen '%d'", preferred_screen);
- xcb_screen_iterator_t iter = xcb_setup_roots_iterator(xcb_get_setup(con->connection));
-
- while (preferred_screen != 0 && iter.rem) {
- xcb_screen_next(&iter);
- preferred_screen--;
- }
-
- con->screen = iter.data;
- xcb_generic_error_t *error;
-
- xcb_randr_query_version_cookie_t version_cookie = xcb_randr_query_version(con->connection,
- XCB_RANDR_MAJOR_VERSION,
- XCB_RANDR_MINOR_VERSION);
-
- xcb_randr_query_version_reply_t *randr_version = xcb_randr_query_version_reply(con->connection,
- version_cookie,
- &error);
-
- g_assert_null(error);
- log_debug("RandR loaded [version=%d.%d]", randr_version->major_version, randr_version->minor_version);
- g_assert_cmpint(randr_version->major_version, >=, 1);
-
- xcb_randr_get_screen_info_cookie_t cookie = xcb_randr_get_screen_info(con->connection, con->screen->root);
- xcb_randr_get_screen_info_reply_t *info_reply = xcb_randr_get_screen_info_reply(con->connection, cookie, &error);
- g_assert_null(error);
-
- con->screen_size = xcb_randr_get_screen_info_sizes(info_reply);
- g_assert_nonnull(con->screen_size);
- log_debug("Screen size [width=%d, height=%d]", con->screen_size->width, con->screen_size->height);
-
- xcb_randr_select_input(con->connection,
- con->screen->root,
- XCB_RANDR_NOTIFY_MASK_SCREEN_CHANGE |
- XCB_RANDR_NOTIFY_MASK_OUTPUT_CHANGE |
- XCB_RANDR_NOTIFY_MASK_OUTPUT_PROPERTY);
-
- log_debug("Xcb searching 32 bit visual");
- con->visual_type = xcb_aux_find_visual_by_attrs(con->screen, XCB_VISUAL_CLASS_TRUE_COLOR, 32);
- con->screen_depth = 32;
-
- if (con->visual_type == NULL) {
- // NOTE: 24 bit visuals don't have the alpha channel for transparency
- log_debug("Fallback to 24 bit visual");
- con->visual_type = xcb_aux_find_visual_by_attrs(con->screen, XCB_VISUAL_CLASS_TRUE_COLOR, 24);
- con->screen_depth = 24;
- }
-
- g_assert_nonnull(con->visual_type);
- log_debug("Xcb visual type found [id=%u]", con->visual_type->visual_id);
-
- xcb_intern_atom_cookie_t *ewmh_cookie = xcb_ewmh_init_atoms(con->connection, &con->ewmh);
- g_assert_true(xcb_ewmh_init_atoms_replies(&con->ewmh, ewmh_cookie, &error));
- g_assert_null(error);
- log_debug("Xcb ewmh initialized");
-
- con->database = xcb_xrm_database_from_default(con->connection);
- g_assert_nonnull(con->database);
-
- update_scale(con);
-
- g_assert(xcb_errors_context_new(con->connection, &con->errors) == 0);
- log_debug("Xcb errors loaded");
-
- xcb_flush(con->connection);
- log_debug("Xcb set up");
-
- con->states = g_ptr_array_new();
- g_assert_nonnull(con->states);
-
- return con;
-}
-
-void connection_attach_source(Connection *con)
-{
- g_assert_null(con->source);
-
- attach_source(con);
- log_debug("Xcb event loop attached");
-}
-
-void connection_attach_state(Connection *con, State *state)
-{
- g_assert_nonnull(state);
- g_ptr_array_add(con->states, state);
- log_debug("Attached state to event loop");
-}
-
-void connection_destroy(Connection *con)
-{
- g_ptr_array_free(con->states, true);
-
- g_source_destroy(con->source);
- g_source_unref(con->source);
-
- xcb_ewmh_connection_wipe(&con->ewmh);
- xcb_errors_context_free(con->errors);
- xcb_xrm_database_free(con->database);
- xcb_disconnect(con->connection);
- g_free(con);
-}
-
-// vim: ts=4 sw=4 et