diff options
| author | Garrett D'Amore <garrett@damore.org> | 2020-02-06 01:14:13 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2020-02-06 01:22:21 -0800 |
| commit | 2dc8214259155d264a50ca56aa88782b304d3afd (patch) | |
| tree | 80cb9aa07315fe8929f18fbdba6773fe95f5b543 /src/core/msgqueue.h | |
| parent | 105bb7216101514a4563252775bcbf1650abadc9 (diff) | |
| download | nng-2dc8214259155d264a50ca56aa88782b304d3afd.tar.gz nng-2dc8214259155d264a50ca56aa88782b304d3afd.tar.bz2 nng-2dc8214259155d264a50ca56aa88782b304d3afd.zip | |
fixes #814 mq_get_error should go
Diffstat (limited to 'src/core/msgqueue.h')
| -rw-r--r-- | src/core/msgqueue.h | 13 |
1 files changed, 1 insertions, 12 deletions
diff --git a/src/core/msgqueue.h b/src/core/msgqueue.h index 2c43e540..d264ee3f 100644 --- a/src/core/msgqueue.h +++ b/src/core/msgqueue.h @@ -1,5 +1,5 @@ // -// Copyright 2019 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2020 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 @@ -33,9 +33,6 @@ extern int nni_msgq_init(nni_msgq **, unsigned); // messages that may be in the queue. extern void nni_msgq_fini(nni_msgq *); -// nni_msgq_flush discards any messages that are sitting in the queue. -// It does not wake any writers that might be waiting. -extern void nni_msgq_flush(nni_msgq *); extern void nni_msgq_aio_put(nni_msgq *, nni_aio *); extern void nni_msgq_aio_get(nni_msgq *, nni_aio *); @@ -44,11 +41,6 @@ extern void nni_msgq_aio_get(nni_msgq *, nni_aio *); // the message queue. extern int nni_msgq_tryput(nni_msgq *, nni_msg *); -// nni_msgq_set_get_error sets an error condition on the get side of the -// message queue, and for that side behaves like nni_msgq_set_error. -// Readers (nni_msgq_put*) are unaffected. -extern void nni_msgq_set_get_error(nni_msgq *, int); - // nni_msgq_close closes the queue. After this all operates on the // message queue will return NNG_ECLOSED. Messages inside the queue // are freed. Unlike closing a go channel, this operation is idempotent. @@ -66,9 +58,6 @@ extern int nni_msgq_resize(nni_msgq *, int); // for the message queue to contain up to 2 more messages than the capacity. extern int nni_msgq_cap(nni_msgq *mq); -// nni_msgq_len returns the number of messages currently in the queue. -extern int nni_msgq_len(nni_msgq *mq); - extern int nni_msgq_get_recvable(nni_msgq *mq, nni_pollable **); extern int nni_msgq_get_sendable(nni_msgq *mq, nni_pollable **); |
