summaryrefslogtreecommitdiff
path: root/src/include
diff options
context:
space:
mode:
authorLaurent Bercot <ska-skaware@skarnet.org>2017-07-27 20:21:38 +0000
committerLaurent Bercot <ska-skaware@skarnet.org>2017-07-27 20:21:38 +0000
commit29f104d8e0b46595d8e7a5d315a9ec3afdf26d43 (patch)
tree469f5e58c4bd89f41f33e4f605862e8a25e8dfb8 /src/include
parentd7588f1fa9d007184163fe5863f87be41d659177 (diff)
downloadskalibs-29f104d8e0b46595d8e7a5d315a9ec3afdf26d43.tar.xz
Add unixmessage_receiver_hasmsginbuf, fix unixmessage_handle
Diffstat (limited to 'src/include')
-rw-r--r--src/include/skalibs/unixmessage.h4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/include/skalibs/unixmessage.h b/src/include/skalibs/unixmessage.h
index 94f62c6..a246cd6 100644
--- a/src/include/skalibs/unixmessage.h
+++ b/src/include/skalibs/unixmessage.h
@@ -43,7 +43,7 @@ extern unixmessage_v_t const unixmessage_v_zero ;
#define UNIXMESSAGE_MAXFDS 255
#define UNIXMESSAGE_BUFSIZE 2048
#define UNIXMESSAGE_AUXBUFSIZE (sizeof(int) * UNIXMESSAGE_MAXFDS + 1)
-#define UNIXMESSAGE_MAXREADS 4096
+#define UNIXMESSAGE_MAXREADS 128
/* Sender */
@@ -125,6 +125,8 @@ extern void unixmessage_receiver_free (unixmessage_receiver_t *) ;
#define unixmessage_receiver_isempty(b) (cbuffer_isempty(&(b)->mainb) && cbuffer_isempty(&(b)->auxb))
#define unixmessage_receiver_isfull(b) (cbuffer_isfull(&(b)->mainb) || cbuffer_isfull(&(b)->auxb))
+extern int unixmessage_receiver_hasmsginbuf (unixmessage_receiver_t const *) ;
+
extern int unixmessage_receive (unixmessage_receiver_t *, unixmessage_t *) ;
extern int unixmessage_timed_receive (unixmessage_receiver_t *, unixmessage_t *, tain_t const *, tain_t *) ;
#define unixmessage_timed_receive_g(receiver, msg, deadline) unixmessage_timed_receive(receiver, msg, (deadline), &STAMP)