diff options
| author | Garrett D'Amore <garrett@damore.org> | 2021-10-27 22:34:41 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2021-11-02 22:56:39 -0700 |
| commit | c42f32722447cc52810b25decee634210f09d70e (patch) | |
| tree | 0e3c460138b619f2f9bad2476d5f474c20edbd6e /src/sp/protocol/pipeline0/push.c | |
| parent | db3d5562e723a6d2e4efd190bd3f1360126f5b10 (diff) | |
| download | nng-c42f32722447cc52810b25decee634210f09d70e.tar.gz nng-c42f32722447cc52810b25decee634210f09d70e.tar.bz2 nng-c42f32722447cc52810b25decee634210f09d70e.zip | |
fixes #1346 windows ipc winsec fails frequently in CI/CD
Diffstat (limited to 'src/sp/protocol/pipeline0/push.c')
| -rw-r--r-- | src/sp/protocol/pipeline0/push.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/sp/protocol/pipeline0/push.c b/src/sp/protocol/pipeline0/push.c index ad43d967..028104cd 100644 --- a/src/sp/protocol/pipeline0/push.c +++ b/src/sp/protocol/pipeline0/push.c @@ -1,5 +1,5 @@ // -// Copyright 2020 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2021 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // // This software is supplied under the terms of the MIT License, a @@ -43,8 +43,8 @@ struct push0_sock { // push0_pipe is our per-pipe protocol private structure. struct push0_pipe { - nni_pipe * pipe; - push0_sock * push; + nni_pipe *pipe; + push0_sock *push; nni_list_node node; nni_aio aio_recv; @@ -85,7 +85,7 @@ static void push0_sock_close(void *arg) { push0_sock *s = arg; - nni_aio * a; + nni_aio *a; nni_mtx_lock(&s->m); while ((a = nni_list_first(&s->aq)) != NULL) { nni_aio_list_remove(a); @@ -182,8 +182,8 @@ static void push0_pipe_ready(push0_pipe *p) { push0_sock *s = p->push; - nni_msg * m; - nni_aio * a = NULL; + nni_msg *m; + nni_aio *a = NULL; size_t l; bool blocked; @@ -266,7 +266,7 @@ push0_sock_send(void *arg, nni_aio *aio) { push0_sock *s = arg; push0_pipe *p; - nni_msg * m; + nni_msg *m; size_t l; int rv; @@ -356,7 +356,7 @@ push0_get_send_buf_len(void *arg, void *buf, size_t *szp, nni_opt_type t) int val; nni_mtx_lock(&s->m); - val = nni_lmq_cap(&s->wq); + val = (int) nni_lmq_cap(&s->wq); nni_mtx_unlock(&s->m); return (nni_copyout_int(val, buf, szp, t)); |