write_queue: Add osmo_wqueue_enqueue_quiet()
Same as osmo_wqueue_enqueue() but without logging queue overruns.
Change-Id: Ic082eb39795b08631284eeb421fef3c28f2e90dc
diff --git a/src/write_queue.c b/src/write_queue.c
index 3399b0f..c7dedc4 100644
--- a/src/write_queue.c
+++ b/src/write_queue.c
@@ -100,6 +100,23 @@
INIT_LLIST_HEAD(&queue->msg_queue);
}
+/*! Enqueue a new \ref msgb into a write queue (without logging full queue events)
+ * \param[in] queue Write queue to be used
+ * \param[in] data to-be-enqueued message buffer
+ * \returns 0 on success; negative on error
+ */
+int osmo_wqueue_enqueue_quiet(struct osmo_wqueue *queue, struct msgb *data)
+{
+ if (queue->current_length >= queue->max_length)
+ return -ENOSPC;
+
+ ++queue->current_length;
+ msgb_enqueue(&queue->msg_queue, data);
+ queue->bfd.when |= OSMO_FD_WRITE;
+
+ return 0;
+}
+
/*! Enqueue a new \ref msgb into a write queue
* \param[in] queue Write queue to be used
* \param[in] data to-be-enqueued message buffer
@@ -113,11 +130,7 @@
return -ENOSPC;
}
- ++queue->current_length;
- msgb_enqueue(&queue->msg_queue, data);
- queue->bfd.when |= OSMO_FD_WRITE;
-
- return 0;
+ return osmo_wqueue_enqueue_quiet(queue, data);
}
/*! Clear a \ref osmo_wqueue