diff options
author | gdisirio <gdisirio@35acf78f-673a-0410-8e92-d51de3d6d3f4> | 2012-06-11 16:54:35 +0000 |
---|---|---|
committer | gdisirio <gdisirio@35acf78f-673a-0410-8e92-d51de3d6d3f4> | 2012-06-11 16:54:35 +0000 |
commit | d094e348c5d1a3785289c69c5185bbaca1257de8 (patch) | |
tree | 982d1606d57103c8ee2d38e9a11d161a65716640 /os/kernel/include | |
parent | c762926b68f6a6c7f1e71b8acf9b1dd29d6e481f (diff) | |
download | ChibiOS-d094e348c5d1a3785289c69c5185bbaca1257de8.tar.gz ChibiOS-d094e348c5d1a3785289c69c5185bbaca1257de8.tar.bz2 ChibiOS-d094e348c5d1a3785289c69c5185bbaca1257de8.zip |
git-svn-id: svn://svn.code.sf.net/p/chibios/svn/trunk@4266 35acf78f-673a-0410-8e92-d51de3d6d3f4
Diffstat (limited to 'os/kernel/include')
-rw-r--r-- | os/kernel/include/chqueues.h | 40 |
1 files changed, 30 insertions, 10 deletions
diff --git a/os/kernel/include/chqueues.h b/os/kernel/include/chqueues.h index b15cd70b0..b16a19609 100644 --- a/os/kernel/include/chqueues.h +++ b/os/kernel/include/chqueues.h @@ -68,6 +68,7 @@ struct GenericQueue { uint8_t *q_wrptr; /**< @brief Write pointer. */
uint8_t *q_rdptr; /**< @brief Read pointer. */
qnotify_t q_notify; /**< @brief Data notification callback. */
+ void *q_link; /**< @brief Application defined field. */
};
/**
@@ -95,6 +96,17 @@ struct GenericQueue { * @iclass
*/
#define chQSpaceI(qp) ((qp)->q_counter)
+
+/**
+ * @brief Returns the queue application-defined link.
+ * @note This function can be called in any context.
+ *
+ * @param[in] qp pointer to a @p GenericQueue structure.
+ * @return The application-defined link.
+ *
+ * @special
+ */
+#define chQGetLink(qp) ((qp)->q_link)
/** @} */
/**
@@ -185,15 +197,17 @@ typedef GenericQueue InputQueue; * @param[in] buffer pointer to the queue buffer area
* @param[in] size size of the queue buffer area
* @param[in] inotify input notification callback pointer
+ * @param[in] link application defined pointer
*/
-#define _INPUTQUEUE_DATA(name, buffer, size, inotify) { \
+#define _INPUTQUEUE_DATA(name, buffer, size, inotify, link) { \
_THREADSQUEUE_DATA(name), \
0, \
(uint8_t *)(buffer), \
(uint8_t *)(buffer) + (size), \
(uint8_t *)(buffer), \
(uint8_t *)(buffer), \
- inotify \
+ (inotify), \
+ (link) \
}
/**
@@ -205,9 +219,10 @@ typedef GenericQueue InputQueue; * @param[in] buffer pointer to the queue buffer area
* @param[in] size size of the queue buffer area
* @param[in] inotify input notification callback pointer
+ * @param[in] link application defined pointer
*/
-#define INPUTQUEUE_DECL(name, buffer, size, inotify) \
- InputQueue name = _INPUTQUEUE_DATA(name, buffer, size, inotify)
+#define INPUTQUEUE_DECL(name, buffer, size, inotify, link) \
+ InputQueue name = _INPUTQUEUE_DATA(name, buffer, size, inotify, link)
/**
* @extends GenericQueue
@@ -299,15 +314,17 @@ typedef GenericQueue OutputQueue; * @param[in] buffer pointer to the queue buffer area
* @param[in] size size of the queue buffer area
* @param[in] onotify output notification callback pointer
+ * @param[in] link application defined pointer
*/
-#define _OUTPUTQUEUE_DATA(name, buffer, size, onotify) { \
+#define _OUTPUTQUEUE_DATA(name, buffer, size, onotify, link) { \
_THREADSQUEUE_DATA(name), \
(size), \
(uint8_t *)(buffer), \
(uint8_t *)(buffer) + (size), \
(uint8_t *)(buffer), \
(uint8_t *)(buffer), \
- onotify \
+ (onotify), \
+ (link) \
}
/**
@@ -319,21 +336,24 @@ typedef GenericQueue OutputQueue; * @param[in] buffer pointer to the queue buffer area
* @param[in] size size of the queue buffer area
* @param[in] onotify output notification callback pointer
+ * @param[in] link application defined pointer
*/
-#define OUTPUTQUEUE_DECL(name, buffer, size, onotify) \
- OutputQueue name = _OUTPUTQUEUE_DATA(name, buffer, size, onotify)
+#define OUTPUTQUEUE_DECL(name, buffer, size, onotify, link) \
+ OutputQueue name = _OUTPUTQUEUE_DATA(name, buffer, size, onotify, link)
#ifdef __cplusplus
extern "C" {
#endif
- void chIQInit(InputQueue *iqp, uint8_t *bp, size_t size, qnotify_t infy);
+ void chIQInit(InputQueue *iqp, uint8_t *bp, size_t size, qnotify_t infy,
+ void *link);
void chIQResetI(InputQueue *iqp);
msg_t chIQPutI(InputQueue *iqp, uint8_t b);
msg_t chIQGetTimeout(InputQueue *iqp, systime_t time);
size_t chIQReadTimeout(InputQueue *iqp, uint8_t *bp,
size_t n, systime_t time);
- void chOQInit(OutputQueue *oqp, uint8_t *bp, size_t size, qnotify_t onfy);
+ void chOQInit(OutputQueue *oqp, uint8_t *bp, size_t size, qnotify_t onfy,
+ void *link);
void chOQResetI(OutputQueue *oqp);
msg_t chOQPutTimeout(OutputQueue *oqp, uint8_t b, systime_t time);
msg_t chOQGetI(OutputQueue *oqp);
|