mguardscsvrsession.cpp

symbian s60手机上的短信拦截源代码。

/*
* ============================================================================
*  Name     : MGuardScSvrSession.cpp
*  Part of  : MGuardSc
*  Created  : 19.08.2007 by xueyw
*  Description:
*  Version  :
*  Copyright: 
* ============================================================================
*/

#include <e32base.h>
#include <e32math.h>

#include "MGuardScSvrSession.h"
#include "MGuardScCommon.h"
#include "MGuardScSvrSession.h"

// FUNCTION PROTOTYPES
static TInt StartServer();
static TInt CreateServerProcess();

// ========================= MEMBER FUNCTIONS ==================================

// -----------------------------------------------------------------------------
// RMGuardSvrSession::RMGuardSvrSession()
// C++ default constructor can NOT contain any code, that might leave.
// -----------------------------------------------------------------------------
//
RMGuardSvrSession::RMGuardSvrSession()
	: RSessionBase(), iTimeBuffer( NULL, 0, 0 )
{
	// No implementation required
}

// -----------------------------------------------------------------------------
// RMGuardSvrSession::Connect()
// Connects to the server and create a session.
// -----------------------------------------------------------------------------
//
TInt RMGuardSvrSession::Connect()
{
	TInt error = ::StartServer();

	if ( KErrNone == error )
	{
		error = CreateSession( KMGuardScSvrName,
			Version(),
			KDefaultMessageSlots );
	}
	return error;
}

// -----------------------------------------------------------------------------
// RTimeServerSession::Version()
// Gets the version number.
// -----------------------------------------------------------------------------
//
TVersion RMGuardSvrSession::Version() const
{
	return( TVersion( KMGuardScSvrMajorVersionNumber,
		KMGuardScSvrMinorVersionNumber,
		KMGuardScSvrBuildVersionNumber ) );
}

void RMGuardSvrSession::RequestLock( TTime& aTime, TRequestStatus& aStatus )
{
	TAny* messageParameters[KMaxMessageArguments];

	iTimeBuffer.Set( reinterpret_cast<TUint8*>( &aTime ), sizeof( aTime ),
		sizeof( aTime ) );
	messageParameters[0] = static_cast<TAny*>( &iTimeBuffer );

	SendReceive( EMGuardServRequestLock, &messageParameters[0], aStatus );
}


void RMGuardSvrSession::RequestUnlock( TTime& aTime, TRequestStatus& aStatus )
{
	TAny* messageParameters[KMaxMessageArguments];

	iTimeBuffer.Set( reinterpret_cast<TUint8*>( &aTime ), sizeof( aTime ),
		sizeof( aTime ) );
	messageParameters[0] = static_cast<TAny*>( &iTimeBuffer );

	SendReceive( EMGuardServRequestUnlock, &messageParameters[0], aStatus );
}


void RMGuardSvrSession::CancelRequestLock() const
{
	SendReceive( EMGuardServCancelRequestLock, NULL );
}

// ============================= OTHER FUNCTIONS ===============================

// -----------------------------------------------------------------------------
// StartServer()
// Starts the server if it is not already running
// -----------------------------------------------------------------------------
//
static TInt StartServer()
{
	TInt result;

	TFindServer findTimeServer( KMGuardScSvrName );
	TFullName name;

	result = findTimeServer.Next( name );
	if ( result == KErrNone )
	{
		// Server already running
		return KErrNone;
	}

	//	If not already running, start the server
	RSemaphore semaphore;
	result = semaphore.CreateGlobal( KMGuardScSvrSemaphoreName, 0 );
	if ( result != KErrNone )
	{
		return  result;
	}

	result = CreateServerProcess();
	if ( result != KErrNone )
	{
		return  result;
	}

	//	Deadlock possible if server panic before calling semaphore.Signal();
	semaphore.Wait();
	semaphore.Close();

	return KErrNone;
}

// -----------------------------------------------------------------------------
// CreateServerProcess()
// Creates a server process
// -----------------------------------------------------------------------------
//
static TInt CreateServerProcess()
{
	TInt result;

	const TUidType serverUid( KNullUid, KNullUid, KServerUid3 );
	//const TUidType serverUid( KNullUid, KNullUid, KNullUid );

#ifdef __WINS__

	RLibrary lib;
	result = lib.Load( KMGuardServerFilename, serverUid );
	if ( result != KErrNone )
	{
		return  result;
	}

	//  Get the WinsMain function
	TLibraryFunction functionWinsMain = lib.Lookup( 1 );

	//  Call it and cast the result to a thread function
	TThreadFunction serverThreadFunction =
		reinterpret_cast<TThreadFunction>( functionWinsMain() );

	TName threadName( KMGuardScSvrName );

	// Append a random number to make it unique
	threadName.AppendNum( Math::Random(), EHex );

	RThread server;

	// Create new server thread
	result = server.Create( threadName,
		serverThreadFunction, // Thread's main function
		KDefaultStackSize,
		NULL,
		&lib,
		NULL,
		KServerMinHeapSize,
		KServerMaxHeapSize,
		EOwnerProcess );

	lib.Close();    // If successful, server thread has handle to library now

	if ( result != KErrNone )
	{
		return  result;
	}

	server.SetPriority( EPriorityMore );


#else

	RProcess server;

	_LIT( KStrEmpty,"" );
	result = server.Create( KMGuardServerFilename, KStrEmpty, serverUid );

	if ( result != KErrNone )
	{
		return  result;
	}

#endif

	server.Resume();
	server.Close();

	return  KErrNone;
}