--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/genericopenlibs/cstdlib/TSTLIB/TPIPE2.C Tue Feb 02 02:01:42 2010 +0200
@@ -0,0 +1,336 @@
+/*
+* Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:
+* Test code for pipes, using dubious WINS extension for multiple processes...
+*
+*
+*/
+
+
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <unistd.h> /* for MAXPATHLEN */
+#include <sys/errno.h>
+#include <sys/ioctl.h>
+
+#include "CTEST.H"
+
+void fillbuf(int seed, char* buf, int buflen)
+ {
+ int j;
+ sleep(seed/3);
+ seed += 'A';
+ for (j=0; j<buflen; j++)
+ {
+ buf[j]=(char)seed;
+ seed+=13;
+ if (seed > 127)
+ seed = seed - 127 + 'A';
+ }
+ }
+
+/**
+@SYMTestCaseID SYSLIB-STDLIB-CT-1078
+@SYMTestCaseDesc Tests for operations on pipes
+@SYMTestPriority High
+@SYMTestActions Tests for writing to an opened pipe and a closed pipe
+@SYMTestExpectedResults Test must not fail
+@SYMREQ REQ0000
+*/
+void producer(int fid, int final)
+ {
+ test_Data;
+ char buf[128];
+ int nbytes;
+ int i;
+ int t_errno;
+
+ test_Title("Producer");
+
+ for (i=1; i<=8; i++)
+ {
+ fillbuf(i,buf,sizeof(buf));
+ printf("%d",i);
+ fflush(stdout);
+ nbytes=write(fid, buf, sizeof(buf));
+ printf(".");
+ fflush(stdout);
+ test(nbytes==sizeof(buf));
+ }
+ printf("\n");
+
+ if (!final)
+ return;
+
+ test_Next("Writing to closed pipe");
+
+ fillbuf(0,buf,sizeof(buf));
+ close(fid);
+ nbytes=write(fid, buf, sizeof(buf));
+ test(nbytes<0);
+ t_errno=errno;
+ test(t_errno==ENOENT);
+ }
+
+#define select_test(fid) \
+ if (async) { \
+ mask=E32SELECT_READ+E32SELECT_WRITE; \
+ err=ioctl(fid,E32IOSELECT,(void*)&mask); \
+ }
+
+/**
+@SYMTestCaseID SYSLIB-STDLIB-CT-1079
+@SYMTestCaseDesc Tests for operations on pipes
+@SYMTestPriority High
+@SYMTestActions Tests for reading from the pipe,
+@SYMTestExpectedResults Test must not fail
+@SYMREQ REQ0000
+*/
+void consumer(int fid, int async)
+ {
+ test_Data;
+ char buf[256];
+ char checkbuf[256];
+ int nbytes;
+ int mask=E32SELECT_READ;
+ int err=0;
+
+ if (async)
+ test_Title("Asynchronous consumer");
+ else
+ test_Title("Consumer");
+
+ fillbuf(1,checkbuf,128);
+
+ /* Simple read, exactly matching single write */
+
+ test_Next("Simple read, exactly matching write");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,128);
+ test(nbytes==128);
+ test(memcmp(buf,checkbuf,128)==0);
+
+ fillbuf(2,checkbuf,128);
+ fillbuf(3,checkbuf+128,128);
+
+ /* Simple read, exactly matching 2 writes */
+
+ test_Next("Simple read, exactly matching 2 writes");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,256);
+
+#ifdef PIPES_SUPPORT_BUFFERING
+ test(nbytes==256);
+#else
+ test(nbytes==128); /* truncated at first write */
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf+128,128); /* manually continue the read */
+ test(nbytes==128);
+#endif
+ test(memcmp(buf,checkbuf,256)==0);
+
+ fillbuf(4,checkbuf,128);
+
+ /* Partial read */
+
+ test_Next("Partial read");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,100);
+ test(nbytes==100);
+ test(memcmp(buf,checkbuf,100)==0);
+
+ /* Partial read, completing the write exactly */
+
+ test_Next("Partial read, completes matching write");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,28);
+ test(nbytes==28);
+ test(memcmp(buf,checkbuf+100,28)==0);
+
+ fillbuf(5,checkbuf,128);
+ fillbuf(6,checkbuf+128,128);
+
+ /* Partial read */
+
+ test_Next("Partial read");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,100);
+ test(nbytes==100);
+ test(memcmp(buf,checkbuf,100)==0);
+
+ /* Partial read, completing the write and the following write exactly */
+
+ test_Next("Partial read across write boundary, completes next write");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,156);
+#ifdef PIPES_SUPPORT_BUFFERING
+ test(nbytes==156);
+#else
+ test(nbytes==28); /* truncated at first write */
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf+28,128); /* manually continue the read */
+ test(nbytes==128);
+#endif
+ test(memcmp(buf,checkbuf+100,156)==0);
+
+ fillbuf(7,checkbuf,128);
+ fillbuf(8,checkbuf+128,128);
+
+ /* Partial read */
+
+ test_Next("Partial read");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,50);
+ test(nbytes==50);
+ test(memcmp(buf,checkbuf,50)==0);
+
+ /* Partial read, starting part way through the write and still not completing it */
+
+ test_Next("Partial read, starting part way through write");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,50);
+ test(nbytes==50);
+ test(memcmp(buf,checkbuf+50,50)==0);
+
+ /* Partial read, completing the 1st write and a partial read on the 2nd write */
+
+ test_Next("Partial read across write boundary");
+
+ nbytes=read(fid,buf,50);
+#ifdef PIPES_SUPPORT_BUFFERING
+ test(nbytes==50);
+#else
+ test(nbytes==28); /* truncated at first write */
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf+28,22); /* manually continue the read */
+ test(nbytes==22);
+#endif
+ test(memcmp(buf,checkbuf+100,50)==0);
+
+ /* Partial read, again in the 2nd write */
+
+ test_Next("Partial read, starting part way through write");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,100);
+ test(nbytes==100);
+ test(memcmp(buf,checkbuf+150,100)==0);
+
+ /* Partial read, completing the 2nd write exactly */
+
+ test_Next("Partial read completing write");
+
+ select_test(fid);
+ test(err==0);
+ test(mask==E32SELECT_READ);
+ nbytes=read(fid,buf,6);
+ test(nbytes==6);
+ test(memcmp(buf,checkbuf+250,6)==0);
+
+ }
+
+
+void do_child()
+ {
+ producer(2,0); /* produce on stderr */
+ producer(2,1); /* produce on stderr */
+
+ consumer(0,0); /* consume on stdin */
+ consumer(0,1); /* consume on stdin */
+
+ close(0);
+ close(1);
+ }
+
+int fids[3];
+
+void do_parent()
+ {
+ consumer(fids[2],0); /* consume on child stderr */
+ consumer(fids[2],1); /* consume on child stderr */
+
+ producer(fids[0],0); /* produce on child stdin */
+ producer(fids[0],1); /* produce on child stdin */
+ }
+
+/* Linked with mcrt0.o, so that the exe starts the CPosixServer automatically as per the
+ * plan all along.
+ */
+
+int main(int argc, char* argv[])
+ {
+ void* proc2;
+
+ start_redirection_server();
+
+ if (argc==1)
+ {
+ proc2 = create_process(do_child, "CHILD", "re", fids);
+ if (proc2)
+ start_process(proc2);
+ else
+ perror("Failed to start processB: ");
+
+ if (proc2)
+ {
+ int exit;
+ do_parent();
+ exit=wait_for_process(proc2);
+ printf("wait_for_process returned %d\r\n", exit);
+ }
+ }
+ else
+ {
+ do_child();
+ }
+
+ return 0;
+ }