[LTP] [PATCH v2] syscalls/pipe12: add new test for pipe when write bytes > PIPE_BUF
Yang Xu
xuyang2018.jy@cn.fujitsu.com
Tue Jan 7 03:53:54 CET 2020
A pipe has a limited capacity. If the pipe with non block mode is full,
then a write(2) will fail and get EAGAIN error. Otherwise, from 1 to
PIPE_BUF bytes may be written.
Signed-off-by: Yang Xu <xuyang2018.jy@cn.fujitsu.com>
---------------
v1->v2:
1)add missing lapi/fcntl.h
2)remove useless return
---------------
---
runtest/syscalls | 1 +
testcases/kernel/syscalls/pipe/.gitignore | 1 +
testcases/kernel/syscalls/pipe/pipe12.c | 106 ++++++++++++++++++++++
3 files changed, 108 insertions(+)
create mode 100644 testcases/kernel/syscalls/pipe/pipe12.c
diff --git a/runtest/syscalls b/runtest/syscalls
index fa87ef63f..92a9ae636 100644
--- a/runtest/syscalls
+++ b/runtest/syscalls
@@ -861,6 +861,7 @@ pipe08 pipe08
pipe09 pipe09
pipe10 pipe10
pipe11 pipe11
+pipe12 pipe12
pipe2_01 pipe2_01
pipe2_02 pipe2_02
diff --git a/testcases/kernel/syscalls/pipe/.gitignore b/testcases/kernel/syscalls/pipe/.gitignore
index ee2974ca8..90b502547 100644
--- a/testcases/kernel/syscalls/pipe/.gitignore
+++ b/testcases/kernel/syscalls/pipe/.gitignore
@@ -9,3 +9,4 @@
/pipe09
/pipe10
/pipe11
+/pipe12
diff --git a/testcases/kernel/syscalls/pipe/pipe12.c b/testcases/kernel/syscalls/pipe/pipe12.c
new file mode 100644
index 000000000..926e03f56
--- /dev/null
+++ b/testcases/kernel/syscalls/pipe/pipe12.c
@@ -0,0 +1,106 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+/*
+ * Copyright (c) 2020 FUJITSU LIMITED. All rights reserved.
+ * Author: Yang Xu <xuyang2018.jy@cn.fujitsu.com>
+ *
+ * Test Description:
+ * A pipe has a limited capacity. If the pipe with non block mode is full,
+ * then a write(2) will fail and get EAGAIN error. Otherwise, from 1 to
+ * PIPE_BUF bytes may be written.
+ */
+#define _GNU_SOURCE
+#include <unistd.h>
+#include <stdlib.h>
+#include <fcntl.h>
+#include "tst_test.h"
+#include "lapi/fcntl.h"
+
+static int fds[2];
+static char *wrbuf;
+static char *rdbuf;
+static ssize_t max_size, invalid_size;
+
+static struct tcase {
+ int full_flag;
+ int need_offset;
+ char *message;
+} tcases[] = {
+ {1, 0, "Test on full pipe"},
+ {0, 1, "Test on non full pipe from 1 offset"},
+ {0, 0, "Test on non full pipe from 0 offset"},
+};
+
+static void verify_pipe(unsigned int n)
+{
+ struct tcase *tc = &tcases[n];
+
+ memset(rdbuf, 0, max_size);
+
+ tst_res(TINFO, "%s", tc->message);
+ if (tc->full_flag) {
+ SAFE_WRITE(1, fds[1], wrbuf, max_size);
+ TEST(write(fds[1], "x", 1));
+ if (TST_RET == 0) {
+ tst_res(TFAIL, "write succeeded unexpectedly");
+ goto clean_pipe_buf;
+ }
+ if (TST_ERR == EAGAIN)
+ tst_res(TPASS | TTERRNO, "write failed as expected");
+ else
+ tst_res(TFAIL | TTERRNO, "write failed, expected EAGAIN but got");
+ } else {
+ if (tc->need_offset)
+ SAFE_WRITE(1, fds[1], "x", 1);
+ TEST(write(fds[1], wrbuf, invalid_size));
+ if (TST_RET == -1) {
+ tst_res(TFAIL, "write failed unexpectedly");
+ goto clean_pipe_buf;
+ }
+ if (TST_RET == invalid_size)
+ tst_res(TFAIL, "write size %ld larger than PIPE_BUF %ld", TST_RET, max_size);
+ else
+ tst_res(TPASS, "write size %ld between [1, %ld]", TST_RET, max_size);
+ }
+
+clean_pipe_buf:
+ SAFE_READ(0, fds[0], rdbuf, max_size);
+}
+
+
+static void cleanup(void)
+{
+ if (fds[0] > 0)
+ SAFE_CLOSE(fds[0]);
+ if (fds[1] > 0)
+ SAFE_CLOSE(fds[1]);
+ if (wrbuf)
+ free(wrbuf);
+ if (rdbuf)
+ free(rdbuf);
+}
+
+static void setup(void)
+{
+
+ TEST(pipe(fds));
+ if (TST_RET == -1) {
+ tst_brk(TBROK | TTERRNO, "pipe");
+ return;
+ }
+
+ max_size = SAFE_FCNTL(fds[1], F_GETPIPE_SZ);
+ invalid_size = max_size + 4096;
+ wrbuf = SAFE_MALLOC(invalid_size);
+ rdbuf = SAFE_MALLOC(max_size);
+ memset(wrbuf, 'x', invalid_size);
+
+ SAFE_FCNTL(fds[1], F_SETFL, O_NONBLOCK);
+ SAFE_FCNTL(fds[0], F_SETFL, O_NONBLOCK);
+}
+
+static struct tst_test test = {
+ .test = verify_pipe,
+ .setup = setup,
+ .cleanup = cleanup,
+ .tcnt = ARRAY_SIZE(tcases),
+};
--
2.18.0
More information about the ltp
mailing list