/*
* 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:   
* This file was autogenerated by rpcgen, but should be modified by the developer.
* Make sure you don't use the -component_mod flag in future or this file will be overwritten.
* Fri Sep 19 13:14:28 2003
* System Includes
*
*/




#include <stdio.h>
#include <unistd.h>
#include <errno.h>


/****************************************************************************************
 * 
 * Local Includes
 * 
 ***************************************************************************************/
#include "CSvcMobster.h"
#include "mobster.h"
#include "../ThreadLibrary/CAThread.h"
#include "mobster_client_server_protocol.h"


/****************************************************************************************
 * 
 * Definitions
 * 
 ***************************************************************************************/
#ifndef WIN32
#define ADDRESS_INTEGER          s_addr
#define closesocket(x)           (shutdown(x,SHUT_RDWR),close(x))
#endif

/****************************************************************************************
 * 
 * File-scope variables
 * 
 ***************************************************************************************/
static CComponentManager<CSMobster> *iComponentManager;
static CAThread *iServerThread;
static int iServerListenSocket, iStopRequestedFlag;

/****************************************************************************************
 * 
 * Implementation
 * 
 ***************************************************************************************/


/****************************************************************************************
 * 
 * PUBLIC: GetInstanceKeyFromArgs
 * 
 ***************************************************************************************/
