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