Menu
▾
▴
[Bigdata-commit] SF.net SVN: bigdata:[8128] branches/RDR/bigdata/src/java/com/bigdata/ journal
|
From: <tho...@us...> - 2014-04-21 14:29:37
|
Revision: 8128
http://sourceforge.net/p/bigdata/code/8128
Author: thompsonbry
Date: 2014-04-21 14:29:33 +0000 (Mon, 21 Apr 2014)
Log Message:
-----------
@Override tags.
Modified Paths:
--------------
branches/RDR/bigdata/src/java/com/bigdata/journal/AbstractJournal.java
branches/RDR/bigdata/src/java/com/bigdata/journal/Journal.java
Modified: branches/RDR/bigdata/src/java/com/bigdata/journal/AbstractJournal.java
===================================================================
--- branches/RDR/bigdata/src/java/com/bigdata/journal/AbstractJournal.java 2014-04-19 00:57:07 UTC (rev 8127)
+++ branches/RDR/bigdata/src/java/com/bigdata/journal/AbstractJournal.java 2014-04-21 14:29:33 UTC (rev 8128)
@@ -2247,6 +2247,7 @@
/**
* Invokes {@link #shutdownNow()}.
*/
+ @Override
synchronized public void close() {
// Note: per contract for close().
@@ -2260,6 +2261,7 @@
}
+ @Override
synchronized public void destroy() {
if (log.isInfoEnabled())
@@ -2324,6 +2326,7 @@
* journal until the quorum has met and {@link #init()} has been invoked for
* the {@link Quorum}.
*/
+ @Override
public boolean isOpen() {
return _bufferStrategy != null && _bufferStrategy.isOpen();
@@ -2335,6 +2338,7 @@
* if {@link #closeForWrites(long)} was used to seal the journal against
* further writes.
*/
+ @Override
public boolean isReadOnly() {
if (readOnly) {
@@ -2443,12 +2447,14 @@
}
+ @Override
public boolean isStable() {
return _bufferStrategy.isStable();
}
+ @Override
public boolean isFullyBuffered() {
return _bufferStrategy.isFullyBuffered();
@@ -2497,6 +2503,7 @@
* through a concurrent {@link #abort()} or {@link #commitNow(long)}. The
* {@link IRootBlockView} itself is an immutable data structure.
*/
+ @Override
final public IRootBlockView getRootBlockView() {
// final ReadLock lock = _fieldReadWriteLock.readLock();
@@ -2564,6 +2571,7 @@
}
+ @Override
final public long getLastCommitTime() {
// final ReadLock lock = _fieldReadWriteLock.readLock();
@@ -2597,6 +2605,7 @@
* @param committer
* The commiter.
*/
+ @Override
final public void setCommitter(final int rootSlot, final ICommitter committer) {
assertOpen();
Modified: branches/RDR/bigdata/src/java/com/bigdata/journal/Journal.java
===================================================================
--- branches/RDR/bigdata/src/java/com/bigdata/journal/Journal.java 2014-04-19 00:57:07 UTC (rev 8127)
+++ branches/RDR/bigdata/src/java/com/bigdata/journal/Journal.java 2014-04-21 14:29:33 UTC (rev 8128)
@@ -3147,6 +3147,7 @@
* {@link #executorService}, then the {@link IConcurrencyManager}, the
* {@link ITransactionService} and finally the {@link IResourceLockService}.
*/
+ @Override
synchronized public void shutdown() {
if (!isOpen())
@@ -3227,6 +3228,7 @@
new ShutdownHelper(executorService, 1000/* logTimeout */,
TimeUnit.MILLISECONDS) {
+ @Override
protected void logTimeout() {
log.warn("Waiting on task(s)"
@@ -3266,6 +3268,7 @@
* Note: The {@link IConcurrencyManager} is shutdown first, then the
* {@link ITransactionService} and finally the {@link IResourceManager}.
*/
+ @Override
synchronized public void shutdownNow() {
if (!isOpen())
@@ -3373,12 +3376,14 @@
}
+ @Override
public <T> Future<T> submit(AbstractTask<T> task) {
return concurrencyManager.submit(task);
}
+ @Override
@SuppressWarnings("rawtypes")
public List<Future> invokeAll(
Collection<? extends AbstractTask> tasks, long timeout,
@@ -3388,6 +3393,7 @@
}
+ @Override
public <T> List<Future<T>> invokeAll(
Collection<? extends AbstractTask<T>> tasks)
throws InterruptedException {
@@ -3396,12 +3402,14 @@
}
+ @Override
public IResourceManager getResourceManager() {
return concurrencyManager.getResourceManager();
}
+ @Override
public ILocalTransactionManager getTransactionManager() {
// return concurrencyManager.getTransactionManager();
@@ -3416,6 +3424,7 @@
}
+ @Override
public WriteExecutorService getWriteService() {
return concurrencyManager.getWriteService();
@@ -3434,6 +3443,7 @@
* @return This implementation returns <code>false</code> since overflow
* is NOT supported.
*/
+ @Override
public boolean shouldOverflow() {
return false;
@@ -3443,12 +3453,14 @@
/**
* Note: This implementation always returns <code>false</code>.
*/
+ @Override
public boolean isOverflowEnabled() {
return false;
}
+ @Override
public Future<Object> overflow() {
throw new UnsupportedOperationException();
@@ -3476,6 +3488,7 @@
* @throws UnsupportedOperationException
* since {@link #overflow()} is not supported.
*/
+ @Override
public File getIndexSegmentFile(IndexMetadata indexMetadata) {
throw new UnsupportedOperationException();
@@ -3486,6 +3499,7 @@
* @throws UnsupportedOperationException
* always.
*/
+ @Override
public IBigdataFederation<?> getFederation() {
throw new UnsupportedOperationException();
@@ -3496,6 +3510,7 @@
* @throws UnsupportedOperationException
* always.
*/
+ @Override
public DataService getDataService() {
throw new UnsupportedOperationException();
@@ -3506,6 +3521,7 @@
* @throws UnsupportedOperationException
* always.
*/
+ @Override
public UUID getDataServiceUUID() {
throw new UnsupportedOperationException();
@@ -3516,6 +3532,7 @@
* Always returns <code>null</code> since index partition moves are not
* supported.
*/
+ @Override
public StaleLocatorReason getIndexPartitionGone(String name) {
return null;
@@ -3525,6 +3542,7 @@
/*
* global row store.
*/
+ @Override
public SparseRowStore getGlobalRowStore() {
return getGlobalRowStoreHelper().getGlobalRowStore();
@@ -3541,6 +3559,7 @@
// * @return The global row store view -or- <code>null</code> if no view
// * exists as of that timestamp.
// */
+ @Override
public SparseRowStore getGlobalRowStore(final long timestamp) {
return getGlobalRowStoreHelper().get(timestamp);
@@ -3591,6 +3610,7 @@
* Note: An atomic reference provides us with a "lock" object which doubles
* as a reference. We are not relying on its CAS properties.
*/
+ @Override
public BigdataFileSystem getGlobalFileSystem() {
GlobalFileSystemHelper t = globalFileSystemHelper.get();
@@ -3623,6 +3643,7 @@
}
final private AtomicReference<GlobalFileSystemHelper> globalFileSystemHelper = new AtomicReference<GlobalFileSystemHelper>();
+ @Override
protected void discardCommitters() {
super.discardCommitters();
@@ -3651,6 +3672,7 @@
}
+ @Override
public TemporaryStore getTempStore() {
return tempStoreFactory.getTempStore();
@@ -3658,6 +3680,7 @@
}
private final TemporaryStoreFactory tempStoreFactory;
+ @Override
public IResourceLocator<?> getResourceLocator() {
assertOpen();
@@ -3667,6 +3690,7 @@
}
private final IResourceLocator<?> resourceLocator;
+ @Override
public IResourceLockService getResourceLockService() {
assertOpen();
@@ -3676,6 +3700,7 @@
}
private final ResourceLockService resourceLockManager;
+ @Override
public ExecutorService getExecutorService() {
assertOpen();
@@ -3785,6 +3810,7 @@
private StartDeferredTasksTask() {
}
+ @Override
public void run() {
try {
@@ -3875,6 +3901,7 @@
} // class StartDeferredTasks
+ @Override
public ScheduledFuture<?> addScheduledTask(final Runnable task,
final long initialDelay, final long delay, final TimeUnit unit) {
@@ -3896,6 +3923,7 @@
*
* @see Options#COLLECT_PLATFORM_STATISTICS
*/
+ @Override
final public boolean getCollectPlatformStatistics() {
return Boolean.valueOf(properties.getProperty(
Options.COLLECT_PLATFORM_STATISTICS,
@@ -3907,6 +3935,7 @@
*
* @see Options#COLLECT_QUEUE_STATISTICS
*/
+ @Override
final public boolean getCollectQueueStatistics() {
return Boolean.valueOf(properties.getProperty(
Options.COLLECT_QUEUE_STATISTICS,
@@ -3918,6 +3947,7 @@
*
* @see Options#HTTPD_PORT
*/
+ @Override
final public int getHttpdPort() {
return Integer.valueOf(properties.getProperty(Options.HTTPD_PORT,
Options.DEFAULT_HTTPD_PORT));
@@ -3941,6 +3971,7 @@
*/
final private ConcurrentHashMap<String/* name */, BTreeCounters> indexCounters = new ConcurrentHashMap<String, BTreeCounters>();
+ @Override
public BTreeCounters getIndexCounters(final String name) {
if (name == null)
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
