Skip to content

Commit

Permalink
isrpipe: split isrpipe_read_timeout to isolate xtimer dependency
Browse files Browse the repository at this point in the history
This defines a new 'isrpipe_read_timeout' that should be used when using
the timeout based function of isrpipe.

This fix the implicit dependency to 'xtimer' that is only needed for the
'_timeout' functions.

It prevents 'stdio_uart' that uses 'isrpipe' to need to depend on xtimer.
This was silently solved at link time for most platforms but not for the
'esp32' for example.

'drivers/at' needed to be updated at the same time to follow the api change.
  • Loading branch information
cladmi committed Mar 25, 2019
1 parent 17063b4 commit c040264
Show file tree
Hide file tree
Showing 8 changed files with 86 additions and 34 deletions.
5 changes: 5 additions & 0 deletions Makefile.dep
Original file line number Diff line number Diff line change
Expand Up @@ -405,6 +405,11 @@ ifneq (,$(filter isrpipe,$(USEMODULE)))
USEMODULE += tsrb
endif

ifneq (,$(filter isrpipe_read_timeout,$(USEMODULE)))
USEMODULE += isrpipe
USEMODULE += xtimer
endif

ifneq (,$(filter shell_commands,$(USEMODULE)))
ifneq (,$(filter fib,$(USEMODULE)))
USEMODULE += posix_inet
Expand Down
1 change: 1 addition & 0 deletions drivers/Makefile.dep
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@ ifneq (,$(filter at,$(USEMODULE)))
USEMODULE += fmt
USEMODULE += xtimer
USEMODULE += isrpipe
USEMODULE += isrpipe_read_timeout
endif

ifneq (,$(filter at30tse75x,$(USEMODULE)))
Expand Down
1 change: 1 addition & 0 deletions drivers/at/at.c
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
#include "at.h"
#include "fmt.h"
#include "isrpipe.h"
#include "isrpipe/read_timeout.h"
#include "periph/uart.h"
#include "xtimer.h"

Expand Down
3 changes: 3 additions & 0 deletions sys/Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,9 @@ endif
ifneq (,$(filter eepreg,$(USEMODULE)))
DIRS += eepreg
endif
ifneq (,$(filter isrpipe_read_timeout,$(USEMODULE)))
DIRS += isrpipe/read_timeout
endif
ifneq (,$(filter posix_inet,$(USEMODULE)))
DIRS += posix/inet
endif
Expand Down
34 changes: 0 additions & 34 deletions sys/include/isrpipe.h
Original file line number Diff line number Diff line change
Expand Up @@ -75,40 +75,6 @@ int isrpipe_write_one(isrpipe_t *isrpipe, char c);
*/
int isrpipe_read(isrpipe_t *isrpipe, char *buf, size_t count);

/**
* @brief Read data from isrpipe (with timeout, blocking)
*
* Currently, the timeout parameter is applied on every underlying read, which
* might be *per single byte*.
*
* @note This function might return less than @p count bytes
*
* @param[in] isrpipe isrpipe object to operate on
* @param[in] buf buffer to write to
* @param[in] count number of bytes to read
* @param[in] timeout timeout in microseconds
*
* @returns number of bytes read
* @returns -ETIMEDOUT on timeout
*/
int isrpipe_read_timeout(isrpipe_t *isrpipe, char *buf, size_t count, uint32_t timeout);

/**
* @brief Read data from isrpipe (with timeout, blocking, wait until all read)
*
* This function is like @ref isrpipe_read_timeout, but will only return on
* timeout or when @p count bytes have been received.
*
* @param[in] isrpipe isrpipe object to operate on
* @param[in] buf buffer to write to
* @param[in] count number of bytes to read
* @param[in] timeout timeout in microseconds
*
* @returns number of bytes read
* @returns -ETIMEDOUT on timeout
*/
int isrpipe_read_all_timeout(isrpipe_t *isrpipe, char *buf, size_t count, uint32_t timeout);

#ifdef __cplusplus
}
#endif
Expand Down
69 changes: 69 additions & 0 deletions sys/include/isrpipe/read_timeout.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
/*
* Copyright (C) 2016 Kaspar Schleiser <kaspar@schleiser.de>
*
* This file is subject to the terms and conditions of the GNU Lesser
* General Public License v2.1. See the file LICENSE in the top level
* directory for more details.
*/

/**
* @defgroup isr_pipe ISR Pipe
* @ingroup sys
* @brief ISR -> userspace pipe with timeout
*
* @{
* @file
* @brief isrpipe read timeout Interface
*
* @author Kaspar Schleiser <kaspar@schleiser.de>
*
*/

#ifndef ISRPIPE_READ_TIMEOUT_H
#define ISRPIPE_READ_TIMEOUT_H

#include "isrpipe.h"

#ifdef __cplusplus
extern "C" {
#endif

/**
* @brief Read data from isrpipe (with timeout, blocking)
*
* Currently, the timeout parameter is applied on every underlying read, which
* might be *per single byte*.
*
* @note This function might return less than @p count bytes
*
* @param[in] isrpipe isrpipe object to operate on
* @param[in] buf buffer to write to
* @param[in] count number of bytes to read
* @param[in] timeout timeout in microseconds
*
* @returns number of bytes read
* @returns -ETIMEDOUT on timeout
*/
int isrpipe_read_timeout(isrpipe_t *isrpipe, char *buf, size_t count, uint32_t timeout);

/**
* @brief Read data from isrpipe (with timeout, blocking, wait until all read)
*
* This function is like @ref isrpipe_read_timeout, but will only return on
* timeout or when @p count bytes have been received.
*
* @param[in] isrpipe isrpipe object to operate on
* @param[in] buf buffer to write to
* @param[in] count number of bytes to read
* @param[in] timeout timeout in microseconds
*
* @returns number of bytes read
* @returns -ETIMEDOUT on timeout
*/
int isrpipe_read_all_timeout(isrpipe_t *isrpipe, char *buf, size_t count, uint32_t timeout);

#ifdef __cplusplus
}
#endif
/** @} */
#endif /* ISRPIPE_READ_TIMEOUT_H_ */
4 changes: 4 additions & 0 deletions sys/isrpipe/isrpipe.c
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,9 @@
#include <errno.h>

#include "isrpipe.h"
#ifdef MODULE_ISRPIPE_READ_TIMEOUT
#include "xtimer.h"
#endif

void isrpipe_init(isrpipe_t *isrpipe, char *buf, size_t bufsize)
{
Expand Down Expand Up @@ -50,6 +52,7 @@ int isrpipe_read(isrpipe_t *isrpipe, char *buffer, size_t count)
return res;
}

#ifdef MODULE_ISRPIPE_READ_TIMEOUT
typedef struct {
mutex_t *mutex;
int flag;
Expand Down Expand Up @@ -102,3 +105,4 @@ int isrpipe_read_all_timeout(isrpipe_t *isrpipe, char *buffer, size_t count, uin

return pos - buffer;
}
#endif
3 changes: 3 additions & 0 deletions sys/isrpipe/read_timeout/Makefile
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
MODULE = isrpipe_read_timeout

include $(RIOTBASE)/Makefile.base

0 comments on commit c040264

Please sign in to comment.