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