--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/testexecmgmt/ucc/Source/PppdGateway/pppdgateway.c Mon Mar 08 15:04:18 2010 +0800
@@ -0,0 +1,336 @@
+/*
+* Copyright (c) 2005-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:
+* Switches
+*
+*/
+
+
+
+//#define SYSTEM_TEST_MP5
+
+
+/*******************************************************************************
+ *
+ * System Includes
+ *
+ ******************************************************************************/
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+#include <unistd.h>
+#include <assert.h>
+#include <errno.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <signal.h>
+#include <string.h>
+
+/*******************************************************************************
+ *
+ * Local Includes
+ *
+ ******************************************************************************/
+#include "socket_helper.h"
+
+
+/*******************************************************************************
+ *
+ * Definitions
+ *
+ ******************************************************************************/
+#define RECVBUFFSIZE (4096*4)
+#define MAXIDSTR 64
+
+
+/*******************************************************************************
+ *
+ * Prototypes
+ *
+ ******************************************************************************/
+void *receive_ppp_frames( void *x );
+void *send_ppp_frames( void * );
+void closesocket( int sockfd );
+int do_client_server_protocol( int aMobsterDeviceID );
+
+
+/*******************************************************************************
+ *
+ * File-scope
+ *
+ ******************************************************************************/
+int sockfd;
+
+
+/*******************************************************************************
+ *
+ * Signal Handler
+ *
+ ******************************************************************************/
+void sigterm( int signum )
+{
+ pid_t mp = getpid();
+ fprintf( stderr, "PG: pppdgateway(%d) received a SIGTERM -- ignoring\n", mp );
+}
+
+
+/*******************************************************************************
+ *
+ * Main()
+ *
+ ******************************************************************************/
+int main( int argc, char *argv[] )
+{
+ int err;
+ int mobster_device_id = 0;
+ pthread_t threadhandle_send, threadhandle_recv;
+ struct sockaddr_in mobster_addr;
+ __sighandler_t oh;
+
+ // check args
+ if( argc != 4 ) {
+ fprintf( stderr, "usage: %s mobster_address mobster_port mobster_device_id\n", argv[0] );
+ return -1;
+ }
+ mobster_device_id = atoi(argv[3]);
+ fprintf( stderr, "PG: pppdgateway starting\n" );
+
+ // setup the signal handler -- note that we ignore SIGTERM! This is because if we shutdown on a SIGTERM we don't
+ // output the TERMREQ -- or receive the TERMACK. Therefore, we rely on the fact that when pppd wants to stop
+ // it will close stdin -- this will cause the output thread to stop -- it will also close the socket which
+ // will cause the input thread to stop -- then the main thread will exit
+ oh = signal( SIGTERM, sigterm );
+ if( oh == SIG_ERR ) {
+ fprintf( stderr, "PG: error registering signal handler (SIGTERM)\n" );
+ return -1;
+ }
+ oh = signal( SIGHUP, sigterm );
+ if( oh == SIG_ERR ) {
+ fprintf( stderr, "PG: error registering signal handler (SIGHUP)\n" );
+ return -1;
+ }
+
+ // create a TCP socket
+ sockfd = socket( AF_INET, SOCK_STREAM, 0 );
+ if( sockfd == -1 ) {
+ fprintf( stderr, "PG: failed to create socket, exiting.\n" );
+ return -1;
+ }
+
+ // create the address
+ mobster_addr = getsockaddr( argv[1], argv[2] );
+ if( mobster_addr.sin_addr.s_addr == 0 ) {
+ fprintf( stderr, "PG: invalid address (zero or couldn't resolve hostname), exiting.\n" );
+ closesocket( sockfd );
+ return -1;
+ }
+
+ // connect to mobster
+ err = connect( sockfd, (struct sockaddr*)&mobster_addr, sizeof(mobster_addr) );
+ if( err != 0 ) {
+ perror( "PG: connect() to server failed\n" );
+ closesocket( sockfd );
+ return -1;
+ }
+
+ // do the client server protocol - if there is an error the exit
+ err = do_client_server_protocol( mobster_device_id );
+ if( err != 0 ) {
+ fprintf( stderr, "PG: client/server protocol failed.\n" );
+ closesocket( sockfd );
+ return -1;
+ }
+
+ // change the streams to unbuffered so that this exe doesn't add latency
+ err = setvbuf( stdout, NULL, _IONBF, 0 );
+ if( err != 0 ) {
+ fprintf( stderr, "PG: failed to set buffering on stdout (%d)\n", err );
+ closesocket( sockfd );
+ return -1;
+ }
+ err = setvbuf( stdin, NULL, _IONBF, 0 );
+ if( err != 0 ) {
+ fprintf( stderr, "PG: failed to set buffering on stdout (%d)\n", err );
+ closesocket( sockfd );
+ return -1;
+ }
+ err = setvbuf( stderr, NULL, _IONBF, 0 );
+ if( err != 0 ) {
+ fprintf( stderr, "PG: failed to set buffering on stdout (%d)\n", err );
+ closesocket( sockfd );
+ return -1;
+ }
+
+ // all the setup is done -- create the threads and let them do their stuff
+ err = pthread_create( &threadhandle_send, NULL, send_ppp_frames, 0 );
+ assert( err == 0 );
+ err = pthread_create( &threadhandle_recv, NULL, receive_ppp_frames, 0 );
+ assert( err == 0 );
+
+
+ // wait for them to exit
+ pthread_join( threadhandle_send, NULL );
+ pthread_join( threadhandle_recv, NULL );
+
+
+ // return
+ fprintf( stderr, "PG: pppdgateway has completed.\n" );
+ return 0;
+}
+
+
+/*******************************************************************************
+ *
+ * receive_ppp_frames
+ *
+ ******************************************************************************/
+void *receive_ppp_frames( void *x )
+{
+ int recvcount, writecount;
+ char recvbuff[RECVBUFFSIZE];
+
+ // listen on the udp socket and send anything received to stdout -- no framing is ever done on the input channel
+ while( 1 ) {
+
+ // wait for some data -- on error print error, close the socket, and exit. Closing the socket means that the other thread will clean up and exit
+ recvcount = recv( sockfd, recvbuff, RECVBUFFSIZE, 0 );
+ if( recvcount == -1 ) {
+ fprintf( stderr, "PG: error occured while reading socket.\n" );
+ closesocket( sockfd );
+ pthread_exit( NULL );
+ }
+ // fprintf( stderr, "PG: %d bytes incoming\n", recvcount );
+
+ // send the data to the pppd server
+ writecount = fwrite( recvbuff, 1, recvcount, stdout );
+ if( writecount != recvcount ) {
+ fprintf( stderr, "PG: error occured while writing to stdout.\n" );
+ closesocket( sockfd );
+ pthread_exit( NULL );
+ }
+ }
+
+ // done
+ return NULL;
+}
+
+
+/*******************************************************************************
+ *
+ * send_ppp_frames
+ *
+ ******************************************************************************/
+void *send_ppp_frames( void *x )
+{
+ int err;
+ int sendcount;
+ int c = 0;
+
+ // listen on stdin for data and write it to the socket -- on error print an error, closesocket, and exit.
+ while( 1 ) {
+
+ // read the next char
+ err = fread( &c, 1, 1, stdin );
+ if( err != 1 ) {
+ fprintf( stderr, "PG: error occured while reading from stdin.\n" );
+ closesocket( sockfd );
+ pthread_exit( NULL );
+ }
+ // fprintf( stderr, "PG: %d bytes outgoing\n", err );
+
+ // write it to the socket
+ sendcount = send( sockfd, &c, 1, 0 );
+ if( sendcount != 1 ) {
+ fprintf( stderr, "PG: error occured while writing to the socket.\n" );
+ closesocket( sockfd );
+ pthread_exit( NULL );
+ }
+ }
+
+ // done
+ return NULL;
+}
+
+
+/*******************************************************************************
+ *
+ * closesocket
+ *
+ ******************************************************************************/
+void closesocket( int sockfd )
+{
+ shutdown( sockfd, SHUT_RDWR );
+ close( sockfd );
+}
+
+
+/*******************************************************************************
+ *
+ * do_client_server_protocol()
+ *
+ ******************************************************************************/
+int do_client_server_protocol( int aMobsterDeviceID )
+{
+ char c;
+ int len, expected_length, i, err;
+ char idstr[MAXIDSTR];
+ char rpstr[MAXIDSTR];
+
+ // construct the client string for the csprotocol
+ snprintf( idstr, MAXIDSTR, "ID=%d", aMobsterDeviceID );
+ len = strlen(idstr);
+ idstr[len] = 0x0d;
+ idstr[len+1] = 0;
+
+#ifdef SYSTEM_TEST_MP5
+ assert( !"TEST" );
+#endif
+
+ // send the string
+ err = send( sockfd, idstr, len+1, 0 );
+ if( err != (len+1) ) {
+ fprintf( stderr, "PG: failed to write id string, exiting.\n" );
+ return -1;
+ }
+
+ // construct the expected reply string to get the expected length
+ snprintf( rpstr, MAXIDSTR, "SERVER(%d)", aMobsterDeviceID );
+ expected_length = strlen(rpstr);
+
+ // now read until there
+ for( i = 0; ; i++ ) {
+
+ // read a byte
+ err = recv( sockfd, &c, 1, 0 );
+ if( err == -1 ) {
+ fprintf( stderr, "PG: failed to read reply string (%d, %d).\n", err, errno );
+ return -1;
+ }
+
+ // check for a mismatch
+ if( c != rpstr[i] ) {
+ fprintf( stderr, "PG: unexpected character from server.\n" );
+ return -1;
+ }
+
+ // see if we've matched all chars
+ if( (i+1) == expected_length ) {
+ break;
+ }
+ }
+
+ // done - success
+ return 0;
+}