summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/if_wg.c6
-rw-r--r--src/mpq.h6
2 files changed, 6 insertions, 6 deletions
diff --git a/src/if_wg.c b/src/if_wg.c
index 9e669f8a522..7a6d530f820 100644
--- a/src/if_wg.c
+++ b/src/if_wg.c
@@ -1036,9 +1036,9 @@ wg_clone_create(struct if_clone * ifc, int unit)
sc = wg_softc_create();
if (SLIST_EMPTY(&wg_devs)) {
- mpq_init(&wg_queue_tx, IPL_NET, wg_transport_encrypt, wg_output_deliver);
- mpq_init(&wg_queue_rx, IPL_NET, wg_transport_decrypt, wg_input_deliver);
- mpq_init(&wg_queue_rx_slow, IPL_NET, wg_receive_slow, NULL);
+ mpq_init(&wg_queue_tx, IPL_NET, 1024, wg_transport_encrypt, wg_output_deliver);
+ mpq_init(&wg_queue_rx, IPL_NET, 1024, wg_transport_decrypt, wg_input_deliver);
+ mpq_init(&wg_queue_rx_slow, IPL_NET, 8, wg_receive_slow, NULL);
}
SLIST_INSERT_HEAD(&wg_devs, sc, sc_next);
diff --git a/src/mpq.h b/src/mpq.h
index 7b7549cfdb3..f32bf7571fb 100644
--- a/src/mpq.h
+++ b/src/mpq.h
@@ -33,7 +33,7 @@ struct mpq {
void (*mpq_serial_fn)(struct mbuf *);
};
-void mpq_init(struct mpq *, int, struct mbuf *(*)(struct mbuf *), void (*)(struct mbuf *));
+void mpq_init(struct mpq *, int, int, struct mbuf *(*)(struct mbuf *), void (*)(struct mbuf *));
void mpq_barrier(struct mpq *);
void mpq_destroy(struct mpq *);
int mpq_enqueue(struct mpq *, struct mbuf *);
@@ -105,12 +105,12 @@ _mpq_thread(struct mpq *mpq)
/* External functions */
void
-mpq_init(struct mpq *mpq, int ipl, struct mbuf *(*parallel)(struct mbuf *), void (*serial)(struct mbuf *))
+mpq_init(struct mpq *mpq, int ipl, int maxlen, struct mbuf *(*parallel)(struct mbuf *), void (*serial)(struct mbuf *))
{
assert(parallel != NULL);
mpq->mpq_sactive = 0;
- mpq->mpq_maxlen = MPQ_DEFAULTLEN;
+ mpq->mpq_maxlen = maxlen;
mtx_init(&mpq->mpq_mtx, ipl);
ml_init(&mpq->mpq_list);
mpq->mpq_cursor = NULL;