1 /***************************************************************************
2 * Copyright (C) 2007 by www.databasecache.com *
3 * Contact: praba_tuty@databasecache.com *
5 * This program is free software; you can redistribute it and/or modify *
6 * it under the terms of the GNU General Public License as published by *
7 * the Free Software Foundation; either version 2 of the License, or *
8 * (at your option) any later version. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 ***************************************************************************/
16 #include<Transaction.h>
20 #include<CatalogTables.h>
25 void TransactionManager::printUsageStatistics()
27 Transaction
*iter
= firstTrans
;
28 int i
=0, usedCount
=0, freeCount
=0, undoLogCount
=0;
29 for (; i
< Conf::config
.getMaxProcs(); i
++)
31 if (iter
->status_
== TransNotUsed
) freeCount
++;
35 undoLogCount
+= iter
->noOfUndoLogs();
39 printf("<TransactionTable>\n");
40 printf(" <UsedSlots> %d </UsedSlots>\n", usedCount
);
41 printf(" <FreeSlots> %d </FreeSlots>\n", freeCount
);
43 printf(" <UndoLogs>\n");
44 printf(" <TotalNodes> %d </TotalNodes>\n", undoLogCount
);
45 printf(" </UndoLogs>\n");
46 printf("</TransactionTable>\n");
50 void TransactionManager::printDebugInfo(Database
*sysdb
)
52 Transaction
*iter
= firstTrans
;
53 int i
=0, usedCount
=0, freeCount
=0, undoLogCount
=0;
54 printf("<TransactionTable>\n");
55 for (; i
< Conf::config
.getMaxProcs(); i
++)
57 if (iter
->status_
== TransNotUsed
|| iter
->status_
== TransReserved
) freeCount
++;
61 undoLogCount
+= iter
->noOfUndoLogs();
62 iter
->printDebugInfo(sysdb
);
67 printf(" <UsedSlots> %d </UsedSlots>\n", usedCount
);
68 printf(" <FreeSlots> %d </FreeSlots>\n", freeCount
);
70 Chunk
*chunk
= sysdb
->getSystemDatabaseChunk(UndoLogTableID
);
72 printf(" <UndoLogs>\n");
73 printf(" <TotalNodes> %d </TotalNodes>\n", undoLogCount
);
74 printf(" <TotalPages> %d </TotalPages>\n", chunk
->totalPages());
75 printf(" </UndoLogs>\n");
76 printf("</TransactionTable>\n");
80 DbRetVal
TransactionManager::startTransaction(LockManager
*lMgr
, IsolationLevel level
)
82 Database
*sysdb
= lMgr
->systemDatabase_
;
83 Transaction
*trans
= ProcessManager::getThreadTransaction(sysdb
->procSlot
);
87 if (trans
->status_
!= TransReserved
) return ErrAlready
;
88 else if (trans
->status_
== TransReserved
)
90 //the previous transaction shall be used again
91 //trans->status_ = TransRunning;
92 if ( 0 != Mutex::CAS((int*)&trans
->status_
,
93 TransReserved
, TransRunning
)) {
94 printError(ErrLockTimeOut
, "unable to get lock to reuse the transaction");
95 return ErrLockTimeOut
;
97 trans
->isoLevel_
= level
;
98 printDebug(DM_Transaction
, "Using the same transaction slot\n");
99 logFinest(Conf::logger
, "Transaction Start:Reusing :%x", trans
);
105 DbRetVal rv
= sysdb
->getTransTableMutex();
108 printError(rv
, "Unable to acquire transtable mutex");
111 Transaction
*iter
= firstTrans
;
113 for (i
=0 ; i
< Conf::config
.getMaxProcs(); i
++)
115 if (iter
->status_
== TransNotUsed
) break;
118 // if Transaction table is full return error
119 if (i
== Conf::config
.getMaxProcs()) {
120 printError(ErrNoResource
, "Transaction slots are full");
121 sysdb
->releaseTransTableMutex();
122 return ErrNoResource
;
124 printDebug(DM_Transaction
, "Using transaction slot %d \n", i
);
126 //Make this free slot, as the current transaction and
129 //trans->status_ = TransRunning;
130 if ( 0 != Mutex::CAS((int*)&trans
->status_
,
131 TransNotUsed
, TransRunning
)) {
132 printError(ErrLockTimeOut
, "Unable to start transaction. Timeout. Retry..");
133 sysdb
->releaseTransTableMutex();
134 return ErrLockTimeOut
;
136 trans
->isoLevel_
= level
;
137 ProcessManager::setThreadTransaction(trans
, sysdb
->procSlot
);
138 sysdb
->releaseTransTableMutex();
139 logFinest(Conf::logger
, "Transaction Start:Using :%x", trans
);
143 void TransactionManager::setFirstTrans(Transaction
*trans
)
149 DbRetVal
TransactionManager::commit(LockManager
*lockManager
)
151 Database
*sysdb
= lockManager
->systemDatabase_
;
152 Transaction
*trans
= ProcessManager::getThreadTransaction(sysdb
->procSlot
);
156 printError(ErrNotOpen
, "No transaction started for this procSlot %d", sysdb
->procSlot
);
159 rv
= trans
->releaseAllLocks(lockManager
);
161 printError(ErrSysInternal
, "Fatal:Unable to release all the locks\n");
163 if(NULL
!= trans
->waitLock_
)
165 printError(ErrSysInternal
, "Fatal:Trans WaitLock is not null\n");
167 trans
->removeUndoLogs(sysdb
);
168 if ( 0 != Mutex::CAS((int*)&trans
->status_
, TransRunning
, TransReserved
))
170 printError(ErrSysFatal
, "Transaction state corrupted %d\n", trans
->status_
);
173 printDebug(DM_Transaction
, "Committed transaction:%x",trans
);
174 logFinest(Conf::logger
, "Transaction Committed:%x", trans
);
178 DbRetVal
TransactionManager::rollback(LockManager
*lockManager
, Transaction
*t
)
180 Database
*sysdb
= lockManager
->systemDatabase_
;
181 Transaction
*trans
= NULL
;
184 trans
= ProcessManager::getThreadTransaction(sysdb
->procSlot
);
192 if (trans
->status_
!= TransRunning
)
194 //sysdb->releaseTransTableMutex();
195 //will be called during connection disconnect without starting transaction.
199 trans
->applyUndoLogs(sysdb
);
200 rv
= trans
->releaseAllLocks(lockManager
);
202 printError(ErrSysInternal
, "Fatal:Unable to release all the locks");
204 if(NULL
!= trans
->waitLock_
)
206 printError(ErrSysInternal
, "Fatal:Trans waitlock is not null");
207 //return ErrSysInternal;
210 //trans->status_ = TransNotUsed;
211 if ( 0 != Mutex::CAS((int*)&trans
->status_
, TransRunning
, TransReserved
))
213 printError(ErrSysFatal
, "Fatal:Unable to abort transaction %d\n", trans
->status_
);
216 printDebug(DM_Transaction
, "Aborted transaction:%x",trans
);
217 logFinest(Conf::logger
, "Transaction Aborted:%x", trans
);
220 bool TransactionManager::isTransactionConsistent(Database
*sysdb
)
222 DbRetVal rv
= sysdb
->getTransTableMutex();
225 printError(rv
, "Unable to acquire transtable mutex");
228 Transaction
*iter
= firstTrans
;
230 for (i
=0 ; i
< Conf::config
.getMaxProcs(); i
++)
232 if (iter
->status_
== TransRunning
&& iter
->noOfUndoLogs()) {
233 printError( ErrSysInternal
, "Transaction slot %d not consistent status:%d undoLogs:%d\n",i
, iter
->status_
, iter
->noOfUndoLogs());
234 sysdb
->releaseTransTableMutex();
239 sysdb
->releaseTransTableMutex();