/*

* 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-1105

@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-1106

@SYMTestCaseDesc	    Tests for communication over the port

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for reading and writing to a port back

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void ping(void)

	{

	char buf1[50];

	char buf2[50];

	char* rptr =buf1;

	char* wptr = buf2;

	char * tptr;

	int err = 0;

	int timeout = 5000;	//5 seconds

	int threshold = -1;

	printf("port is %d\n",port);

	ioctl(port, COMMIOCTL_SETREADTHRESHOLD, &threshold);

	ioctl(port, COMMIOCTL_SETREADTIMEOUT, &timeout);

	strcpy(wptr, "ping");

	while (err >= 0)

		{

		err = read(port,rptr, 50);

		if (err >= 0)

			{

			rptr[err] = 0;

			err = write(port, wptr, strlen(wptr));

//			printf("read %s, written %s\n", rptr, wptr);

			tptr = wptr;

			wptr = rptr;

			rptr = 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(ping, "ping");

	start_thread(t1);

	start_thread(t2);

	wait_for_thread(t2);

	close(port);

	wait_for_thread(t1);

	return 0;

	}