diff options
| author | Sebastian Huber <sebastian.huber@embedded-brains.de> | 2017-02-24 14:44:04 +0100 |
|---|---|---|
| committer | Sebastian Huber <sebastian.huber@embedded-brains.de> | 2017-02-28 09:09:23 +0100 |
| commit | 36635433921323438501e1ffc21392c094773765 (patch) | |
| tree | 8113d0ff6ae69ea49de608f15899c7b877cb6451 /testsuites | |
| parent | termios: Make write POSIX compatible (diff) | |
| download | rtems-36635433921323438501e1ffc21392c094773765.tar.bz2 | |
termios: Implement non-blocking write
Diffstat (limited to 'testsuites')
| -rw-r--r-- | testsuites/libtests/termios09/init.c | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/testsuites/libtests/termios09/init.c b/testsuites/libtests/termios09/init.c index 648d1bf7ed..f13804dcc1 100644 --- a/testsuites/libtests/termios09/init.c +++ b/testsuites/libtests/termios09/init.c @@ -199,6 +199,24 @@ static void input(test_context *ctx, size_t i, char c) } } +static void enable_non_blocking(test_context *ctx, size_t i, bool enable) +{ + int flags; + int rv; + + flags = fcntl(ctx->fds[i], F_GETFL, 0); + rtems_test_assert(flags >= 0); + + if (enable) { + flags |= O_NONBLOCK; + } else { + flags &= ~O_NONBLOCK; + } + + rv = fcntl(ctx->fds[i], F_SETFL, flags); + rtems_test_assert(rv == 0); +} + static void clear_set_iflag( test_context *ctx, size_t i, @@ -968,6 +986,11 @@ static void test_write(test_context *ctx) rtems_test_assert(ctx->context_switch_counter == 0); + enable_non_blocking(ctx, i, true); + n = write(ctx->fds[i], &buf[OUTPUT_BUFFER_SIZE - 1], 1); + rtems_test_assert(n == 0); + + enable_non_blocking(ctx, i, false); n = write(ctx->fds[i], &buf[OUTPUT_BUFFER_SIZE - 1], 1); rtems_test_assert(n == 1); @@ -994,6 +1017,11 @@ static void test_write(test_context *ctx) rtems_test_assert(ctx->context_switch_counter == 2); + enable_non_blocking(ctx, i, true); + n = write(ctx->fds[i], &buf[OUTPUT_BUFFER_SIZE - 2], 1); + rtems_test_assert(n == 0); + + enable_non_blocking(ctx, i, false); n = write(ctx->fds[i], &buf[OUTPUT_BUFFER_SIZE - 2], 1); rtems_test_assert(n == 1); @@ -1020,6 +1048,11 @@ static void test_write(test_context *ctx) rtems_test_assert(ctx->context_switch_counter == 4); + enable_non_blocking(ctx, i, true); + n = write(ctx->fds[i], &buf[OUTPUT_BUFFER_SIZE - 8], 1); + rtems_test_assert(n == 0); + + enable_non_blocking(ctx, i, false); n = write(ctx->fds[i], &buf[OUTPUT_BUFFER_SIZE - 8], 1); rtems_test_assert(n == 1); |