1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/tdbms/t_dbthrd.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,399 @@
1.4 +// Copyright (c) 1998-2009 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 +#include "t_dbstress.h"
1.20 +
1.21 +const TInt KCashLimit=500;
1.22 +const TInt KOverdraftLimit=100;
1.23 +
1.24 +const TInt KMinHeap=0x2000;
1.25 +const TInt KMaxHeap=0x20000;
1.26 +#ifdef _DEBUG
1.27 +const TInt KAllocFailRate=1000;
1.28 +#endif
1.29 +
1.30 +LOCAL_D TBuf<256> Sql;
1.31 +LOCAL_D TBuf8<256> LogBuf;
1.32 +
1.33 +class CThread : public CBase
1.34 + {
1.35 +public:
1.36 + static TInt Entry(TAny*);
1.37 +protected:
1.38 + CThread() {}
1.39 + ~CThread();
1.40 +private:
1.41 + static void EntryL();
1.42 + void GoL();
1.43 + void ConstructL();
1.44 + void OpenViewsL();
1.45 + void RecoverL();
1.46 + void CompactL();
1.47 + void Rollback();
1.48 + void Reset();
1.49 + void WorkL();
1.50 + void TransactionL();
1.51 + void AccountL(TInt anAccount);
1.52 + void StatementTimeL();
1.53 + void VerifyL();
1.54 +//
1.55 + void LogSize();
1.56 +private:
1.57 + RFs iFs;
1.58 + RFile iLog;
1.59 + CFileStore* iStore;
1.60 + RDbStoreDatabase iData;
1.61 + TBool iOpen;
1.62 + RDbView iAccs;
1.63 + RDbView iTrans;
1.64 + TInt iError;
1.65 + TInt iPoint;
1.66 + };
1.67 +
1.68 +GLDEF_C TInt StartThread(RThread& aThread,TRequestStatus& aStat)
1.69 + {
1.70 + TInt r=aThread.Create(_L("Thread"),CThread::Entry,KDefaultStackSize,KMinHeap,KMaxHeap,NULL);
1.71 + if (r==KErrNone)
1.72 + {
1.73 + aThread.SetPriority(EPriorityLess);
1.74 + aThread.Logon(aStat);
1.75 + aThread.Resume();
1.76 + RunTimer.Start();
1.77 + }
1.78 + return r;
1.79 + }
1.80 +
1.81 +TInt CThread::Entry(TAny*)
1.82 + {
1.83 + CTrapCleanup* cleanup=CTrapCleanup::New();
1.84 + if (cleanup==NULL)
1.85 + return KErrNoMemory;
1.86 + TRAPD(r,EntryL());
1.87 + delete cleanup;
1.88 + return r;
1.89 + }
1.90 +
1.91 +void CThread::EntryL()
1.92 + {
1.93 + CThread* self=new(ELeave) CThread;
1.94 + CleanupStack::PushL(self);
1.95 + self->ConstructL();
1.96 + self->GoL(); // never returns
1.97 + }
1.98 +
1.99 +CThread::~CThread()
1.100 + {//The destructor is never ever executed! See CThread::EntryL() for details!
1.101 + iAccs.Close();
1.102 + iTrans.Close();
1.103 + iData.Close();
1.104 + delete iStore;
1.105 + iLog.Close();
1.106 + TInt err = iFs.Delete(KLogFile);
1.107 + if(err != KErrNone)
1.108 + {
1.109 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &KLogFile);
1.110 + }
1.111 + iFs.Close();
1.112 + }
1.113 +
1.114 +void CThread::ConstructL()
1.115 + {
1.116 + User::LeaveIfError(iFs.Connect());
1.117 + User::LeaveIfError(iFs.SetSessionPath(KTestDir));
1.118 + User::LeaveIfError(iLog.Replace(iFs,KLogFile,EFileWrite|EFileStreamText));
1.119 + iStore=CFileStore::OpenL(iFs,KTestDatabase,EFileRead|EFileWrite|EFileWriteDirectIO);
1.120 + LogSize();
1.121 + iData.OpenL(iStore,iStore->Root());
1.122 + }
1.123 +
1.124 +//
1.125 +// Never exits
1.126 +//
1.127 +void CThread::GoL()
1.128 + {
1.129 + __UHEAP_SETFAIL(RHeap::ETrueRandom,KAllocFailRate);
1.130 + for (;;)
1.131 + {
1.132 + TRAPD(r,WorkL());
1.133 + NewCount=OldCount;
1.134 + LogBuf.Format(_L8(" *** Point %d with code %d"),iPoint,r);
1.135 + iLog.Write(LogBuf);
1.136 + LogSize();
1.137 + iError=r;
1.138 + Rollback();
1.139 + LogSize();
1.140 + if (r==KErrDiskFull)
1.141 + User::Leave(r);
1.142 + }
1.143 + }
1.144 +
1.145 +//
1.146 +// Report the file size
1.147 +//
1.148 +void CThread::LogSize()
1.149 + {
1.150 + TInt size;
1.151 + if (iStore->File().Size(size)==KErrNone)
1.152 + {
1.153 + LogBuf.Format(_L8("\nFile size=%d"),size);
1.154 + iLog.Write(LogBuf);
1.155 + }
1.156 + }
1.157 +
1.158 +void CThread::Rollback()
1.159 + {
1.160 + if (iOpen)
1.161 + {
1.162 + iLog.Write(_L8("\nCancel"));
1.163 + iAccs.Cancel();
1.164 + iTrans.Cancel();
1.165 + }
1.166 + if (iData.InTransaction())
1.167 + {
1.168 + iLog.Write(_L8("\nRollback"));
1.169 + iData.Rollback();
1.170 + }
1.171 + }
1.172 +
1.173 +void CThread::Reset()
1.174 + {
1.175 + iLog.Write(_L8("\nReset"));
1.176 + TEST(iOpen);
1.177 + iAccs.Reset();
1.178 + iTrans.Reset();
1.179 + }
1.180 +
1.181 +void CThread::RecoverL()
1.182 + {
1.183 + iPoint=70;
1.184 + User::LeaveIfError(iLog.Write(_L8("\nRecovering")));
1.185 + if (iOpen)
1.186 + {
1.187 + iAccs.Close();
1.188 + iTrans.Close();
1.189 + iOpen=EFalse;
1.190 + }
1.191 + User::LeaveIfError(iData.Recover());
1.192 + }
1.193 +
1.194 +void CThread::CompactL()
1.195 + {
1.196 + iPoint=90;
1.197 + User::LeaveIfError(iLog.Write(_L8("\nCompacting")));
1.198 + TInt b=iStore->ReclaimL();
1.199 + b-=iStore->CompactL();
1.200 + iStore->CommitL();
1.201 + LogBuf.Format(_L8(": %d bytes reclaimed"),b);
1.202 + User::LeaveIfError(iLog.Write(LogBuf));
1.203 + }
1.204 +
1.205 +void CThread::OpenViewsL()
1.206 + {
1.207 + iPoint=80;
1.208 + User::LeaveIfError(iLog.Write(_L8("\nOpening")));
1.209 + User::LeaveIfError(iAccs.Prepare(iData,_L("select id,balance,statement_balance from accounts")));
1.210 + TInt r=iTrans.Prepare(iData,_L("select t_date,from_id,to_id,amount from transactions"));
1.211 + if (r!=KErrNone)
1.212 + {
1.213 + iAccs.Close();
1.214 + User::Leave(r);
1.215 + }
1.216 + iOpen=ETrue;
1.217 + }
1.218 +
1.219 +void CThread::WorkL()
1.220 + {
1.221 + iPoint=0;
1.222 + switch (iError)
1.223 + {
1.224 + case KErrDied:
1.225 + Rollback();
1.226 + break;
1.227 + case KErrNotReady:
1.228 + Reset();
1.229 + break;
1.230 + case KErrCorrupt:
1.231 + RecoverL();
1.232 + break;
1.233 + }
1.234 + iPoint=1;
1.235 + for (;;)
1.236 + {
1.237 + LogSize();
1.238 + if (!iOpen)
1.239 + OpenViewsL();
1.240 + switch (Random(100))
1.241 + {
1.242 + case 0: case 1:
1.243 + StatementTimeL();
1.244 + break;
1.245 + case 2: case 3:
1.246 + RecoverL();
1.247 + break;
1.248 + case 4: // case 5: case 6: case 7: case 8: case 9:
1.249 + CompactL();
1.250 + break;
1.251 + default:
1.252 + TransactionL();
1.253 + break;
1.254 + }
1.255 + }
1.256 + }
1.257 +
1.258 +void CThread::AccountL(TInt anAccount)
1.259 + {
1.260 + Sql.Format(_L("id=%d"),anAccount);
1.261 + iAccs.FirstL();
1.262 + TEST(iAccs.FindL(iAccs.EForwards,Sql)>=0);
1.263 + }
1.264 +
1.265 +//
1.266 +// generate and add a single transaction
1.267 +//
1.268 +void CThread::TransactionL()
1.269 + {
1.270 + iPoint=2;
1.271 + User::LeaveIfError(iLog.Write(_L8("\nTransaction")));
1.272 + TInt from;
1.273 + if (Random(3)==0)
1.274 + from=ECash;
1.275 + else
1.276 + from=Random(KAccountIDs);
1.277 + TInt to=(Random(KAccountIDs-1)+from+1)%KAccountIDs;
1.278 + AccountL(from);
1.279 + iAccs.GetL();
1.280 + TEST(iAccs.ColInt(1)==from);
1.281 + TInt avail=iAccs.ColInt(2)+KOverdraftLimit;
1.282 + TInt amount;
1.283 + if (to==ECash)
1.284 + {
1.285 + if (avail<10)
1.286 + return;
1.287 + amount=10*(1+Random(Min(avail,KCashLimit)/10));
1.288 + }
1.289 + else
1.290 + {
1.291 + amount=1+Random(100);
1.292 + if (Random(100)<5)
1.293 + amount*=10;
1.294 + if (Random(100)<5)
1.295 + amount*=10;
1.296 + while (amount>avail)
1.297 + amount/=4;
1.298 + if (amount==0)
1.299 + return;
1.300 + }
1.301 + iPoint=3;
1.302 + LogBuf.Format(_L8(" %08d: %d -> %d, %5d"),++TransId,from,to,amount);
1.303 + User::LeaveIfError(iLog.Write(LogBuf));
1.304 + iPoint=4;
1.305 + iData.Begin();
1.306 + iTrans.InsertL();
1.307 + iTrans.SetColL(1,TransId);
1.308 + iTrans.SetColL(2,from);
1.309 + iTrans.SetColL(3,to);
1.310 + iTrans.SetColL(4,amount);
1.311 + iPoint=5;
1.312 + iTrans.PutL();
1.313 + iPoint=6;
1.314 + iAccs.UpdateL(); // from
1.315 + TInt frombalance=iAccs.ColInt(2)-amount;
1.316 + iAccs.SetColL(2,frombalance);
1.317 + iPoint=7;
1.318 + iAccs.PutL();
1.319 + iPoint=8;
1.320 + AccountL(to);
1.321 + iPoint=9;
1.322 + iAccs.UpdateL(); // to
1.323 + TInt tobalance=iAccs.ColInt(2)+amount;
1.324 + iAccs.SetColL(2,tobalance);
1.325 + iPoint=10;
1.326 + iAccs.PutL();
1.327 + iPoint=11;
1.328 +// this will invoke commit, so update counts now
1.329 + NewCount=OldCount+1;
1.330 + TInt r=iData.Commit();
1.331 + if (r!=KErrNone)
1.332 + {
1.333 + NewCount=OldCount;
1.334 + User::Leave(r);
1.335 + }
1.336 +// succeeded
1.337 + OldCount=NewCount;
1.338 + LogBuf.Format(_L8("; [%d,%d]"),frombalance,tobalance);
1.339 + iLog.Write(LogBuf);
1.340 + }
1.341 +
1.342 +//
1.343 +// deliver statements
1.344 +//
1.345 +void CThread::StatementTimeL()
1.346 + {
1.347 + iPoint=50;
1.348 + User::LeaveIfError(iLog.Write(_L8("\nStatement")));
1.349 + iPoint=51;
1.350 + VerifyL();
1.351 + // discard transactions
1.352 + iPoint=52;
1.353 + iData.Begin();
1.354 + for (iTrans.BeginningL();iTrans.NextL();)
1.355 + iTrans.DeleteL();
1.356 + for (iAccs.BeginningL();iAccs.NextL();)
1.357 + {
1.358 + iAccs.UpdateL();
1.359 + iAccs.SetColL(3,iAccs.ColInt(2)); // set statement balance
1.360 + iAccs.PutL();
1.361 + }
1.362 + iPoint=53;
1.363 + NewCount=0;
1.364 + TInt r=iData.Commit();
1.365 + if (r!=KErrNone)
1.366 + {
1.367 + NewCount=OldCount;
1.368 + User::Leave(r);
1.369 + }
1.370 + OldCount=NewCount;
1.371 + }
1.372 +
1.373 +void CThread::VerifyL()
1.374 + {
1.375 + TInt balance[KAccountIDs];
1.376 + TEST(iAccs.CountL()==KAccountIDs);
1.377 + for (iAccs.BeginningL();iAccs.NextL();)
1.378 + {
1.379 + iAccs.GetL();
1.380 + TInt id=iAccs.ColInt(1);
1.381 + balance[id]=iAccs.ColInt(3);
1.382 + }
1.383 + TInt transact=0;
1.384 + for (iTrans.BeginningL();iTrans.NextL();)
1.385 + {
1.386 + ++transact;
1.387 + iTrans.GetL();
1.388 + TInt from=iTrans.ColInt(2);
1.389 + TInt to=iTrans.ColInt(3);
1.390 + TInt amount=iTrans.ColInt(4);
1.391 + balance[from]-=amount;
1.392 + balance[to]+=amount;
1.393 + }
1.394 + TEST(transact==iTrans.CountL());
1.395 + for (iAccs.BeginningL();iAccs.NextL();)
1.396 + {
1.397 + iAccs.GetL();
1.398 + TInt id=iAccs.ColInt(1);
1.399 + if (balance[id]!=iAccs.ColInt(2))
1.400 + User::Panic(_L("Oh-oh"),4321);
1.401 + }
1.402 + }