summaryrefslogtreecommitdiff
path: root/src/libs6/ftrigr_check.c
diff options
context:
space:
mode:
authorLaurent Bercot <ska-skaware@skarnet.org>2017-06-14 04:09:00 +0000
committerLaurent Bercot <ska-skaware@skarnet.org>2017-06-14 04:09:00 +0000
commit0445f2a3590f67441602a05fe3924ab677c79ff0 (patch)
tree1a011697fbd92ca53468efe019c8c93c364ad6a8 /src/libs6/ftrigr_check.c
parentf287ac765101f21b530f1a9886e06976c165c922 (diff)
downloads6-0445f2a3590f67441602a05fe3924ab677c79ff0.tar.xz
Add ftrigr_checksa(), rewrite s6_svlisten_loop() around it
- Fixes the race condition hit by permanent failure, i.e. two ftrig events close to each other - Requires storing the sequence of events client-side, so an additional stralloc, bleh - The visible struct ftrigr_s changes, so a major bump is needed -> prepare for 2.6.0.0 - ftrigr_check() is now a trivial wrapper around ftrigr_checksa()
Diffstat (limited to 'src/libs6/ftrigr_check.c')
-rw-r--r--src/libs6/ftrigr_check.c39
1 files changed, 10 insertions, 29 deletions
diff --git a/src/libs6/ftrigr_check.c b/src/libs6/ftrigr_check.c
index 0a7fcdc..30be701 100644
--- a/src/libs6/ftrigr_check.c
+++ b/src/libs6/ftrigr_check.c
@@ -1,39 +1,20 @@
/* ISC license. */
#include <errno.h>
-#include <skalibs/gensetdyn.h>
+#include <skalibs/stralloc.h>
#include <s6/ftrigr.h>
int ftrigr_check (ftrigr_t *a, uint16_t id, char *c)
{
- ftrigr1_t *p ;
- if (!id--) return (errno = EINVAL, -1) ;
- p = GENSETDYN_P(ftrigr1_t, &a->data, id) ;
- if (!p) return (errno = EINVAL, -1) ;
- switch (p->state)
+ stralloc sa = STRALLOC_ZERO ;
+ int r = ftrigr_checksa(a, id, &sa) ;
+
+ if (r && sa.len)
{
- case FR1STATE_WAITACKDATA :
- {
- *c = p->what ;
- *p = ftrigr1_zero ;
- gensetdyn_delete(&a->data, id) ;
- return 1 ;
- }
- case FR1STATE_LISTENING :
- {
- unsigned int r = p->count ;
- if (r) *c = p->what ;
- p->count = 0 ;
- return (int)r ;
- }
- case FR1STATE_WAITACK :
- {
- errno = p->what ;
- *p = ftrigr1_zero ;
- gensetdyn_delete(&a->data, id) ;
- return -1 ;
- }
- default: return (errno = EINVAL, -1) ;
+ int e = errno ;
+ *c = sa.s[sa.len - 1] ;
+ stralloc_free(&sa) ;
+ errno = e ;
}
- return 0 ;
+ return r ;
}