xfnw
/
solanum
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

librb/event: delete indirectly via a dead flag 

This avoids an issue where deleting an event inside the handler of a
different event puts the event iteration in an invalid state.
This commit is contained in:
Ed Kellett 2019-08-03 06:41:58 +01:00
parent 9ac0390734
commit 3576d1b482
No known key found for this signature in database
GPG Key ID: CB9986DEF342FABC
2 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
librb/include/event-int.h
View File

@ -33,5 +33,6 @@ struct ev_entry
time_t next;
void *data;
void *comm_ptr;
int dead;
};
void rb_event_io_register_all(void);

13
librb/src/event.c
View File

@ -87,6 +87,7 @@ rb_event_add_common(const char *name, EVH * func, void *arg, time_t when, time_t
ev->when = rb_current_time() + when;
ev->next = when;
ev->frequency = frequency;
ev->dead = 0;
if((ev->when < event_time_min) || (event_time_min == -1))
event_time_min = ev->when;
@ -142,10 +143,9 @@ rb_event_delete(struct ev_entry *ev)
if(ev == NULL)
return;
rb_dlinkDelete(&ev->node, &event_list);
ev->dead = 1;
rb_io_unsched_event(ev);
rb_free(ev->name);
rb_free(ev);
}
/*
@ -228,6 +228,13 @@ rb_event_run(void)
RB_DLINK_FOREACH_SAFE(ptr, next, event_list.head)
{
ev = ptr->data;
if (ev->dead)
{
rb_dlinkDelete(&ev->node, &event_list);
rb_free(ev->name);
rb_free(ev);
continue;
}
if(ev->when <= rb_current_time())
{
rb_strlcpy(last_event_ran, ev->name, sizeof(last_event_ran));