sl@0: // Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include <estlib.h>
sl@0: #include <stdlib.h>	/* definition of exit() */
sl@0: #include <stdio.h>
sl@0: #include <errno.h>
sl@0: #include <string.h>
sl@0: #include <sys/unistd.h>
sl@0: #include <sys/ioctl.h>
sl@0: #include "CTEST.H"
sl@0: 
sl@0: #ifdef __cplusplus
sl@0: extern "C" {
sl@0: #endif
sl@0: 
sl@0: 
sl@0: #define SIZE 10000
sl@0: 
sl@0: int ReaderPort;
sl@0: int WriterPort;
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-STDLIB-CT-1102
sl@0: @SYMTestCaseDesc	    Tests for serial port
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Tests by writing a string buffer to the port
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */		
sl@0: void Writer()
sl@0: 	{
sl@0: 	char *buffer;
sl@0: 	
sl@0: 	buffer = (char*)malloc(SIZE);
sl@0: 	memset(buffer, '*', SIZE);
sl@0: 
sl@0: 	printf("\nbig write\n");
sl@0: 	(void)write(WriterPort, buffer, SIZE);
sl@0: 	(void)errno;
sl@0: 	printf("\n>>Writer<<small read\n");
sl@0: 	read(WriterPort,buffer,1);
sl@0: 	printf("\nbig write\n");
sl@0: 	write(WriterPort, buffer, SIZE);
sl@0: 	printf("\n>>Writer<<small read\n");
sl@0: 	read(WriterPort,buffer,1);
sl@0: 
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-STDLIB-CT-1103
sl@0: @SYMTestCaseDesc	    Tests for serial port
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Notifies on a read operation 
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */		
sl@0: void Watcher()
sl@0: 	{
sl@0: 	int res=0;
sl@0: 	int notify[2] = {0,0};
sl@0: 	int supported = 0;
sl@0: 
sl@0: 
sl@0: 	res = ioctl(ReaderPort, COMMIOCTL_NOTIFYSUPPORTED, &supported);
sl@0: 	printf("\nsupported notifies are %08x\n",supported);
sl@0: 	while (-1 != res)
sl@0: 		{
sl@0: 		notify[0] = supported;
sl@0: 		printf("asking for %08x\n",notify[0]);
sl@0: 		res = ioctl(ReaderPort, COMMIOCTL_NOTIFY, &notify[0]);
sl@0: 		printf("\n**Notify** res = %d params %d, %d, errno %d\n",res, notify[0], notify[1],errno);
sl@0: 		}
sl@0: 
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-STDLIB-CT-1104
sl@0: @SYMTestCaseDesc	    Tests for serial port
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Reads to buffer from serial port,test for failure conditions
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */		
sl@0: void Reader()
sl@0: 	{
sl@0: 	int res;
sl@0: 	char *buffer, *p;
sl@0: 	int x;
sl@0: 
sl@0: 
sl@0: 	
sl@0: 	buffer = (char*)malloc(SIZE*2);
sl@0: 
sl@0: 	res = 0;
sl@0: 	p = buffer;
sl@0: 	
sl@0: 
sl@0: 	x = 5000;
sl@0: 	res = ioctl(ReaderPort, COMMIOCTL_SETREADTIMEOUT, &x);
sl@0: 
sl@0: 	for(x = 0;;x++)
sl@0: 		{
sl@0: 		res = read(ReaderPort, p, 100);
sl@0: 		if (res > 0)
sl@0: 			{
sl@0: 			putchar('.');
sl@0: 			p += res;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			printf("\nread failed with errno %d\n",errno);
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 		
sl@0: 	printf("\n>>Reader<<small write\n");
sl@0: 	res = write(ReaderPort, buffer ,1);
sl@0: 
sl@0: 	printf("\n>>Reader<<set threshold\n");
sl@0: 	x = 100;
sl@0: 	res = ioctl(ReaderPort, COMMIOCTL_SETREADTHRESHOLD, &x);
sl@0: 	p = buffer;
sl@0: 
sl@0: 	printf("\nAnd again with a threshold of 100\n");
sl@0: 	
sl@0: 	for(x = 0;;x++)
sl@0: 		{
sl@0: 		res = read(ReaderPort, p, 100);
sl@0: 		if (res > 0)
sl@0: 			{
sl@0: 			putchar('.');
sl@0: 			p += res;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			printf("\nread failed with errno %d\n",errno);
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 		
sl@0: 	printf("\n>>Reader<<Small write\n");
sl@0: 	write(ReaderPort, buffer ,1);
sl@0: 	
sl@0: 
sl@0: 	}
sl@0: 
sl@0: #ifdef __cplusplus
sl@0: }
sl@0: #endif
sl@0: 
sl@0: int main(int, char**)
sl@0: 	{
sl@0: 	void* t1;
sl@0: 	void* t2;
sl@0: 	void* t3;
sl@0: 	
sl@0: 	SerialConfig sc;
sl@0: 
sl@0: 	start_posix_server();	/* calls SpawnPosixServer from C++ code */
sl@0: 
sl@0: 	WriterPort = open("COM1:",0);
sl@0: 	if (-1 == WriterPort)
sl@0: 		exit(-1);
sl@0: 	(void)ioctl(WriterPort, COMMIOCTL_GETCONFIG, &sc);
sl@0: 	sc.iHandshake = 0;
sl@0: 	sc.iRate = Bps115200;
sl@0: 	sc.iParity = ParityNone;
sl@0: 	(void)ioctl(WriterPort, COMMIOCTL_SETCONFIG, &sc);
sl@0: 	
sl@0: 	ReaderPort = open("COM2:",0);
sl@0: 	if (-1 == ReaderPort)
sl@0: 		exit(-2);
sl@0: 	(void)ioctl(ReaderPort, COMMIOCTL_GETCONFIG, &sc);
sl@0: 	sc.iHandshake = 0;
sl@0: 	sc.iRate = Bps115200;
sl@0: 	sc.iParity = ParityNone;
sl@0: 	(void)ioctl(ReaderPort, COMMIOCTL_SETCONFIG, &sc);
sl@0: 
sl@0: 	t3 = create_thread(Watcher, "watcher1");
sl@0: 	t1 = create_thread(Reader, "reader");
sl@0: 	t2 = create_thread(Writer, "writer");
sl@0: 
sl@0: 	start_thread(t3);
sl@0: 	start_thread(t2);
sl@0: 	start_thread(t1);
sl@0: 
sl@0: 	(void)wait_for_thread(t1);
sl@0: 	(void)wait_for_thread(t2);
sl@0: 
sl@0: 	close(WriterPort);
sl@0: 	close(ReaderPort);
sl@0: 	(void)wait_for_thread(t3);
sl@0: 	printf("\nPress a key\n");
sl@0: 	getchar();
sl@0: 	return 0;
sl@0: 	}
sl@0: 
sl@0: