firebird/firebird-mirror
firebird/firebird-mirror
8
0
Fork 1
mirror of https://github.com/FirebirdSQL/firebird.git synced 2025-01-24 07:23:03 +01:00
Code Issues

Improvement CORE-3598 : TRACE: add statistics of actions that were after transaction finished

Browse Source
This commit is contained in:
hvlad 2012-05-03 11:11:44 +00:00
parent ec32e5d006
commit a2e489ed28
3 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/jrd/jrd.cpp
View File

@ -6057,8 +6057,9 @@ static unsigned int purge_transactions(thread_db* tdbb,
if ((transaction->tra_flags & TRA_prepared) || (dbb->dbb_ast_flags & DBB_shutdown) || if ((transaction->tra_flags & TRA_prepared) || (dbb->dbb_ast_flags & DBB_shutdown) ||
(att_flags & ATT_shutdown)) (att_flags & ATT_shutdown))
{ {
TraceTransactionEnd trace(transaction, false, false);
EDS::Transaction::jrdTransactionEnd(tdbb, transaction, false, false, true); EDS::Transaction::jrdTransactionEnd(tdbb, transaction, false, false, true);
TRA_release_transaction(tdbb, transaction); TRA_release_transaction(tdbb, transaction, &trace);
} }
else if (force_flag) else if (force_flag)
TRA_rollback(tdbb, transaction, false, true); TRA_rollback(tdbb, transaction, false, true);
@ -6078,7 +6079,8 @@ static unsigned int purge_transactions(thread_db* tdbb,
attachment->att_dbkey_trans = NULL; attachment->att_dbkey_trans = NULL;
if ((dbb->dbb_ast_flags & DBB_shutdown) || (att_flags & ATT_shutdown)) if ((dbb->dbb_ast_flags & DBB_shutdown) || (att_flags & ATT_shutdown))
{ {
TRA_release_transaction(tdbb, trans_dbk); TraceTransactionEnd trace(trans_dbk, false, false);
TRA_release_transaction(tdbb, trans_dbk, &trace);
} }
else else
{ {

11
src/jrd/tra.cpp
View File

@ -490,8 +490,7 @@ void TRA_commit(thread_db* tdbb, jrd_tra* transaction, const bool retaining_flag
LCK_convert(tdbb, lock, LCK_write, LCK_WAIT); LCK_convert(tdbb, lock, LCK_write, LCK_WAIT);
--transaction->tra_use_count; --transaction->tra_use_count;
trace.finish(res_successful); TRA_release_transaction(tdbb, transaction, &trace);
TRA_release_transaction(tdbb, transaction);
} }
@ -1086,7 +1085,7 @@ jrd_tra* TRA_reconnect(thread_db* tdbb, const UCHAR* id, USHORT length)
} }
void TRA_release_transaction(thread_db* tdbb, jrd_tra* transaction) void TRA_release_transaction(thread_db* tdbb, jrd_tra* transaction, TraceTransactionEnd* trace)
{ {
/************************************** /**************************************
* *
@ -1202,6 +1201,9 @@ void TRA_release_transaction(thread_db* tdbb, jrd_tra* transaction)
if (transaction->tra_flags & TRA_precommitted) if (transaction->tra_flags & TRA_precommitted)
TRA_precommited(tdbb, transaction->tra_number, 0); TRA_precommited(tdbb, transaction->tra_number, 0);
if (trace)
trace->finish(res_successful);
// Unlink the transaction from the database block // Unlink the transaction from the database block
for (jrd_tra** ptr = &attachment->att_transactions; *ptr; ptr = &(*ptr)->tra_next) for (jrd_tra** ptr = &attachment->att_transactions; *ptr; ptr = &(*ptr)->tra_next)
@ -1391,8 +1393,7 @@ void TRA_rollback(thread_db* tdbb, jrd_tra* transaction, const bool retaining_fl
TRA_set_state(tdbb, transaction, transaction->tra_number, state); TRA_set_state(tdbb, transaction, transaction->tra_number, state);
trace.finish(res_successful); TRA_release_transaction(tdbb, transaction, &trace);
TRA_release_transaction(tdbb, transaction);
} }

3
src/jrd/tra_proto.h
View File

@ -29,6 +29,7 @@
namespace Jrd { namespace Jrd {
class Attachment; class Attachment;
class Database; class Database;
class TraceTransactionEnd;
} }
bool TRA_active_transactions(Jrd::thread_db*, Jrd::Database*); bool TRA_active_transactions(Jrd::thread_db*, Jrd::Database*);
@ -50,7 +51,7 @@ void TRA_post_resources(Jrd::thread_db*, Jrd::jrd_tra*, Jrd::ResourceList&);
bool TRA_precommited(Jrd::thread_db*, SLONG, SLONG); bool TRA_precommited(Jrd::thread_db*, SLONG, SLONG);
void TRA_prepare(Jrd::thread_db*, Jrd::jrd_tra*, USHORT, const UCHAR*); void TRA_prepare(Jrd::thread_db*, Jrd::jrd_tra*, USHORT, const UCHAR*);
Jrd::jrd_tra* TRA_reconnect(Jrd::thread_db*, const UCHAR*, USHORT); Jrd::jrd_tra* TRA_reconnect(Jrd::thread_db*, const UCHAR*, USHORT);
void TRA_release_transaction(Jrd::thread_db*, Jrd::jrd_tra*); void TRA_release_transaction(Jrd::thread_db*, Jrd::jrd_tra*, Jrd::TraceTransactionEnd*);
void TRA_rollback(Jrd::thread_db*, Jrd::jrd_tra*, const bool, const bool); void TRA_rollback(Jrd::thread_db*, Jrd::jrd_tra*, const bool, const bool);
void TRA_set_state(Jrd::thread_db*, Jrd::jrd_tra*, SLONG, SSHORT); void TRA_set_state(Jrd::thread_db*, Jrd::jrd_tra*, SLONG, SSHORT);
void TRA_shutdown_attachment(Jrd::thread_db*, Jrd::Attachment*); void TRA_shutdown_attachment(Jrd::thread_db*, Jrd::Attachment*);