1 /* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */
2 /* expirelist.c List of items that expire
4 * Copyright (C) 2003 Red Hat, Inc.
6 * Licensed under the Academic Free License version 2.1
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.
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.
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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
24 #include "expirelist.h"
26 #include <dbus/dbus-internals.h>
27 #include <dbus/dbus-mainloop.h>
28 #include <dbus/dbus-timeout.h>
32 DBusList *items; /**< List of BusExpireItem */
35 BusExpireFunc expire_func;
37 int expire_after; /**< Expire after milliseconds (thousandths) */
40 static dbus_bool_t expire_timeout_handler (void *data);
43 call_timeout_callback (DBusTimeout *timeout,
46 /* can return FALSE on OOM but we just let it fire again later */
47 dbus_timeout_handle (timeout);
51 bus_expire_list_new (DBusLoop *loop,
53 BusExpireFunc expire_func,
58 list = dbus_new0 (BusExpireList, 1);
62 list->expire_func = expire_func;
65 list->expire_after = expire_after;
67 list->timeout = _dbus_timeout_new (100, /* irrelevant */
68 expire_timeout_handler,
70 if (list->timeout == NULL)
73 _dbus_timeout_set_enabled (list->timeout, FALSE);
75 if (!_dbus_loop_add_timeout (list->loop,
77 call_timeout_callback, NULL, NULL))
84 _dbus_timeout_unref (list->timeout);
92 bus_expire_list_free (BusExpireList *list)
94 _dbus_assert (list->items == NULL);
96 _dbus_loop_remove_timeout (list->loop, list->timeout,
97 call_timeout_callback, NULL);
99 _dbus_timeout_unref (list->timeout);
105 bus_expire_timeout_set_interval (DBusTimeout *timeout,
108 if (next_interval >= 0)
110 _dbus_timeout_set_interval (timeout,
112 _dbus_timeout_set_enabled (timeout, TRUE);
114 _dbus_verbose ("Enabled an expire timeout with interval %d\n",
117 else if (dbus_timeout_get_enabled (timeout))
119 _dbus_timeout_set_enabled (timeout, FALSE);
121 _dbus_verbose ("Disabled an expire timeout\n");
124 _dbus_verbose ("No need to disable this expire timeout\n");
128 bus_expire_list_recheck_immediately (BusExpireList *list)
130 _dbus_verbose ("setting interval on expire list to 0 for immediate recheck\n");
132 bus_expire_timeout_set_interval (list->timeout, 0);
136 do_expiration_with_current_time (BusExpireList *list,
145 link = _dbus_list_get_first_link (&list->items);
148 DBusList *next = _dbus_list_get_next_link (&list->items, link);
154 elapsed = ELAPSED_MILLISECONDS_SINCE (item->added_tv_sec,
158 if (elapsed >= (double) list->expire_after)
160 _dbus_verbose ("Expiring an item %p\n", item);
162 /* If the expire function fails, we just end up expiring
163 * this item next time we walk through the list. This would
164 * be an indeterminate time normally, so we set up the
165 * next_interval to be "shortly" (just enough to avoid
168 if (!(* list->expire_func) (list, link, list->data))
170 next_interval = _dbus_get_oom_wait ();
176 /* We can end the loop, since the connections are in oldest-first order */
177 next_interval = ((double)list->expire_after) - elapsed;
178 _dbus_verbose ("Item %p expires in %d milliseconds\n",
179 item, next_interval);
187 return next_interval;
191 bus_expirelist_expire (BusExpireList *list)
197 if (list->items != NULL)
199 long tv_sec, tv_usec;
201 _dbus_get_current_time (&tv_sec, &tv_usec);
203 next_interval = do_expiration_with_current_time (list, tv_sec, tv_usec);
206 bus_expire_timeout_set_interval (list->timeout, next_interval);
210 expire_timeout_handler (void *data)
212 BusExpireList *list = data;
214 _dbus_verbose ("Running %s\n", _DBUS_FUNCTION_NAME);
216 /* note that this may remove the timeout */
217 bus_expirelist_expire (list);
223 bus_expire_list_remove_link (BusExpireList *list,
226 _dbus_list_remove_link (&list->items,
231 bus_expire_list_remove (BusExpireList *list,
234 return _dbus_list_remove (&list->items,
239 bus_expire_list_unlink (BusExpireList *list,
242 _dbus_list_unlink (&list->items, link);
246 bus_expire_list_add (BusExpireList *list,
249 return _dbus_list_prepend (&list->items,
254 bus_expire_list_add_link (BusExpireList *list,
257 _dbus_assert (link->data != NULL);
259 _dbus_list_prepend_link (&list->items,
264 bus_expire_list_get_first_link (BusExpireList *list)
266 return _dbus_list_get_first_link (&list->items);
270 bus_expire_list_get_next_link (BusExpireList *list,
273 return _dbus_list_get_next_link (&list->items,
278 bus_expire_list_contains_item (BusExpireList *list,
281 return _dbus_list_find_last (&list->items, item) != NULL;
284 #ifdef DBUS_BUILD_TESTS
293 test_expire_func (BusExpireList *list,
299 t = (TestExpireItem*) link->data;
301 t->expire_count += 1;
307 time_add_milliseconds (long *tv_sec,
311 *tv_sec = *tv_sec + milliseconds / 1000;
312 *tv_usec = *tv_usec + milliseconds * 1000;
313 if (*tv_usec >= 1000000)
321 bus_expire_list_test (const DBusString *test_data_dir)
325 long tv_sec, tv_usec;
326 long tv_sec_not_expired, tv_usec_not_expired;
327 long tv_sec_expired, tv_usec_expired;
328 long tv_sec_past, tv_usec_past;
329 TestExpireItem *item;
331 dbus_bool_t result = FALSE;
334 loop = _dbus_loop_new ();
335 _dbus_assert (loop != NULL);
337 #define EXPIRE_AFTER 100
339 list = bus_expire_list_new (loop, EXPIRE_AFTER,
340 test_expire_func, NULL);
341 _dbus_assert (list != NULL);
343 _dbus_get_current_time (&tv_sec, &tv_usec);
345 tv_sec_not_expired = tv_sec;
346 tv_usec_not_expired = tv_usec;
347 time_add_milliseconds (&tv_sec_not_expired,
348 &tv_usec_not_expired, EXPIRE_AFTER - 1);
350 tv_sec_expired = tv_sec;
351 tv_usec_expired = tv_usec;
352 time_add_milliseconds (&tv_sec_expired,
353 &tv_usec_expired, EXPIRE_AFTER);
356 tv_sec_past = tv_sec - 1;
357 tv_usec_past = tv_usec;
359 item = dbus_new0 (TestExpireItem, 1);
364 item->item.added_tv_sec = tv_sec;
365 item->item.added_tv_usec = tv_usec;
366 if (!bus_expire_list_add (list, &item->item))
367 _dbus_assert_not_reached ("out of memory");
370 do_expiration_with_current_time (list, tv_sec_not_expired,
371 tv_usec_not_expired);
372 _dbus_assert (item->expire_count == 0);
373 _dbus_verbose ("next_interval = %d\n", next_interval);
374 _dbus_assert (next_interval == 1);
377 do_expiration_with_current_time (list, tv_sec_expired,
379 _dbus_assert (item->expire_count == 1);
380 _dbus_verbose ("next_interval = %d\n", next_interval);
381 _dbus_assert (next_interval == -1);
384 do_expiration_with_current_time (list, tv_sec_past,
386 _dbus_assert (item->expire_count == 1);
387 _dbus_verbose ("next_interval = %d\n", next_interval);
388 _dbus_assert (next_interval == 1000 + EXPIRE_AFTER);
390 bus_expire_list_remove (list, &item->item);
393 bus_expire_list_free (list);
394 _dbus_loop_unref (loop);
402 #endif /* DBUS_BUILD_TESTS */