// 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;
	}