1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/loggingservices/filelogger/SSVR/FLOGSVR.CPP Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,378 @@
1.4 +// Copyright (c) 1997-2010 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +/**
1.20 + @file
1.21 +*/
1.22 +
1.23 +#include "FLOGSVR.H"
1.24 +#include "FLOGMAN.H"
1.25 +#include "FLOGSTD.H"
1.26 +
1.27 +/**
1.28 +@internalComponent
1.29 +*/
1.30 +const TInt KOpenLogFilesGranularity=5;
1.31 +
1.32 +/* Internal error. Use positive number to ensure no conflict with other error code
1.33 + Indicate that client message has panic'ed and should not be completed.
1.34 +*/
1.35 +const TInt KErrMessagePanic = 1;
1.36 +
1.37 +/**
1.38 +panics for log client
1.39 +
1.40 +@internalComponent
1.41 +*/
1.42 +enum TLogClientPanic
1.43 + {
1.44 + ELogDirectoryNameDoesNotExist =1, ///< panic if no log directory name
1.45 + ELogFileNameDoesNotExist ///< panic if file name doesnot exist
1.46 + };
1.47 +
1.48 +/**
1.49 +CFileLoggerServer class definition
1.50 +*/
1.51 +
1.52 +CFileLoggerServer* CFileLoggerServer::NewL()
1.53 +/**
1.54 +Creates new CFileLoggerServer object
1.55 +
1.56 +@return Pointer to CFileLoggerServer object
1.57 +*/
1.58 + {
1.59 +
1.60 + CFileLoggerServer* r=new(ELeave) CFileLoggerServer();
1.61 + CleanupStack::PushL(r);
1.62 + r->ConstructL();
1.63 + r->StartL(KFLoggerServerName);
1.64 + CleanupStack::Pop();
1.65 + return r;
1.66 + }
1.67 +
1.68 +CFileLoggerServer::CFileLoggerServer()
1.69 + : CServer2(EPriority)
1.70 + {}
1.71 +
1.72 +void CFileLoggerServer::ConstructL()
1.73 + {
1.74 +
1.75 + iLoggerManager=CFileLoggerManager::NewL();
1.76 + iSessionCounter=CFileLogSessionCounter::NewL();
1.77 + }
1.78 +
1.79 +CFileLoggerServer::~CFileLoggerServer()
1.80 +/**
1.81 +Destructor
1.82 +*/
1.83 + {
1.84 +
1.85 + delete iSessionCounter;
1.86 + delete iLoggerManager;
1.87 + }
1.88 +
1.89 +CFileLogSessionCounter* CFileLoggerServer::SessionCounter() const
1.90 + {
1.91 +
1.92 + return iSessionCounter;
1.93 + }
1.94 +
1.95 +void CFileLoggerServer::Error(TInt aError)
1.96 + {
1.97 +
1.98 + Message().Complete(aError);
1.99 + ReStart();
1.100 + }
1.101 +
1.102 +CSession2* CFileLoggerServer::NewSessionL(const TVersion &aVersion, const RMessage2& /* aMessage */) const
1.103 +/**
1.104 +Create a new server session. Check we're the right version and make a new session
1.105 +
1.106 +@param aVersion version of new session
1.107 +*/
1.108 + {
1.109 +
1.110 + TVersion v(KFLogSrvMajorVersionNumber,KFLogSrvMinorVersionNumber,KFLogSrvBuildVersionNumber);
1.111 + if (!User::QueryVersionSupported(v,aVersion))
1.112 + User::Leave(KErrNotSupported);
1.113 +
1.114 + iSessionCounter->CancelTimer();
1.115 + return CFileLogSession::NewL(CONST_CAST(CFileLoggerServer*,this),iLoggerManager);
1.116 + }
1.117 +/**
1.118 +CFileLogSessionCounter class definition
1.119 +*/
1.120 +
1.121 +CFileLogSessionCounter* CFileLogSessionCounter::NewL()
1.122 +/**
1.123 +Creates new CFileLogSessionCounter object
1.124 +
1.125 +@return Pointer to CFileLogSessionCounter object
1.126 +*/
1.127 + {
1.128 +
1.129 + CFileLogSessionCounter* r=new(ELeave) CFileLogSessionCounter();
1.130 + CleanupStack::PushL(r);
1.131 + r->ConstructL();
1.132 + CleanupStack::Pop();
1.133 + return r;
1.134 + }
1.135 +
1.136 +CFileLogSessionCounter::~CFileLogSessionCounter()
1.137 +/**
1.138 +Destructor
1.139 +*/
1.140 + {
1.141 +
1.142 + delete iShutdownTimer;
1.143 + }
1.144 +
1.145 +CFileLogSessionCounter::CFileLogSessionCounter()
1.146 + : iSessionCount(0)
1.147 +/**
1.148 +Default Constructor
1.149 +*/
1.150 + {}
1.151 +
1.152 +void CFileLogSessionCounter::ConstructL()
1.153 + {
1.154 +
1.155 + iShutdownTimer=CShutdownTimer::NewL();
1.156 + }
1.157 +
1.158 +void CFileLogSessionCounter::IncrementSessionCount()
1.159 +/**
1.160 +Increments the Session count
1.161 +*/
1.162 + {
1.163 +
1.164 + iSessionCount++;
1.165 + }
1.166 +
1.167 +void CFileLogSessionCounter::DecrementSessionCount()
1.168 +/**
1.169 +Decrements the Session count
1.170 +*/
1.171 + {
1.172 +
1.173 + iSessionCount--;
1.174 + if (iSessionCount<=0)
1.175 + iShutdownTimer->After(KShutdownPause);
1.176 + }
1.177 +
1.178 +void CFileLogSessionCounter::CancelTimer()
1.179 +/**
1.180 +Cancels the timer
1.181 +*/
1.182 + {
1.183 +
1.184 + iShutdownTimer->Cancel();
1.185 + }
1.186 +
1.187 +/**
1.188 +CShutdownTimer class definitions
1.189 +*/
1.190 +
1.191 +CShutdownTimer* CShutdownTimer::NewL()
1.192 +/**
1.193 +Creates new CShutdownTimer object
1.194 +@return Pointer to CShutdownTimer object
1.195 +*/
1.196 + {
1.197 +
1.198 + CShutdownTimer* r=new(ELeave) CShutdownTimer();
1.199 + CleanupStack::PushL(r);
1.200 + r->ConstructL();
1.201 + CleanupStack::Pop();
1.202 + return r;
1.203 + }
1.204 +
1.205 +CShutdownTimer::~CShutdownTimer()
1.206 +/**
1.207 +Destructor
1.208 +*/
1.209 + {}
1.210 +
1.211 +CShutdownTimer::CShutdownTimer()
1.212 + : CTimer(EPriorityIdle)
1.213 +/**
1.214 +Default Constructor
1.215 +*/
1.216 + {
1.217 + CActiveScheduler::Add(this);
1.218 + }
1.219 +
1.220 +void CShutdownTimer::RunL()
1.221 +/**
1.222 +*/
1.223 + {
1.224 +
1.225 + CActiveScheduler::Stop();
1.226 + }
1.227 +
1.228 +/**
1.229 +CFileLogSession class definition
1.230 +*/
1.231 +
1.232 +CFileLogSession* CFileLogSession::NewL(CFileLoggerServer* aServer, CFileLoggerManager* aManager)
1.233 + {
1.234 +
1.235 + CFileLogSession* r=new(ELeave) CFileLogSession(aServer,aManager);
1.236 + CleanupStack::PushL(r);
1.237 + r->ConstructL();
1.238 + CleanupStack::Pop();
1.239 + return r;
1.240 + }
1.241 +
1.242 +CFileLogSession::CFileLogSession( CFileLoggerServer* aServer, CFileLoggerManager* aManager)
1.243 + : CSession2(), iLoggerServer(aServer), iLoggerManager(aManager)
1.244 + {}
1.245 +
1.246 +void CFileLogSession::ConstructL()
1.247 + {
1.248 +
1.249 + iLoggerServer->SessionCounter()->IncrementSessionCount(); // should be done first because it will be decremented in the destructor
1.250 + iOpenLogFiles=new(ELeave) CArrayFixFlat<TLogFile>(KOpenLogFilesGranularity);
1.251 + }
1.252 +
1.253 +CFileLogSession::~CFileLogSession()
1.254 +/**
1.255 +Destructor
1.256 +*/
1.257 + {
1.258 + if (iOpenLogFiles)
1.259 + {
1.260 + TInt count=iOpenLogFiles->Count();
1.261 + TInt i;
1.262 + for (i=0; i<count; i++)
1.263 + {
1.264 + iLoggerManager->CloseLog(iOpenLogFiles->At(i));
1.265 + }
1.266 + iOpenLogFiles->Delete(0,count);
1.267 + delete iOpenLogFiles;
1.268 + }
1.269 + iLoggerServer->SessionCounter()->DecrementSessionCount(); // starts the timer if this is the last session
1.270 + }
1.271 +
1.272 +void CFileLogSession::ServiceL(const RMessage2& aMessage)
1.273 +/**
1.274 +@internalTechnology
1.275 +*/
1.276 + {
1.277 +
1.278 + TRAPD(ret,DispatchMessageL(aMessage));
1.279 + if (ret!=KErrMessagePanic)
1.280 + {
1.281 + aMessage.Complete(ret);
1.282 + }
1.283 + }
1.284 +
1.285 +void CFileLogSession::DispatchMessageL(const RMessage2& aMessage)
1.286 + {
1.287 +
1.288 + TInt func=aMessage.Function();
1.289 + if (func!=ECreateLog && func!=EWriteLog && func!=ECloseLog && func!=ECreateWriteAndCloseLog)
1.290 + User::Leave(KErrNotSupported);
1.291 +
1.292 + TLogFile log;
1.293 + TPckg<TLogFile> logPckg(log);
1.294 + aMessage.ReadL(0,logPckg);
1.295 + if (log.Directory().Length()<=0)
1.296 + {
1.297 + aMessage.Panic(KFLoggerServerName,ELogDirectoryNameDoesNotExist);
1.298 + User::Leave(KErrMessagePanic);
1.299 + }
1.300 +
1.301 + if (log.Name().Length()<=0)
1.302 + {
1.303 + aMessage.Panic(KFLoggerServerName,ELogFileNameDoesNotExist);
1.304 + User::Leave(KErrMessagePanic);
1.305 + }
1.306 +
1.307 + // TBuf8<KLogBufferSize> buf;
1.308 + TBuf8<1600> buf;
1.309 + if (func==EWriteLog || func==ECreateWriteAndCloseLog)
1.310 + {
1.311 + aMessage.ReadL(1,buf);
1.312 + }
1.313 +
1.314 + switch (func)
1.315 + {
1.316 + case ECreateLog:
1.317 + OpenLogL(log);
1.318 + aMessage.WriteL(0,logPckg);
1.319 + break;
1.320 +
1.321 + case EWriteLog:
1.322 + iLoggerManager->WriteToLogL(log,buf);
1.323 + break;
1.324 +
1.325 + case ECloseLog:
1.326 + CloseLog(log);
1.327 + break;
1.328 +
1.329 + case ECreateWriteAndCloseLog:
1.330 + {
1.331 + OpenLogL(log); // Ok to leave here; assume that log not left open
1.332 + TInt rc = aMessage.Write(0,logPckg);
1.333 + if (rc == KErrNone && log.Valid())
1.334 + TRAP(rc,iLoggerManager->WriteToLogL(log,buf));
1.335 + CloseLog(log);
1.336 + User::LeaveIfError(rc);
1.337 + break;
1.338 + }
1.339 +
1.340 + default:
1.341 + User::Leave(KErrNotSupported);
1.342 + break;
1.343 + }
1.344 + }
1.345 +
1.346 +
1.347 +void CFileLogSession::OpenLogL(TLogFile& aLogFile)
1.348 +/**
1.349 +Opens log file
1.350 +
1.351 +@param aLogFile Log file name
1.352 +*/
1.353 + {
1.354 +
1.355 + iOpenLogFiles->AppendL(aLogFile);
1.356 + iLoggerManager->FindOrCreateLogL(aLogFile);
1.357 + }
1.358 +
1.359 +void CFileLogSession::CloseLog(TLogFile& aLogFile)
1.360 +/**
1.361 +Closes the log file
1.362 +
1.363 +@param aLogFile Log file name
1.364 +*/
1.365 + {
1.366 +
1.367 + iLoggerManager->CloseLog(aLogFile);
1.368 + TInt count=iOpenLogFiles->Count();
1.369 + TInt i=0;
1.370 + for (i=0; i<count; i++)
1.371 + {
1.372 + if (iOpenLogFiles->At(i)==aLogFile)
1.373 + {
1.374 + iOpenLogFiles->Delete(i,1);
1.375 + break;
1.376 + }
1.377 + }
1.378 +
1.379 + __ASSERT_DEBUG(i<=count, User::Invariant());
1.380 + }
1.381 +