Mercurial > ecos-v3_0-branch
diff packages/io/fileio/current/tests/socket.c @ 115:6ed91473a1cd ecos-sw-2000-08-21
Merge from eCos master repository on 2000-08-21-22:40:54-BST
| author | jlarmour |
|---|---|
| date | Fri, 25 Aug 2000 17:32:38 +0000 |
| parents | |
| children | 8f2f7615e727 |
line wrap: on
line diff
new file mode 100644 --- /dev/null +++ b/packages/io/fileio/current/tests/socket.c @@ -0,0 +1,340 @@ +//========================================================================== +// +// socket.c +// +// Test socket API +// +//========================================================================== +//####COPYRIGHTBEGIN#### +// +// ------------------------------------------- +// The contents of this file are subject to the Red Hat eCos Public License +// Version 1.1 (the "License"); you may not use this file except in +// compliance with the License. You may obtain a copy of the License at +// http://www.redhat.com/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +// License for the specific language governing rights and limitations under +// the License. +// +// The Original Code is eCos - Embedded Configurable Operating System, +// released September 30, 1998. +// +// The Initial Developer of the Original Code is Red Hat. +// Portions created by Red Hat are +// Copyright (C) 1998, 1999, 2000 Red Hat, Inc. +// All Rights Reserved. +// ------------------------------------------- +// +//####COPYRIGHTEND#### +//========================================================================== +//#####DESCRIPTIONBEGIN#### +// +// Author(s): nickg +// Contributors: nickg +// Date: 2000-05-25 +// Purpose: Test socket API +// Description: This program tests the socket API. Note that it is only +// intended to test the API and not the functionality of +// the underlying network stack. That is assumed to have +// been established by other tests elsewhere. +// +//####DESCRIPTIONEND#### +// +//========================================================================== + +#include <pkgconf/hal.h> +#include <pkgconf/kernel.h> +#include <pkgconf/io_fileio.h> + + +#define __ECOS 1 + +#include <cyg/kernel/ktypes.h> // base kernel types +#include <cyg/infra/cyg_trac.h> // tracing macros +#include <cyg/infra/cyg_ass.h> // assertion macros + +#include <cyg/infra/testcase.h> + +#if defined(CYGPKG_NET) && defined(CYGPKG_POSIX) + +#include <unistd.h> +#include <fcntl.h> +#include <sys/stat.h> +#include <errno.h> + +#include <network.h> +#include <arpa/inet.h> + +#include <pthread.h> +#include <signal.h> + + +#include <cyg/infra/diag.h> // HAL polled output + +//-------------------------------------------------------------------------- + +#define SHOW_RESULT( _fn, _res ) \ +diag_printf(#_fn " returned %d %s\n", _res, _res<0?strerror(errno):""); + +//-------------------------------------------------------------------------- +// Thread stack. + +char thread1_stack[PTHREAD_STACK_MIN*2]; +char thread2_stack[PTHREAD_STACK_MIN*2]; + +//-------------------------------------------------------------------------- +// Local variables + +// Thread IDs +pthread_t thread1; +pthread_t thread2; + +struct sockaddr_in sa; + +//-------------------------------------------------------------------------- +// test buffers + +#define TEST_BUFSIZE 512 + +static char buf1[TEST_BUFSIZE]; +static char buf2[TEST_BUFSIZE]; +static char buf3[TEST_BUFSIZE]; + +//-------------------------------------------------------------------------- + +void *pthread_entry1( void *arg) +{ + int fd, fd2; + struct sockaddr_in accsa; + socklen_t accsa_len = sizeof(accsa); + int err; +// int one = 1; +// int so1 = sizeof(one); + fd_set rd; + int i; + ssize_t done; + + CYG_TEST_INFO( "Thread 1 running" ); + + CYG_TEST_INFO( "Thread1: calling socket()"); + fd = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP ); + if( fd < 0 ) SHOW_RESULT( socket, fd ); + CYG_TEST_CHECK( fd >= 0, "socket() returned error"); + +// err = setsockopt( fd, SOL_SOCKET, SO_DONTROUTE, (void *)&one, so1); +// if( err < 0 ) SHOW_RESULT( setsockopt, err ); +// CYG_TEST_CHECK( err == 0, "setsockopt() returned error"); + + CYG_TEST_INFO( "Thread1: calling bind()"); + err = bind( fd, (struct sockaddr *)&sa, sizeof(sa)); + if( err < 0 ) SHOW_RESULT( bind, err ); + CYG_TEST_CHECK( err == 0, "bind() returned error"); + + CYG_TEST_INFO( "Thread1: calling listen()"); + err = listen( fd, 1); + if( err < 0 ) SHOW_RESULT( listen, err ); + CYG_TEST_CHECK( err == 0, "listen() returned error"); + + FD_ZERO( &rd ); + FD_SET( fd, &rd ); + + CYG_TEST_INFO( "Thread1: calling select()"); + err = select( fd+1, &rd, NULL, NULL, NULL ); + if( err < 0 ) SHOW_RESULT( select, err ); + CYG_TEST_CHECK( err >= 0, "select() returned error"); + CYG_TEST_CHECK( FD_ISSET( fd, &rd ), "Fd not set in select() result"); + + CYG_TEST_INFO( "Thread1: calling accept()"); + fd2 = accept( fd, (struct sockaddr *)&accsa, &accsa_len ); + if( fd2 < 0 ) SHOW_RESULT( accept, fd2 ); + CYG_TEST_CHECK( fd2 >= 0, "accept() returned error"); + + + for( i = 0; i < TEST_BUFSIZE; i++ ) buf1[i] = i; + + CYG_TEST_INFO( "Thread1: calling write()"); + done = write( fd2, buf1, TEST_BUFSIZE); + if( done != TEST_BUFSIZE ) SHOW_RESULT( write, done ); + CYG_TEST_CHECK( done == TEST_BUFSIZE, "write() returned bad size"); + + FD_ZERO( &rd ); + FD_SET( fd2, &rd ); + + CYG_TEST_INFO( "Thread1: calling select()"); + err = select( fd2+1, &rd, NULL, NULL, NULL ); + if( err < 0 ) SHOW_RESULT( select, err ); + CYG_TEST_CHECK( err >= 0, "select() returned error"); + CYG_TEST_CHECK( FD_ISSET( fd2, &rd ), "Fd2 not set in select() result"); + + CYG_TEST_INFO( "Thread1: calling read()"); + done = read( fd2, buf3, TEST_BUFSIZE); + if( done != TEST_BUFSIZE ) SHOW_RESULT( read, done ); + CYG_TEST_CHECK( done == TEST_BUFSIZE, "read() returned bad size"); + + for( i = 0; i < TEST_BUFSIZE; i++ ) + if( buf1[i] != buf3[i] ) + diag_printf("buf1[%d](%02x) != buf3[%d](%02x)\n",i,buf1[i],i,buf3[i]); + + CYG_TEST_INFO( "Thread1: calling close(fd)"); + err = close(fd); + if( err < 0 ) SHOW_RESULT( close, err ); + CYG_TEST_CHECK( err == 0, "close() returned error"); + + CYG_TEST_INFO( "Thread1: calling close(fd2)"); + err = close(fd2); + if( err < 0 ) SHOW_RESULT( close, err ); + CYG_TEST_CHECK( err == 0, "close() returned error"); + + CYG_TEST_INFO( "Thread1: calling pthread_exit()"); + pthread_exit( arg ); +} + +//-------------------------------------------------------------------------- + +void *pthread_entry2( void *arg) +{ + int fd; + int err; +// int one = 1; +// int so1 = sizeof(one); + int i; + ssize_t done; + fd_set rd; + + CYG_TEST_INFO( "Thread 2 running" ); + + CYG_TEST_INFO( "Thread2: calling socket()"); + fd = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP ); + if( fd < 0 ) SHOW_RESULT( socket, fd ); + CYG_TEST_CHECK( fd >= 0, "socket() returned error"); + +// err = setsockopt( fd, SOL_SOCKET, SO_DONTROUTE, (void *)&one, so1); +// if( err < 0 ) SHOW_RESULT( setsockopt, err ); +// CYG_TEST_CHECK( err == 0, "setsockopt() returned error"); + + CYG_TEST_INFO( "Thread2: calling connect()"); + err = connect( fd, (struct sockaddr *)&sa, sizeof(sa)); + if( err < 0 ) SHOW_RESULT( connect, err ); + CYG_TEST_CHECK( err == 0, "connect() returned error"); + + FD_ZERO( &rd ); + FD_SET( fd, &rd ); + + CYG_TEST_INFO( "Thread2: calling select()"); + err = select( fd+1, &rd, NULL, NULL, NULL ); + if( err < 0 ) SHOW_RESULT( select, err ); + CYG_TEST_CHECK( err >= 0, "select() returned error"); + CYG_TEST_CHECK( FD_ISSET( fd, &rd ), "Fd not set in select() result"); + + CYG_TEST_INFO( "Thread2: calling read()"); + done = read( fd, buf2, TEST_BUFSIZE); + if( done != TEST_BUFSIZE ) SHOW_RESULT( read, done ); + CYG_TEST_CHECK( done == TEST_BUFSIZE, "read() returned bad size"); + + for( i = 0; i < TEST_BUFSIZE; i++ ) + if( buf1[i] != buf2[i] ) + diag_printf("buf1[%d](%02x) != buf2[%d](%02x)\n",i,buf1[i],i,buf2[i]); + + CYG_TEST_INFO( "Thread2: calling write()"); + done = write( fd, buf2, TEST_BUFSIZE); + if( done != TEST_BUFSIZE ) SHOW_RESULT( write, done ); + CYG_TEST_CHECK( done == TEST_BUFSIZE, "write() returned bad size"); + + CYG_TEST_INFO( "Thread2: calling close(fd)"); + err = close(fd); + if( err < 0 ) SHOW_RESULT( close, err ); + CYG_TEST_CHECK( err == 0, "close() returned error"); + + CYG_TEST_INFO( "Thread2: calling pthread_exit()"); + pthread_exit( arg ); +} + +//========================================================================== +// main + +int main( int argc, char **argv ) +{ + struct in_addr ina; + char *addr1 = "127.0.255.106"; + char *addr2; + void *retval; + pthread_attr_t attr; + struct sched_param schedparam; + + sa.sin_family = AF_INET; + inet_aton("127.0.0.1", &sa.sin_addr); + sa.sin_port = htons(1234); + + CYG_TEST_INIT(); + + // Test inet_ntoa() and inet_aton() + + inet_aton(addr1, &ina); + addr2 = inet_ntoa(ina); + CYG_TEST_CHECK( strcmp(addr1, addr2) == 0, "Bad inet adderess conversion"); + + + // Create test threads + + { + pthread_attr_init( &attr ); + + schedparam.sched_priority = 10; + pthread_attr_setinheritsched( &attr, PTHREAD_EXPLICIT_SCHED ); + pthread_attr_setschedpolicy( &attr, SCHED_RR ); + pthread_attr_setschedparam( &attr, &schedparam ); + pthread_attr_setstackaddr( &attr, (void *)&thread1_stack[sizeof(thread1_stack)] ); + pthread_attr_setstacksize( &attr, sizeof(thread1_stack) ); + + pthread_create( &thread1, + &attr, + pthread_entry1, + (void *)0x12345671); + } + + { + pthread_attr_init( &attr ); + + schedparam.sched_priority = 5; + pthread_attr_setinheritsched( &attr, PTHREAD_EXPLICIT_SCHED ); + pthread_attr_setschedpolicy( &attr, SCHED_RR ); + pthread_attr_setschedparam( &attr, &schedparam ); + pthread_attr_setstackaddr( &attr, (void *)&thread2_stack[sizeof(thread2_stack)] ); + pthread_attr_setstacksize( &attr, sizeof(thread2_stack) ); + + pthread_create( &thread2, + &attr, + pthread_entry2, + (void *)0x12345672); + } + + // Now join with thread1 + CYG_TEST_INFO( "Main: calling pthread_join(thread1)"); + pthread_join( thread1, &retval ); + + // And thread 2 + CYG_TEST_INFO( "Main: calling pthread_join(thread2)"); + pthread_join( thread2, &retval ); + + CYG_TEST_PASS_FINISH("socket"); +} + +#else + +//========================================================================== +// main + +int main( int argc, char **argv ) +{ + CYG_TEST_INIT(); + + CYG_TEST_NA("socket"); +} + +#endif + + +// ------------------------------------------------------------------------- +// EOF socket.c
