* NEW [nng] Expose lmq to public.

Signed-off-by: wanghaemq <[email protected]>

include/nng/nng.h

@@ -1600,6 +1600,18 @@ NNG_DECL void nng_cv_wake(nng_cv *);
 // reduce the thundering herd problem, but care must be taken to ensure
 // that no waiter starves forever.
 NNG_DECL void nng_cv_wake1(nng_cv *);
+
+typedef struct nng_lmq nng_lmq;
+
+NNG_DECL int nng_lmq_alloc(nng_lmq **qp, size_t sz);
+NNG_DECL void nng_lmq_free(nng_lmq *q);
+NNG_DECL size_t nng_lmq_len(nng_lmq *q);
+NNG_DECL size_t nng_lmq_cap(nng_lmq *q);
+NNG_DECL int nng_lmq_put(nng_lmq *q, nng_msg *m);
+NNG_DECL int nng_lmq_get(nng_lmq *q, nng_msg **mp);
+NNG_DECL bool nng_lmq_full(nng_lmq *q);
+NNG_DECL bool nng_lmq_empty(nng_lmq *q);
+
 // Logging support.
 
 // Log levels.  These correspond to RFC 5424 (syslog) levels.

src/nng.c

@@ -2194,6 +2194,68 @@ nng_cv_wake1(nng_cv *cv)
 	nni_cv_wake1(&cv->c);
 }
 
+struct nng_lmq {
+	nni_lmq q;
+};
+
+int
+nng_lmq_alloc(nng_lmq **qp, size_t sz)
+{
+	nng_lmq *q;
+
+	if ((q = NNI_ALLOC_STRUCT(q)) == NULL) {
+		return (NNG_ENOMEM);
+	}
+	nni_lmq_init(&q->q, sz);
+	*qp = q;
+	return (0);
+}
+
+void
+nng_lmq_free(nng_lmq *q)
+{
+	if (q != NULL) {
+		nni_lmq_fini(&q->q);
+		NNI_FREE_STRUCT(q);
+	}
+}
+
+size_t
+nng_lmq_len(nng_lmq *q)
+{
+	return nni_lmq_len(&q->q);
+}
+
+size_t
+nng_lmq_cap(nng_lmq *q)
+{
+	return nni_lmq_cap(&q->q);
+}
+
+int
+nng_lmq_put(nng_lmq *q, nng_msg *m)
+{
+	return nni_lmq_put(&q->q, m);
+}
+
+int
+nng_lmq_get(nng_lmq *q, nng_msg **mp)
+{
+	return nni_lmq_get(&q->q, mp);
+}
+
+bool
+nng_lmq_full(nng_lmq *q)
+{
+	return nni_lmq_full(&q->q);
+}
+
+bool
+nng_lmq_empty(nng_lmq *q)
+{
+	return nni_lmq_empty(&q->q);
+}
+
 uint32_t
 nng_random(void)
 {