mirrors/foot
1
0
Fork 0
mirror of https://codeberg.org/dnkl/foot.git synced 2026-03-13 05:33:51 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fdm: add support for hooks

Browse source 
Hooks are functions executed just before going into a poll(). Or just
after executing all FD handlers, if you like.
This commit is contained in:
Daniel Eklöf 2020-01-04 19:48:15 +01:00
parent 14d897ac75
commit a3c18e72f5
No known key found for this signature in database
GPG key ID: 5BBD4992C116573F
2 changed files with 53 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

49
fdm.c
View file

@ -21,11 +21,17 @@ struct handler {
bool deleted; bool deleted;
}; };
struct hook {
fdm_hook_t callback;
void *callback_data;
};
struct fdm { struct fdm {
int epoll_fd; int epoll_fd;
bool is_polling; bool is_polling;
tll(struct handler *) fds; tll(struct handler *) fds;
tll(struct handler *) deferred_delete; tll(struct handler *) deferred_delete;
tll(struct hook) hooks;
}; };
struct fdm * struct fdm *
@ -43,6 +49,7 @@ fdm_init(void)
.is_polling = false, .is_polling = false,
.fds = tll_init(), .fds = tll_init(),
.deferred_delete = tll_init(), .deferred_delete = tll_init(),
.hooks = tll_init(),
}; };
return fdm; return fdm;
} }
@ -56,11 +63,16 @@ fdm_destroy(struct fdm *fdm)
if (tll_length(fdm->fds) > 0) if (tll_length(fdm->fds) > 0)
LOG_WARN("FD list not empty"); LOG_WARN("FD list not empty");
if (tll_length(fdm->hooks) > 0)
LOG_WARN("hook list not empty");
assert(tll_length(fdm->fds) == 0); assert(tll_length(fdm->fds) == 0);
assert(tll_length(fdm->deferred_delete) == 0); assert(tll_length(fdm->deferred_delete) == 0);
assert(tll_length(fdm->hooks) == 0);
tll_free(fdm->fds); tll_free(fdm->fds);
tll_free(fdm->deferred_delete); tll_free(fdm->deferred_delete);
tll_free(fdm->hooks);
close(fdm->epoll_fd); close(fdm->epoll_fd);
free(fdm); free(fdm);
} }
@ -195,6 +207,37 @@ fdm_event_del(struct fdm *fdm, int fd, int events)
return false; return false;
} }
bool
fdm_hook_add(struct fdm *fdm, fdm_hook_t hook, void *data)
{
#if defined(_DEBUG)
tll_foreach(fdm->hooks, it) {
if (it->item.callback == hook) {
LOG_ERR("hook=%p already registered", hook);
return false;
}
}
#endif
tll_push_back(fdm->hooks, ((struct hook){hook, data}));
return true;
}
bool
fdm_hook_del(struct fdm *fdm, fdm_hook_t hook)
{
tll_foreach(fdm->hooks, it) {
if (it->item.callback != hook)
continue;
tll_remove(fdm->hooks, it);
return true;
}
LOG_WARN("hook=%p not registered, hook", hook);
return false;
}
bool bool
fdm_poll(struct fdm *fdm) fdm_poll(struct fdm *fdm)
{ {
@ -204,6 +247,12 @@ fdm_poll(struct fdm *fdm)
return false; return false;
} }
tll_foreach(fdm->hooks, it) {
LOG_DBG("executing hook %p(fdm=%p, data=%p)",
it->item.callback, fdm, it->item.callback_data);
it->item.callback(fdm, it->item.callback_data);
}
struct epoll_event events[tll_length(fdm->fds)]; struct epoll_event events[tll_length(fdm->fds)];
int r = epoll_wait(fdm->epoll_fd, events, tll_length(fdm->fds), -1); int r = epoll_wait(fdm->epoll_fd, events, tll_length(fdm->fds), -1);

4
fdm.h
View file

@ -5,6 +5,7 @@
struct fdm; struct fdm;
typedef bool (*fdm_handler_t)(struct fdm *fdm, int fd, int events, void *data); typedef bool (*fdm_handler_t)(struct fdm *fdm, int fd, int events, void *data);
typedef void (*fdm_hook_t)(struct fdm *fdm, void *data);
struct fdm *fdm_init(void); struct fdm *fdm_init(void);
void fdm_destroy(struct fdm *fdm); void fdm_destroy(struct fdm *fdm);
@ -16,4 +17,7 @@ bool fdm_del_no_close(struct fdm *fdm, int fd);
bool fdm_event_add(struct fdm *fdm, int fd, int events); bool fdm_event_add(struct fdm *fdm, int fd, int events);
bool fdm_event_del(struct fdm *fdm, int fd, int events); bool fdm_event_del(struct fdm *fdm, int fd, int events);
bool fdm_hook_add(struct fdm *fdm, fdm_hook_t hook, void *data);
bool fdm_hook_del(struct fdm *fdm, fdm_hook_t hook);
bool fdm_poll(struct fdm *fdm); bool fdm_poll(struct fdm *fdm);