// Copyright (c) 2003-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:

 //

 #include <estlib.h>

 #include <stdlib.h>	/* definition of exit() */

 #include <stdio.h>

 #include <errno.h>

 #include <string.h>

 #include <sys/unistd.h>

 #include <sys/ioctl.h>

 #include "CTEST.H"

 #ifdef __cplusplus

 extern "C" {

 #endif

 #define SIZE 10000

 int ReaderPort;

 int WriterPort;

 /**

 @SYMTestCaseID          SYSLIB-STDLIB-CT-1102

 @SYMTestCaseDesc	    Tests for serial port

 @SYMTestPriority 	    High

 @SYMTestActions  	    Tests by writing a string buffer to the port

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */		

 void Writer()

 	{

 	char *buffer;

 	buffer = (char*)malloc(SIZE);

 	memset(buffer, '*', SIZE);

 	printf("\nbig write\n");

 	(void)write(WriterPort, buffer, SIZE);

 	(void)errno;

 	printf("\n>>Writer<<small read\n");

 	read(WriterPort,buffer,1);

 	printf("\nbig write\n");

 	write(WriterPort, buffer, SIZE);

 	printf("\n>>Writer<<small read\n");

 	read(WriterPort,buffer,1);

 	}

 /**

 @SYMTestCaseID          SYSLIB-STDLIB-CT-1103

 @SYMTestCaseDesc	    Tests for serial port

 @SYMTestPriority 	    High

 @SYMTestActions  	    Notifies on a read operation 

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */		

 void Watcher()

 	{

 	int res=0;

 	int notify[2] = {0,0};

 	int supported = 0;

 	res = ioctl(ReaderPort, COMMIOCTL_NOTIFYSUPPORTED, &supported);

 	printf("\nsupported notifies are %08x\n",supported);

 	while (-1 != res)

 		{

 		notify[0] = supported;

 		printf("asking for %08x\n",notify[0]);

 		res = ioctl(ReaderPort, COMMIOCTL_NOTIFY, &notify[0]);

 		printf("\n**Notify** res = %d params %d, %d, errno %d\n",res, notify[0], notify[1],errno);

 		}

 	}

 /**

 @SYMTestCaseID          SYSLIB-STDLIB-CT-1104

 @SYMTestCaseDesc	    Tests for serial port

 @SYMTestPriority 	    High

 @SYMTestActions  	    Reads to buffer from serial port,test for failure conditions

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */		

 void Reader()

 	{

 	int res;

 	char *buffer, *p;

 	int x;

 	buffer = (char*)malloc(SIZE*2);

 	res = 0;

 	p = buffer;

 	x = 5000;

 	res = ioctl(ReaderPort, COMMIOCTL_SETREADTIMEOUT, &x);

 	for(x = 0;;x++)

 		{

 		res = read(ReaderPort, p, 100);

 		if (res > 0)

 			{

 			putchar('.');

 			p += res;

 			}

 		else

 			{

 			printf("\nread failed with errno %d\n",errno);

 			break;

 			}

 		}

 	printf("\n>>Reader<<small write\n");

 	res = write(ReaderPort, buffer ,1);

 	printf("\n>>Reader<<set threshold\n");

 	x = 100;

 	res = ioctl(ReaderPort, COMMIOCTL_SETREADTHRESHOLD, &x);

 	p = buffer;

 	printf("\nAnd again with a threshold of 100\n");

 	for(x = 0;;x++)

 		{

 		res = read(ReaderPort, p, 100);

 		if (res > 0)

 			{

 			putchar('.');

 			p += res;

 			}

 		else

 			{

 			printf("\nread failed with errno %d\n",errno);

 			break;

 			}

 		}

 	printf("\n>>Reader<<Small write\n");

 	write(ReaderPort, buffer ,1);

 	}

 #ifdef __cplusplus

 }

 #endif

 int main(int, char**)

 	{

 	void* t1;

 	void* t2;

 	void* t3;

 	SerialConfig sc;

 	start_posix_server();	/* calls SpawnPosixServer from C++ code */

 	WriterPort = open("COM1:",0);

 	if (-1 == WriterPort)

 		exit(-1);

 	(void)ioctl(WriterPort, COMMIOCTL_GETCONFIG, &sc);

 	sc.iHandshake = 0;

 	sc.iRate = Bps115200;

 	sc.iParity = ParityNone;

 	(void)ioctl(WriterPort, COMMIOCTL_SETCONFIG, &sc);

 	ReaderPort = open("COM2:",0);

 	if (-1 == ReaderPort)

 		exit(-2);

 	(void)ioctl(ReaderPort, COMMIOCTL_GETCONFIG, &sc);

 	sc.iHandshake = 0;

 	sc.iRate = Bps115200;

 	sc.iParity = ParityNone;

 	(void)ioctl(ReaderPort, COMMIOCTL_SETCONFIG, &sc);

 	t3 = create_thread(Watcher, "watcher1");

 	t1 = create_thread(Reader, "reader");

 	t2 = create_thread(Writer, "writer");

 	start_thread(t3);

 	start_thread(t2);

 	start_thread(t1);

 	(void)wait_for_thread(t1);

 	(void)wait_for_thread(t2);

 	close(WriterPort);

 	close(ReaderPort);

 	(void)wait_for_thread(t3);

 	printf("\nPress a key\n");

 	getchar();

 	return 0;

 	}