1 /* -*- mode: C; c-file-style: "gnu" -*- */
2 /* expirelist.c List of items that expire
4 * Copyright (C) 2003 Red Hat, Inc.
6 * Licensed under the Academic Free License version 1.2
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>
30 static dbus_bool_t expire_timeout_handler (void *data);
33 call_timeout_callback (DBusTimeout *timeout,
36 /* can return FALSE on OOM but we just let it fire again later */
37 dbus_timeout_handle (timeout);
41 bus_expire_list_new (DBusLoop *loop,
43 BusExpireFunc expire_func,
48 list = dbus_new0 (BusExpireList, 1);
52 list->expire_func = expire_func;
55 list->expire_after = expire_after;
57 list->timeout = _dbus_timeout_new (100, /* irrelevant */
58 expire_timeout_handler,
60 if (list->timeout == NULL)
63 _dbus_timeout_set_enabled (list->timeout, FALSE);
65 if (!_dbus_loop_add_timeout (list->loop,
67 call_timeout_callback, NULL, NULL))
74 _dbus_timeout_unref (list->timeout);
82 bus_expire_list_free (BusExpireList *list)
84 _dbus_assert (list->n_items == 0);
85 _dbus_assert (list->items == NULL);
87 _dbus_loop_remove_timeout (list->loop, list->timeout,
88 call_timeout_callback, NULL);
90 _dbus_timeout_unref (list->timeout);
96 bus_expire_timeout_set_interval (DBusTimeout *timeout,
99 if (next_interval >= 0)
101 _dbus_timeout_set_interval (timeout,
103 _dbus_timeout_set_enabled (timeout, TRUE);
105 _dbus_verbose ("Enabled expire timeout with interval %d\n",
108 else if (dbus_timeout_get_enabled (timeout))
110 _dbus_timeout_set_enabled (timeout, FALSE);
112 _dbus_verbose ("Disabled expire timeout\n");
115 _dbus_verbose ("No need to disable expire timeout\n");
119 do_expiration_with_current_time (BusExpireList *list,
128 link = _dbus_list_get_first_link (&list->items);
131 DBusList *next = _dbus_list_get_next_link (&list->items, link);
137 elapsed = ELAPSED_MILLISECONDS_SINCE (item->added_tv_sec,
141 if (elapsed >= (double) list->expire_after)
143 _dbus_verbose ("Expiring an item %p\n", item);
144 (* list->expire_func) (list, item, list->data);
148 /* We can end the loop, since the connections are in oldest-first order */
149 next_interval = ((double)list->expire_after) - elapsed;
150 _dbus_verbose ("Item %p expires in %d milliseconds\n",
151 item, next_interval);
159 return next_interval;
163 bus_expirelist_expire (BusExpireList *list)
169 if (list->items != NULL)
171 long tv_sec, tv_usec;
173 _dbus_get_current_time (&tv_sec, &tv_usec);
175 next_interval = do_expiration_with_current_time (list, tv_sec, tv_usec);
178 bus_expire_timeout_set_interval (list->timeout, next_interval);
182 expire_timeout_handler (void *data)
184 BusExpireList *list = data;
186 _dbus_verbose ("Running %s\n", _DBUS_FUNCTION_NAME);
188 /* note that this may remove the timeout */
189 bus_expirelist_expire (list);
194 #ifdef DBUS_BUILD_TESTS
203 test_expire_func (BusExpireList *list,
209 t = (TestExpireItem*) item;
211 t->expire_count += 1;
215 time_add_milliseconds (long *tv_sec,
219 *tv_sec = *tv_sec + milliseconds / 1000;
220 *tv_usec = *tv_usec + milliseconds * 1000;
221 if (*tv_usec >= 1000000)
229 bus_expire_list_test (const DBusString *test_data_dir)
233 long tv_sec, tv_usec;
234 long tv_sec_not_expired, tv_usec_not_expired;
235 long tv_sec_expired, tv_usec_expired;
236 long tv_sec_past, tv_usec_past;
237 TestExpireItem *item;
240 loop = _dbus_loop_new ();
241 _dbus_assert (loop != NULL);
243 #define EXPIRE_AFTER 100
245 list = bus_expire_list_new (loop, EXPIRE_AFTER,
246 test_expire_func, NULL);
247 _dbus_assert (list != NULL);
249 _dbus_get_current_time (&tv_sec, &tv_usec);
251 tv_sec_not_expired = tv_sec;
252 tv_usec_not_expired = tv_usec;
253 time_add_milliseconds (&tv_sec_not_expired,
254 &tv_usec_not_expired, EXPIRE_AFTER - 1);
256 tv_sec_expired = tv_sec;
257 tv_usec_expired = tv_usec;
258 time_add_milliseconds (&tv_sec_expired,
259 &tv_usec_expired, EXPIRE_AFTER);
262 tv_sec_past = tv_sec - 1;
263 tv_usec_past = tv_usec;
265 item = dbus_new0 (TestExpireItem, 1);
267 item->item.added_tv_sec = tv_sec;
268 item->item.added_tv_usec = tv_usec;
269 if (!_dbus_list_append (&list->items, item))
270 _dbus_assert_not_reached ("out of memory");
273 do_expiration_with_current_time (list, tv_sec_not_expired,
274 tv_usec_not_expired);
275 _dbus_assert (item->expire_count == 0);
276 _dbus_verbose ("next_interval = %d\n", next_interval);
277 _dbus_assert (next_interval == 1);
280 do_expiration_with_current_time (list, tv_sec_expired,
282 _dbus_assert (item->expire_count == 1);
283 _dbus_verbose ("next_interval = %d\n", next_interval);
284 _dbus_assert (next_interval == -1);
287 do_expiration_with_current_time (list, tv_sec_past,
289 _dbus_assert (item->expire_count == 1);
290 _dbus_verbose ("next_interval = %d\n", next_interval);
291 _dbus_assert (next_interval == 1000 + EXPIRE_AFTER);
293 _dbus_list_clear (&list->items);
296 bus_expire_list_free (list);
297 _dbus_loop_unref (loop);
302 #endif /* DBUS_BUILD_TESTS */