1 /* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */ 2 /* dbus-timeout.c DBusTimeout implementation 3 * 4 * Copyright (C) 2003 CodeFactory AB 5 * 6 * Licensed under the Academic Free License version 2.1 7 * 8 * This program is free software; you can redistribute it and/or modify 9 * it under the terms of the GNU General Public License as published by 10 * the Free Software Foundation; either version 2 of the License, or 11 * (at your option) any later version. 12 * 13 * This program is distributed in the hope that it will be useful, 14 * but WITHOUT ANY WARRANTY; without even the implied warranty of 15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 16 * GNU General Public License for more details. 17 * 18 * You should have received a copy of the GNU General Public License 19 * along with this program; if not, write to the Free Software 20 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA 21 * 22 */ 23 24 #include <config.h> 25 #include "dbus-internals.h" 26 #include "dbus-timeout.h" 27 #include "dbus-list.h" 28 29 /** 30 * @defgroup DBusTimeoutInternals DBusTimeout implementation details 31 * @ingroup DBusInternals 32 * @brief implementation details for DBusTimeout 33 * 34 * @{ 35 */ 36 37 /** 38 * Internals of DBusTimeout 39 */ 40 struct DBusTimeout 41 { 42 int refcount; /**< Reference count */ 43 int interval; /**< Timeout interval in milliseconds. */ 44 45 DBusTimeoutHandler handler; /**< Timeout handler. */ 46 void *handler_data; /**< Timeout handler data. */ 47 DBusFreeFunction free_handler_data_function; /**< Free the timeout handler data. */ 48 49 void *data; /**< Application data. */ 50 DBusFreeFunction free_data_function; /**< Free the application data. */ 51 unsigned int enabled : 1; /**< True if timeout is active. */ 52 }; 53 54 /** 55 * Creates a new DBusTimeout, enabled by default. 56 * @param interval the timeout interval in milliseconds. 57 * @param handler function to call when the timeout occurs. 58 * @param data data to pass to the handler 59 * @param free_data_function function to be called to free the data. 60 * @returns the new DBusTimeout object, 61 */ 62 DBusTimeout* 63 _dbus_timeout_new (int interval, 64 DBusTimeoutHandler handler, 65 void *data, 66 DBusFreeFunction free_data_function) 67 { 68 DBusTimeout *timeout; 69 70 timeout = dbus_new0 (DBusTimeout, 1); 71 if (timeout == NULL) 72 return NULL; 73 74 timeout->refcount = 1; 75 timeout->interval = interval; 76 77 timeout->handler = handler; 78 timeout->handler_data = data; 79 timeout->free_handler_data_function = free_data_function; 80 81 timeout->enabled = TRUE; 82 83 return timeout; 84 } 85 86 /** 87 * Increments the reference count of a DBusTimeout object. 88 * 89 * @param timeout the timeout object. 90 * @returns the timeout object. 91 */ 92 DBusTimeout * 93 _dbus_timeout_ref (DBusTimeout *timeout) 94 { 95 timeout->refcount += 1; 96 97 return timeout; 98 } 99 100 /** 101 * Decrements the reference count of a DBusTimeout object 102 * and finalizes the object if the count reaches zero. 103 * 104 * @param timeout the timeout object. 105 */ 106 void 107 _dbus_timeout_unref (DBusTimeout *timeout) 108 { 109 _dbus_assert (timeout != NULL); 110 _dbus_assert (timeout->refcount > 0); 111 112 timeout->refcount -= 1; 113 if (timeout->refcount == 0) 114 { 115 dbus_timeout_set_data (timeout, NULL, NULL); /* call free_data_function */ 116 117 if (timeout->free_handler_data_function) 118 (* timeout->free_handler_data_function) (timeout->handler_data); 119 120 dbus_free (timeout); 121 } 122 } 123 124 /** 125 * Changes the timeout interval. Note that you have to disable and 126 * re-enable the timeout using the timeout toggle function 127 * (_dbus_connection_toggle_timeout_unlocked() etc.) to notify the 128 * application of this change. 129 * 130 * @param timeout the timeout 131 * @param interval the new interval 132 */ 133 void 134 _dbus_timeout_set_interval (DBusTimeout *timeout, 135 int interval) 136 { 137 _dbus_assert (interval >= 0); 138 139 timeout->interval = interval; 140 } 141 142 /** 143 * Changes the timeout's enabled-ness. Note that you should use 144 * _dbus_connection_toggle_timeout_unlocked() etc. instead, if 145 * the timeout is passed out to an application main loop. 146 * i.e. you can't use this function in the D-Bus library, it's 147 * only used in the message bus daemon implementation. 148 * 149 * @param timeout the timeout 150 * @param enabled #TRUE if timeout should be enabled. 151 */ 152 void 153 _dbus_timeout_set_enabled (DBusTimeout *timeout, 154 dbus_bool_t enabled) 155 { 156 timeout->enabled = enabled != FALSE; 157 } 158 159 160 /** 161 * @typedef DBusTimeoutList 162 * 163 * Opaque data type representing a list of timeouts 164 * and a set of DBusAddTimeoutFunction/DBusRemoveTimeoutFunction. 165 * Automatically handles removing/re-adding timeouts 166 * when the DBusAddTimeoutFunction is updated or changed. 167 * Holds a reference count to each timeout. 168 * 169 */ 170 171 /** 172 * DBusTimeoutList implementation details. All fields 173 * are private. 174 * 175 */ 176 struct DBusTimeoutList 177 { 178 DBusList *timeouts; /**< Timeout objects. */ 179 180 DBusAddTimeoutFunction add_timeout_function; /**< Callback for adding a timeout. */ 181 DBusRemoveTimeoutFunction remove_timeout_function; /**< Callback for removing a timeout. */ 182 DBusTimeoutToggledFunction timeout_toggled_function; /**< Callback when timeout is enabled/disabled or changes interval */ 183 void *timeout_data; /**< Data for timeout callbacks */ 184 DBusFreeFunction timeout_free_data_function; /**< Free function for timeout callback data */ 185 }; 186 187 /** 188 * Creates a new timeout list. Returns #NULL if insufficient 189 * memory exists. 190 * 191 * @returns the new timeout list, or #NULL on failure. 192 */ 193 DBusTimeoutList* 194 _dbus_timeout_list_new (void) 195 { 196 DBusTimeoutList *timeout_list; 197 198 timeout_list = dbus_new0 (DBusTimeoutList, 1); 199 if (timeout_list == NULL) 200 return NULL; 201 202 return timeout_list; 203 } 204 205 /** 206 * Frees a DBusTimeoutList. 207 * 208 * @param timeout_list the timeout list. 209 */ 210 void 211 _dbus_timeout_list_free (DBusTimeoutList *timeout_list) 212 { 213 /* free timeout_data and remove timeouts as a side effect */ 214 _dbus_timeout_list_set_functions (timeout_list, 215 NULL, NULL, NULL, NULL, NULL); 216 217 _dbus_list_foreach (&timeout_list->timeouts, 218 (DBusForeachFunction) _dbus_timeout_unref, 219 NULL); 220 _dbus_list_clear (&timeout_list->timeouts); 221 222 dbus_free (timeout_list); 223 } 224 225 /** 226 * Sets the timeout functions. This function is the "backend" 227 * for dbus_connection_set_timeout_functions(). 228 * 229 * @param timeout_list the timeout list 230 * @param add_function the add timeout function. 231 * @param remove_function the remove timeout function. 232 * @param toggled_function toggle notify function, or #NULL 233 * @param data the data for those functions. 234 * @param free_data_function the function to free the data. 235 * @returns #FALSE if no memory 236 * 237 */ 238 dbus_bool_t 239 _dbus_timeout_list_set_functions (DBusTimeoutList *timeout_list, 240 DBusAddTimeoutFunction add_function, 241 DBusRemoveTimeoutFunction remove_function, 242 DBusTimeoutToggledFunction toggled_function, 243 void *data, 244 DBusFreeFunction free_data_function) 245 { 246 /* Add timeouts with the new function, failing on OOM */ 247 if (add_function != NULL) 248 { 249 DBusList *link; 250 251 link = _dbus_list_get_first_link (&timeout_list->timeouts); 252 while (link != NULL) 253 { 254 DBusList *next = _dbus_list_get_next_link (&timeout_list->timeouts, 255 link); 256 257 if (!(* add_function) (link->data, data)) 258 { 259 /* remove it all again and return FALSE */ 260 DBusList *link2; 261 262 link2 = _dbus_list_get_first_link (&timeout_list->timeouts); 263 while (link2 != link) 264 { 265 DBusList *next = _dbus_list_get_next_link (&timeout_list->timeouts, 266 link2); 267 268 (* remove_function) (link2->data, data); 269 270 link2 = next; 271 } 272 273 return FALSE; 274 } 275 276 link = next; 277 } 278 } 279 280 /* Remove all current timeouts from previous timeout handlers */ 281 282 if (timeout_list->remove_timeout_function != NULL) 283 { 284 _dbus_list_foreach (&timeout_list->timeouts, 285 (DBusForeachFunction) timeout_list->remove_timeout_function, 286 timeout_list->timeout_data); 287 } 288 289 if (timeout_list->timeout_free_data_function != NULL) 290 (* timeout_list->timeout_free_data_function) (timeout_list->timeout_data); 291 292 timeout_list->add_timeout_function = add_function; 293 timeout_list->remove_timeout_function = remove_function; 294 timeout_list->timeout_toggled_function = toggled_function; 295 timeout_list->timeout_data = data; 296 timeout_list->timeout_free_data_function = free_data_function; 297 298 return TRUE; 299 } 300 301 /** 302 * Adds a new timeout to the timeout list, invoking the 303 * application DBusAddTimeoutFunction if appropriate. 304 * 305 * @param timeout_list the timeout list. 306 * @param timeout the timeout to add. 307 * @returns #TRUE on success, #FALSE If no memory. 308 */ 309 dbus_bool_t 310 _dbus_timeout_list_add_timeout (DBusTimeoutList *timeout_list, 311 DBusTimeout *timeout) 312 { 313 if (!_dbus_list_append (&timeout_list->timeouts, timeout)) 314 return FALSE; 315 316 _dbus_timeout_ref (timeout); 317 318 if (timeout_list->add_timeout_function != NULL) 319 { 320 if (!(* timeout_list->add_timeout_function) (timeout, 321 timeout_list->timeout_data)) 322 { 323 _dbus_list_remove_last (&timeout_list->timeouts, timeout); 324 _dbus_timeout_unref (timeout); 325 return FALSE; 326 } 327 } 328 329 return TRUE; 330 } 331 332 /** 333 * Removes a timeout from the timeout list, invoking the 334 * application's DBusRemoveTimeoutFunction if appropriate. 335 * 336 * @param timeout_list the timeout list. 337 * @param timeout the timeout to remove. 338 */ 339 void 340 _dbus_timeout_list_remove_timeout (DBusTimeoutList *timeout_list, 341 DBusTimeout *timeout) 342 { 343 if (!_dbus_list_remove (&timeout_list->timeouts, timeout)) 344 _dbus_assert_not_reached ("Nonexistent timeout was removed"); 345 346 if (timeout_list->remove_timeout_function != NULL) 347 (* timeout_list->remove_timeout_function) (timeout, 348 timeout_list->timeout_data); 349 350 _dbus_timeout_unref (timeout); 351 } 352 353 /** 354 * Sets a timeout to the given enabled state, invoking the 355 * application's DBusTimeoutToggledFunction if appropriate. 356 * 357 * @param timeout_list the timeout list. 358 * @param timeout the timeout to toggle. 359 * @param enabled #TRUE to enable 360 */ 361 void 362 _dbus_timeout_list_toggle_timeout (DBusTimeoutList *timeout_list, 363 DBusTimeout *timeout, 364 dbus_bool_t enabled) 365 { 366 enabled = !!enabled; 367 368 if (enabled == timeout->enabled) 369 return; 370 371 timeout->enabled = enabled; 372 373 if (timeout_list->timeout_toggled_function != NULL) 374 (* timeout_list->timeout_toggled_function) (timeout, 375 timeout_list->timeout_data); 376 } 377 378 /** @} */ 379 380 /** 381 * @defgroup DBusTimeout DBusTimeout 382 * @ingroup DBus 383 * @brief Object representing a timeout 384 * 385 * Types and functions related to DBusTimeout. A timeout 386 * represents a timeout that the main loop needs to monitor, 387 * as in Qt's QTimer or GLib's g_timeout_add(). 388 * 389 * Use dbus_connection_set_timeout_functions() or dbus_server_set_timeout_functions() 390 * to be notified when libdbus needs to add or remove timeouts. 391 * 392 * @{ 393 */ 394 395 396 /** 397 * @typedef DBusTimeout 398 * 399 * Opaque object representing a timeout. 400 */ 401 402 /** 403 * Gets the timeout interval. The dbus_timeout_handle() 404 * should be called each time this interval elapses, 405 * starting after it elapses once. 406 * 407 * The interval may change during the life of the 408 * timeout; if so, the timeout will be disabled and 409 * re-enabled (calling the "timeout toggled function") 410 * to notify you of the change. 411 * 412 * @param timeout the DBusTimeout object. 413 * @returns the interval in milliseconds. 414 */ 415 int 416 dbus_timeout_get_interval (DBusTimeout *timeout) 417 { 418 return timeout->interval; 419 } 420 421 /** 422 * Gets data previously set with dbus_timeout_set_data() 423 * or #NULL if none. 424 * 425 * @param timeout the DBusTimeout object. 426 * @returns previously-set data. 427 */ 428 void* 429 dbus_timeout_get_data (DBusTimeout *timeout) 430 { 431 return timeout->data; 432 } 433 434 /** 435 * Sets data which can be retrieved with dbus_timeout_get_data(). 436 * Intended for use by the DBusAddTimeoutFunction and 437 * DBusRemoveTimeoutFunction to store their own data. For example with 438 * Qt you might store the QTimer for this timeout and with GLib 439 * you might store a g_timeout_add result id. 440 * 441 * @param timeout the DBusTimeout object. 442 * @param data the data. 443 * @param free_data_function function to be called to free the data. 444 */ 445 void 446 dbus_timeout_set_data (DBusTimeout *timeout, 447 void *data, 448 DBusFreeFunction free_data_function) 449 { 450 if (timeout->free_data_function != NULL) 451 (* timeout->free_data_function) (timeout->data); 452 453 timeout->data = data; 454 timeout->free_data_function = free_data_function; 455 } 456 457 /** 458 * Calls the timeout handler for this timeout. 459 * This function should be called when the timeout 460 * occurs. 461 * 462 * If this function returns #FALSE, then there wasn't 463 * enough memory to handle the timeout. Typically just 464 * letting the timeout fire again next time it naturally 465 * times out is an adequate response to that problem, 466 * but you could try to do more if you wanted. 467 * 468 * @param timeout the DBusTimeout object. 469 * @returns #FALSE if there wasn't enough memory 470 */ 471 dbus_bool_t 472 dbus_timeout_handle (DBusTimeout *timeout) 473 { 474 return (* timeout->handler) (timeout->handler_data); 475 } 476 477 478 /** 479 * Returns whether a timeout is enabled or not. If not 480 * enabled, it should not be polled by the main loop. 481 * 482 * @param timeout the DBusTimeout object 483 * @returns #TRUE if the timeout is enabled 484 */ 485 dbus_bool_t 486 dbus_timeout_get_enabled (DBusTimeout *timeout) 487 { 488 return timeout->enabled; 489 } 490 491 /** @} end public API docs */ 492