summaryrefslogtreecommitdiffstats
path: root/src/mpq.h
diff options
context:
space:
mode:
authorMatt Dunwoodie <ncon@mail.noconroy.net>2019-09-28 12:44:27 +0100
committerMatt Dunwoodie <ncon@mail.noconroy.net>2019-09-28 12:44:27 +0100
commitd89af84ddc40436e1d879de3145235b8a35dd7d1 (patch)
treef95a6d494356de9f727d40f7f0b697d8680ee4fb /src/mpq.h
parentAdjust queueing process (diff)
downloadwireguard-openbsd-d89af84ddc40436e1d879de3145235b8a35dd7d1.tar.xz
wireguard-openbsd-d89af84ddc40436e1d879de3145235b8a35dd7d1.zip
Add more verbose messages
Diffstat (limited to 'src/mpq.h')
-rw-r--r--src/mpq.h6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mpq.h b/src/mpq.h
index b818f6b7ca7..70f0dba675c 100644
--- a/src/mpq.h
+++ b/src/mpq.h
@@ -32,8 +32,8 @@ void mpq_init(struct mpq *, int);
int mpq_full(struct mpq *);
int mpq_serialize_try_enter(struct mpq *);
void mpq_serialize_leave(struct mpq *);
-int mpq_enqueue(struct mpq *, struct mbuf *);
-void mpq_enlist(struct mpq *, struct mbuf_list *);
+void mpq_threaddone(struct mpq *, struct mbuf *);
+void mpq_enqueue(struct mpq *, struct mbuf *);
struct mbuf *mpq_dethread(struct mpq *);
struct mbuf *mpq_dequeue(struct mpq *);
void mpq_done(struct mbuf *m);
@@ -45,7 +45,7 @@ void fn_name(void *_mpq) { \
struct mpq *mpq = _mpq; \
while ((m = mpq_dethread(mpq)) != NULL) { \
parallel_fn(m); \
- SET(m->m_flags, M_LINK0); \
+ mpq_threaddone(mpq, m); \
} \
if (mpq_serialize_try_enter(mpq) == 0) { \
while((m = mpq_dequeue(mpq)) != NULL) { \