src/backend/logging/loggers/wal_frontend_logger.cpp
/**
 * @brief Add new txn to recovery table
 */
@brief Add new txn to recovery table
@brief Add new txn to recovery table
void WriteAheadFrontendLogger::AbortActiveTransactions() {
  for (auto it = recovery_txn_table.begin(); it != recovery_txn_table.end();
       it++) {
    for (auto it2 = it->second.begin(); it2 != it->second.end(); it2++) {
      delete *it2;
    }
  }
  recovery_txn_table.clear();
}
void WriteAheadFrontendLogger :: AbortActiveTransactions ( ) { for ( auto it = recovery_txn_table . begin ( ) ; it != recovery_txn_table . end ( ) ; it ++ ) { for ( auto it2 = it -> second . begin ( ) ; it2 != it -> second . end ( ) ; it2 ++ ) { delete * it2 ; } } recovery_txn_table . clear ( ) ; }
@brief Add new txn to recovery table
@brief Add new txn to recovery table