aboutsummaryrefslogtreecommitdiff
path: root/src/protocol/pipeline0/pull.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/protocol/pipeline0/pull.c')
-rw-r--r--src/protocol/pipeline0/pull.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/protocol/pipeline0/pull.c b/src/protocol/pipeline0/pull.c
index ccc1ef40..5e0a9d00 100644
--- a/src/protocol/pipeline0/pull.c
+++ b/src/protocol/pipeline0/pull.c
@@ -34,7 +34,7 @@ static void pull0_putq(pull0_pipe *, nni_msg *);
// pull0_sock is our per-socket protocol private structure.
struct pull0_sock {
nni_msgq *urq;
- int raw;
+ bool raw;
};
// pull0_pipe is our per-pipe protocol private structure.
@@ -53,7 +53,7 @@ pull0_sock_init(void **sp, nni_sock *sock)
if ((s = NNI_ALLOC_STRUCT(s)) == NULL) {
return (NNG_ENOMEM);
}
- s->raw = 0;
+ s->raw = false;
s->urq = nni_sock_recvq(sock);
*sp = s;
@@ -184,14 +184,14 @@ static int
pull0_sock_setopt_raw(void *arg, const void *buf, size_t sz)
{
pull0_sock *s = arg;
- return (nni_setopt_int(&s->raw, buf, sz, 0, 1));
+ return (nni_setopt_bool(&s->raw, buf, sz));
}
static int
pull0_sock_getopt_raw(void *arg, void *buf, size_t *szp)
{
pull0_sock *s = arg;
- return (nni_getopt_int(s->raw, buf, szp));
+ return (nni_getopt_bool(s->raw, buf, szp));
}
static void