diff options
Diffstat (limited to 'src/core/lmq.h')
| -rw-r--r-- | src/core/lmq.h | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/src/core/lmq.h b/src/core/lmq.h new file mode 100644 index 00000000..0a64c984 --- /dev/null +++ b/src/core/lmq.h @@ -0,0 +1,39 @@ +// +// Copyright 2019 Staysail Systems, Inc. <info@staysail.tech> +// +// This software is supplied under the terms of the MIT License, a +// copy of which should be located in the distribution where this +// file was obtained (LICENSE.txt). A copy of the license may also be +// found online at https://opensource.org/licenses/MIT. +// + +#ifndef CORE_LMQ_H +#define CORE_LMQ_H + +#include "nng_impl.h" + +// nni_lmq is a very lightweight message queue. Defining it this way allows +// us to share some common code. Locking must be supplied by the caller. +// For performance reasons, this is allocated inline. +typedef struct nni_lmq { + size_t lmq_cap; + size_t lmq_alloc; // alloc is cap, rounded up to power of 2 + size_t lmq_mask; + size_t lmq_len; + size_t lmq_get; + size_t lmq_put; + nng_msg **lmq_msgs; +} nni_lmq; + +extern int nni_lmq_init(nni_lmq *, size_t); +extern void nni_lmq_fini(nni_lmq *); +extern void nni_lmq_flush(nni_lmq *); +extern size_t nni_lmq_len(nni_lmq *); +extern size_t nni_lmq_cap(nni_lmq *); +extern int nni_lmq_putq(nni_lmq *, nng_msg *); +extern int nni_lmq_getq(nni_lmq *, nng_msg **); +extern int nni_lmq_resize(nni_lmq *, size_t); +extern bool nni_lmq_full(nni_lmq *); +extern bool nni_lmq_empty(nni_lmq *); + +#endif // CORE_LMQ_H |