/*

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

 	}