Database.cpp (Firebird-3.0.2.32703-0.tar.bz2) | : | Database.cpp (Firebird-3.0.4.33054-0.tar.bz2) | ||
---|---|---|---|---|
skipping to change at line 234 | skipping to change at line 234 | |||
{ | { | |||
if (!(dbb_flags & (DBB_sweep_starting | DBB_sweep_in_progress))) | if (!(dbb_flags & (DBB_sweep_starting | DBB_sweep_in_progress))) | |||
return; | return; | |||
if (dbb_sweep_lock) | if (dbb_sweep_lock) | |||
LCK_release(tdbb, dbb_sweep_lock); | LCK_release(tdbb, dbb_sweep_lock); | |||
dbb_flags &= ~(DBB_sweep_in_progress | DBB_sweep_starting); | dbb_flags &= ~(DBB_sweep_in_progress | DBB_sweep_starting); | |||
} | } | |||
void Database::registerModule(Module& module) | ||||
{ | ||||
Sync sync(&dbb_modules_sync, FB_FUNCTION); | ||||
sync.lock(SYNC_SHARED); | ||||
if (dbb_modules.exist(module)) | ||||
return; | ||||
sync.unlock(); | ||||
sync.lock(SYNC_EXCLUSIVE); | ||||
if (!dbb_modules.exist(module)) | ||||
dbb_modules.add(module); | ||||
} | ||||
void Database::SharedCounter::shutdown(thread_db* tdbb) | void Database::SharedCounter::shutdown(thread_db* tdbb) | |||
{ | { | |||
for (size_t i = 0; i < TOTAL_ITEMS; i++) | for (size_t i = 0; i < TOTAL_ITEMS; i++) | |||
{ | { | |||
if (m_counters[i].lock) | if (m_counters[i].lock) | |||
LCK_release(tdbb, m_counters[i].lock); | LCK_release(tdbb, m_counters[i].lock); | |||
} | } | |||
} | } | |||
SINT64 Database::SharedCounter::generate(thread_db* tdbb, ULONG space, UL ONG prefetch) | SINT64 Database::SharedCounter::generate(thread_db* tdbb, ULONG space, UL ONG prefetch) | |||
End of changes. 1 change blocks. | ||||
0 lines changed or deleted | 13 lines changed or added |