summaryrefslogtreecommitdiffstats
path: root/cpukit
diff options
context:
space:
mode:
authorJoel Sherrill <joel.sherrill@OARcorp.com>1997-10-23 13:13:46 +0000
committerJoel Sherrill <joel.sherrill@OARcorp.com>1997-10-23 13:13:46 +0000
commit118a81295d28049584d60479ac4e524303dc911d (patch)
treeb62df968ca030be3e9004d15bcc34205d10cd188 /cpukit
parentAdded test case for rtems_interrupt_catch checking that the pointer (diff)
downloadrtems-118a81295d28049584d60479ac4e524303dc911d.tar.bz2
New termios.c from Eric Norum.
Added new entry point to add in per physical port resource requirements.
Diffstat (limited to 'cpukit')
-rw-r--r--cpukit/libcsupport/include/rtems/libio.h4
-rw-r--r--cpukit/libcsupport/src/termios.c1243
2 files changed, 646 insertions, 601 deletions
diff --git a/cpukit/libcsupport/include/rtems/libio.h b/cpukit/libcsupport/include/rtems/libio.h
index 2761a333c6..7f8baadd56 100644
--- a/cpukit/libcsupport/include/rtems/libio.h
+++ b/cpukit/libcsupport/include/rtems/libio.h
@@ -147,5 +147,9 @@ rtems_status_code rtems_termios_read (void *arg);
rtems_status_code rtems_termios_write (void *arg);
rtems_status_code rtems_termios_ioctl (void *arg);
void rtems_termios_enqueue_raw_characters (void *ttyp, char *buf, int len);
+void rtems_termios_reserve_resources(
+ rtems_configuration_table *configuration,
+ rtems_unsigned32 number_of_devices
+);
#endif /* _RTEMS_LIBIO_H */
diff --git a/cpukit/libcsupport/src/termios.c b/cpukit/libcsupport/src/termios.c
index 43f49c014b..d3e0eceeac 100644
--- a/cpukit/libcsupport/src/termios.c
+++ b/cpukit/libcsupport/src/termios.c
@@ -23,76 +23,82 @@
#include <stdlib.h>
#include <termios.h>
#include <unistd.h>
-#include <ringbuf.h>
/*
* The size of the cooked buffer
*/
-#define CBUFSIZE 256
+#define CBUFSIZE 256
+
+/*
+ * The size of the raw input message queue
+ */
+#define RAW_BUFFER_SIZE 128
/*
* Variables associated with each termios instance.
* One structure for each hardware I/O device.
*/
struct rtems_termios_tty {
- /*
- * Linked-list of active TERMIOS devices
- */
- struct rtems_termios_tty *forw;
- struct rtems_termios_tty *back;
-
- /*
- * How many times has this device been opened
- */
- int refcount;
-
- /*
- * This device
- */
- rtems_device_major_number major;
- rtems_device_major_number minor;
-
- /*
- * Mutual-exclusion semaphores
- */
- rtems_id isem;
- rtems_id osem;
-
- /*
- * The canonical (cooked) character buffer
- */
- char cbuf[CBUFSIZE];
- int ccount;
- int cindex;
-
- /*
- * Keep track of cursor (printhead) position
- */
- int column;
- int read_start_column;
-
- /*
- * The ioctl settings
- */
- struct termios termios;
- rtems_interval vtimeTicks;
-
- /*
- * Raw character buffer
- */
- rtems_id rawInputSem;
- Ring_buffer_t rawInputBuffer;
-
- rtems_unsigned32 rawMessageOptions;
- rtems_interval rawMessageTimeout;
- rtems_interval rawMessageFirstTimeout;
-
- /*
- * Callbacks to device-specific routines
- */
- int (*lastClose)(int major, int minor, void *arg);
- int (*read)(int minor, char *buf );
- int (*write)(int minor, char *buf, int len);
+ /*
+ * Linked-list of active TERMIOS devices
+ */
+ struct rtems_termios_tty *forw;
+ struct rtems_termios_tty *back;
+
+ /*
+ * How many times has this device been opened
+ */
+ int refcount;
+
+ /*
+ * This device
+ */
+ rtems_device_major_number major;
+ rtems_device_major_number minor;
+
+ /*
+ * Mutual-exclusion semaphores
+ */
+ rtems_id isem;
+ rtems_id osem;
+
+ /*
+ * The canonical (cooked) character buffer
+ */
+ char cbuf[CBUFSIZE];
+ int ccount;
+ int cindex;
+
+ /*
+ * Keep track of cursor (printhead) position
+ */
+ int column;
+ int read_start_column;
+
+ /*
+ * The ioctl settings
+ */
+ struct termios termios;
+ rtems_interval vtimeTicks;
+
+ /*
+ * Raw character buffer
+ */
+ volatile char rawBuf[RAW_BUFFER_SIZE];
+ volatile unsigned int rawBufHead;
+ volatile unsigned int rawBufTail;
+ rtems_id rawBufSemaphore;
+ rtems_unsigned32 rawBufSemaphoreOptions;
+ rtems_interval rawBufSemaphoreTimeout;
+ rtems_interval rawBufSemaphoreFirstTimeout;
+ unsigned int rawBufDropped; /* Statistics */
+
+ /*
+ * Callbacks to device-specific routines
+ */
+ int (*lastClose)(int major, int minor, void *arg);
+ int (*read)(int minor, char *buf);
+ int (*write)(int minor, char *buf, int len);
};
static struct rtems_termios_tty *ttyHead, *ttyTail;
static rtems_id ttyMutex;
@@ -100,23 +106,23 @@ static rtems_id ttyMutex;
void
rtems_termios_initialize (void)
{
- rtems_status_code sc;
-
- /*
- * Create the mutex semaphore for the tty list
- */
- if (!ttyMutex) {
- sc = rtems_semaphore_create (
- rtems_build_name ('T', 'R', 'm', 'i'),
- 1,
- RTEMS_BINARY_SEMAPHORE | RTEMS_INHERIT_PRIORITY | RTEMS_PRIORITY,
- RTEMS_NO_PRIORITY,
- &ttyMutex);
- if (sc != RTEMS_SUCCESSFUL)
- rtems_fatal_error_occurred (sc);
- }
+ rtems_status_code sc;
+
+ /*
+ * Create the mutex semaphore for the tty list
+ */
+ if (!ttyMutex) {
+ sc = rtems_semaphore_create (
+ rtems_build_name ('T', 'R', 'm', 'i'),
+ 1,
+ RTEMS_BINARY_SEMAPHORE | RTEMS_INHERIT_PRIORITY | RTEMS_PRIORITY,
+ RTEMS_NO_PRIORITY,
+ &ttyMutex);
+ if (sc != RTEMS_SUCCESSFUL)
+ rtems_fatal_error_occurred (sc);
+ }
}
-
+
/*
* Open a termios device
*/
@@ -127,207 +133,209 @@ rtems_termios_open (
void *arg,
int (*deviceFirstOpen)(int major, int minor, void *arg),
int (*deviceLastClose)(int major, int minor, void *arg),
- int (*deviceRead)(int minor, char *buf/*, int len*/),
+ int (*deviceRead)(int minor, char *buf),
int (*deviceWrite)(int minor, char *buf, int len)
)
{
- rtems_status_code sc;
- rtems_libio_open_close_args_t *args = arg;
- struct rtems_termios_tty *tty;
-
- /*
- * See if the device has already been opened
- */
- sc = rtems_semaphore_obtain (ttyMutex, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
- if (sc != RTEMS_SUCCESSFUL)
- return sc;
- for (tty = ttyHead ; tty != NULL ; tty = tty->forw) {
- if ((tty->major == major) && (tty->minor == minor))
- break;
- }
- if (tty == NULL) {
- static char c = 'a';
-
- /*
- * Create a new device
- */
- tty = malloc (sizeof (struct rtems_termios_tty));
- if (tty == NULL) {
- rtems_semaphore_release (ttyMutex);
- return RTEMS_NO_MEMORY;
- }
- tty->forw = ttyHead;
- ttyHead = tty;
- tty->back = NULL;
- if (ttyTail == NULL)
- ttyTail = tty;
-
- /*
- * Set up mutex semaphores
- */
- sc = rtems_semaphore_create (
- rtems_build_name ('T', 'R', 'i', c),
- 1,
- RTEMS_BINARY_SEMAPHORE | RTEMS_INHERIT_PRIORITY | RTEMS_PRIORITY,
- RTEMS_NO_PRIORITY,
- &tty->isem);
- if (sc != RTEMS_SUCCESSFUL)
- rtems_fatal_error_occurred (sc);
- sc = rtems_semaphore_create (
- rtems_build_name ('T', 'R', 'o', c),
- 1,
- RTEMS_BINARY_SEMAPHORE | RTEMS_INHERIT_PRIORITY | RTEMS_PRIORITY,
- RTEMS_NO_PRIORITY,
- &tty->osem);
- if (sc != RTEMS_SUCCESSFUL)
- rtems_fatal_error_occurred (sc);
-
- /*
- * Set callbacks
- */
- tty->write = deviceWrite;
- tty->lastClose = deviceLastClose;
- if ((tty->read = deviceRead) == NULL) {
- sc = rtems_semaphore_create (
- rtems_build_name ('T', 'R', 'r', c),
- 0,
- RTEMS_COUNTING_SEMAPHORE | RTEMS_FIFO | RTEMS_LOCAL,
- RTEMS_NO_PRIORITY,
- &tty->rawInputSem);
- if (sc != RTEMS_SUCCESSFUL)
- rtems_fatal_error_occurred (sc);
- }
-
- /*
- * Initialize variables
- */
- tty->column = 0;
- tty->cindex = tty->ccount = 0;
-
- /*
- * Set default parameters
- */
- tty->termios.c_iflag = BRKINT | ICRNL | IXON | IMAXBEL;
- tty->termios.c_oflag = OPOST | ONLCR | XTABS;
- tty->termios.c_cflag = B9600 | CS8 | CREAD;
- tty->termios.c_lflag = ISIG | ICANON | IEXTEN | ECHO | ECHOK | ECHOE | ECHOCTL;
- tty->termios.c_cc[VINTR] = '\003';
- tty->termios.c_cc[VQUIT] = '\034';
- tty->termios.c_cc[VERASE] = '\177';
- tty->termios.c_cc[VKILL] = '\025';
- tty->termios.c_cc[VEOF] = '\004';
- tty->termios.c_cc[VEOL] = '\000';
- tty->termios.c_cc[VEOL2] = '\000';
- tty->termios.c_cc[VSTART] = '\021';
- tty->termios.c_cc[VSTOP] = '\023';
- tty->termios.c_cc[VSUSP] = '\032';
- tty->termios.c_cc[VREPRINT] = '\022';
- tty->termios.c_cc[VDISCARD] = '\017';
- tty->termios.c_cc[VWERASE] = '\027';
- tty->termios.c_cc[VLNEXT] = '\026';
-
- /*
- * Device-specific open
- */
- if (deviceFirstOpen)
- (*deviceFirstOpen) (major, minor, arg);
-
- /*
- * Bump name characer
- */
- if (c++ == 'z')
- c = 'a';
- }
- tty->refcount++;
- args->iop->data1 = tty;
- rtems_semaphore_release (ttyMutex);
- return RTEMS_SUCCESSFUL;
+ rtems_status_code sc;
+ rtems_libio_open_close_args_t *args = arg;
+ struct rtems_termios_tty *tty;
+
+ /*
+ * See if the device has already been opened
+ */
+ sc = rtems_semaphore_obtain (ttyMutex, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
+ if (sc != RTEMS_SUCCESSFUL)
+ return sc;
+ for (tty = ttyHead ; tty != NULL ; tty = tty->forw) {
+ if ((tty->major == major) && (tty->minor == minor))
+ break;
+ }
+ if (tty == NULL) {
+ static char c = 'a';
+
+ /*
+ * Create a new device
+ */
+ tty = malloc (sizeof (struct rtems_termios_tty));
+ if (tty == NULL) {
+ rtems_semaphore_release (ttyMutex);
+ return RTEMS_NO_MEMORY;
+ }
+ tty->forw = ttyHead;
+ ttyHead = tty;
+ tty->back = NULL;
+ if (ttyTail == NULL)
+ ttyTail = tty;
+
+ /*
+ * Set up mutex semaphores
+ */
+ sc = rtems_semaphore_create (
+ rtems_build_name ('T', 'R', 'i', c),
+ 1,
+ RTEMS_BINARY_SEMAPHORE | RTEMS_INHERIT_PRIORITY | RTEMS_PRIORITY,
+ RTEMS_NO_PRIORITY,
+ &tty->isem);
+ if (sc != RTEMS_SUCCESSFUL)
+ rtems_fatal_error_occurred (sc);
+ sc = rtems_semaphore_create (
+ rtems_build_name ('T', 'R', 'o', c),
+ 1,
+ RTEMS_BINARY_SEMAPHORE | RTEMS_INHERIT_PRIORITY | RTEMS_PRIORITY,
+ RTEMS_NO_PRIORITY,
+ &tty->osem);
+ if (sc != RTEMS_SUCCESSFUL)
+ rtems_fatal_error_occurred (sc);
+
+ /*
+ * Set callbacks
+ */
+ tty->write = deviceWrite;
+ tty->lastClose = deviceLastClose;
+ if ((tty->read = deviceRead) == NULL) {
+ sc = rtems_semaphore_create (
+ rtems_build_name ('T', 'R', 'r', c),
+ 0,
+ RTEMS_COUNTING_SEMAPHORE | RTEMS_PRIORITY,
+ RTEMS_NO_PRIORITY,
+ &tty->rawBufSemaphore);
+ if (sc != RTEMS_SUCCESSFUL)
+ rtems_fatal_error_occurred (sc);
+ tty->rawBufHead = 0;
+ tty->rawBufTail = 0;
+ }
+
+ /*
+ * Initialize variables
+ */
+ tty->column = 0;
+ tty->cindex = tty->ccount = 0;
+
+ /*
+ * Set default parameters
+ */
+ tty->termios.c_iflag = BRKINT | ICRNL | IXON | IMAXBEL;
+ tty->termios.c_oflag = OPOST | ONLCR | XTABS;
+ tty->termios.c_cflag = B9600 | CS8 | CREAD;
+ tty->termios.c_lflag = ISIG | ICANON | IEXTEN | ECHO | ECHOK | ECHOE | ECHOCTL;
+ tty->termios.c_cc[VINTR] = '\003';
+ tty->termios.c_cc[VQUIT] = '\034';
+ tty->termios.c_cc[VERASE] = '\177';
+ tty->termios.c_cc[VKILL] = '\025';
+ tty->termios.c_cc[VEOF] = '\004';
+ tty->termios.c_cc[VEOL] = '\000';
+ tty->termios.c_cc[VEOL2] = '\000';
+ tty->termios.c_cc[VSTART] = '\021';
+ tty->termios.c_cc[VSTOP] = '\023';
+ tty->termios.c_cc[VSUSP] = '\032';
+ tty->termios.c_cc[VREPRINT] = '\022';
+ tty->termios.c_cc[VDISCARD] = '\017';
+ tty->termios.c_cc[VWERASE] = '\027';
+ tty->termios.c_cc[VLNEXT] = '\026';
+
+ /*
+ * Device-specific open
+ */
+ if (deviceFirstOpen)
+ (*deviceFirstOpen) (major, minor, arg);
+
+ /*
+ * Bump name characer
+ */
+ if (c++ == 'z')
+ c = 'a';
+ }
+ tty->refcount++;
+ args->iop->data1 = tty;
+ rtems_semaphore_release (ttyMutex);
+ return RTEMS_SUCCESSFUL;
}
rtems_status_code
rtems_termios_close (void *arg)
{
- rtems_libio_open_close_args_t *args = arg;
- struct rtems_termios_tty *tty = args->iop->data1;
- rtems_status_code sc;
-
- sc = rtems_semaphore_obtain (ttyMutex, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
- if (sc != RTEMS_SUCCESSFUL)
- rtems_fatal_error_occurred (sc);
- if (--tty->refcount == 0) {
- if (tty->lastClose)
- (*tty->lastClose) (tty->major, tty->minor, arg);
- if (tty->forw == NULL)
- ttyTail = tty->back;
- else
- tty->forw->back = tty->back;
- if (tty->back == NULL)
- ttyHead = tty->forw;
- else
- tty->back->forw = tty->forw;
- rtems_semaphore_delete (tty->isem);
- rtems_semaphore_delete (tty->osem);
- if (tty->read == NULL)
- rtems_semaphore_delete (tty->rawInputSem);
- free (tty);
- }
- rtems_semaphore_release (ttyMutex);
- return RTEMS_SUCCESSFUL;
+ rtems_libio_open_close_args_t *args = arg;
+ struct rtems_termios_tty *tty = args->iop->data1;
+ rtems_status_code sc;
+
+ sc = rtems_semaphore_obtain (ttyMutex, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
+ if (sc != RTEMS_SUCCESSFUL)
+ rtems_fatal_error_occurred (sc);
+ if (--tty->refcount == 0) {
+ if (tty->lastClose)
+ (*tty->lastClose) (tty->major, tty->minor, arg);
+ if (tty->forw == NULL)
+ ttyTail = tty->back;
+ else
+ tty->forw->back = tty->back;
+ if (tty->back == NULL)
+ ttyHead = tty->forw;
+ else
+ tty->back->forw = tty->forw;
+ rtems_semaphore_delete (tty->isem);
+ rtems_semaphore_delete (tty->osem);
+ if (tty->read == NULL)
+ rtems_semaphore_delete (tty->rawBufSemaphore);
+ free (tty);
+ }
+ rtems_semaphore_release (ttyMutex);
+ return RTEMS_SUCCESSFUL;
}
rtems_status_code
rtems_termios_ioctl (void *arg)
{
- rtems_libio_ioctl_args_t *args = arg;
- struct rtems_termios_tty *tty = args->iop->data1;
- rtems_status_code sc;
-
- sc = rtems_semaphore_obtain (tty->osem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
- if (sc != RTEMS_SUCCESSFUL)
- return sc;
- switch (args->command) {
- default:
- sc = RTEMS_INVALID_NUMBER;
- break;
-
- case RTEMS_IO_GET_ATTRIBUTES:
- *(struct termios *)args->buffer = tty->termios;
- break;
-
- case RTEMS_IO_SET_ATTRIBUTES:
- tty->termios = *(struct termios *)args->buffer;
- if (tty->termios.c_lflag & ICANON) {
- tty->rawMessageOptions = RTEMS_WAIT;
- tty->rawMessageTimeout = RTEMS_NO_TIMEOUT;
- tty->rawMessageFirstTimeout = RTEMS_NO_TIMEOUT;
- }
- else {
- rtems_interval ticksPerSecond;
- rtems_clock_get (RTEMS_CLOCK_GET_TICKS_PER_SECOND, &ticksPerSecond);
- tty->vtimeTicks = tty->termios.c_cc[VTIME] * ticksPerSecond / 10;
- if (tty->termios.c_cc[VTIME]) {
- tty->rawMessageOptions = RTEMS_WAIT;
- tty->rawMessageTimeout = tty->vtimeTicks;
- if (tty->termios.c_cc[VMIN])
- tty->rawMessageFirstTimeout = RTEMS_NO_TIMEOUT;
- else
- tty->rawMessageFirstTimeout = tty->vtimeTicks;
- }
- else {
- if (tty->termios.c_cc[VMIN]) {
- tty->rawMessageOptions = RTEMS_WAIT;
- tty->rawMessageTimeout = RTEMS_NO_TIMEOUT;
- tty->rawMessageFirstTimeout = RTEMS_NO_TIMEOUT;
- }
- else {
- tty->rawMessageOptions = RTEMS_NO_WAIT;
- }
- }
- }
- break;
- }
- rtems_semaphore_release (tty->osem);
- return sc;
+ rtems_libio_ioctl_args_t *args = arg;
+ struct rtems_termios_tty *tty = args->iop->data1;
+ rtems_status_code sc;
+
+ sc = rtems_semaphore_obtain (tty->osem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
+ if (sc != RTEMS_SUCCESSFUL)
+ return sc;
+ switch (args->command) {
+ default:
+ sc = RTEMS_INVALID_NUMBER;
+ break;
+
+ case RTEMS_IO_GET_ATTRIBUTES:
+ *(struct termios *)args->buffer = tty->termios;
+ break;
+
+ case RTEMS_IO_SET_ATTRIBUTES:
+ tty->termios = *(struct termios *)args->buffer;
+ if (tty->termios.c_lflag & ICANON) {
+ tty->rawBufSemaphoreOptions = RTEMS_WAIT;
+ tty->rawBufSemaphoreTimeout = RTEMS_NO_TIMEOUT;
+ tty->rawBufSemaphoreFirstTimeout = RTEMS_NO_TIMEOUT;
+ }
+ else {
+ rtems_interval ticksPerSecond;
+ rtems_clock_get (RTEMS_CLOCK_GET_TICKS_PER_SECOND, &ticksPerSecond);
+ tty->vtimeTicks = tty->termios.c_cc[VTIME] * ticksPerSecond / 10;
+ if (tty->termios.c_cc[VTIME]) {
+ tty->rawBufSemaphoreOptions = RTEMS_WAIT;
+ tty->rawBufSemap`oreTimeout = tty->vtimeTicks;
+ if (tty->termios.c_cc[VMIN])
+ tty->rawBufSemaphoreFirstTimeout = RTEMS_NO_TIMEOUT;
+ else
+ tty->rawBufSemaphoreFirstTimeout = tty->vtimeTicks;
+ }
+ else {
+ if (tty->termios.c_cc[VMIN]) {
+ tty->rawBufSemaphoreOptions = RTEMS_WAIT;
+ tty->rawBufSemaphoreTimeout = RTEMS_NO_TIMEOUT;
+ tty->rawBufSemaphoreFirstTimeout = RTEMS_NO_TIMEOUT;
+ }
+ else {
+ tty->rawBufSemaphoreOptions = RTEMS_NO_WAIT;
+ }
+ }
+ }
+ break;
+ }
+ rtems_semaphore_release (tty->osem);
+ return sc;
}
/*
@@ -336,82 +344,82 @@ rtems_termios_ioctl (void *arg)
static void
oproc (unsigned char c, struct rtems_termios_tty *tty)
{
- int i;
-
- if (tty->termios.c_oflag & OPOST) {
- switch (c) {
- case '\n':
- if (tty->termios.c_oflag & ONLRET)
- tty->column = 0;
- if (tty->termios.c_oflag & ONLCR) {
- (*tty->write)(tty->minor, "\r", 1);
- tty->column = 0;
- }
- break;
-
- case '\r':
- if ((tty->termios.c_oflag & ONOCR) && (tty->column == 0))
- return;
- if (tty->termios.c_oflag & OCRNL) {
- c = '\n';
- if (tty->termios.c_oflag & ONLRET)
- tty->column = 0;
- break;
- }
- tty->column = 0;
- break;
-
- case '\t':
- i = 8 - (tty->column & 7);
- if ((tty->termios.c_oflag & TABDLY) == XTABS) {
- tty->column += i;
- (*tty->write)(tty->minor, " ", i);
- return;
- }
- tty->column += i;
- break;
-
- case '\b':
- if (tty->column > 0)
- tty->column--;
- break;
-
- default:
- if (tty->termios.c_oflag & OLCUC)
- c = toupper(c);
- if (!iscntrl(c))
- tty->column++;
- break;
- }
- }
- (*tty->write)(tty->minor, &c, 1);
+ int i;
+
+ if (tty->termios.c_oflag & OPOST) {
+ switch (c) {
+ case '\n':
+ if (tty->termios.c_oflag & ONLRET)
+ tty->column = 0;
+ if (tty->termios.c_oflag & ONLCR) {
+ (*tty->write)(tty->minor, "\r", 1);
+ tty->column = 0;
+ }
+ break;
+
+ case '\r':
+ if ((tty->termios.c_oflag & ONOCR) && (tty->column == 0))
+ return;
+ if (tty->termios.c_oflag & OCRNL) {
+ c = '\n';
+ if (tty->termios.c_oflag & ONLRET)
+ tty->column = 0;
+ break;
+ }
+ tty->column = 0;
+ break;
+
+ case '\t':
+ i = 8 - (tty->column & 7);
+ if ((tty->termios.c_oflag & TABDLY) == XTABS) {
+ tty->column += i;
+ (*tty->write)(tty->minor, " ", i);
+ return;
+ }
+ tty->column += i;
+ break;
+
+ case '\b':
+ if (tty->column > 0)
+ tty->column--;
+ break;
+
+ default:
+ if (tty->termios.c_oflag & OLCUC)
+ c = toupper(c);
+ if (!iscntrl(c))
+ tty->column++;
+ break;
+ }
+ }
+ (*tty->write)(tty->minor, &c, 1);
}
rtems_status_code
rtems_termios_write (void *arg)
{
- rtems_libio_rw_args_t *args = arg;
- struct rtems_termios_tty *tty = args->iop->data1;
- rtems_status_code sc;
-
- sc = rtems_semaphore_obtain (tty->osem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
- if (sc != RTEMS_SUCCESSFUL)
- return sc;
- if (tty->termios.c_oflag & OPOST) {
- unsigned32 count = args->count;
- unsigned8 *buffer = args->buffer;
- while (count--)
- oproc (*buffer++, tty);
- args->bytes_moved = args->count;
- }
- else {
- if ((*tty->write)(tty->minor, args->buffer, args->count) < 0)
- sc = RTEMS_UNSATISFIED;
- else
- args->bytes_moved = args->count;
- }
- rtems_semaphore_release (tty->osem);
- return sc;
+ rtems_libio_rw_args_t *args = arg;
+ struct rtems_termios_tty *tty = args->iop->data1;
+ rtems_status_code sc;
+
+ sc = rtems_semaphore_obtain (tty->osem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
+ if (sc != RTEMS_SUCCESSFUL)
+ return sc;
+ if (tty->termios.c_oflag & OPOST) {
+ unsigned32 count = args->count;
+ unsigned8 *buffer = args->buffer;
+ while (count--)
+ oproc (*buffer++, tty);
+ args->bytes_moved = args->count;
+ }
+ else {
+ if ((*tty->write)(tty->minor, args->buffer, args->count) < 0)
+ sc = RTEMS_UNSATISFIED;
+ else
+ args->bytes_moved = args->count;
+ }
+ rtems_semaphore_release (tty->osem);
+ return sc;
}
/*
@@ -420,17 +428,17 @@ rtems_termios_write (void *arg)
static void
echo (unsigned char c, struct rtems_termios_tty *tty)
{
- if ((tty->termios.c_lflag & ECHOCTL) && iscntrl(c) && (c != '\t') && (c != '\n')) {
- char echobuf[2];
-
- echobuf[0] = '^';
- echobuf[1] = c ^ 0x40;
- (*tty->write)(tty->minor, echobuf, 2);
- tty->column += 2;
- }
- else {
- oproc (c, tty);
- }
+ if ((tty->termios.c_lflag & ECHOCTL) && iscntrl(c) && (c != '\t') && (c != '\n')) {
+ char echobuf[2];
+
+ echobuf[0] = '^';
+ echobuf[1] = c ^ 0x40;
+ (*tty->write)(tty->minor, echobuf, 2);
+ tty->column += 2;
+ }
+ else {
+ oproc (c, tty);
+ }
}
/*
@@ -441,73 +449,73 @@ echo (unsigned char c, struct rtems_termios_tty *tty)
static void
erase (struct rtems_termios_tty *tty, int lineFlag)
{
- if (tty->ccount == 0)
- return;
- if (lineFlag) {
- if (!(tty->termios.c_lflag & ECHO)) {
- tty->ccount = 0;
- return;
- }
- if (!(tty->termios.c_lflag & ECHOE)) {
- tty->ccount = 0;
- echo (tty->termios.c_cc[VKILL], tty);
- if (tty->termios.c_lflag & ECHOK)
- echo ('\n', tty);
- return;
- }
- }
- while (tty->ccount) {
- unsigned char c = tty->cbuf[--tty->ccount];
-
- if (tty->termios.c_lflag & ECHO) {
- if (!lineFlag && !(tty->termios.c_lflag & ECHOE)) {
- echo (tty->termios.c_cc[VERASE], tty);
- }
- else if (c == '\t') {
- int col = tty->read_start_column;
- int i = 0;
-
- /*
- * Find the character before the tab
- */
- while (i != tty->ccount) {
- c = tty->cbuf[i++];
- if (c == '\t') {
- col = (col | 7) + 1;
- }
- else if (iscntrl (c)) {
- if (tty->termios.c_lflag & ECHOCTL)
- col += 2;
- }
- else {
- col++;
- }
- }
-
- /*
- * Back up over the tab
- */
- while (tty->column > col) {
- (*tty->write)(tty->minor, "\b", 1);
- tty->column--;
- }
- }
- else {
- if (iscntrl (c) && (tty->termios.c_lflag & ECHOCTL)) {
- (*tty->write)(tty->minor, "\b \b", 3);
- if (tty->column)
- tty->column--;
- }
- if (!iscntrl (c) || (tty->termios.c_lflag & ECHOCTL)) {
- (*tty->write)(tty->minor, "\b \b", 3);
- if (tty->column)
- tty->column--;
- }
- }
- }
- if (!lineFlag)
- break;
- }
+ if (tty->ccount == 0)
+ return;
+ if (lineFlag) {
+ if (!(tty->termios.c_lflag & ECHO)) {
+ tty->ccount = 0;
+ return;
+ }
+ if (!(tty->termios.c_lflag & ECHOE)) {
+ tty->ccount = 0;
+ echo (tty->termios.c_cc[VKILL], tty);
+ if (tty->termios.c_lflag & ECHOK)
+ echo ('\n', tty);
+ return;
+ }
+ }
+ while (tty->ccount) {
+ unsigned char c = tty->cbuf[--tty->ccount];
+
+ if (tty->termios.c_lflag & ECHO) {
+ if (!lineFlag && !(tty->termios.c_lflag & ECHOE)) {
+ echo (tty->termios.c_cc[VERASE], tty);
+ }
+ else if (c == '\t') {
+ int col = tty->read_start_column;
+ int i = 0;
+
+ /*
+ * Find the character before the tab
+ */
+ while (i != tty->ccount) {
+ c = tty->cbuf[i++];
+ if (c == '\t') {
+ col = (col | 7) + 1;
+ }
+ else if (iscntrl (c)) {
+ if (tty->termios.c_lflag & ECHOCTL)
+ col += 2;
+ }
+ else {
+ col++;
+ }
+ }
+
+ /*
+ * Back up over the tab
+ */
+ while (tty->column > col) {
+ (*tty->write)(tty->minor, "\b", 1);
+ tty->column--;
+ }
+ }
+ else {
+ if (iscntrl (c) && (tty->termios.c_lflag & ECHOCTL)) {
+ (*tty->write)(tty->minor, "\b \b", 3);
+ if (tty->column)
+ tty->column--;
+ }
+ if (!iscntrl (c) || (tty->termios.c_lflag & ECHOCTL)) {
+ (*tty->write)(tty->minor, "\b \b", 3);
+ if (tty->column)
+ tty->column--;
+ }
+ }
+ }
+ if (!lineFlag)
+ break;
+ }
}
/*
@@ -516,55 +524,55 @@ erase (struct rtems_termios_tty *tty, int lineFlag)
static int
iproc (unsigned char c, struct rtems_termios_tty *tty)
{
- if (tty->termios.c_iflag & ISTRIP)
- c &= 0x7f;
- if (tty->termios.c_iflag & IUCLC)
- c = tolower (c);
- if (c == '\r') {
- if (tty->termios.c_iflag & IGNCR)
- return 0;
- if (tty->termios.c_iflag & ICRNL)
- c = '\n';
- }
- else if ((c == '\n') && (tty->termios.c_iflag & INLCR)) {
- c = '\r';
- }
- if ((c != '\0') && (tty->termios.c_lflag & ICANON)) {
- if (c == tty->termios.c_cc[VERASE]) {
- erase (tty, 0);
- return 0;
- }
- else if (c == tty->termios.c_cc[VKILL]) {
- erase (tty, 1);
- return 0;
- }
- else if (c == tty->termios.c_cc[VEOF]) {
- return 1;
- }
- else if (c == '\n') {
- if (tty->termios.c_lflag & (ECHO | ECHONL))
- echo (c, tty);
- tty->cbuf[tty->ccount++] = c;
- return 1;
- }
- else if ((c == tty->termios.c_cc[VEOL])
- || (c == tty->termios.c_cc[VEOL2])) {
- if (tty->termios.c_lflag & ECHO)
- echo (c, tty);
- tty->cbuf[tty->ccount++] = c;
- return 1;
- }
- }
-
- /*
- * FIXME: Should do IMAXBEL handling somehow
- */
- if (tty->ccount < (CBUFSIZE-1)) {
- if (tty->termios.c_lflag & ECHO)
- echo (c, tty);
- tty->cbuf[tty->ccount++] = c;
- }
- return 0;
+ if (tty->termios.c_iflag & ISTRIP)
+ c &= 0x7f;
+ if (tty->termios.c_iflag & IUCLC)
+ c = tolower (c);
+ if (c == '\r') {
+ if (tty->termios.c_iflag & IGNCR)
+ return 0;
+ if (tty->termios.c_iflag & ICRNL)
+ c = '\n';
+ }
+ else if ((c == '\n') && (tty->termios.c_iflag & INLCR)) {
+ c = '\r';
+ }
+ if ((c != '\0') && (tty->termios.c_lflag & ICANON)) {
+ if (c == tty->termios.c_cc[VERASE]) {
+ erase (tty, 0);
+ return 0;
+ }
+ else if (c == tty->termios.c_cc[VKILL]) {
+ erase (tty, 1);
+ return 0;
+ }
+ else if (c == tty->termios.c_cc[VEOF]) {
+ return 1;
+ }
+ else if (c == '\n') {
+ if (tty->termios.c_lflag & (ECHO | ECHONL))
+ echo (c, tty);
+ tty->cbuf[tty->ccount++] = c;
+ return 1;
+ }
+ else if ((c == tty->termios.c_cc[VEOL])
+ || (c == tty->termios.c_cc[VEOL2])) {
+ if (tty->termios.c_lflag & ECHO)
+ echo (c, tty);
+ tty->cbuf[tty->ccount++] = c;
+ return 1;
+ }
+ }
+
+ /*
+ * FIXME: Should do IMAXBEL handling somehow
+ */
+ if (tty->ccount < (CBUFSIZE-1)) {
+ if (tty->termios.c_lflag & ECHO)
+ echo (c, tty);
+ tty->cbuf[tty->ccount++] = c;
+ }
+ return 0;
}
/*
@@ -573,20 +581,20 @@ iproc (unsigned char c, struct rtems_termios_tty *tty)
static int
siproc (unsigned char c, struct rtems_termios_tty *tty)
{
- int i;
-
- /*
- * Obtain output semaphore if character will be echoed
- */
- if (tty->termios.c_lflag & (ECHO|ECHOE|ECHOK|ECHONL|ECHOPRT|ECHOCTL|ECHOKE)) {
- rtems_semaphore_obtain (tty->osem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
- i = iproc (c, tty);
- rtems_semaphore_release (tty->osem);
- }
- else {
- i = iproc (c, tty);
- }
- return i;
+ int i;
+
+ /*
+ * Obtain output semaphore if character will be echoed
+ */
+ if (tty->termios.c_lflag & (ECHO|ECHOE|ECHOK|ECHONL|ECHOPRT|ECHOCTL|ECHOKE)) {
+ rtems_semaphore_obtain (tty->osem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
+ i = iproc (c, tty);
+ rtems_semaphore_release (tty->osem);
+ }
+ else {
+ i = iproc (c, tty);
+ }
+ return i;
}
/*
@@ -595,62 +603,62 @@ siproc (unsigned char c, struct rtems_termios_tty *tty)
static rtems_status_code
fillBufferPoll (struct rtems_termios_tty *tty)
{
- unsigned char c;
- int n;
-
- if (tty->termios.c_lflag & ICANON) {
- for (;;) {
- n = (*tty->read)(tty->minor, &c);
- if (n < 0) {
- return RTEMS_UNSATISFIED;
- }
- else if (n == 0) {
- rtems_task_wake_after (1);
- }
- else {
- if (siproc (c, tty))
- break;
- }
- }
- }
- else {
- rtems_interval then, now;
- if (!tty->termios.c_cc[VMIN] && tty->termios.c_cc[VTIME])
- rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &then);
- for (;;) {
- n = (*tty->read)(tty->minor, &c);
- if (n < 0) {
- return RTEMS_UNSATISFIED;
- }
- else if (n == 0) {
- if (tty->termios.c_cc[VMIN]) {
- if (tty->termios.c_cc[VTIME] && tty->ccount) {
- rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &now);
- if ((now - then) > tty->vtimeTicks) {
- break;
- }
- }
- }
- else {
- if (!tty->termios.c_cc[VTIME])
- break;
- rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &now);
- if ((now - then) > tty->vtimeTicks) {
- break;
- }
- }
- rtems_task_wake_after (1);
- }
- else {
- siproc (c, tty);
- if (tty->ccount >= tty->termios.c_cc[VMIN])
- break;
- if (tty->termios.c_cc[VMIN] && tty->termios.c_cc[VTIME])
- rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &then);
- }
- }
- }
- return RTEMS_SUCCESSFUL;
+ unsigned char c;
+ int n;
+
+ if (tty->termios.c_lflag & ICANON) {
+ for (;;) {
+ n = (*tty->read)(tty->minor, &c);
+ if (n < 0) {
+ return RTEMS_UNSATISFIED;
+ }
+ else if (n == 0) {
+ rtems_task_wake_after (1);
+ }
+ else {
+ if (siproc (c, tty))
+ break;
+ }
+ }
+ }
+ else {
+ rtems_interval then, now;
+ if (!tty->termios.c_cc[VMIN] && tty->termios.c_cc[VTIME])
+ rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &then);
+ for (;;) {
+ n = (*tty->read)(tty->minor, &c);
+ if (n < 0) {
+ return RTEMS_UNSATISFIED;
+ }
+ else if (n == 0) {
+ if (tty->termios.c_cc[VMIN]) {
+ if (tty->termios.c_cc[VTIME] && tty->ccount) {
+ rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &now);
+ if ((now - then) > tty->vtimeTicks) {
+ break;
+ }
+ }
+ }
+ else {
+ if (!tty->termios.c_cc[VTIME])
+ break;
+ rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &now);
+ if ((now - then) > tty->vtimeTicks) {
+ break;
+ }
+ }
+ rtems_task_wake_after (1);
+ }
+ else {
+ siproc (c, tty);
+ if (tty->ccount >= tty->termios.c_cc[VMIN])
+ break;
+ if (tty->termios.c_cc[VMIN] && tty->termios.c_cc[VTIME])
+ rtems_clock_get (RTEMS_CLOCK_GET_TICKS_SINCE_BOOT, &then);
+ }
+ }
+ }
+ return RTEMS_SUCCESSFUL;
}
/*
@@ -659,69 +667,73 @@ fillBufferPoll (struct rtems_termios_tty *tty)
static rtems_status_code
fillBufferQueue (struct rtems_termios_tty *tty)
{
- rtems_interval timeout = tty->rawMessageFirstTimeout;
- rtems_status_code sc;
- rtems_unsigned8 c;
-
- for (;;) {
-
- /*
- * Read characters from raw queue
- */
- sc = rtems_semaphore_obtain (tty->rawInputSem,
- tty->rawMessageOptions,
- timeout);
- if (sc != RTEMS_SUCCESSFUL)
- break;
- Ring_buffer_Remove_character( &tty->rawInputBuffer, c );
-
- /*
- * Process characters read from raw queue
- */
- if (tty->termios.c_lflag & ICANON) {
- if (siproc (c, tty))
- return RTEMS_SUCCESSFUL;
- }
- else {
- siproc (c, tty);
- if (tty->ccount >= tty->termios.c_cc[VMIN])
- return RTEMS_SUCCESSFUL;
- }
-
- timeout = tty->rawMessageTimeout;
- }
- return RTEMS_SUCCESSFUL;
+ rtems_interval timeout = tty->rawBufSemaphoreFirstTimeout;
+ rtems_status_code sc;
+
+ for (;;) {
+ /*
+ * Process characters read from raw queue
+ */
+ while (tty->rawBufHead != tty->rawBufTail) {
+ unsigned char c;
+ unsigned int newHead;
+
+ newHead = (tty->rawBufHead + 1) % RAW_BUFFER_SIZE;
+ c = tty->rawBuf[newHead];
+ tty->rawBufHead = newHead;
+ if (tty->termios.c_lflag & ICANON) {
+ if (siproc (c, tty))
+ return RTEMS_SUCCESSFUL;
+ }
+ else {
+ siproc (c, tty);
+ if (tty->ccount >= tty->termios.c_cc[VMIN])
+ return RTEMS_SUCCESSFUL;
+ }
+ timeout = tty->rawBufSemaphoreTimeout;
+ }
+
+ /*
+ * Wait for characters
+ */
+ sc = rtems_semaphore_obtain (tty->rawBufSemaphore,
+ tty->rawBufSemaphoreOptions,
+ timeout);
+ if (sc != RTEMS_SUCCESSFUL)
+ break;
+ }
+ return RTEMS_SUCCESSFUL;
}
rtems_status_code
rtems_termios_read (void *arg)
{
- rtems_libio_rw_args_t *args = arg;
- struct rtems_termios_tty *tty = args->iop->data1;
- unsigned32 count = args->count;
- unsigned8 *buffer = args->buffer;
- rtems_status_code sc;
-
- sc = rtems_semaphore_obtain (tty->isem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
- if (sc != RTEMS_SUCCESSFUL)
- return sc;
- if (tty->cindex == tty->ccount) {
- tty->cindex = tty->ccount = 0;
- tty->read_start_column = tty->column;
- if (tty->read)
- sc = fillBufferPoll (tty);
- else
- sc = fillBufferQueue (tty);
- if (sc != RTEMS_SUCCESSFUL)
- tty->cindex = tty->ccount = 0;
- }
- while (count && (tty->cindex < tty->ccount)) {
- *buffer++ = tty->cbuf[tty->cindex++];
- count--;
- }
- args->bytes_moved = args->count - count;
- rtems_semaphore_release (tty->isem);
- return sc;
+ rtems_libio_rw_args_t *args = arg;
+ struct rtems_termios_tty *tty = args->iop->data1;
+ unsigned32 count = args->count;
+ unsigned8 *buffer = args->buffer;
+ rtems_status_code sc;
+
+ sc = rtems_semaphore_obtain (tty->isem, RTEMS_WAIT, RTEMS_NO_TIMEOUT);
+ if (sc != RTEMS_SUCCESSFUL)
+ return sc;
+ if (tty->cindex == tty->ccount) {
+ tty->cindex = tty->ccount = 0;
+ tty->read_start_column = tty->column;
+ if (tty->read)
+ sc = fillBufferPoll (tty);
+ else
+ sc = fillBufferQueue (tty);
+ if (sc != RTEMS_SUCCESSFUL)
+ tty->cindex = tty->ccount = 0;
+ }
+ while (count && (tty->cindex < tty->ccount)) {
+ *buffer++ = tty->cbuf[tty->cindex++];
+ count--;
+ }
+ args->bytes_moved = args->count - count;
+ rtems_semaphore_release (tty->isem);
+ return sc;
}
/*
@@ -731,16 +743,45 @@ rtems_termios_read (void *arg)
void
rtems_termios_enqueue_raw_characters (void *ttyp, char *buf, int len)
{
- struct rtems_termios_tty *tty = ttyp;
-
- while (len) {
- if (Ring_buffer_Is_full(&tty->rawInputBuffer))
- break;
- Ring_buffer_Add_character(&tty->rawInputBuffer, *buf);
- if (rtems_semaphore_release(tty->rawInputSem) != RTEMS_SUCCESSFUL)
- break;
- len -= 1;
- buf += 1;
- }
+ struct rtems_termios_tty *tty = ttyp;
+ unsigned int newTail;
+
+ while (len) {
+ newTail = (tty->rawBufTail + 1) % RAW_BUFFER_SIZE;
+ if (newTail == tty->rawBufHead) {
+ tty->rawBufDropped += len;
+ break;
+ }
+ tty->rawBuf[newTail] = *buf++;
+ len--;
+ tty->rawBufTail = newTail;
+ }
+ rtems_semaphore_release (tty->rawBufSemaphore);
}
+/*
+ * Reserve enough resources to at least open every physical device
+ * once.
+ */
+
+void rtems_termios_reserve_resources(
+ rtems_configuration_table *configuration,
+ rtems_unsigned32 number_of_devices
+)
+{
+ static int first_time = 1;
+ rtems_api_configuration_table *rtems_config;
+
+ if (!configuration)
+ rtems_fatal_error_occurred (0xFFF0F001);
+
+ rtems_config = configuration->RTEMS_api_configuration;
+ if (!rtems_config)
+ rtems_fatal_error_occurred (0xFFF0F002);
+
+ if (first_time)
+ rtems_config->maximum_semaphores += 1;
+
+ first_time = 0;
+ rtems_config->maximum_semaphores += (3 * number_of_devices);
+}