summaryrefslogtreecommitdiff
path: root/src/core/msgqueue.h
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2020-02-06 01:14:13 -0800
committerGarrett D'Amore <garrett@damore.org>2020-02-06 01:22:21 -0800
commit2dc8214259155d264a50ca56aa88782b304d3afd (patch)
tree80cb9aa07315fe8929f18fbdba6773fe95f5b543 /src/core/msgqueue.h
parent105bb7216101514a4563252775bcbf1650abadc9 (diff)
downloadnng-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.h13
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 **);