int CSvcMobster::GetInstanceKeyFromArgs( int aMethod, void *aArgs )
{
	int rv;
	int *ia;
	TUUAddress *ua;

	switch( aMethod ) {

	case DSTR_REMOVEDEVICE:
	case GETDEVICEINFO:
	case GETDEVICELOG:
	case STOPDEVICE:
		ia = (int*)aArgs;
		rv = *ia;
		break;

	case SETREMOTEUUADDRESS:
		ua = (TUUAddress*)aArgs;
		rv = ua->iDeviceID;
		break;

	default:
		rv = ERR_INVALID_METHOD;
		break;
	}
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC: SetError
 * 
 ***************************************************************************************/
int CSvcMobster::SetError( int aMethod, void *aArgs, int aError )
{
	int rv;
	TComponentList *cl;
	TDeviceDesc *dd;
	TVarData *vd;

	switch( aMethod ) {

	case LIST_DEVICES:
		cl = (TComponentList*)aArgs;
		if( aError != ERR_NONE ) {
			if( cl->TComponentList_val != NULL ) {
				free(cl->TComponentList_val);
				cl->TComponentList_val = NULL;
			}
			cl->TComponentList_len = 0;
		}
		rv = ERR_NONE;
		break;

	case GETDEVICEINFO:
		dd = (TDeviceDesc*)aArgs;
		dd->iMTID = aError;
		rv = ERR_NONE;
		break;

	case GETDEVICELOG:
		vd = (TVarData*)aArgs;
		if( aError != ERR_NONE ) {
			if( vd->TVarData_val != NULL ) {
				free(vd->TVarData_val);
				vd->TVarData_val = NULL;
			}
			vd->TVarData_len = 0;
		}
		rv = ERR_NONE;
		break;

	default:
		rv = ERR_INVALID_METHOD;
		break;
	}
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC: StartRPCService
 * 
 ***************************************************************************************/
int CSvcMobster::StartRPCService( CComponentManager<CSMobster> *aComponentManager, TChannelAddress *aArg )
{
	TThreadError terr;
	int err;
	struct sockaddr_in local_address;

	// prologue
	assert( iComponentManager == NULL );
	assert( iServerThread == NULL );

	// create a socket to listen for connections
	iServerListenSocket = socket( AF_INET, SOCK_STREAM, 0 );
	if( iServerListenSocket == -1 ) {
		return ERR_CREATE_SOCKET_FAILED;
	}

	// bind the specified port (ignore address)
	local_address.sin_family = AF_INET;
	local_address.sin_addr.ADDRESS_INTEGER = INADDR_ANY;
	local_address.sin_port = htons(aArg->iPort);
	err = bind( iServerListenSocket, (struct sockaddr *)&local_address, sizeof(local_address) );
	if( err == -1 ) {
		closesocket( iServerListenSocket );
		return ERR_BIND_FAILED;
	}

	// listen
	err = listen( iServerListenSocket, 5 );
	if( err == -1 ) {
		closesocket( iServerListenSocket );
		return ERR_LISTEN_FAILED;
	}

	// ok the socket is all setup to do an accept - so we pass over to the other thread
	// and let the main call continue
	iStopRequestedFlag = 0;
	iServerThread = new CAThread( "CSvcMobster::iServerThread" );
	assert( iServerThread != NULL );
	terr = iServerThread->StartThread( (void*)CSvcMobster::WaitForConnectionsFromTerminalEmulations, NULL, &err ); 
	if( terr != TE_NONE ) {
		closesocket( iServerListenSocket );
		delete iServerThread;
		iServerThread = NULL;
		return ERR_CREATE_SERVER_THREAD_FAILED;
	}

	// done 
	iComponentManager = aComponentManager;
	return ERR_NONE;
}


/****************************************************************************************
 * 
 * PUBLIC: StopRPCService
 * 
 ***************************************************************************************/
int CSvcMobster::StopRPCService()
{
	TThreadError terr;

	// close the socket to stop the thread
	iStopRequestedFlag = 1;
	closesocket( iServerListenSocket );
	terr = iServerThread->WaitForThread( -1 );
	if( terr != TE_NONE ) {
		fprintf( stderr, "WARNING: CSvcMobster::StopRPCService - WaitForThread returned %d.\n", terr );
	}

	// clean up the thread
	if( iServerThread != NULL ) {
		delete iServerThread;
		iServerThread = NULL;
	}

	// reset the component manager (though not responsible for delete)
	iComponentManager = NULL;
	return ERR_NONE;
}


/****************************************************************************************
 * 
 * PRIVATE: WaitForConnectionsFromTerminalEmulations
 * 
 ***************************************************************************************/
void CSvcMobster::WaitForConnectionsFromTerminalEmulations( void )
{
	int client_sockfd;

	// repeat until StopRPCService is called (or an error occurs)
	while( 1 ) {

		// wait for a connection
		client_sockfd = accept( iServerListenSocket, NULL, NULL );
		if( client_sockfd == -1 ) {
		  if( ((errno != 0) && (errno != EINVAL)) || ((errno == EINVAL) && (iStopRequestedFlag == 0)) ) {
		    fprintf( stderr, "WARNING: Accept has failed with errno = %d.\n", errno );
		  }
		  break;
		}

		// we have a socket -- now it has to do the c/s protocol so that we know which 
		// MT to connect it to -- but if there is a problem then this could block 
		// forever -- so I'm going to create a thread per connection to deal with this. 
		// These threads are responsible for cleaning themselves up.
#ifdef WIN32
		{
		  HANDLE client_thread;
		  client_thread = CreateThread( NULL, 0, (LPTHREAD_START_ROUTINE)CSvcMobster::ConnectClientToMobileTermination, (void*)client_sockfd, 0, NULL );
		  if( client_thread == NULL ) {
		    fprintf( stderr, "WARNING: Failed to create the client thread to connect to MobileTermination (%d).\n", GetLastError() );
		  }
		  client_thread = NULL;
#else
		{
		  int err;
		  pthread_t client_thread;
		  err = pthread_create( &client_thread, NULL, (void*(*)(void*))(CSvcMobster::ConnectClientToMobileTermination), (void*)client_sockfd );
		  if( err != 0 ) {
		    fprintf( stderr, "WARNING: Failed to create the client thread to connect to MobileTermination (%d).\n", errno );
		  }
		  client_thread = 0;
		}
#endif

		// this is all we have to do
	}

	// done
	return;
}


/****************************************************************************************
 * 
 * PRIVATE: ConnectClientToMobileTermination
 * 
 ***************************************************************************************/
void CSvcMobster::ConnectClientToMobileTermination( int aSock )
{
	int mtid, err;
	CSMobster *mt;

	// do the csprotocol across the socket to get the config info
	mtid = client_server_protocol( aSock );
	if( mtid < 0 ) {
		fprintf( stderr, "WARNING: Invalid MTID received (%d).\n", mtid );
		closesocket( aSock );
		return;
	}

	// try and get the instance
	mt = iComponentManager->GetInstance( mtid );
	if( mt == NULL ) {
		fprintf( stderr, "WARNING: Client requested non-existant device %d.\n", mtid );
		closesocket( aSock );
		return;
	}

	// pass the new socket to the mt
	err = mt->settesocket( aSock );
	if( err != ERR_NONE ) {
		fprintf( stderr, "WARNING: Failed to set the socket on device %d (%d).\n", mtid, err );
		closesocket( aSock );
		return;
	}

	// all done -- thread exit
#ifdef WIN32
	ExitThread( 0 );
#else
	pthread_exit( 0 );
#endif
}