From: <tho...@us...> - 2013-10-11 15:21:47
|
Revision: 7451 http://bigdata.svn.sourceforge.net/bigdata/?rev=7451&view=rev Author: thompsonbry Date: 2013-10-11 15:21:41 +0000 (Fri, 11 Oct 2013) Log Message: ----------- javadoc Modified Paths: -------------- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java Modified: branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java =================================================================== --- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2013-10-11 15:20:47 UTC (rev 7450) +++ branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2013-10-11 15:21:41 UTC (rev 7451) @@ -1919,6 +1919,7 @@ } catch (RuntimeException re) { if (InnerCause.isInnerCause(re, KeeperException.class)) { + // Do not retry in a tight loop. Thread.sleep(250/* ms */); // Retry. continue; This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |
From: <tho...@us...> - 2013-12-13 21:01:13
|
Revision: 7647 http://bigdata.svn.sourceforge.net/bigdata/?rev=7647&view=rev Author: thompsonbry Date: 2013-12-13 21:01:07 +0000 (Fri, 13 Dec 2013) Log Message: ----------- comment on purgeLogs() Modified Paths: -------------- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java Modified: branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java =================================================================== --- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2013-12-13 20:55:50 UTC (rev 7646) +++ branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2013-12-13 21:01:07 UTC (rev 7647) @@ -4181,7 +4181,10 @@ * Halt operation. * * Note: This is not an error, but we can not remove - * snapshots or HALogs if this invariant is violated. + * snapshots or HALogs if this invariant is violated. This + * is because a leader fail could then cause the + * IRestorePolicy to be violated if a service that lacked + * some HALogs was elected as the leader. */ return; } This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |
From: <tho...@us...> - 2013-12-13 21:05:16
|
Revision: 7648 http://bigdata.svn.sourceforge.net/bigdata/?rev=7648&view=rev Author: thompsonbry Date: 2013-12-13 21:05:10 +0000 (Fri, 13 Dec 2013) Log Message: ----------- comment on purgeHA() Modified Paths: -------------- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java Modified: branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java =================================================================== --- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2013-12-13 21:01:07 UTC (rev 7647) +++ branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2013-12-13 21:05:10 UTC (rev 7648) @@ -4181,10 +4181,17 @@ * Halt operation. * * Note: This is not an error, but we can not remove - * snapshots or HALogs if this invariant is violated. This - * is because a leader fail could then cause the - * IRestorePolicy to be violated if a service that lacked - * some HALogs was elected as the leader. + * snapshots or HALogs if this invariant is violated. + * + * Note: We do not permit HALog files to be purged if the + * quorum is not fully met. This is done in order to prevent + * a situation a leader would not have sufficient log files + * on hand to restore the failed service. If this were to + * occur, then the failed service would have to undergo a + * disaster rebuild rather than simply resynchronizing from + * the leader. Hence, HALog files are NOT purged unless the + * quorum is fully met (all services for its replication + * count are joined with the met quorum). */ return; } This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |
From: <tho...@us...> - 2014-05-17 16:04:37
|
Revision: 8350 http://sourceforge.net/p/bigdata/code/8350 Author: thompsonbry Date: 2014-05-17 16:04:33 +0000 (Sat, 17 May 2014) Log Message: ----------- Removed import. Suppressed warning. Modified Paths: -------------- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java Modified: branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java =================================================================== --- branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2014-05-16 19:05:43 UTC (rev 8349) +++ branches/BIGDATA_RELEASE_1_3_0/bigdata-jini/src/java/com/bigdata/journal/jini/ha/HAJournalServer.java 2014-05-17 16:04:33 UTC (rev 8350) @@ -104,7 +104,6 @@ import com.bigdata.rdf.sail.webapp.ConfigParams; import com.bigdata.rdf.sail.webapp.HALoadBalancerServlet; import com.bigdata.rdf.sail.webapp.NanoSparqlServer; -import com.bigdata.rdf.sail.webapp.NanoSparqlServer.SystemProperties; import com.bigdata.rdf.sail.webapp.lbs.IHALoadBalancerPolicy; import com.bigdata.rwstore.RWStore; import com.bigdata.service.AbstractHATransactionService; @@ -752,6 +751,7 @@ /* * Zookeeper quorum. */ + @SuppressWarnings({ "unchecked", "rawtypes" }) final Quorum<HAGlue, QuorumService<HAGlue>> quorum = (Quorum) new ZKQuorumImpl<HAGlue, HAQuorumService<HAGlue, HAJournal>>( replicationFactor); This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |