GTimeVal last;
/* When this timer will next trigger */
GTimeVal timeout;
+
+ /* Only allow a timer's function to fire once per run through the list,
+ so that it doesn't get locked in there forever */
+ gboolean fired;
};
struct _ObMainLoopSignalHandlerType
{
GSList *it;
+ ob_debug("removing data 0x%x\n", data);
for (it = loop->timers; it; it = g_slist_next(it)) {
ObMainLoopTimer *t = it->data;
- if (t->func == handler &&
- (t->equal ? t->equal(t->data, data) : (t->data == data)))
- {
+ if (t->func == handler && t->equal(t->data, data)) {
+ ob_debug("found data 0x%x\n", data);
t->del_me = TRUE;
if (cancel_dest)
t->destroy = NULL;
g_get_current_time(&loop->now);
+ /* do this first, cuz the list can get reordered */
+ for (it = loop->timers; it; it = g_slist_next(it)) {
+ ObMainLoopTimer *curr = it->data;
+ curr->fired = FALSE;
+ }
+
for (it = loop->timers; it; it = next) {
ObMainLoopTimer *curr;
if (timecompare(&NEAREST_TIMEOUT(loop), &loop->now) < 0)
break;
+ /* don't let it fire again this time around. otherwise, if the first
+ timer in the queue becomes ready, we'll loop on the later ones
+ forever if they repeat */
+ if (curr->fired)
+ continue;
+
/* we set the last fired time to delay msec after the previous firing,
then re-insert. timers maintain their order and may trigger more
than once if they've waited more than one delay's worth of time.
g_free(curr);
}
+ curr->fired = TRUE;
fired = TRUE;
}
ping_send(t);
ping_targets = g_slist_prepend(ping_targets, t);
ob_main_loop_timeout_add(ob_main_loop, PING_TIMEOUT, ping_timeout,
- t, NULL, NULL);
+ t, g_direct_equal, NULL);
if (!active) {
active = TRUE;