aboutsummaryrefslogtreecommitdiffstats
path: root/include/osmocom/core/write_queue.h
diff options
context:
space:
mode:
authorHarald Welte <laforge@gnumonks.org>2011-08-16 23:26:52 +0200
committerHarald Welte <laforge@gnumonks.org>2011-08-16 23:26:52 +0200
commitbd598e3c5eff85ed3958909584d3d8e1e2235b41 (patch)
tree1b47f59c634cc1139be16e4625f7809c4d3e4460 /include/osmocom/core/write_queue.h
parent300e78d3e5714449e73a056dd5878adab97c6423 (diff)
start to add doxygen documentation to libosmocore headers
Diffstat (limited to 'include/osmocom/core/write_queue.h')
-rw-r--r--include/osmocom/core/write_queue.h35
1 files changed, 35 insertions, 0 deletions
diff --git a/include/osmocom/core/write_queue.h b/include/osmocom/core/write_queue.h
index 41748d72..373b64ff 100644
--- a/include/osmocom/core/write_queue.h
+++ b/include/osmocom/core/write_queue.h
@@ -23,24 +23,59 @@
#ifndef OSMO_WQUEUE_H
#define OSMO_WQUEUE_H
+/*! \file write_queue.h
+ * \brief Osmocom write queues
+ */
+
#include <osmocom/core/select.h>
#include <osmocom/core/msgb.h>
+/*! write queue instance */
struct osmo_wqueue {
+ /*! \brief osmocom file descriptor */
struct osmo_fd bfd;
+ /*! \brief maximum length of write queue */
unsigned int max_length;
+ /*! \brief current length of write queue */
unsigned int current_length;
+ /*! \brief actual linked list implementing the queue */
struct llist_head msg_queue;
+ /*! \brief call-back in case qeueue is readable */
int (*read_cb)(struct osmo_fd *fd);
+ /*! \brief call-back in case qeueue is writable */
int (*write_cb)(struct osmo_fd *fd, struct msgb *msg);
+ /*! \brief call-back in case qeueue has exceptions */
int (*except_cb)(struct osmo_fd *fd);
};
+/*! \brief Initialize a \ref osmo_wqueue structure
+ * \param[in] queue Write queue to operate on
+ * \param[in] max_length Maximum length of write queue
+ */
void osmo_wqueue_init(struct osmo_wqueue *queue, int max_length);
+
+/*! \brief Clear a \ref osmo_wqueue
+ * \param[in] queue Write queue to be cleared
+ *
+ * This function will clear (remove/release) all messages in it.
+ */
void osmo_wqueue_clear(struct osmo_wqueue *queue);
+
+/*! \brief 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
+ */
int osmo_wqueue_enqueue(struct osmo_wqueue *queue, struct msgb *data);
+
+/*! \brief Select loop function for write queue handling
+ * \param[in] fd osmocom file descriptor
+ * \param[in] what bit-mask of events that have happened
+ *
+ * This function is provided so that it can be registered with the
+ * select loop abstraction code (\ref osmo_fd::cb).
+ */
int osmo_wqueue_bfd_cb(struct osmo_fd *fd, unsigned int what);
#endif