diff options
author | Giovanni Di Sirio <gdisirio@gmail.com> | 2018-09-26 11:53:05 +0000 |
---|---|---|
committer | Giovanni Di Sirio <gdisirio@gmail.com> | 2018-09-26 11:53:05 +0000 |
commit | 687ea96f1528fbe47f447e2c3622ba0b65b70a5d (patch) | |
tree | 1c8dcb20368a1164b6a9f7d6950fc4c93347b318 /os/lib/include/chpipes.h | |
parent | 5111601c13e6a1151dfd39a02a48d7fd0efd68cd (diff) | |
download | ChibiOS-687ea96f1528fbe47f447e2c3622ba0b65b70a5d.tar.gz ChibiOS-687ea96f1528fbe47f447e2c3622ba0b65b70a5d.tar.bz2 ChibiOS-687ea96f1528fbe47f447e2c3622ba0b65b70a5d.zip |
Added pipes to OSLIB.
git-svn-id: svn://svn.code.sf.net/p/chibios/svn/trunk@12295 110e8d01-0319-4d1e-a829-52ad28d1bb01
Diffstat (limited to 'os/lib/include/chpipes.h')
-rw-r--r-- | os/lib/include/chpipes.h | 30 |
1 files changed, 12 insertions, 18 deletions
diff --git a/os/lib/include/chpipes.h b/os/lib/include/chpipes.h index c66c48d68..a09b3c72a 100644 --- a/os/lib/include/chpipes.h +++ b/os/lib/include/chpipes.h @@ -56,7 +56,7 @@ typedef struct { after the buffer. */ uint8_t *wrptr; /**< @brief Write pointer. */ uint8_t *rdptr; /**< @brief Read pointer. */ - size_t cnt; /**< @brief Messages in queue. */ + size_t cnt; /**< @brief Bytes in the pipe. */ bool reset; /**< @brief True if in reset state. */ threads_queue_t qw; /**< @brief Queued writers. */ threads_queue_t qr; /**< @brief Queued readers. */ @@ -145,9 +145,9 @@ extern "C" { * @param[in] pp the pointer to an initialized @p pipe_t object * @return The size of the pipe. * - * @iclass + * @api */ -static inline size_t chPipeGetSizeI(const pipe_t *pp) { +static inline size_t chPipeGetSize(const pipe_t *pp) { /*lint -save -e9033 [10.8] Perfectly safe pointers arithmetic.*/ @@ -161,11 +161,9 @@ static inline size_t chPipeGetSizeI(const pipe_t *pp) { * @param[in] pp the pointer to an initialized @p pipe_t object * @return The number of queued bytes. * - * @iclass + * @api */ -static inline size_t chPipeGetUsedCountI(const pipe_t *pp) { - - chDbgCheckClassI(); +static inline size_t chPipeGetUsedCount(const pipe_t *pp) { return pp->cnt; } @@ -176,13 +174,11 @@ static inline size_t chPipeGetUsedCountI(const pipe_t *pp) { * @param[in] pp the pointer to an initialized @p pipe_t object * @return The number of empty byte slots. * - * @iclass + * @api */ -static inline size_t chPipeGetFreeCountI(const pipe_t *pp) { - - chDbgCheckClassI(); +static inline size_t chPipeGetFreeCount(const pipe_t *pp) { - return chPipeGetSizeI(pp) - chPipeGetUsedCountI(pp); + return chPipeGetSize(pp) - chPipeGetUsedCount(pp); } /** @@ -195,11 +191,9 @@ static inline size_t chPipeGetFreeCountI(const pipe_t *pp) { * @param[in] pp the pointer to an initialized @p pipe_t object * @return The next byte in queue. * - * @iclass + * @api */ -static inline uint8_t chPipePeekI(const pipe_t *pp) { - - chDbgCheckClassI(); +static inline uint8_t chPipePeek(const pipe_t *pp) { return *pp->rdptr; } @@ -209,9 +203,9 @@ static inline uint8_t chPipePeekI(const pipe_t *pp) { * * @param[in] pp the pointer to an initialized @p pipe_t object * - * @xclass + * @api */ -static inline void chPipeResumeX(pipe_t *pp) { +static inline void chPipeResume(pipe_t *pp) { pp->reset = false; } |