diff options
| author | Laurent Bercot <ska-skaware@skarnet.org> | 2017-11-25 14:15:08 +0000 |
|---|---|---|
| committer | Laurent Bercot <ska-skaware@skarnet.org> | 2017-11-25 14:15:08 +0000 |
| commit | 7ae80340d621d6add95f6c7d9e5e7a0e921f0b42 (patch) | |
| tree | fdf6c4edee23a85248dc448c347d7056a0bebfff /src/libskabus/skabus_rpc_get.c | |
| parent | 38c9492b4fb971fe08e4ac0167e06e5dccb3eb2e (diff) | |
| download | skabus-7ae80340d621d6add95f6c7d9e5e7a0e921f0b42.tar.gz | |
Finish skabus_rpc doc, add missing functions
Diffstat (limited to 'src/libskabus/skabus_rpc_get.c')
| -rw-r--r-- | src/libskabus/skabus_rpc_get.c | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/libskabus/skabus_rpc_get.c b/src/libskabus/skabus_rpc_get.c index d780211..132597a 100644 --- a/src/libskabus/skabus_rpc_get.c +++ b/src/libskabus/skabus_rpc_get.c @@ -2,6 +2,7 @@ #include <stdint.h> #include <errno.h> +#include <skalibs/error.h> #include <skalibs/gensetdyn.h> #include <skalibs/avltree.h> #include <skabus/rpc.h> @@ -10,9 +11,14 @@ int skabus_rpc_get (skabus_rpc_t *a, uint64_t serial, int *result, unixmessage_t { uint32_t id ; skabus_rpc_qinfo_t *p ; - if (!avltree_search(&a->qmap, &serial, &id)) return 0 ; + if (!avltree_search(&a->qmap, &serial, &id)) + { + if (errno == ESRCH) errno = EINVAL ; + return -1 ; + } p = GENSETDYN_P(skabus_rpc_qinfo_t, &a->q, id) ; - if (p->status) return (errno = p->status, 0) ; + if (p->status) + return error_isagain(p->status) ? 0 : (errno = p->status, -1) ; *result = (int)(unsigned char)p->result ; *m = p->message ; return 1 ; |
