diff -r aba6b8104af3 -r 84a16765cd86 installationservices/swtransactionservices/test/tintegrityservices/source/tintegrityservicesclientserver.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/installationservices/swtransactionservices/test/tintegrityservices/source/tintegrityservicesclientserver.cpp Fri Mar 19 09:33:35 2010 +0200 @@ -0,0 +1,120 @@ +/* +* Copyright (c) 2006-2009 Nokia Corporation and/or its subsidiary(-ies). +* All rights reserved. +* This component and the accompanying materials are made available +* under the terms of the License "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: +* +*/ + + +#include +#include "tintegrityservicesclientserver.h" +#include "tintegrityservicescommon.h" + +// +// Starts the IntegrityServices Server in a new process +// +static TInt StartIntegrityServicesServer() + { + const TUidType serverUid(KExecutableImageUid, KNullUid, KIntegrityServicesServerUid3); + RProcess server; + TInt err = server.Create(KIntegrityServicesServerImage, KNullDesC); + + if (err != KErrNone) + { + return err; + } + + TRequestStatus stat; + server.Rendezvous(stat); + + if (stat != KRequestPending) + { + server.Kill(0); // abort startup + } + else + { + server.Resume(); // logon OK, start the server + } + + User::WaitForRequest(stat); // wait for start or death + // We can't use the 'exit reason' if the server panicked as this is the + // panic 'reason' and may be 0 which cannot be distinguished from KErrNone. + err = (server.ExitType() == EExitPanic) ? KErrGeneral : stat.Int(); + server.Close(); + return err; + } + +EXPORT_C TInt RIntegrityServicesServerSession::Connect() + { + TInt retry = 2; + for(;;) + { + TInt err = CreateSession(KIntegrityServicesServerName, TVersion(0,0,0), 1); + if (err != KErrNotFound && err != KErrServerTerminated) + { + return err; + } + + if (--retry == 0) + { + return err; + } + + err = StartIntegrityServicesServer(); + if (err != KErrNone && err != KErrAlreadyExists) + { + return err; + } + } + } + +EXPORT_C void RIntegrityServicesServerSession::AddL(const TDesC& aFileName) + { + User::LeaveIfError(SendReceive(EAdd, TIpcArgs(&aFileName))); + } + +EXPORT_C void RIntegrityServicesServerSession::RemoveL(const TDesC& aFileName) + { + User::LeaveIfError(SendReceive(ERemove, TIpcArgs(&aFileName))); + } + +EXPORT_C void RIntegrityServicesServerSession::TemporaryL(const TDesC& aFileName) + { + User::LeaveIfError(SendReceive(ETemporary, TIpcArgs(&aFileName))); + } + +EXPORT_C void RIntegrityServicesServerSession::CommitL() + { + User::LeaveIfError(SendReceive(ECommit)); + } + +EXPORT_C void RIntegrityServicesServerSession::RollBackL(TBool aAllTransactions) + { + TPckg all(aAllTransactions); + User::LeaveIfError(SendReceive(ERollBack, TIpcArgs(&all))); + } + +EXPORT_C void RIntegrityServicesServerSession::SetSimulatedFailureL(TPtrC aFailType, TPtrC aFailPosition, TPtrC aFileName) + { + User::LeaveIfError(SendReceive(ESetSimulatedFailure, TIpcArgs(&aFailType, &aFailPosition, &aFileName))); + } + +EXPORT_C void RIntegrityServicesServerSession::CreateNewTestFileL(const TDesC& aFileName) + { + User::LeaveIfError(SendReceive(ECreateNewTestFile, TIpcArgs(&aFileName))); + } + +EXPORT_C void RIntegrityServicesServerSession::CreateTempTestFileL(const TDesC& aFileName) + { + User::LeaveIfError(SendReceive(ECreateTempTestFile, TIpcArgs(&aFileName))); + }