mirrors/Astral
1
0
Fork 0
mirror of https://github.com/Mathewnd/Astral.git synced 2026-10-27 12:48:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

event: support multiple attachments per event

Browse Source
This commit is contained in:
Matheus
2024-09-08 15:31:16 -03:00
parent cdcce89fa5
commit b6806c6065
2 changed files with 24 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kernel-src/fs/pipefs.c
+3 -2
View File
@@ -75,10 +75,11 @@ int pipefs_open(vnode_t **node, int flags, cred_t *cred) {
// and there are either no writers or no readers.
eventlistener_t listener;
EVENT_INITLISTENER(&listener);
if (flags & V_FFLAGS_READ)
if (flags & V_FFLAGS_READ) {
EVENT_ATTACH(&listener, &pipenode->writeopenevent);
else
} else {
EVENT_ATTACH(&listener, &pipenode->readopenevent);
}
INTERNAL_UNLOCK(*node);
error = EVENT_WAIT(&listener, 0);
kernel-src/include/kernel/event.h
+21 -5
View File
@@ -4,22 +4,38 @@
#include <kernel/poll.h>
typedef pollheader_t eventheader_t;
#define EVENT_MAX_ATTACHMENT 5
typedef struct {
polldesc_t polldesc;
polldata_t polldata;
polldata_t polldata[EVENT_MAX_ATTACHMENT];
int current;
} eventlistener_t;
#define EVENT_INITHEADER(e) POLL_INITHEADER(e)
#define EVENT_INITLISTENER(e) { \
poll_initdesc(&(e)->polldesc, 0); \
(e)->polldesc.data = &(e)->polldata; \
(e)->polldata.desc = &(e)->polldesc; \
(e)->polldesc.data = (e)->polldata; \
(e)->current = 0; \
for (int i = 0; i < EVENT_MAX_ATTACHMENT; ++i) \
(e)->polldata[i].desc = &(e)->polldesc; \
}
#define EVENT_ATTACH(e, h) { \
poll_add(h, &(e)->polldata[(e)->current++], POLLPRI); \
if ((e)->current >= EVENT_MAX_ATTACHMENT) { \
/* spin forever to say that there have been too many attachments */ \
/* this should never happen normally and is meant as a way to alert whoever is programming about it */ \
for (;;) asm volatile(""); \
} \
}
#define EVENT_ATTACH(e, h) poll_add(h, &(e)->polldata, POLLPRI)
#define EVENT_WAIT(e, t) poll_dowait(&(e)->polldesc, t)
#define EVENT_SIGNAL(h) poll_event(h, POLLPRI)
#define EVENT_DETACHALL(e) poll_leave(&(e)->polldesc)
#define EVENT_DETACHALL(e) { \
poll_leave(&(e)->polldesc); \
(e)->current = 0; \
}
#endif