diff options
| author | Garrett D'Amore <garrett@damore.org> | 2025-04-27 23:35:25 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2025-04-27 23:35:25 -0700 |
| commit | 7bb5ab9c4f70c9fa0a67a22c4aee83b0109318c4 (patch) | |
| tree | 5a3036d609404ee5218b6189a89799e70f4623df /src/core/pollable.c | |
| parent | 70ae513e4dda50864f7d45b6676549ed5246144d (diff) | |
| download | nng-7bb5ab9c4f70c9fa0a67a22c4aee83b0109318c4.tar.gz nng-7bb5ab9c4f70c9fa0a67a22c4aee83b0109318c4.tar.bz2 nng-7bb5ab9c4f70c9fa0a67a22c4aee83b0109318c4.zip | |
Converted property functions to use nng_err.
Diffstat (limited to 'src/core/pollable.c')
| -rw-r--r-- | src/core/pollable.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/core/pollable.c b/src/core/pollable.c index 8e5ad7c1..d07c9b10 100644 --- a/src/core/pollable.c +++ b/src/core/pollable.c @@ -14,7 +14,7 @@ // atomically and use nni_atomic_cas64, to be lock free. #define WFD(fds) ((int) ((fds) &0xffffffffu)) #define RFD(fds) ((int) (((fds) >> 32u) & 0xffffffffu)) -#define FD_JOIN(wfd, rfd) ((uint64_t)(wfd) + ((uint64_t)(rfd) << 32u)) +#define FD_JOIN(wfd, rfd) ((uint64_t) (wfd) + ((uint64_t) (rfd) << 32u)) void nni_pollable_init(nni_pollable *p) @@ -60,7 +60,7 @@ nni_pollable_clear(nni_pollable *p) } } -int +nng_err nni_pollable_getfd(nni_pollable *p, int *fdp) { if (p == NULL) { @@ -75,7 +75,7 @@ nni_pollable_getfd(nni_pollable *p, int *fdp) if ((fds = nni_atomic_get64(&p->p_fds)) != (uint64_t) -1) { *fdp = RFD(fds); - return (0); + return (NNG_OK); } if ((rv = nni_plat_pipe_open(&wfd, &rfd)) != 0) { return (rv); @@ -87,7 +87,7 @@ nni_pollable_getfd(nni_pollable *p, int *fdp) nni_plat_pipe_raise(wfd); } *fdp = rfd; - return (0); + return (NNG_OK); } // Someone beat us. Close ours, and try again. |