d/freebsd-skq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Ensure data in pipe is available to read.

Browse Source 
Useful for latest (5th, direct mode) test only.

Sponsored by:	DARPA, AFRL
Sponsored by:	HEIF5
This commit is contained in:
br 2016-10-10 13:40:05 +00:00
parent 1ab62cd0c0
commit aec9e62c60
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/sys/kern/pipe/pipe_fstat_bug_test.c
View File

@ -26,6 +26,7 @@ SUCH DAMAGE.
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/event.h>
#include <assert.h>
#include <err.h>
#include <errno.h>
@ -49,10 +50,12 @@ main(void)
{
char buffer[32768], buffer2[32768], go[] = "go", go2[] = "go2";
int desc[2], ipc_coord[2];
struct kevent event, ke;
ssize_t error;
int successes = 0;
struct stat status;
pid_t new_pid;
int kq;
error = pipe(desc);
if (error == -1)
@ -118,9 +121,24 @@ main(void)
_exit(0);
}
kq = kqueue();
if (kq == -1)
_exit(1);
EV_SET(&ke, desc[0], EVFILT_READ, EV_ADD, 0, 0, NULL);
/* Attach event to the kqueue. */
if (kevent(kq, &ke, 1, NULL, 0, NULL) != 0)
_exit(2);
while (successes < 5) {
SYNC_W(1, go);
SYNC_R(1, go2);
/* Ensure data is available to read */
if (kevent(kq, NULL, 0, &event, 1, NULL) != 1)
_exit(3);
fstat(desc[0], &status);
error = read(desc[0], &buffer2, sizeof(buffer2));