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 LogCommitEvent extends LogRequestEvent 38 { 39 44 public LogCommitEvent(LogEntry entry) 45 { 46 super(entry); 47 } 48 49 52 public void execute(LoggerThread loggerThread) 53 { 54 Trace logger = loggerThread.getLogger(); 55 56 try 59 { 60 if (!loggerThread.getRecoveryLog().isRecovering()) 61 { 62 if (loggerThread.removeEmptyTransaction(logEntry.getTid())) 63 return; 64 } 65 } 66 catch (SQLException e) 67 { 68 loggerThread.invalidateLogStatements(); 69 logger.error(Translate.get("recovery.jdbc.loggerthread.log.failed", 70 new String []{"Commit", String.valueOf(logEntry.getTid())}), e); 71 } 73 74 super.execute(loggerThread); 76 } 77 78 } 79 | Popular Tags |