1 21 22 package org.continuent.sequoia.controller.recoverylog.events; 23 24 import java.sql.SQLException ; 25 26 import org.continuent.sequoia.controller.recoverylog.LoggerThread; 27 28 32 public class RemoveCheckpointEvent implements LogEvent 33 { 34 35 private String checkpointName; 36 37 42 public RemoveCheckpointEvent(String checkpointName) 43 { 44 this.checkpointName = checkpointName; 45 } 46 47 50 public boolean belongToTransaction(long tid) 51 { 52 return false; 53 } 54 55 58 public void execute(LoggerThread loggerThread) 59 { 60 61 try 62 { 63 loggerThread.removeCheckpoint(checkpointName); 64 } 65 catch (SQLException e) 66 { 67 loggerThread.putBackAtHeadOfQueue(this, e); 70 } 71 72 synchronized (this) 74 { 75 notify(); 76 } 77 } 78 79 82 public String toString() 83 { 84 return "RemoveCheckpointEvent for checkpoint " + checkpointName; 85 } 86 87 } 88 | Popular Tags |