Aren/haiku
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Updated the pipe_test to also test buffering of writes to the pipe.

Browse Source 
git-svn-id: file:///srv/svn/repos/haiku/trunk/current@3735 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Axel Dörfler 2003-06-29 18:12:48 +00:00
parent 7619f562d5
commit 62ef93d044
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/kernel/apps/pipe_test.c
View File

@ -25,7 +25,11 @@ reader_func(void *data)
// null-terminate, just in case // null-terminate, just in case
printf("reader: (%d) %s\n", bytes, buffer); printf("reader: (%d) %s\n", bytes, buffer);
if (!strcmp(buffer, "QUIT")) if (buffer[0] == '2') {
puts("reader: wait a second and let the writer lead (the pipe has to be buffered)");
snooze(1000000);
}
if (strstr(buffer, "QUIT"))
break; break;
} }
puts("reader quits"); puts("reader quits");
@ -41,11 +45,11 @@ writer_func(void *data)
int i; int i;
const char *strings[] = { const char *strings[] = {
"1. If you read this", "1. If you read this ",
"2. the pipe implementation", "2. the pipe implementation ",
"3. seems to work", "3. seems to work ",
"4. at least a bit", "4. at least a bit ",
"QUIT", "5. QUIT",
NULL}; NULL};
for (i = 0; strings[i] != NULL; i++) { for (i = 0; strings[i] != NULL; i++) {
@ -53,7 +57,7 @@ writer_func(void *data)
// make sure the reader is waiting for us... // make sure the reader is waiting for us...
// (needed by the current pipefs implementation :) // (needed by the current pipefs implementation :)
printf("writer: (%ld)\n", write(output, strings[i], strlen(strings[i]) + 1)); printf("writer: (%ld)\n", write(output, strings[i], strlen(strings[i])));
} }
puts("writer quits"); puts("writer quits");