1 21 22 package org.continuent.sequoia.controller.recoverylog.events; 23 24 import java.sql.SQLException ; 25 26 import org.continuent.sequoia.common.i18n.Translate; 27 import org.continuent.sequoia.common.log.Trace; 28 import org.continuent.sequoia.controller.recoverylog.LoggerThread; 29 30 37 public class LogRollbackEvent extends LogRequestEvent 38 { 39 45 public LogRollbackEvent(LogEntry entry) 46 { 47 super(entry); 48 } 49 50 53 public void execute(LoggerThread loggerThread) 54 { 55 Trace logger = loggerThread.getLogger(); 56 57 try 60 { 61 if (!loggerThread.getRecoveryLog().isRecovering()) 62 { 63 if (loggerThread.removeEmptyTransaction(logEntry.getTid())) 64 return; 65 } 66 } 67 catch (SQLException e) 68 { 69 loggerThread.invalidateLogStatements(); 70 logger.error(Translate.get("recovery.jdbc.loggerthread.log.failed", 71 new String []{"rollback", String.valueOf(logEntry.getTid())}), e); 72 } 74 75 super.execute(loggerThread); 77 } 78 79 } 80 | Popular Tags |