You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
102 lines
2.0 KiB
102 lines
2.0 KiB
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
/*
|
|
* Copyright (c) International Business Machines Corp., 2001
|
|
* Ported to LTP: Wayne Boyer
|
|
* Copyright (c) 2018 Cyril Hrubis <chrubis@suse.cz>
|
|
*/
|
|
|
|
/*
|
|
* Check if many children can read what is written to a pipe by the parent.
|
|
*
|
|
* ALGORITHM
|
|
* For a different nchilds number:
|
|
* 1. Open a pipe and write nchilds * (PIPE_BUF/nchilds) bytes into it
|
|
* 2. Fork nchilds children
|
|
* 3. Each child reads PIPE_BUF/nchilds characters and checks that the
|
|
* bytes read are correct
|
|
*/
|
|
#include <stdlib.h>
|
|
#include "tst_test.h"
|
|
|
|
static int fds[2];
|
|
static unsigned char buf[PIPE_BUF];
|
|
static size_t read_per_child;
|
|
|
|
void do_child(void)
|
|
{
|
|
size_t nread;
|
|
unsigned char rbuf[read_per_child];
|
|
unsigned int i;
|
|
|
|
SAFE_CLOSE(fds[1]);
|
|
|
|
nread = SAFE_READ(0, fds[0], rbuf, sizeof(rbuf));
|
|
|
|
if (nread != read_per_child) {
|
|
tst_res(TFAIL, "Invalid read size child %i size %zu",
|
|
getpid(), nread);
|
|
return;
|
|
}
|
|
|
|
for (i = 0; i < read_per_child; i++) {
|
|
if (rbuf[i] != (i % 256)) {
|
|
tst_res(TFAIL,
|
|
"Invalid byte read child %i byte %i have %i expected %i",
|
|
getpid(), i, rbuf[i], i % 256);
|
|
return;
|
|
}
|
|
}
|
|
|
|
tst_res(TPASS, "Child %i read pipe buffer correctly", getpid());
|
|
}
|
|
|
|
static unsigned int childs[] = {
|
|
1,
|
|
2,
|
|
3,
|
|
4,
|
|
10,
|
|
50
|
|
};
|
|
|
|
static void run(unsigned int tcase)
|
|
{
|
|
pid_t pid;
|
|
unsigned int nchilds = childs[tcase];
|
|
read_per_child = PIPE_BUF/nchilds;
|
|
unsigned int i, j;
|
|
|
|
tst_res(TINFO, "Reading %zu per each of %u children",
|
|
read_per_child, nchilds);
|
|
|
|
for (i = 0; i < nchilds; i++) {
|
|
for (j = 0; j < read_per_child; j++) {
|
|
buf[i * read_per_child + j] = j % 256;
|
|
}
|
|
}
|
|
|
|
SAFE_PIPE(fds);
|
|
|
|
SAFE_WRITE(1, fds[1], buf, read_per_child * nchilds);
|
|
|
|
for (i = 0; i < nchilds; i++) {
|
|
pid = SAFE_FORK();
|
|
|
|
if (!pid) {
|
|
do_child();
|
|
exit(0);
|
|
}
|
|
}
|
|
|
|
tst_reap_children();
|
|
|
|
SAFE_CLOSE(fds[0]);
|
|
SAFE_CLOSE(fds[1]);
|
|
}
|
|
|
|
static struct tst_test test = {
|
|
.forks_child = 1,
|
|
.test = run,
|
|
.tcnt = ARRAY_SIZE(childs),
|
|
};
|