/*

 * Copyright (c) 1997-2009 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:

 * Test of AF_LOCAL datagram sockets, based on Datagram example in GCC.HELP

 * 

 *

 */

 #include <stddef.h>

 #include <stdio.h>

 #include <errno.h>

 #include <stdlib.h>

 #include <string.h>

 #ifdef __X86GCC__  

 #undef WIN32  // Seems to be included in the X86 baseport somewhere (we don't want winsock as this isn't an emulator build)

 #endif

 #ifdef WIN32

 	#include <winsock.h>

 #else

 	#include <unistd.h>

 	#include <sys/socket.h>

 	#include <sys/ioctl.h>

 	#include <libc/netinet/in.h>

 	#include <libc/arpa/inet.h>

 #endif

 int

 make_named_socket (int port)

 {

 //  struct sockaddr name;

   struct sockaddr_in name;

   int sock;

   size_t size;

   /* Create the socket. */

   sock = socket (AF_INET, SOCK_DGRAM, 0);

 #ifdef WIN32

 	if ( INVALID_SOCKET == sock )

 	{

 		printf( "%s,%s,%d","CreateSocket", "socket", WSAGetLastError ( ) );

 		  exit (EXIT_FAILURE);

 	}

 #else

 	if (-1 == sock )

 	{

       perror ("make_named_socket");

 		  exit (EXIT_FAILURE);

 	}

 #endif

   /* Bind a name to the socket. */

   name.sin_family = AF_INET;

   name.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");

   name.sin_port = htons((unsigned short)port);

   size = sizeof(struct sockaddr);

   if (bind (sock, (struct sockaddr *) &name, size) < 0)

     {

       perror ("bind");

       exit (EXIT_FAILURE);

     }

   return sock;

 }

 #define SERVER  99

 #define MAXMSG  512

 int server(void)

 	{

 	int server_sock;

 	char server_message[MAXMSG];

 	struct sockaddr name;

 	size_t size;

 	int nbytes = -1;

 	/* Make the socket, then loop endlessly. */

 	server_sock = make_named_socket (SERVER);

 	nbytes = sendto (server_sock, server_message, nbytes, 0, (struct sockaddr *) & name, size);

 	if (nbytes < 0)

 		{

 		perror ("sendto (server)");

 		exit (EXIT_FAILURE);

 		}

 	while (1)

 		{

 		/* Wait for a datagram. */

 		size = sizeof (name);

 		nbytes = recvfrom (server_sock, server_message, MAXMSG, 0, (struct sockaddr *) & name, &size);

 		if (nbytes < 0)

 			{

 			perror ("recfrom (server)");

 			break;

 			}

 		/* Give a diagnostic message. */

 		fprintf (stderr, "Server: got message: %s\n", server_message);

 		/* Bounce the message back to the sender. */

 		nbytes = sendto (server_sock, server_message, nbytes, 0, (struct sockaddr *) & name, size);

 		if (nbytes < 0)

 			{

 			perror ("sendto (server)");

 			break;

 			}

 		}/* end of - "while (1)" */

 	exit (EXIT_FAILURE);

 	return 0;

 	}

 #define CLIENT  125

 #define MESSAGE "Yow!!! Are we having fun yet?!? I'd like a 99 please..."

 int

 client (void)

 {

   int sock;

   char message[MAXMSG];

   struct sockaddr_in name;

   size_t size;

   int nbytes;

   /* Make the socket. */

   sock = make_named_socket (CLIENT);

   /* Initialize the server socket address. */

   name.sin_family = AF_INET;

   name.sin_port = htons((unsigned short)SERVER);

   size = sizeof(name);

   /* Send the datagram. */

   nbytes = sendto (sock, MESSAGE, strlen (MESSAGE) + 1, 0,

                    (struct sockaddr *) & name, size);

   if (nbytes < 0)

     {

       perror ("sendto (client)");

       exit (EXIT_FAILURE);

     }

   /* Wait for a reply. */

   nbytes = recvfrom (sock, message, MAXMSG, 0, NULL, 0);

   if (nbytes < 0)

     {

       perror ("recfrom (client)");

       exit (EXIT_FAILURE);

     }

   /* Print a diagnostic message. */

   fprintf (stderr, "Client: got message: %s\n", message);

   /* Clean up. */

 #ifdef WIN32

     closesocket (sock);

 #else

 	close(sock);

 #endif

 	return 0;

 }

 /**

 @SYMTestCaseID          SYSLIB-STDLIB-CT-1046

 @SYMTestCaseDesc	    Tests for AF_LOCAL datagram sockets

 @SYMTestPriority 	    High

 @SYMTestActions  	    Initialize the server socket address,send and receive messages on the socket.

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */		

 int both_together(void)

 {

   int server_sock;

   char server_message[MAXMSG];

   struct sockaddr_in name;

   size_t size;

   int nbytes;

   int sock;

   char message[MAXMSG];

   /* Make the server socket */

   server_sock = make_named_socket (SERVER);

   sock = make_named_socket (CLIENT);

   /* Initialize the server socket address. */

   name.sin_family = AF_INET;

   //name.sin_port = SERVER;

   name.sin_port = htons((unsigned short)SERVER);

 	  name.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");

  size = sizeof(name);

   /* Send the datagram. */

   nbytes = sendto (server_sock, MESSAGE, strlen (MESSAGE) + 1, 0,

                    (struct sockaddr *) & name, size);

 #ifdef WIN32

   if (nbytes < 0)

 	{

 		printf( "%s,%s,%d","sendto", "socket", WSAGetLastError ( ) );

 		  exit (EXIT_FAILURE);

 	}

 #else

   if (nbytes < 0)

 	{

       perror ("sendto (server)");

 		  exit (EXIT_FAILURE);

 	}

 #endif

   {

   /* more server stuff */

       size = sizeof (name);

       nbytes = recvfrom (server_sock, server_message, MAXMSG, 0,

                          (struct sockaddr *) & name, &size);

 #ifdef WIN32

       if (nbytes < 0)

 	{

 		printf( "%s,%s,%d","recvfrom", "socket", WSAGetLastError ( ) );

 		  exit (EXIT_FAILURE);

 	}

 #else

       if (nbytes < 0)

 	{

       perror ("recvfrom (server)");

 		  exit (EXIT_FAILURE);

 	}

 #endif

       /* Give a diagnostic message. */

       fprintf (stderr, "Server: got message: %s\n", server_message);

       /* Bounce the message back to the sender. */

   name.sin_port = htons((unsigned short)CLIENT);

       nbytes = sendto (sock, server_message, nbytes, 0,

                        (struct sockaddr *) & name, size);

 #ifdef WIN32

       if (nbytes < 0)

         {

 		printf( "%s,%s,%d","sendto", "socket", WSAGetLastError ( ) );

           exit (EXIT_FAILURE);

         }

 #else

       if (nbytes < 0)

 	{

       perror ("sendto (client)");

 		  exit (EXIT_FAILURE);

 	}

 #endif

   }

   /* Wait for a reply. */

   nbytes = recvfrom (sock, message, MAXMSG, 0, NULL, 0);

 #ifdef WIN32

       if (nbytes < 0)

         {

 		printf( "%s,%s,%d","recvfrom", "socket", WSAGetLastError ( ) );

           exit (EXIT_FAILURE);

         }

 #else

       if (nbytes < 0)

 	{

       perror ("recvfrom (client)");

 		  exit (EXIT_FAILURE);

 	}

 #endif

   /* Print a diagnostic message. */

   fprintf (stderr, "Client: got message: %s\n", message);

   /* Clean up. */

 #ifdef WIN32

   closesocket (sock);

   closesocket(server_sock);

 #else

   close(sock);

   close(server_sock);

 #endif

   return 0;

 }

 int main(int argc, char*argv[])

 	{

 #ifdef WIN32

 	WORD wVersionRequested;WSADATA wsaData;int err; 

 	wVersionRequested = MAKEWORD( 1, 0 ); 

 	err = WSAStartup( wVersionRequested, &wsaData );

 #endif

 	return both_together();

 }