From 29f104d8e0b46595d8e7a5d315a9ec3afdf26d43 Mon Sep 17 00:00:00 2001 From: Laurent Bercot Date: Thu, 27 Jul 2017 20:21:38 +0000 Subject: Add unixmessage_receiver_hasmsginbuf, fix unixmessage_handle --- src/include/skalibs/unixmessage.h | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'src/include') 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) -- cgit v1.3.1