From mboxrd@z Thu Jan 1 00:00:00 1970 From: bxue@redhat.com Date: Fri, 12 May 2017 17:14:35 +0800 Subject: [LTP] [PATCH v4 2/2] syscalls/splice05: add test for splice() between pipe and socket In-Reply-To: <1494580475-3522-1-git-send-email-bxue@redhat.com> References: <1494580475-3522-1-git-send-email-bxue@redhat.com> Message-ID: <1494580475-3522-2-git-send-email-bxue@redhat.com> List-Id: MIME-Version: 1.0 Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit To: ltp@lists.linux.it From: Boyang Xue This test case covers splice operation between pipe and socket. Signed-off-by: Boyang Xue --- runtest/syscalls | 1 + testcases/kernel/syscalls/.gitignore | 1 + testcases/kernel/syscalls/splice/splice05.c | 122 ++++++++++++++++++++++++++++ 3 files changed, 124 insertions(+) create mode 100644 testcases/kernel/syscalls/splice/splice05.c diff --git a/runtest/syscalls b/runtest/syscalls index d6c9ab4..0fae11a 100644 --- a/runtest/syscalls +++ b/runtest/syscalls @@ -1225,6 +1225,7 @@ splice01 splice01 splice02 seq 1 20000 | splice02 splice02-temp splice03 splice03 splice04 splice04 +splice05 splice05 tee01 tee01 tee02 tee02 diff --git a/testcases/kernel/syscalls/.gitignore b/testcases/kernel/syscalls/.gitignore index 92ddbbe..604730f 100644 --- a/testcases/kernel/syscalls/.gitignore +++ b/testcases/kernel/syscalls/.gitignore @@ -977,6 +977,7 @@ /splice/splice02 /splice/splice03 /splice/splice04 +/splice/splice05 /ssetmask/ssetmask01 /stat/stat01 /stat/stat01_64 diff --git a/testcases/kernel/syscalls/splice/splice05.c b/testcases/kernel/syscalls/splice/splice05.c new file mode 100644 index 0000000..ea6ca7c --- /dev/null +++ b/testcases/kernel/syscalls/splice/splice05.c @@ -0,0 +1,122 @@ +/* + * Copyright (c) 2017 Red Hat, Inc. + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + * + * Author: Boyang Xue + */ + +/* + * Functional test for splice(2): pipe <-> socket + * + * This test case tests splice(2) from a pipe to a socket and vice versa + */ + +#define _GNU_SOURCE +#include +#include +#include +#include +#include +#include +#include +#include "tst_test.h" + +#define PIPE_MAX (64*1024) + +static char *str_len_data; +static int num_len_data = PIPE_MAX; +static char *arr_in, *arr_out; + +static struct tst_option options[] = { + {"l:", &str_len_data, "-l Length of test data (in bytes)"}, + {NULL, NULL, NULL}, +}; + +static void setup(void) +{ + int i, pipe_max_unpriv, pipe_limit; + + SAFE_FILE_SCANF("/proc/sys/fs/pipe-max-size", "%d", &pipe_max_unpriv); + pipe_limit = pipe_max_unpriv < num_len_data ? pipe_max_unpriv : + num_len_data; + num_len_data = pipe_limit; + + if (tst_parse_int(str_len_data, &num_len_data, 1, pipe_limit)) + tst_brk(TBROK, "Invalid length of data: '%s', " + "valid value: [1, %d]", str_len_data, pipe_limit); + tst_res(TINFO, "splice size = %d", num_len_data); + arr_in = SAFE_MALLOC(num_len_data); + arr_out = SAFE_MALLOC(num_len_data); + for (i = 0; i < num_len_data; i++) + arr_in[i] = i & 0xff; + +} + +static void cleanup(void) +{ + free(arr_in); + free(arr_out); +} + +static void pipe_socket(void) +{ + int pp1[2], pp2[2], sv[2], i, ret; + + SAFE_PIPE(pp1); + SAFE_PIPE(pp2); + if (socketpair(AF_UNIX, SOCK_STREAM, 0, sv)) + tst_brk(TBROK | TERRNO, "fail to create socket pair."); + + SAFE_WRITE(1, pp1[1], arr_in, num_len_data); + for (i = 0; i < num_len_data; i++) { + ret = splice(pp1[0], NULL, sv[0], 0, 1, SPLICE_F_MOVE); + if (ret == -1) { + tst_res(TFAIL | TERRNO, "splice error"); + goto exit; + } + } + for (i = 0; i < num_len_data; i++) { + ret = splice(sv[1], 0, pp2[1], NULL, 1, SPLICE_F_MOVE); + if (ret == -1) { + tst_res(TFAIL | TERRNO, "splice error"); + goto exit; + } + SAFE_READ(1, pp2[0], arr_out + i, 1); + } + + for (i = 0; i < num_len_data; i++) { + if (arr_in[i] != arr_out[i]) { + tst_res(TFAIL, "wrong data@%d: expected: %d, " + "actual %d", i, arr_in[i], arr_out[i]); + goto exit; + } + } + tst_res(TPASS, "splice(2): pipe <-> socket run pass."); +exit: + for (i = 0; i < 2; i++) { + SAFE_CLOSE(pp1[i]); + SAFE_CLOSE(pp2[i]); + SAFE_CLOSE(sv[i]); + } +} + +static struct tst_test test = { + .tid = "splice05", + .test_all = pipe_socket, + .setup = setup, + .cleanup = cleanup, + .options = options, + .min_kver = "2.6.17" +}; -- 1.8.3.1