| 1 | // Copyright (C) 2016 The Qt Company Ltd. |
| 2 | // SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only |
| 3 | |
| 4 | #include "qxcbxsettings.h" |
| 5 | |
| 6 | #include <QtCore/QByteArray> |
| 7 | #include <QtCore/QtEndian> |
| 8 | |
| 9 | #include <vector> |
| 10 | #include <algorithm> |
| 11 | |
| 12 | QT_BEGIN_NAMESPACE |
| 13 | /* Implementation of http://standards.freedesktop.org/xsettings-spec/xsettings-0.5.html */ |
| 14 | |
| 15 | enum XSettingsType { |
| 16 | XSettingsTypeInteger = 0, |
| 17 | XSettingsTypeString = 1, |
| 18 | XSettingsTypeColor = 2 |
| 19 | }; |
| 20 | |
| 21 | struct QXcbXSettingsCallback |
| 22 | { |
| 23 | QXcbXSettings::PropertyChangeFunc func; |
| 24 | void *handle; |
| 25 | }; |
| 26 | |
| 27 | class QXcbXSettingsPropertyValue |
| 28 | { |
| 29 | public: |
| 30 | QXcbXSettingsPropertyValue() |
| 31 | : last_change_serial(-1) |
| 32 | {} |
| 33 | |
| 34 | void updateValue(QXcbVirtualDesktop *screen, const QByteArray &name, const QVariant &value, int last_change_serial) |
| 35 | { |
| 36 | if (last_change_serial <= this->last_change_serial) |
| 37 | return; |
| 38 | this->value = value; |
| 39 | this->last_change_serial = last_change_serial; |
| 40 | for (const auto &callback : callback_links) |
| 41 | callback.func(screen, name, value, callback.handle); |
| 42 | } |
| 43 | |
| 44 | void addCallback(QXcbXSettings::PropertyChangeFunc func, void *handle) |
| 45 | { |
| 46 | QXcbXSettingsCallback callback = { .func: func, .handle: handle }; |
| 47 | callback_links.push_back(x: callback); |
| 48 | } |
| 49 | |
| 50 | QVariant value; |
| 51 | int last_change_serial; |
| 52 | std::vector<QXcbXSettingsCallback> callback_links; |
| 53 | |
| 54 | }; |
| 55 | |
| 56 | class QXcbXSettingsPrivate |
| 57 | { |
| 58 | public: |
| 59 | QXcbXSettingsPrivate(QXcbVirtualDesktop *screen) |
| 60 | : screen(screen) |
| 61 | , initialized(false) |
| 62 | { |
| 63 | } |
| 64 | |
| 65 | QByteArray getSettings() |
| 66 | { |
| 67 | QXcbConnectionGrabber connectionGrabber(screen->connection()); |
| 68 | |
| 69 | int offset = 0; |
| 70 | QByteArray settings; |
| 71 | xcb_atom_t _xsettings_atom = screen->connection()->atom(qatom: QXcbAtom::Atom_XSETTINGS_SETTINGS); |
| 72 | while (1) { |
| 73 | auto reply = Q_XCB_REPLY_UNCHECKED(xcb_get_property, |
| 74 | screen->xcb_connection(), |
| 75 | false, |
| 76 | x_settings_window, |
| 77 | _xsettings_atom, |
| 78 | _xsettings_atom, |
| 79 | offset/4, |
| 80 | 8192); |
| 81 | bool more = false; |
| 82 | if (!reply) |
| 83 | return settings; |
| 84 | |
| 85 | const auto property_value_length = xcb_get_property_value_length(R: reply.get()); |
| 86 | settings.append(s: static_cast<const char *>(xcb_get_property_value(R: reply.get())), len: property_value_length); |
| 87 | offset += property_value_length; |
| 88 | more = reply->bytes_after != 0; |
| 89 | |
| 90 | if (!more) |
| 91 | break; |
| 92 | } |
| 93 | |
| 94 | return settings; |
| 95 | } |
| 96 | |
| 97 | static int round_to_nearest_multiple_of_4(int value) |
| 98 | { |
| 99 | int remainder = value % 4; |
| 100 | if (!remainder) |
| 101 | return value; |
| 102 | return value + 4 - remainder; |
| 103 | } |
| 104 | |
| 105 | void populateSettings(const QByteArray &xSettings) |
| 106 | { |
| 107 | if (xSettings.size() < 12) |
| 108 | return; |
| 109 | char byteOrder = xSettings.at(i: 0); |
| 110 | if (byteOrder != XCB_IMAGE_ORDER_LSB_FIRST && byteOrder != XCB_IMAGE_ORDER_MSB_FIRST) { |
| 111 | qWarning(msg: "ByteOrder byte %d not 0 or 1" , byteOrder); |
| 112 | return; |
| 113 | } |
| 114 | |
| 115 | #define ADJUST_BO(b, t, x) \ |
| 116 | ((b == XCB_IMAGE_ORDER_LSB_FIRST) ? \ |
| 117 | qFromLittleEndian<t>(x) : \ |
| 118 | qFromBigEndian<t>(x)) |
| 119 | #define VALIDATE_LENGTH(x) \ |
| 120 | if ((size_t)xSettings.length() < (offset + local_offset + 12 + x)) { \ |
| 121 | qWarning("Length %d runs past end of data", x); \ |
| 122 | return; \ |
| 123 | } |
| 124 | |
| 125 | uint number_of_settings = ADJUST_BO(byteOrder, quint32, xSettings.mid(8,4).constData()); |
| 126 | const char *data = xSettings.constData() + 12; |
| 127 | size_t offset = 0; |
| 128 | for (uint i = 0; i < number_of_settings; i++) { |
| 129 | int local_offset = 0; |
| 130 | VALIDATE_LENGTH(2); |
| 131 | XSettingsType type = static_cast<XSettingsType>(*reinterpret_cast<const quint8 *>(data + offset)); |
| 132 | local_offset += 2; |
| 133 | |
| 134 | VALIDATE_LENGTH(2); |
| 135 | quint16 name_len = ADJUST_BO(byteOrder, quint16, data + offset + local_offset); |
| 136 | local_offset += 2; |
| 137 | |
| 138 | VALIDATE_LENGTH(name_len); |
| 139 | QByteArray name(data + offset + local_offset, name_len); |
| 140 | local_offset += round_to_nearest_multiple_of_4(value: name_len); |
| 141 | |
| 142 | VALIDATE_LENGTH(4); |
| 143 | int last_change_serial = ADJUST_BO(byteOrder, qint32, data + offset + local_offset); |
| 144 | Q_UNUSED(last_change_serial); |
| 145 | local_offset += 4; |
| 146 | |
| 147 | QVariant value; |
| 148 | if (type == XSettingsTypeString) { |
| 149 | VALIDATE_LENGTH(4); |
| 150 | int value_length = ADJUST_BO(byteOrder, qint32, data + offset + local_offset); |
| 151 | local_offset+=4; |
| 152 | VALIDATE_LENGTH(value_length); |
| 153 | QByteArray value_string(data + offset + local_offset, value_length); |
| 154 | value.setValue(value_string); |
| 155 | local_offset += round_to_nearest_multiple_of_4(value: value_length); |
| 156 | } else if (type == XSettingsTypeInteger) { |
| 157 | VALIDATE_LENGTH(4); |
| 158 | int value_length = ADJUST_BO(byteOrder, qint32, data + offset + local_offset); |
| 159 | local_offset += 4; |
| 160 | value.setValue(value_length); |
| 161 | } else if (type == XSettingsTypeColor) { |
| 162 | VALIDATE_LENGTH(2*4); |
| 163 | quint16 red = ADJUST_BO(byteOrder, quint16, data + offset + local_offset); |
| 164 | local_offset += 2; |
| 165 | quint16 green = ADJUST_BO(byteOrder, quint16, data + offset + local_offset); |
| 166 | local_offset += 2; |
| 167 | quint16 blue = ADJUST_BO(byteOrder, quint16, data + offset + local_offset); |
| 168 | local_offset += 2; |
| 169 | quint16 alpha= ADJUST_BO(byteOrder, quint16, data + offset + local_offset); |
| 170 | local_offset += 2; |
| 171 | QColor color_value(red,green,blue,alpha); |
| 172 | value.setValue(color_value); |
| 173 | } |
| 174 | offset += local_offset; |
| 175 | settings[name].updateValue(screen,name,value,last_change_serial); |
| 176 | } |
| 177 | |
| 178 | } |
| 179 | |
| 180 | QXcbVirtualDesktop *screen; |
| 181 | xcb_window_t x_settings_window; |
| 182 | QMap<QByteArray, QXcbXSettingsPropertyValue> settings; |
| 183 | bool initialized; |
| 184 | }; |
| 185 | |
| 186 | |
| 187 | QXcbXSettings::QXcbXSettings(QXcbVirtualDesktop *screen) |
| 188 | : d_ptr(new QXcbXSettingsPrivate(screen)) |
| 189 | { |
| 190 | QByteArray settings_atom_for_screen("_XSETTINGS_S" ); |
| 191 | settings_atom_for_screen.append(a: QByteArray::number(screen->number())); |
| 192 | auto atom_reply = Q_XCB_REPLY(xcb_intern_atom, |
| 193 | screen->xcb_connection(), |
| 194 | true, |
| 195 | settings_atom_for_screen.size(), |
| 196 | settings_atom_for_screen.constData()); |
| 197 | if (!atom_reply) |
| 198 | return; |
| 199 | |
| 200 | xcb_atom_t selection_owner_atom = atom_reply->atom; |
| 201 | |
| 202 | xcb_window_t owner = screen->connection()->selectionOwner(atom: selection_owner_atom); |
| 203 | if (owner == XCB_NONE) |
| 204 | return; |
| 205 | |
| 206 | d_ptr->x_settings_window = owner; |
| 207 | if (!d_ptr->x_settings_window) |
| 208 | return; |
| 209 | |
| 210 | screen->connection()->addWindowEventListener(id: d_ptr->x_settings_window, eventListener: this); |
| 211 | const uint32_t event = XCB_CW_EVENT_MASK; |
| 212 | const uint32_t event_mask[] = { XCB_EVENT_MASK_STRUCTURE_NOTIFY|XCB_EVENT_MASK_PROPERTY_CHANGE }; |
| 213 | xcb_change_window_attributes(c: screen->xcb_connection(),window: d_ptr->x_settings_window,value_mask: event,value_list: event_mask); |
| 214 | |
| 215 | d_ptr->populateSettings(xSettings: d_ptr->getSettings()); |
| 216 | d_ptr->initialized = true; |
| 217 | } |
| 218 | |
| 219 | QXcbXSettings::~QXcbXSettings() |
| 220 | { |
| 221 | delete d_ptr; |
| 222 | d_ptr = nullptr; |
| 223 | } |
| 224 | |
| 225 | bool QXcbXSettings::initialized() const |
| 226 | { |
| 227 | Q_D(const QXcbXSettings); |
| 228 | return d->initialized; |
| 229 | } |
| 230 | |
| 231 | void QXcbXSettings::handlePropertyNotifyEvent(const xcb_property_notify_event_t *event) |
| 232 | { |
| 233 | Q_D(QXcbXSettings); |
| 234 | if (event->window != d->x_settings_window) |
| 235 | return; |
| 236 | |
| 237 | d->populateSettings(xSettings: d->getSettings()); |
| 238 | } |
| 239 | |
| 240 | void QXcbXSettings::registerCallbackForProperty(const QByteArray &property, QXcbXSettings::PropertyChangeFunc func, void *handle) |
| 241 | { |
| 242 | Q_D(QXcbXSettings); |
| 243 | d->settings[property].addCallback(func,handle); |
| 244 | } |
| 245 | |
| 246 | void QXcbXSettings::removeCallbackForHandle(const QByteArray &property, void *handle) |
| 247 | { |
| 248 | Q_D(QXcbXSettings); |
| 249 | auto &callbacks = d->settings[property].callback_links; |
| 250 | |
| 251 | auto isCallbackForHandle = [handle](const QXcbXSettingsCallback &cb) { return cb.handle == handle; }; |
| 252 | |
| 253 | callbacks.erase(first: std::remove_if(first: callbacks.begin(), last: callbacks.end(), |
| 254 | pred: isCallbackForHandle), |
| 255 | last: callbacks.end()); |
| 256 | } |
| 257 | |
| 258 | void QXcbXSettings::removeCallbackForHandle(void *handle) |
| 259 | { |
| 260 | Q_D(QXcbXSettings); |
| 261 | for (QMap<QByteArray, QXcbXSettingsPropertyValue>::const_iterator it = d->settings.cbegin(); |
| 262 | it != d->settings.cend(); ++it) { |
| 263 | removeCallbackForHandle(property: it.key(),handle); |
| 264 | } |
| 265 | } |
| 266 | |
| 267 | QVariant QXcbXSettings::setting(const QByteArray &property) const |
| 268 | { |
| 269 | Q_D(const QXcbXSettings); |
| 270 | return d->settings.value(key: property).value; |
| 271 | } |
| 272 | |
| 273 | QT_END_NAMESPACE |
| 274 | |