/*

* Copyright (c) 1997-2005 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 <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"

int GlobalPort;

void DoSharedStuff(void)

	{

		int p1, p2, ret;

		SerialConfig config;

		p1 = open("COM1:",  1);

		p2 = open("COM1:",  1);

		//try changing the settings

		ret = ioctl(p1, COMMIOCTL_GETCONFIG, &config);

		config.iRate = Bps115200;

		ret = ioctl(p2, COMMIOCTL_SETCONFIG, &config);

		config.iRate = Bps1200;

		ret = ioctl(p1, COMMIOCTL_GETCONFIG, &config);

		close(p2);

		config.iRate = Bps1200;

		ret = ioctl(p1, COMMIOCTL_GETCONFIG, &config);

		close(p1);

	}

void OpenAndConfigure(void)

	{

	int res;

	SerialConfig sc;

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

	res = ioctl(GlobalPort, COMMIOCTL_GETCONFIG, &sc);

	sc.iRate = Bps115200;

	sc.iParity = ParityNone;

	res = ioctl(GlobalPort, COMMIOCTL_SETCONFIG, &sc);

	}

void WaitAndRead(void)

	{

	int port = GlobalPort;

	int ret;

	char buffer[100];

	printf("Wait and read\n");

	ret = read(port, buffer, 10);

	printf("got it %x\n",buffer[0]);

	}

void WriteABit(int x)

	{

	int port = GlobalPort;

	char bob[100];

	sprintf(bob, "Test Write >>%d<<    >>%x<<\n", x, x);

	write(port, bob, strlen(bob));

	}

void writelots(void)

	{

	int n;

	for (n=0;n<10000;n++)

		WriteABit(n);

	}

void DoTests(void)

	{	

	int port1, port2;

	int timeout = 0;

	int threshold = 0;

	int ret=0;

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

	//this one should fail

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

	if (-1 != port1)

		{

		//play with the signals

		int sigs[] = {0,0};

 		int sig = 0;

		ret = ioctl(port1, COMMIOCTL_SETSIGNALS, &sigs[0]);

		ret = ioctl(port1, COMMIOCTL_GETSIGNALS, &sig);

		sig = 5000;

		ret = ioctl(port1, COMMIOCTL_BREAK, &sig);

		close(port1);

		}

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

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

	if (-1 != port2)

		{

		int len;

		SerialConfig config;

		char buffer[1024];

		size_t size = 100;

		timeout = 2000;

		ret = ioctl(port2, COMMIOCTL_SETREADTIMEOUT, &timeout);

		timeout = 0;

		ret = ioctl(port2, COMMIOCTL_GETREADTIMEOUT, &timeout);

		threshold = 2000;

		ret = ioctl(port2, COMMIOCTL_SETREADTHRESHOLD, &threshold);

		threshold = 0;

		ret = ioctl(port2, COMMIOCTL_GETREADTHRESHOLD, &threshold);

		//buffer lengths

		len = 0;

		ret = ioctl(port1, COMMIOCTL_GETBUFFERLENGTH, &len);

		len = 2048;

		ret = ioctl(port1, COMMIOCTL_SETBUFFERLENGTH, &len);

		len = 0;

		ret = ioctl(port1, COMMIOCTL_GETBUFFERLENGTH, &len);

		len = 10000000;

		ret = ioctl(port1, COMMIOCTL_SETBUFFERLENGTH, &len);

		len = 0;

		ret = ioctl(port1, COMMIOCTL_GETBUFFERLENGTH, &len);

		//try changing the settings

		ret = ioctl(port1, COMMIOCTL_GETCONFIG, &config);

		config.iRate = Bps115200;

		ret = ioctl(port1, COMMIOCTL_SETCONFIG, &config);

		config.iRate = Bps1200;

		ret = ioctl(port1, COMMIOCTL_GETCONFIG, &config);

		timeout = threshold = -1;

		ret = ioctl(port1, COMMIOCTL_SETREADTHRESHOLD, &threshold);

		ret = ioctl(port1, COMMIOCTL_SETREADTIMEOUT, &timeout);

		printf("Talk to me, ESC to exit\n");

		do

			{

			ret = read(port1, buffer, size);

			if (ret != -1)

				printf("look what I got >>> %c\t%x\n",buffer[0],buffer[0]);

			else

				printf("error, errno is %x \n",errno);

			}

		while (buffer[0] != 27);

		printf("Talk to me in blocks of 5, EXIT! to exit\n");

		threshold = 5;

		ret = ioctl(port1, COMMIOCTL_SETREADTHRESHOLD, &threshold);

		do

			{

			ret = read(port1, buffer, size);

			if (ret >=0)

				{

				buffer[ret] = 0;

				printf("look what I got >>> %s\n",buffer);

				}

			else

				printf("error\n");

			}

		while (strcmp(buffer, "EXIT!"));

		printf("Wait 10 seconds then give up\n");

		timeout = 10000;

		ret = ioctl(port1, COMMIOCTL_SETREADTIMEOUT, &timeout);

		threshold = 1;

		ret = ioctl(port1, COMMIOCTL_SETREADTHRESHOLD, &threshold);

		ret = read(port1, buffer, size);

		if (ret > 0)

			printf("look what I got >>> %c\t%x\n",buffer[0],buffer[0]);

		else

			printf("timeout\n");

		//no threshold, but with a 5 second timeout

		printf("Now for the hard one!\n");

		timeout = 5000;

		ret = ioctl(port1, COMMIOCTL_SETREADTIMEOUT, &timeout);

		threshold = -1;

		ret = ioctl(port1, COMMIOCTL_SETREADTHRESHOLD, &threshold);

		ret = read(port1, buffer, size);

		if (ret<0)

			printf("got an error, errno is 56 if it a timeout. erno = %d\n", errno);

		else

			printf("look what I got >>> %c\t%x\n",buffer[0],buffer[0]);

		printf("Going to write some stuff now\n");

		ret = write(port1, "Lardy dardy dardy cheese\n\n",26);

		printf("Written some stuff now and got a ret of %d\n", ret);

		close(port2);

		}

	if (-1 != port1)

		close(port1);

	printf("Press key to exit");

	getchar();

	}

void pong(void)

	{

		char buf[50];

		int port = open("IRCOM:0", 0);

		int x;

		strcpy(buf,"test shot #");

		for (x=0;x<10;x++);

			{

			write(port, buf, strlen(buf));

			read(port,buf, 50);

			strcat(buf,"#");

			}

		close(port);

	}

void ping(void)

	{

		char buf[50];

		int x;

		int port = open("IRCOM:0", 0);

		for (x=0;x<10;x++);

			{

			read(port,buf, 50);

			strcat(buf,"*");

			write(port, buf, strlen(buf));

			}

		close(port);

	}

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1112

@SYMTestCaseDesc	    Tests for serial port

@SYMTestPriority 	    High

@SYMTestActions  	    Notifies a thread for events on port 

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/					

void WaitForNotifyThread(void)

	{

	int val[2];

	int ret = 0;

	while (!ret)

		{

		val[0] = KNotifyFramingError|KNotifyOverrunError|KNotifyParityError;

		val[1] = -1;

		ret = ioctl(GlobalPort, COMMIOCTL_NOTIFY, &val[0]);

		printf("NotifyThread ret = %d, val[0] is %d, val[1] is %d\n", ret, val[0], val[1]);

		}

	}

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1113

@SYMTestCaseDesc	    Tests for serial port

@SYMTestPriority 	    High

@SYMTestActions  	    Keep reading infinitely from the port

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/					

void readloop(void)

	{

	char buf[100];

	int ret = 0;

	while (!ret)

		{

		read(GlobalPort, buf, 100);

		printf("ReadThread got %x\n", buf[0]);

		}

	}

int main(void)

	{

	void* client;

	void* t1;

	void*t2;

	void*t3;

	int err;

//	DoTests();

//	printf("Do it again using the CPosixServer\n");

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

//	client=create_thread(DoTests, "serial tests");

//	start_thread(client);

//	err=wait_for_thread(client);

//	t3 = create_thread(OpenAndConfigure,"cfg");

//	start_thread(t3);

//	err=wait_for_thread(t3);

//	t1 = create_thread(WaitAndRead, "open and wait");

//	t2 = create_thread(writelots, "writelots");

//	start_thread(t1);

//	start_thread(t2);

//	err=wait_for_thread(t1);

//	err=wait_for_thread(t2);

//	close(GlobalPort);

	OpenAndConfigure();

	t1 = create_thread(WaitForNotifyThread, "notify");

	t2 = create_thread(readloop, "readloop");

	start_thread(t1);

	start_thread(t2);

	err=wait_for_thread(t2);

	err=wait_for_thread(t1);

	close(GlobalPort);

	return 0;

	}