/*
* Copyright (c) 1997-2007 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 port;

/**
@SYMTestCaseID          SYSLIB-STDLIB-CT-1107
@SYMTestCaseDesc	    Tests for serial port
@SYMTestPriority 	    High
@SYMTestActions  	    Tests for notification support
@SYMTestExpectedResults Test must not fail
@SYMREQ                 REQ0000
*/				
void Watcher(void)
	{
	int res;
	int notify[2] = {0,0};
	int supported = 0;


	res = ioctl(port, COMMIOCTL_NOTIFYSUPPORTED, &supported);
	printf("\nsupported notifies are %08lx\n",supported);
	while (-1 != res)
		{
		notify[0] = supported;
		res = ioctl(port, 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-1108
@SYMTestCaseDesc	    Tests for serial port
@SYMTestPriority 	    High
@SYMTestActions  	    Tests for writing and reading to a port
@SYMTestExpectedResults Test must not fail
@SYMREQ                 REQ0000
*/				
void pong(void)
	{
	char buf1[50];
	char buf2[50];
	char * rptr;
	char * wptr;
	char * tptr;

	int err = 0;
	int timeout = 5000;	//5 seconds
	int threshold = -1;

	rptr = buf1;
	wptr = buf2;
	
	printf("port is %d\n",port);
	ioctl(port, COMMIOCTL_SETREADTHRESHOLD, &threshold);
	ioctl(port, COMMIOCTL_SETREADTIMEOUT, &timeout);

	strcpy(buf2,"pong");
	while (err >= 0)
		{
		err = write(port, wptr, strlen(wptr));
		if (err >= 0)
			{
			err = read(port,rptr, 50);
			if (err >= 0)
				{
				rptr[err] = 0;
//				printf ("read %s, written %s\n",rptr, wptr);
				tptr = rptr;
				rptr = wptr;
				wptr = tptr;
				}
			}
		}

	}


int main(void)
	{
	void* t1;
	void* t2;
	
	start_posix_server();	/* calls SpawnPosixServer from C++ code */
	
	port = open("IRCOM1:", 0);
	
	t1 = create_thread(Watcher, "watcher");
	t2 = create_thread(pong, "pong");
	
	start_thread(t1);
	start_thread(t2);

	wait_for_thread(t2);
	
	close(port);

	wait_for_thread(t1);

	return 0;
	}