add syn on checkpoint

cat-consumer/src/main/java/com/dianping/cat/consumer/cross/CrossAnalyzer.java

@@ -64,7 +64,7 @@ public class CrossAnalyzer extends AbstractMessageAnalyzer<CrossReport> implemen
 	}
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 

cat-consumer/src/main/java/com/dianping/cat/consumer/dependency/DependencyAnalyzer.java

@@ -36,7 +36,7 @@ public class DependencyAnalyzer extends AbstractMessageAnalyzer<DependencyReport
 	private Set<String> m_exceptions = new HashSet<String>(Arrays.asList("Exception", "RuntimeException", "Error"));
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 		} else {

cat-consumer/src/main/java/com/dianping/cat/consumer/dump/DumpAnalyzer.java

@@ -54,7 +54,7 @@ public class DumpAnalyzer extends AbstractMessageAnalyzer<Object> implements Log
 	}
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		try {
 			long startTime = getStartTime();
 

cat-consumer/src/main/java/com/dianping/cat/consumer/event/EventAnalyzer.java

@@ -28,7 +28,7 @@ public class EventAnalyzer extends AbstractMessageAnalyzer<EventReport> implemen
 	private ReportManager<EventReport> m_reportManager;
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 		} else {

cat-consumer/src/main/java/com/dianping/cat/consumer/heartbeat/HeartbeatAnalyzer.java

@@ -138,7 +138,7 @@ public class HeartbeatAnalyzer extends AbstractMessageAnalyzer<HeartbeatReport>
 	}
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 		} else {

cat-consumer/src/main/java/com/dianping/cat/consumer/matrix/MatrixAnalyzer.java

@@ -26,7 +26,7 @@ public class MatrixAnalyzer extends AbstractMessageAnalyzer<MatrixReport> implem
 	private ReportManager<MatrixReport> m_reportManager;
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 		} else {

cat-consumer/src/main/java/com/dianping/cat/consumer/metric/MetricAnalyzer.java

@@ -56,7 +56,7 @@ public class MetricAnalyzer extends AbstractMessageAnalyzer<MetricReport> implem
 	private static final String METRIC = "Metric";
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		storeReports(atEnd);
 	}
 

cat-consumer/src/main/java/com/dianping/cat/consumer/problem/ProblemAnalyzer.java

@@ -26,7 +26,7 @@ public class ProblemAnalyzer extends AbstractMessageAnalyzer<ProblemReport> impl
 	private List<ProblemHandler> m_handlers;
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 		} else {

cat-consumer/src/main/java/com/dianping/cat/consumer/state/StateAnalyzer.java

@@ -135,7 +135,7 @@ public class StateAnalyzer extends AbstractMessageAnalyzer<StateReport> implemen
 	}
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		long startTime = getStartTime();
 		StateReport stateReport = getReport(Constants.CAT);
 		Map<String, StateReport> reports = m_reportManager.getHourlyReports(startTime);

cat-consumer/src/main/java/com/dianping/cat/consumer/storage/StorageAnalyzer.java

@@ -38,7 +38,7 @@ public class StorageAnalyzer extends AbstractMessageAnalyzer<StorageReport> impl
 	private static final long LONG_CACHE_THRESHOLD = 50;
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 			m_databaseParser.showErrorCon();

cat-consumer/src/main/java/com/dianping/cat/consumer/top/TopAnalyzer.java

@@ -40,7 +40,7 @@ public class TopAnalyzer extends AbstractMessageAnalyzer<TopReport> implements L
 	private ProblemAnalyzer m_problemAnalyzer;
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		long startTime = getStartTime();
 
 		if (atEnd && !isLocalMode()) {

cat-consumer/src/main/java/com/dianping/cat/consumer/transaction/TransactionAnalyzer.java

@@ -80,7 +80,7 @@ public class TransactionAnalyzer extends AbstractMessageAnalyzer<TransactionRepo
 	}
 
 	@Override
-	public void doCheckpoint(boolean atEnd) {
+	public synchronized void doCheckpoint(boolean atEnd) {
 		if (atEnd && !isLocalMode()) {
 			m_reportManager.storeHourlyReports(getStartTime(), StoragePolicy.FILE_AND_DB);
 		} else {

cat-core/src/main/java/com/dianping/cat/service/DefaultReportManager.java

@@ -281,9 +281,7 @@ public class DefaultReportManager<T> implements ReportManager<T>, LogEnabled {
 			t.setStatus(e);
 			m_logger.error(String.format("Error when storing %s reports of %s!", m_name, new Date(startTime)), e);
 		} finally {
-			if (policy.forDatabase()) {
-				cleanup(startTime);
-			}
+			cleanup(startTime);
 			t.complete();
 
 			if (bucket != null) {