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