This is an automated email from the ASF dual-hosted git repository. prhomberg pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push: new f280247 GEODE-4954, GEODE-4955: Remove trivial javadoc stubs and empty blocks: geode-core:internal (#1784) f280247 is described below commit f280247a5dbbc3a1f26a581e35b7f7d8091b4bf3 Author: Patrick Rhomberg <prhomb...@pivotal.io> AuthorDate: Fri Apr 13 13:07:48 2018 -0700 GEODE-4954, GEODE-4955: Remove trivial javadoc stubs and empty blocks: geode-core:internal (#1784) --- .../org/apache/geode/internal/AvailablePort.java | 1 - .../apache/geode/internal/HeapDataOutputStream.java | 2 -- .../org/apache/geode/internal/HistogramStats.java | 2 -- .../apache/geode/internal/InternalInstantiator.java | 4 ---- .../ScheduledThreadPoolExecutorWithKeepAlive.java | 4 ---- .../java/org/apache/geode/internal/Sendable.java | 1 - .../java/org/apache/geode/internal/SystemAdmin.java | 1 - .../main/java/org/apache/geode/internal/Version.java | 1 - .../geode/internal/admin/StatAlertsManager.java | 1 - .../admin/remote/AddStatListenerRequest.java | 1 - .../internal/admin/remote/CacheInfoRequest.java | 1 - .../geode/internal/admin/remote/CompactResponse.java | 3 --- .../internal/admin/remote/DistributionLocatorId.java | 1 - .../admin/remote/DurableClientInfoRequest.java | 1 - .../admin/remote/FetchDistLockInfoRequest.java | 1 - .../internal/admin/remote/LicenseInfoRequest.java | 1 - .../internal/admin/remote/ObjectDetailsRequest.java | 1 - .../internal/admin/remote/ObjectNamesRequest.java | 1 - .../admin/remote/RegionAttributesRequest.java | 1 - .../geode/internal/admin/remote/RegionRequest.java | 1 - .../internal/admin/remote/RegionSizeRequest.java | 1 - .../admin/remote/ResetHealthStatusRequest.java | 1 - .../admin/remote/RevokePersistentIDResponse.java | 3 --- .../internal/admin/remote/ShutdownAllResponse.java | 3 --- .../internal/admin/remote/StatListenerMessage.java | 1 - .../internal/admin/remote/SubRegionRequest.java | 1 - .../internal/admin/remote/VersionInfoRequest.java | 1 - .../internal/admin/statalerts/BaseDecoratorImpl.java | 3 --- .../admin/statalerts/DummyStatisticInfoImpl.java | 4 ---- .../statalerts/GaugeThresholdDecoratorImpl.java | 3 --- .../admin/statalerts/MultiAttrDefinitionImpl.java | 3 --- .../admin/statalerts/SingleAttrDefinitionImpl.java | 3 --- .../internal/admin/statalerts/StatisticInfoImpl.java | 4 ---- .../org/apache/geode/internal/concurrent/AL.java | 1 - .../internal/datasource/AbstractDataSource.java | 20 -------------------- .../geode/internal/datasource/AbstractPoolCache.java | 9 +-------- .../datasource/ConfiguredDataSourceProperties.java | 15 --------------- .../internal/datasource/ConnectionPoolCache.java | 1 - .../internal/datasource/ConnectionPoolCacheImpl.java | 1 - .../datasource/ConnectionProviderException.java | 3 --- .../datasource/DataSourceCreateException.java | 3 --- .../geode/internal/datasource/DataSourceFactory.java | 7 ------- .../internal/datasource/DataSourceResources.java | 2 -- .../datasource/FacetsJCAConnectionManagerImpl.java | 1 - .../internal/datasource/GemFireBasicDataSource.java | 6 ------ .../datasource/GemFireConnPooledDataSource.java | 7 ------- .../datasource/GemFireConnectionPoolManager.java | 4 ---- .../datasource/GemFireTransactionDataSource.java | 10 ---------- .../datasource/JCAConnectionManagerImpl.java | 1 - .../internal/datasource/ManagedPoolCacheImpl.java | 3 --- .../geode/internal/datasource/PoolException.java | 3 --- .../internal/datasource/TranxPoolCacheImpl.java | 5 ----- .../apache/geode/internal/hll/HyperLogLogPlus.java | 4 ---- .../org/apache/geode/internal/hll/ICardinality.java | 1 - .../internal/jndi/InitialContextFactoryImpl.java | 1 - .../org/apache/geode/internal/jndi/JNDIInvoker.java | 2 -- .../apache/geode/internal/jta/GlobalTransaction.java | 2 -- .../apache/geode/internal/jta/TransactionUtils.java | 2 -- .../geode/internal/logging/LoggingThreadGroup.java | 1 - .../geode/internal/memcached/CommandProcessor.java | 6 ------ .../geode/internal/memcached/ValueWrapper.java | 1 - .../internal/memcached/commands/AddQCommand.java | 4 ---- .../internal/memcached/commands/AppendQCommand.java | 3 --- .../memcached/commands/DecrementQCommand.java | 3 --- .../internal/memcached/commands/DeleteQCommand.java | 3 --- .../memcached/commands/FlushAllQCommand.java | 3 --- .../internal/memcached/commands/GATCommand.java | 3 --- .../internal/memcached/commands/GATQCommand.java | 3 --- .../internal/memcached/commands/GetKCommand.java | 3 --- .../internal/memcached/commands/GetKQCommand.java | 4 ---- .../memcached/commands/IncrementQCommand.java | 3 --- .../internal/memcached/commands/NoOpCommand.java | 3 --- .../memcached/commands/NotSupportedCommand.java | 3 --- .../internal/memcached/commands/PrependQCommand.java | 3 --- .../internal/memcached/commands/QuitQCommand.java | 3 --- .../internal/memcached/commands/ReplaceQCommand.java | 3 --- .../internal/memcached/commands/SetQCommand.java | 4 ---- .../internal/memcached/commands/StorageCommand.java | 5 ----- .../internal/memcached/commands/TouchCommand.java | 3 --- .../org/apache/geode/internal/net/SocketCreator.java | 11 ----------- .../geode/internal/net/SocketCreatorFactory.java | 5 ----- .../apache/geode/internal/offheap/StoredObject.java | 2 -- .../apache/geode/internal/sequencelog/GraphType.java | 3 --- .../geode/internal/sequencelog/MembershipLogger.java | 3 --- .../geode/internal/sequencelog/MessageLogger.java | 3 --- .../geode/internal/sequencelog/RegionLogger.java | 2 -- .../internal/sequencelog/SequenceLoggerImpl.java | 3 --- .../geode/internal/sequencelog/Transition.java | 3 --- .../apache/geode/internal/sequencelog/io/Filter.java | 3 --- .../internal/sequencelog/io/GemfireLogConverter.java | 7 ------- .../geode/internal/sequencelog/io/GraphReader.java | 3 --- .../internal/sequencelog/io/InputStreamReader.java | 3 --- .../geode/internal/sequencelog/model/Graph.java | 5 ----- .../geode/internal/sequencelog/model/GraphID.java | 3 --- .../sequencelog/model/GraphReaderCallback.java | 3 --- .../geode/internal/sequencelog/model/GraphSet.java | 3 --- .../geode/internal/sequencelog/model/Vertex.java | 3 --- .../sequencelog/visualization/text/TextDisplay.java | 7 ------- .../apache/geode/internal/shared/NativeCalls.java | 1 - .../geode/internal/shared/NativeCallsJNAImpl.java | 1 - .../internal/size/CachingSingleObjectSizer.java | 3 --- .../apache/geode/internal/size/ObjectTraverser.java | 2 -- .../geode/internal/size/SingleObjectSizer.java | 1 - .../internal/statistics/StatArchiveHandler.java | 7 ------- .../java/org/apache/geode/internal/tcp/Buffers.java | 3 --- .../apache/geode/internal/tcp/ConnectionTable.java | 5 ----- .../org/apache/geode/internal/tcp/MsgReader.java | 3 --- .../org/apache/geode/internal/tcp/MsgStreamer.java | 3 --- .../org/apache/geode/internal/util/LogFileUtils.java | 3 --- .../geode/internal/util/VersionedArrayList.java | 9 --------- .../internal/util/concurrent/ReentrantSemaphore.java | 3 --- .../util/concurrent/StoppableCountDownLatch.java | 3 --- .../util/concurrent/StoppableReentrantLock.java | 4 ---- .../concurrent/StoppableReentrantReadWriteLock.java | 11 ----------- 114 files changed, 1 insertion(+), 378 deletions(-) diff --git a/geode-core/src/main/java/org/apache/geode/internal/AvailablePort.java b/geode-core/src/main/java/org/apache/geode/internal/AvailablePort.java index 94bc569..1caf3e5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/AvailablePort.java +++ b/geode-core/src/main/java/org/apache/geode/internal/AvailablePort.java @@ -233,7 +233,6 @@ public class AvailablePort { /** * Test to see if a given port is available port on all interfaces on this host. * - * @param port * @return true of if the port is free on all interfaces */ private static boolean testAllInterfaces(int port) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java b/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java index 6ea37e2..6f3346b 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java +++ b/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java @@ -136,7 +136,6 @@ public class HeapDataOutputStream extends OutputStream * Construct a HeapDataOutputStream which uses the byte array provided as its underlying * ByteBuffer * - * @param bytes */ public HeapDataOutputStream(byte[] bytes) { int len = bytes.length; @@ -463,7 +462,6 @@ public class HeapDataOutputStream extends OutputStream * wrapper. However the filled byte array may or may not be the same as that used for seeding , * depending upon whether the data got accommodated in the original byte buffer or not. * - * @param wrapper */ // Asif public void sendTo(BytesAndBitsForCompactor wrapper, byte userBits) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/HistogramStats.java b/geode-core/src/main/java/org/apache/geode/internal/HistogramStats.java index 16c9978..c99833d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/HistogramStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/HistogramStats.java @@ -36,9 +36,7 @@ public class HistogramStats { * * @param name a unique name for the histogram type * @param unit the unit of data collected - * @param factory * @param breakPoints the breakpoints for each bucket - * @param largerIsBetter */ public HistogramStats(String name, String unit, StatisticsFactory factory, long[] breakPoints, boolean largerIsBetter) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java b/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java index 2731ed5..86f5283 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java @@ -102,8 +102,6 @@ public class InternalInstantiator { /** * Actually registers an {@code Instantiator} with the data serialization framework. * - * @param instantiator - * @param distribute * @throws IllegalArgumentException If the instantiator has an id of zero * @throws IllegalStateException The instantiator cannot be registered */ @@ -216,7 +214,6 @@ public class InternalInstantiator { /** * Sends Instantiator registration message to one of the servers * - * @param instantiator */ private static void sendRegistrationMessageToServers(Instantiator instantiator) { PoolManagerImpl.allPoolsRegisterInstantiator(instantiator); @@ -225,7 +222,6 @@ public class InternalInstantiator { /** * Sends Instantiator registration message to one of the servers * - * @param holder */ private static void sendRegistrationMessageToServers(InstantiatorAttributesHolder holder) { PoolManagerImpl.allPoolsRegisterInstantiator(holder); diff --git a/geode-core/src/main/java/org/apache/geode/internal/ScheduledThreadPoolExecutorWithKeepAlive.java b/geode-core/src/main/java/org/apache/geode/internal/ScheduledThreadPoolExecutorWithKeepAlive.java index 9ca3dce..9902374 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/ScheduledThreadPoolExecutorWithKeepAlive.java +++ b/geode-core/src/main/java/org/apache/geode/internal/ScheduledThreadPoolExecutorWithKeepAlive.java @@ -46,10 +46,6 @@ public class ScheduledThreadPoolExecutorWithKeepAlive extends ThreadPoolExecutor private final ScheduledThreadPoolExecutor timer; - /** - * @param corePoolSize - * @param threadFactory - */ public ScheduledThreadPoolExecutorWithKeepAlive(int corePoolSize, long keepAlive, TimeUnit timeUnit, ThreadFactory threadFactory) { super(0, corePoolSize - 1, keepAlive, timeUnit, new SynchronousQueue(), threadFactory, diff --git a/geode-core/src/main/java/org/apache/geode/internal/Sendable.java b/geode-core/src/main/java/org/apache/geode/internal/Sendable.java index 2dc0dc3..a361fb2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/Sendable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/Sendable.java @@ -31,7 +31,6 @@ public interface Sendable { * called. * * @param out the data output to send this object to - * @throws IOException */ void sendTo(DataOutput out) throws IOException; } diff --git a/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java b/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java index 336320e..c35b297 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java +++ b/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java @@ -557,7 +557,6 @@ public class SystemAdmin { * this is a test hook to allow us to drive SystemAdmin functions without invoking main(), which * can call System.exit(). * - * @param props */ public static void setDistributedSystemProperties(Properties props) { propertyOption = props; diff --git a/geode-core/src/main/java/org/apache/geode/internal/Version.java b/geode-core/src/main/java/org/apache/geode/internal/Version.java index f7a01e7..3d7e4dc 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/Version.java +++ b/geode-core/src/main/java/org/apache/geode/internal/Version.java @@ -272,7 +272,6 @@ public class Version implements Comparable<Version> { /** * return the version corresponding to the given ordinal, or CURRENT if the ordinal isn't valid * - * @param ordinal * @return the corresponding ordinal */ public static Version fromOrdinalOrCurrent(short ordinal) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/StatAlertsManager.java b/geode-core/src/main/java/org/apache/geode/internal/admin/StatAlertsManager.java index f2e804a..d127766 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/StatAlertsManager.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/StatAlertsManager.java @@ -218,7 +218,6 @@ public class StatAlertsManager { * * TODO never called * - * @param refreshAtFixedRate */ public synchronized void setRefreshAtFixedRate(boolean refreshAtFixedRate) { this.refreshAtFixedRate = refreshAtFixedRate; diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java index 36e9deb..df6b5d0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java @@ -48,7 +48,6 @@ public class AddStatListenerRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CacheInfoRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CacheInfoRequest.java index 200e18e..c7cbad8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CacheInfoRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CacheInfoRequest.java @@ -43,7 +43,6 @@ public class CacheInfoRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CompactResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CompactResponse.java index 23f76a9..5bf2cb1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CompactResponse.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/CompactResponse.java @@ -23,9 +23,6 @@ import org.apache.geode.DataSerializer; import org.apache.geode.cache.persistence.PersistentID; import org.apache.geode.distributed.internal.membership.InternalDistributedMember; -/** - * - */ public class CompactResponse extends AdminResponse { private HashSet<PersistentID> persistentIds; diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DistributionLocatorId.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DistributionLocatorId.java index 39c6095..c915bfb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DistributionLocatorId.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DistributionLocatorId.java @@ -362,7 +362,6 @@ public class DistributionLocatorId implements java.io.Serializable { * * @param locators collection of Locator instances * @return collection of DistributionLocatorId instances - * @throws UnknownHostException * @see Locator */ public static Collection<DistributionLocatorId> asDistributionLocatorIds( diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DurableClientInfoRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DurableClientInfoRequest.java index c8610f9..9efb070 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DurableClientInfoRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/DurableClientInfoRequest.java @@ -56,7 +56,6 @@ public class DurableClientInfoRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ protected AdminResponse createResponse(DistributionManager dm) { return DurableClientInfoResponse.create(dm, this.getSender(), this); diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/FetchDistLockInfoRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/FetchDistLockInfoRequest.java index cfafbfc..51aa248 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/FetchDistLockInfoRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/FetchDistLockInfoRequest.java @@ -38,7 +38,6 @@ public class FetchDistLockInfoRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/LicenseInfoRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/LicenseInfoRequest.java index 71262a4..2184562 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/LicenseInfoRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/LicenseInfoRequest.java @@ -41,7 +41,6 @@ public class LicenseInfoRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectDetailsRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectDetailsRequest.java index b688557..cb0e6c5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectDetailsRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectDetailsRequest.java @@ -57,7 +57,6 @@ public class ObjectDetailsRequest extends RegionAdminRequest implements Cancella /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectNamesRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectNamesRequest.java index 619b74f..4aa563d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectNamesRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ObjectNamesRequest.java @@ -45,7 +45,6 @@ public class ObjectNamesRequest extends RegionAdminRequest implements Cancellabl /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionAttributesRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionAttributesRequest.java index 624f40e..1c500a0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionAttributesRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionAttributesRequest.java @@ -43,7 +43,6 @@ public class RegionAttributesRequest extends RegionAdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionRequest.java index cf4ed95..1ba3013 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionRequest.java @@ -112,7 +112,6 @@ public class RegionRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionSizeRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionSizeRequest.java index 5e6f698..ed042c3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionSizeRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RegionSizeRequest.java @@ -41,7 +41,6 @@ public class RegionSizeRequest extends RegionAdminRequest implements Cancellable /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ResetHealthStatusRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ResetHealthStatusRequest.java index a1ca6a5..11a0873 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ResetHealthStatusRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ResetHealthStatusRequest.java @@ -47,7 +47,6 @@ public class ResetHealthStatusRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RevokePersistentIDResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RevokePersistentIDResponse.java index 90b03f4..7cd4eeb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RevokePersistentIDResponse.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/RevokePersistentIDResponse.java @@ -16,9 +16,6 @@ package org.apache.geode.internal.admin.remote; import org.apache.geode.distributed.internal.membership.InternalDistributedMember; -/** - * - */ public class RevokePersistentIDResponse extends AdminResponse { public RevokePersistentIDResponse() {} diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ShutdownAllResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ShutdownAllResponse.java index 85aaba3..adf1c72 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ShutdownAllResponse.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/ShutdownAllResponse.java @@ -20,9 +20,6 @@ import java.io.IOException; import org.apache.geode.distributed.internal.membership.InternalDistributedMember; -/** - * - */ public class ShutdownAllResponse extends AdminResponse { private transient boolean isToShutDown = true; diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/StatListenerMessage.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/StatListenerMessage.java index 82af97f..47391a0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/StatListenerMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/StatListenerMessage.java @@ -50,7 +50,6 @@ public class StatListenerMessage extends PooledDistributionMessage implements Ad /** * Notes that the value of a given statistics has changed * - * @param listenerId * */ public void addChange(int listenerId, double value) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/SubRegionRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/SubRegionRequest.java index 8233b1d..34abc38 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/SubRegionRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/SubRegionRequest.java @@ -43,7 +43,6 @@ public class SubRegionRequest extends RegionAdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoRequest.java index 22cd57c..b24ec2f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoRequest.java @@ -43,7 +43,6 @@ public class VersionInfoRequest extends AdminRequest { /** * Must return a proper response to this request. * - * @param dm */ @Override protected AdminResponse createResponse(DistributionManager dm) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java index 35f3add..6cf290e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java @@ -40,9 +40,6 @@ public abstract class BaseDecoratorImpl implements StatAlertDefinition { super(); } - /** - * @param definition - */ public BaseDecoratorImpl(StatAlertDefinition definition) { super(); this._def = definition; diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java index 9e42283..0326563 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java @@ -44,10 +44,6 @@ public class DummyStatisticInfoImpl implements StatisticInfo { public DummyStatisticInfoImpl() {} - /** - * @param statisticsTextId - * @param statisticName - */ public DummyStatisticInfoImpl(String statisticsTypeName, String statisticsTextId, String statisticName) { super(); diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java index 83b7f49..db5ee5a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java @@ -40,9 +40,6 @@ public class GaugeThresholdDecoratorImpl extends BaseDecoratorImpl public GaugeThresholdDecoratorImpl() {} - /** - * @param definition - */ public GaugeThresholdDecoratorImpl(StatAlertDefinition definition, Number lowerLimit, Number upperLimit) { super(definition); diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java index 639bd06..36bf73a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java @@ -40,9 +40,6 @@ public class MultiAttrDefinitionImpl implements StatAlertDefinition { public MultiAttrDefinitionImpl() {} - /** - * @param statInfo - */ public MultiAttrDefinitionImpl(String name, StatisticInfo[] statInfo) { super(); setStatisticInfo(statInfo); diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java index baf0b19..59de3a2 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java @@ -40,9 +40,6 @@ public class SingleAttrDefinitionImpl implements StatAlertDefinition { public SingleAttrDefinitionImpl() {} - /** - * @param statisticInfo - */ public SingleAttrDefinitionImpl(String name, StatisticInfo statisticInfo) { super(); this.statisticInfo = statisticInfo; diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java index 1d6f986..23d5ce3 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java @@ -39,10 +39,6 @@ public class StatisticInfoImpl implements StatisticInfo { protected transient StatisticDescriptor descriptor; - /** - * @param statistics - * @param descriptor - */ public StatisticInfoImpl(Statistics statistics, StatisticDescriptor descriptor) { super(); this.statistics = statistics; diff --git a/geode-core/src/main/java/org/apache/geode/internal/concurrent/AL.java b/geode-core/src/main/java/org/apache/geode/internal/concurrent/AL.java index e8db99c..b44b2298 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/concurrent/AL.java +++ b/geode-core/src/main/java/org/apache/geode/internal/concurrent/AL.java @@ -117,7 +117,6 @@ public interface AL { * value. This could be sub-optimat when the update being done by multiple thread is not in in an * incremental fashion. * - * @param update */ boolean setIfGreater(long update); } diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractDataSource.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractDataSource.java index 32e6ae9..6d9149f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractDataSource.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractDataSource.java @@ -54,7 +54,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * * @param configs ConfiguredDataSourceProperties object containing all the data required to * construct the datasource object. - * @throws SQLException * */ public AbstractDataSource(ConfiguredDataSourceProperties configs) throws SQLException { @@ -71,7 +70,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * Behavior from the dataSource interface. This is an abstract function which will implemented in * the Datasource classes. * - * @throws SQLException * @return Connection Connection object for the Database connection. */ public abstract Connection getConnection() throws SQLException; @@ -82,7 +80,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * * @param username Username used for making database connection. * @param password Passowrd used for making database connection. - * @throws SQLException * @return ??? */ public abstract Connection getConnection(String username, String password) throws SQLException; @@ -91,7 +88,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { /** * Returns the writer for logging * - * @throws SQLException * @return PrintWriter for logs. */ public PrintWriter getLogWriter() throws SQLException { @@ -102,7 +98,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * Returns the amount of time that login will wait for the connection to happen before it gets * time out. * - * @throws SQLException * @return int login time out. */ public int getLoginTimeout() throws SQLException { @@ -113,7 +108,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * sets the log writer for the datasource. * * @param out PrintWriter for writing the logs. - * @throws SQLException */ public void setLogWriter(java.io.PrintWriter out) throws SQLException { dataSourcePW = out; @@ -123,7 +117,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * Sets the login time out for the database connection * * @param seconds login time out in seconds. - * @throws SQLException */ public void setLoginTimeout(int seconds) throws SQLException { loginTimeOut = seconds; @@ -134,10 +127,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { throw new SQLFeatureNotSupportedException(); } - /** - * @param conn - * @return boolean - */ protected boolean validateConnection(Connection conn) { try { return (!conn.isClosed()); @@ -154,7 +143,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { /** * Returns the default user for the database. * - * @return String */ public String getUser() { return user; @@ -163,7 +151,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { /** * Returns the default password for the database. * - * @return String */ public String getPassword() { return password; @@ -172,7 +159,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { /** * The name of the JDBC driver for the database. * - * @return String */ public String getJDBCDriver() { return jdbcDriver; @@ -182,7 +168,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { /** * Sets the default username for the database * - * @param usr */ public void setUser(String usr) { user = usr; @@ -200,7 +185,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { /** * Sets the JDBC driver name of the datasource * - * @param confDriver */ public void setJDBCDriver(String confDriver) { jdbcDriver = confDriver; @@ -211,7 +195,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { * * @param clUser The username for the database connection * @param clPass The password for the database connection - * @throws SQLException */ public void checkCredentials(String clUser, String clPass) throws SQLException { if (clUser == null || !clUser.equals(user) || clPass == null || !clPass.equals(password)) { @@ -222,9 +205,6 @@ public abstract class AbstractDataSource implements Serializable, DataSource { } } - /** - * - */ public void clearUp() { isActive = false; } diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractPoolCache.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractPoolCache.java index ff1ba43..dc03cf6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractPoolCache.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/AbstractPoolCache.java @@ -71,7 +71,6 @@ public abstract class AbstractPoolCache implements ConnectionPoolCache, Serializ * @param eventListner The event listner for the database connections. * @param configs The ConfiguredDataSourceProperties object containing the configuration for the * pool. - * @throws PoolException */ @edu.umd.cs.findbugs.annotations.SuppressWarnings(value = "SC_START_IN_CTOR", justification = "the thread started is a cleanup thread and is not active until there is a timeout tx") @@ -116,12 +115,10 @@ public abstract class AbstractPoolCache implements ConnectionPoolCache, Serializ * * @param user The username for the database connection * @param pass The password for the database connection - * @throws SQLException * - * public abstract void checkCredentials(String user, String pass) + * public abstract void checkCredentials(String user, String pass) */ /** - * @throws PoolException * @return ??? */ public abstract Object getNewPoolConnection() throws PoolException; @@ -173,7 +170,6 @@ public abstract class AbstractPoolCache implements ConnectionPoolCache, Serializ /** * Expires connection in the available pool. * - * @param connectionObject */ abstract void destroyPooledConnection(Object connectionObject); @@ -232,7 +228,6 @@ public abstract class AbstractPoolCache implements ConnectionPoolCache, Serializ * this iteslf guarantees that atleast one connection expired so the current thread can safely * demand one new connection. * - * @throws PoolException * @return Object connection object from the pool. */ public Object getPooledConnectionFromPool() throws PoolException { @@ -290,7 +285,6 @@ public abstract class AbstractPoolCache implements ConnectionPoolCache, Serializ /** * Returns the max pool limit. * - * @return int */ public int getMaxLimit() { return MAX_LIMIT; @@ -301,7 +295,6 @@ public abstract class AbstractPoolCache implements ConnectionPoolCache, Serializ * block where the lock is taken on this.availableCache * * @param now Current time in milliseconds - * @throws PoolException * @return Object Connection object from the pool. */ private Object checkOutConnection(long now) throws PoolException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConfiguredDataSourceProperties.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConfiguredDataSourceProperties.java index e036f39..2fff243 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConfiguredDataSourceProperties.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConfiguredDataSourceProperties.java @@ -135,7 +135,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Returns the class name for managed connection factory. * - * @return String */ public String getMCFClass() { return mcfClass; @@ -153,7 +152,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the login time * - * @param loginTime */ public void setLoginTimeOut(int loginTime) { if (loginTime > 0) @@ -163,7 +161,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the database user name . * - * @param usr */ public void setUser(String usr) { this.user = usr; @@ -172,7 +169,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the database user password . * - * @param passwd */ public void setPassword(String passwd) { this.password = passwd; @@ -181,7 +177,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the database driver name. * - * @param confDriver */ public void setJDBCDriver(String confDriver) { this.jdbcDriver = confDriver; @@ -190,7 +185,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the initiale pool size. * - * @param inpoolSize */ public void setInitialPoolSize(int inpoolSize) { if (inpoolSize >= 0) @@ -200,7 +194,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the maximum pool size * - * @param mxpoolSize */ public void setMaxPoolSize(int mxpoolSize) { if (mxpoolSize > 0) @@ -210,12 +203,10 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the max idle time * - * @param mxIdleTime */ /** * * Sets the db URL. * - * @param urlStr */ public void setURL(String urlStr) { url = urlStr; @@ -224,7 +215,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the connection expiration time * - * @param time */ public void setConnectionExpirationTime(int time) { if (time > 0) @@ -234,7 +224,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the connection time out. * - * @param time */ public void setConnectionTimeOut(int time) { if (time > 0) @@ -244,7 +233,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the ConnectionPoolDataSource class name * - * @param classname */ public void setConnectionPoolDSClass(String classname) { connPoolDSClass = classname; @@ -253,7 +241,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the XADatasource class name * - * @param classname */ public void setXADSClass(String classname) { xadsClass = classname; @@ -262,7 +249,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the log writer. * - * @param pw */ public void setPrintWriter(PrintWriter pw) { dataSourcePW = pw; @@ -271,7 +257,6 @@ public class ConfiguredDataSourceProperties implements Serializable { /** * Sets the MCFClass class name. * - * @param classname */ public void setMCFClass(String classname) { mcfClass = classname; diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCache.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCache.java index a599cac..296a3b2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCache.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCache.java @@ -25,7 +25,6 @@ public interface ConnectionPoolCache { * used for making the conections. * * @return Object - connection from the pool. - * @throws PoolException */ Object getPooledConnectionFromPool() throws PoolException; diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCacheImpl.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCacheImpl.java index c1539c7..67425fa 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCacheImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionPoolCacheImpl.java @@ -71,7 +71,6 @@ public class ConnectionPoolCacheImpl extends AbstractPoolCache { * Creates a new connection for the pool. * * @return the connection from the database as Object. - * @throws PoolException */ @Override public Object getNewPoolConnection() throws PoolException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionProviderException.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionProviderException.java index 24eb6f0..698d43f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionProviderException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/ConnectionProviderException.java @@ -35,9 +35,6 @@ public class ConnectionProviderException extends GemFireCheckedException { super(); } - /** - * @param message - */ public ConnectionProviderException(String message) { super(message); } diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceCreateException.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceCreateException.java index 743de21..675b6df 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceCreateException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceCreateException.java @@ -30,9 +30,6 @@ public class DataSourceCreateException extends GemFireCheckedException { super(); } - /** - * @param message - */ public DataSourceCreateException(String message) { super(message); } diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceFactory.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceFactory.java index a634af9..5f2d97c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceFactory.java @@ -59,7 +59,6 @@ public class DataSourceFactory { * This function returns the Basic datasource without any pooling. * * @param configMap a map containing configurations required for datasource. - * @throws DataSourceCreateException * @return ?? */ public static DataSource getSimpleDataSource(Map configMap) throws DataSourceCreateException { @@ -95,10 +94,7 @@ public class DataSourceFactory { * This function creats a data dource from the ManagedConnectionFactory class using the * connectionManager. * - * @param configMap - * @param props * @return javax.sql.DataSource - * @throws DataSourceCreateException */ public static ClientConnectionFactoryWrapper getManagedDataSource(Map configMap, List<ConfigProperty> props) throws DataSourceCreateException { @@ -151,7 +147,6 @@ public class DataSourceFactory { * This function returns the datasource with connection pooling. * * @param configMap a map containing configurations required for datasource. - * @throws DataSourceCreateException * @return ??? */ public static DataSource getPooledDataSource(Map configMap, List<ConfigProperty> props) @@ -186,7 +181,6 @@ public class DataSourceFactory { * capabilities. * * @param configMap a map containing configurations required for datasource. - * @throws DataSourceCreateException * @return ??? */ public static DataSource getTranxDataSource(Map configMap, List<ConfigProperty> props) @@ -226,7 +220,6 @@ public class DataSourceFactory { * Creates ConfiguredDataSourceProperties from map. * * @param configMap a map containing configurations required for datasource. - * @return ConfiguredDataSourceProperties */ private static ConfiguredDataSourceProperties createDataSourceProperties(Map configMap) { ConfiguredDataSourceProperties configs = new ConfiguredDataSourceProperties(); diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceResources.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceResources.java index 0a8d934..3f73ed5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceResources.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/DataSourceResources.java @@ -19,8 +19,6 @@ */ package org.apache.geode.internal.datasource; -/** - */ public interface DataSourceResources { /** Creates a new instance of DataSourceResources */ diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/FacetsJCAConnectionManagerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/FacetsJCAConnectionManagerImpl.java index 652c1a5..c219059 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/FacetsJCAConnectionManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/FacetsJCAConnectionManagerImpl.java @@ -92,7 +92,6 @@ public class FacetsJCAConnectionManagerImpl * * @param javax.resource.spi.ConnectionRequestInfo * - * @throws ResourceException */ public Object allocateConnection(ManagedConnectionFactory mcf, ConnectionRequestInfo reqInfo) throws ResourceException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireBasicDataSource.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireBasicDataSource.java index 5854d67..37f4db4 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireBasicDataSource.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireBasicDataSource.java @@ -45,8 +45,6 @@ public class GemFireBasicDataSource extends AbstractDataSource { * jdk 1.6 * * @param iface - a Class defining an interface. - * @throws SQLException - * @return boolean */ public boolean isWrapperFor(Class iface) throws SQLException { return true; @@ -57,7 +55,6 @@ public class GemFireBasicDataSource extends AbstractDataSource { * required by jdk 1.6 * * @param iface - a Class defining an interface. - * @throws SQLException * @return java.lang.Object */ public Object unwrap(Class iface) throws SQLException { @@ -68,7 +65,6 @@ public class GemFireBasicDataSource extends AbstractDataSource { * Creates a new instance of GemFireBasicDataSource * * @param configs The ConfiguredDataSourceProperties containing the datasource properties. - * @throws SQLException */ public GemFireBasicDataSource(ConfiguredDataSourceProperties configs) throws SQLException { super(configs); @@ -79,7 +75,6 @@ public class GemFireBasicDataSource extends AbstractDataSource { * Implementation of datasource interface function. This method is used to get the connection from * the database. Default user name and password will be used. * - * @throws SQLException * @return ??? */ @Override @@ -114,7 +109,6 @@ public class GemFireBasicDataSource extends AbstractDataSource { * * @param clUsername The username for the database connection. * @param clPassword The password for the database connection. - * @throws SQLException * @return ??? */ @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnPooledDataSource.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnPooledDataSource.java index a02a4f8..2b09ad1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnPooledDataSource.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnPooledDataSource.java @@ -48,7 +48,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource * * @param connPoolDS The ConnectionPoolDataSource object for the database driver. * @param configs The ConfiguredDataSourceProperties containing the datasource properties. - * @throws SQLException */ @@ -57,7 +56,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource * jdk 1.6 * * @param iface - a Class defining an interface. - * @throws SQLException */ public boolean isWrapperFor(Class iface) throws SQLException { return true; @@ -90,7 +88,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource * Implementation of datasource interface function. This method is used to get the connection from * the pool. Default user name and password will be used. * - * @throws SQLException * @return ??? */ @Override @@ -115,7 +112,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource * * @param clUsername The username for the database connection. * @param clPassword The password for the database connection. - * @throws SQLException * @return ??? */ @Override @@ -128,7 +124,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource * Implementation of call back function from ConnectionEventListener interface. This callback will * be invoked on connection close event. * - * @param event */ public void connectionClosed(ConnectionEvent event) { if (isActive) { @@ -148,7 +143,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource * Implementation of call back function from ConnectionEventListener interface. This callback will * be invoked on connection error event. * - * @param event */ public void connectionErrorOccurred(ConnectionEvent event) { if (isActive) { @@ -184,7 +178,6 @@ public class GemFireConnPooledDataSource extends AbstractDataSource /** * gets tha connection from the pool * - * @param poolC * @return ??? */ protected Connection getSQLConnection(PooledConnection poolC) throws SQLException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnectionPoolManager.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnectionPoolManager.java index cf2749f..46839fb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnectionPoolManager.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireConnectionPoolManager.java @@ -14,8 +14,6 @@ */ package org.apache.geode.internal.datasource; -/** - */ import java.io.Serializable; import javax.sql.*; @@ -66,7 +64,6 @@ public class GemFireConnectionPoolManager implements ConnectionProvider, Seriali /** * Returns the connection to the pool and the closes it. * - * @param connectionObject * */ public void returnAndExpireConnection(Object connectionObject) { @@ -81,7 +78,6 @@ public class GemFireConnectionPoolManager implements ConnectionProvider, Seriali /** * Return connection to pool * - * @param connectionObject */ public void returnConnection(Object connectionObject) { connPoolCache.returnPooledConnectionToPool(connectionObject); diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireTransactionDataSource.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireTransactionDataSource.java index e174af9..8f8f153 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireTransactionDataSource.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/GemFireTransactionDataSource.java @@ -57,8 +57,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource * jdk 1.6 * * @param iface - a Class defining an interface. - * @throws SQLException - * @return boolean */ public boolean isWrapperFor(Class iface) throws SQLException { return true; @@ -69,7 +67,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource * required by jdk 1.6 * * @param iface - a Class defining an interface. - * @throws SQLException * @return java.lang.Object */ @@ -82,7 +79,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource * * @param xaDS The XADataSource object for the database driver. * @param configs - The ConfiguredDataSourceProperties containing the datasource properties. - * @throws SQLException */ public GemFireTransactionDataSource(XADataSource xaDS, ConfiguredDataSourceProperties configs) throws SQLException { @@ -108,7 +104,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource * Implementation of datasource function. This method is used to get the connection from the pool. * Default user name and password will be used. * - * @throws SQLException * @return ??? */ @Override @@ -137,7 +132,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource * * @param clUsername The username for the database connection. * @param clPassword The password for the database connection. - * @throws SQLException * @return ??? */ @Override @@ -194,9 +188,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource } } - /** - * - */ void registerTranxConnection(XAConnection xaConn) throws Exception { try { synchronized (this) { @@ -223,7 +214,6 @@ public class GemFireTransactionDataSource extends AbstractDataSource /** * gets the connection from the pool * - * @param poolC * @return ??? */ protected Connection getSQLConnection(PooledConnection poolC) throws SQLException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/JCAConnectionManagerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/JCAConnectionManagerImpl.java index fab8516..c7c59cb 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/JCAConnectionManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/JCAConnectionManagerImpl.java @@ -81,7 +81,6 @@ public class JCAConnectionManagerImpl implements ConnectionManager, ConnectionEv * * @param javax.resource.spi.ConnectionRequestInfo * - * @throws ResourceException */ public Object allocateConnection(ManagedConnectionFactory mcf, ConnectionRequestInfo reqInfo) throws ResourceException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/ManagedPoolCacheImpl.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/ManagedPoolCacheImpl.java index f3cf49b..269d715 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/ManagedPoolCacheImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/ManagedPoolCacheImpl.java @@ -14,8 +14,6 @@ */ package org.apache.geode.internal.datasource; -/** - */ import javax.resource.ResourceException; import javax.resource.spi.ConnectionEventListener; import javax.resource.spi.ConnectionRequestInfo; @@ -59,7 +57,6 @@ public class ManagedPoolCacheImpl extends AbstractPoolCache { * Creates a new connection for the managed connection pool. * * @return the managed connection from the EIS as ManagedConnection object. - * @throws PoolException */ @Override public Object getNewPoolConnection() throws PoolException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/PoolException.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/PoolException.java index be3d0bd..49d4d42 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/PoolException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/PoolException.java @@ -30,9 +30,6 @@ public class PoolException extends GemFireCheckedException { super(); } - /** - * @param message - */ public PoolException(String message) { super(message); } diff --git a/geode-core/src/main/java/org/apache/geode/internal/datasource/TranxPoolCacheImpl.java b/geode-core/src/main/java/org/apache/geode/internal/datasource/TranxPoolCacheImpl.java index c577471..8b0dba6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/datasource/TranxPoolCacheImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/datasource/TranxPoolCacheImpl.java @@ -14,8 +14,6 @@ */ package org.apache.geode.internal.datasource; -/** - */ import java.sql.SQLException; import javax.sql.ConnectionEventListener; @@ -49,9 +47,6 @@ public class TranxPoolCacheImpl extends AbstractPoolCache { initializePool(); } - /** - * - */ @Override void destroyPooledConnection(Object connectionObject) { try { diff --git a/geode-core/src/main/java/org/apache/geode/internal/hll/HyperLogLogPlus.java b/geode-core/src/main/java/org/apache/geode/internal/hll/HyperLogLogPlus.java index 1160f0f..76f8516 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/hll/HyperLogLogPlus.java +++ b/geode-core/src/main/java/org/apache/geode/internal/hll/HyperLogLogPlus.java @@ -1253,7 +1253,6 @@ public class HyperLogLogPlus implements ICardinality, Serializable { * * @param k encoded data * @param p 'normal' precision - * @return index */ private int getIndex(int k, int p) { k = getSparseIndex(k); @@ -1266,7 +1265,6 @@ public class HyperLogLogPlus implements ICardinality, Serializable { * Has two procedures based on current mode. 'Normal' mode works similar to HLL but has some new * bias corrections. 'Sparse' mode is linear counting. * - * @return cardinality */ @Override public long cardinality() { @@ -1445,7 +1443,6 @@ public class HyperLogLogPlus implements ICardinality, Serializable { * However, in this case, both lists will need their own delta decoding and neither will have to * worry about consuming duplicates. * - * @param other * @return the new sparse set */ private int[] mergeEstimators(HyperLogLogPlus other) { @@ -1649,7 +1646,6 @@ public class HyperLogLogPlus implements ICardinality, Serializable { * * @param estimators the estimators to merge with this one * @return a new estimator with their combined knowledge - * @throws CardinalityMergeException */ @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/hll/ICardinality.java b/geode-core/src/main/java/org/apache/geode/internal/hll/ICardinality.java index 125b621..aadef5e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/hll/ICardinality.java +++ b/geode-core/src/main/java/org/apache/geode/internal/hll/ICardinality.java @@ -56,7 +56,6 @@ public interface ICardinality { /** * @return byte[] - * @throws IOException */ byte[] getBytes() throws IOException; diff --git a/geode-core/src/main/java/org/apache/geode/internal/jndi/InitialContextFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/internal/jndi/InitialContextFactoryImpl.java index 510c120..84237ea 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/jndi/InitialContextFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/jndi/InitialContextFactoryImpl.java @@ -61,7 +61,6 @@ public class InitialContextFactoryImpl implements InitialContextFactory { * application resource file (jndi.properties). * java.naming.factory.initial=org.apache.geode.internal.jndi.InitialContextFactoryImpl * - * @throws NamingException */ public void setAsInitial() throws NamingException { // Preserve current set system props diff --git a/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java b/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java index c51558f..593f6d6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java +++ b/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java @@ -301,7 +301,6 @@ public class JNDIInvoker { /** * Initialises the GemFire context. This is called when no external JNDI Context is found. * - * @throws NamingException */ private static void initializeGemFireContext() throws NamingException { Hashtable table = new Hashtable(); @@ -392,7 +391,6 @@ public class JNDIInvoker { /** * returns the GemFire TransactionManager. * - * @return TransactionManager */ public static TransactionManager getTransactionManager() { return transactionManager; diff --git a/geode-core/src/main/java/org/apache/geode/internal/jta/GlobalTransaction.java b/geode-core/src/main/java/org/apache/geode/internal/jta/GlobalTransaction.java index bfac0cf..c0a8e42 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/jta/GlobalTransaction.java +++ b/geode-core/src/main/java/org/apache/geode/internal/jta/GlobalTransaction.java @@ -616,8 +616,6 @@ public class GlobalTransaction { * Set the transaction TimeOut of the Global Transaction Asif : It returns the new expiry time for * the GTX. * - * @param seconds - * @throws SystemException */ long setTransactionTimeoutForXARes(int seconds) throws SystemException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/jta/TransactionUtils.java b/geode-core/src/main/java/org/apache/geode/internal/jta/TransactionUtils.java index 425433d..400e96c 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/jta/TransactionUtils.java +++ b/geode-core/src/main/java/org/apache/geode/internal/jta/TransactionUtils.java @@ -31,7 +31,6 @@ public class TransactionUtils { * Returns the logWriter associated with the existing DistributedSystem. If DS is null then the * PureLogWriter is returned * - * @return LogWriterI18n */ public static LogWriterI18n getLogWriterI18n() { if (dslogWriter != null) { @@ -48,7 +47,6 @@ public class TransactionUtils { * To be used by mapTransaction method of JNDIInvoker to set the dsLogwriter before the binding of * the datasources * - * @param logWriter */ public static void setLogWriter(LogWriterI18n logWriter) { dslogWriter = logWriter; diff --git a/geode-core/src/main/java/org/apache/geode/internal/logging/LoggingThreadGroup.java b/geode-core/src/main/java/org/apache/geode/internal/logging/LoggingThreadGroup.java index e7c853d..c275a3d 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/logging/LoggingThreadGroup.java +++ b/geode-core/src/main/java/org/apache/geode/internal/logging/LoggingThreadGroup.java @@ -196,7 +196,6 @@ public class LoggingThreadGroup extends ThreadGroup { /** * Note: Must be used for test purposes ONLY. * - * @param threadGroupName * @return thread group with given name. */ public static ThreadGroup getThreadGroup(final String threadGroupName) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/CommandProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/CommandProcessor.java index 779dd61..ec6c5ab 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/CommandProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/CommandProcessor.java @@ -27,12 +27,6 @@ import org.apache.geode.memcached.GemFireMemcachedServer.Protocol; */ public interface CommandProcessor { - /** - * - * @param reader - * @param protocol - * @param cache - */ ByteBuffer processCommand(RequestReader reader, Protocol protocol, Cache cache); } diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/ValueWrapper.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/ValueWrapper.java index f8d9049..28b3c3a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/ValueWrapper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/ValueWrapper.java @@ -78,7 +78,6 @@ public class ValueWrapper implements DataSerializable { * get and replace, use ValueWrapper instances from this method which only uses cas version. note * that equals and hashCode of this class have also been changed to only use the cas version. * - * @param cas * @return an instance with null value */ public static ValueWrapper getDummyValue(long cas) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AddQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AddQCommand.java index 1bcb9c4..96ebeb0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AddQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AddQCommand.java @@ -14,10 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - * - */ public class AddQCommand extends AddCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AppendQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AppendQCommand.java index f3077c8..7fe18cb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AppendQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/AppendQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class AppendQCommand extends AppendCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DecrementQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DecrementQCommand.java index 1f1ce4f..22f5140 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DecrementQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DecrementQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class DecrementQCommand extends DecrementCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DeleteQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DeleteQCommand.java index e171688..7775a0c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DeleteQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/DeleteQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class DeleteQCommand extends DeleteCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/FlushAllQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/FlushAllQCommand.java index 910a9dc..c9e0f4f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/FlushAllQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/FlushAllQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class FlushAllQCommand extends FlushAllCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATCommand.java index 350f2a7..da2925a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class GATCommand extends TouchCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATQCommand.java index 2497898..f55c875 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GATQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class GATQCommand extends GATCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKCommand.java index 3f16bda..9c37e9c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class GetKCommand extends GetCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKQCommand.java index 1d96333..3de00c8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/GetKQCommand.java @@ -14,10 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - * - */ public class GetKQCommand extends GetKCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/IncrementQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/IncrementQCommand.java index e66deed..996c30c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/IncrementQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/IncrementQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class IncrementQCommand extends IncrementCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NoOpCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NoOpCommand.java index 5ebe03f..217b3f7 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NoOpCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NoOpCommand.java @@ -20,9 +20,6 @@ import org.apache.geode.cache.Cache; import org.apache.geode.internal.memcached.RequestReader; import org.apache.geode.memcached.GemFireMemcachedServer.Protocol; -/** - * - */ public class NoOpCommand extends AbstractCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NotSupportedCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NotSupportedCommand.java index d192b38..ef7ca07 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NotSupportedCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/NotSupportedCommand.java @@ -21,9 +21,6 @@ import org.apache.geode.internal.memcached.RequestReader; import org.apache.geode.internal.memcached.ResponseStatus; import org.apache.geode.memcached.GemFireMemcachedServer.Protocol; -/** - * - */ public class NotSupportedCommand extends AbstractCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/PrependQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/PrependQCommand.java index baa93b0..a727477 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/PrependQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/PrependQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class PrependQCommand extends PrependCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/QuitQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/QuitQCommand.java index c71409b..c24970f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/QuitQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/QuitQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class QuitQCommand extends QuitCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/ReplaceQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/ReplaceQCommand.java index f4a71b8..bd4e839 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/ReplaceQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/ReplaceQCommand.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - */ public class ReplaceQCommand extends ReplaceCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/SetQCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/SetQCommand.java index ae491ec..d5e3f46 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/SetQCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/SetQCommand.java @@ -14,10 +14,6 @@ */ package org.apache.geode.internal.memcached.commands; -/** - * - * - */ public class SetQCommand extends SetCommand { @Override diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/StorageCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/StorageCommand.java index e935d0c..8ea413d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/StorageCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/StorageCommand.java @@ -146,9 +146,6 @@ public abstract class StorageCommand extends AbstractCommand { * 60*60*24*30 (number of seconds in 30 days); if the number sent by a client is larger than that, * the server will consider it to be real Unix time value rather than an offset from current time. * - * @param key - * @param p_expTime - * @param cache */ private void scheduleExpiration(final Object key, long p_expTime, final Cache cache) { long expTime = p_expTime; @@ -178,8 +175,6 @@ public abstract class StorageCommand extends AbstractCommand { /** * reschedules expiration for a key only if one was previously scheduled * - * @param key - * @param newExpTime * @return true if successfully rescheduled, false otherwise */ public static boolean rescheduleExpiration(Cache cache, Object key, int newExpTime) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/TouchCommand.java b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/TouchCommand.java index 5f6e6cb..c44e948 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/TouchCommand.java +++ b/geode-core/src/main/java/org/apache/geode/internal/memcached/commands/TouchCommand.java @@ -24,9 +24,6 @@ import org.apache.geode.internal.memcached.ResponseStatus; import org.apache.geode.internal.memcached.ValueWrapper; import org.apache.geode.memcached.GemFireMemcachedServer.Protocol; -/** - * - */ public class TouchCommand extends AbstractCommand { private static final int EXTRAS_LENGTH = 4; diff --git a/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreator.java b/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreator.java index 31456c0..21f48a7 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreator.java @@ -761,14 +761,9 @@ public class SocketCreator { * Creates or bind server socket to a random port selected from tcp-port-range which is same as * membership-port-range. * - * @param ba - * @param backlog - * @param isBindAddress - * @param tcpBufferSize * * @return Returns the new server socket. * - * @throws IOException */ public ServerSocket createServerSocketUsingPortRange(InetAddress ba, int backlog, boolean isBindAddress, boolean useNIO, int tcpBufferSize, int[] tcpPortRange) @@ -781,15 +776,10 @@ public class SocketCreator { * Creates or bind server socket to a random port selected from tcp-port-range which is same as * membership-port-range. * - * @param ba - * @param backlog - * @param isBindAddress - * @param tcpBufferSize * @param sslConnection whether to connect using SSL * * @return Returns the new server socket. * - * @throws IOException */ public ServerSocket createServerSocketUsingPortRange(InetAddress ba, int backlog, boolean isBindAddress, boolean useNIO, int tcpBufferSize, int[] tcpPortRange, @@ -1178,7 +1168,6 @@ public class SocketCreator { /** * This method uses JNDI to look up an address in DNS and return its name * - * @param addr * * @return the host name associated with the address or null if lookup isn't possible or there is * no host name for this address diff --git a/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreatorFactory.java b/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreatorFactory.java index f2c05b0..9a85782 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreatorFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/net/SocketCreatorFactory.java @@ -127,11 +127,6 @@ public class SocketCreatorFactory { /** * This a legacy SocketCreator initializer. * - * @param useSSL - * @param needClientAuth - * @param protocols - * @param ciphers - * @param gfsecurityProps * * @return SocketCreator for the defined properties * diff --git a/geode-core/src/main/java/org/apache/geode/internal/offheap/StoredObject.java b/geode-core/src/main/java/org/apache/geode/internal/offheap/StoredObject.java index fe945b9..edcb490 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/offheap/StoredObject.java +++ b/geode-core/src/main/java/org/apache/geode/internal/offheap/StoredObject.java @@ -65,7 +65,6 @@ public interface StoredObject extends Sendable, CachedDeserializable, Releasable * readByteArray. * * @param out the data output to send this object to - * @throws IOException */ void sendAsByteArray(DataOutput out) throws IOException; @@ -76,7 +75,6 @@ public interface StoredObject extends Sendable, CachedDeserializable, Releasable * VMCachedDeserializable. * * @param out the data output to send this object to - * @throws IOException */ void sendAsCachedDeserializable(DataOutput out) throws IOException; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/GraphType.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/GraphType.java index 37df832..7a07486 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/GraphType.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/GraphType.java @@ -16,9 +16,6 @@ package org.apache.geode.internal.sequencelog; import java.util.EnumSet; -/** - * - */ public enum GraphType { REGION, KEY, MESSAGE, MEMBER; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MembershipLogger.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MembershipLogger.java index 7fec68c..c46ddbb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MembershipLogger.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MembershipLogger.java @@ -18,9 +18,6 @@ import java.util.regex.Pattern; import org.apache.geode.distributed.internal.membership.InternalDistributedMember; -/** - * - */ public class MembershipLogger { private static final SequenceLogger GRAPH_LOGGER = SequenceLoggerImpl.getInstance(); diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MessageLogger.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MessageLogger.java index ecdf902..0abdbea 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MessageLogger.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/MessageLogger.java @@ -17,9 +17,6 @@ package org.apache.geode.internal.sequencelog; import org.apache.geode.distributed.internal.DistributionMessage; import org.apache.geode.distributed.internal.membership.InternalDistributedMember; -/** - * - */ public class MessageLogger { public static final SequenceLogger LOGGER = SequenceLoggerImpl.getInstance(); diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/RegionLogger.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/RegionLogger.java index 86cb89e..c20b2c1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/RegionLogger.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/RegionLogger.java @@ -31,8 +31,6 @@ public class RegionLogger { * Log the creation of a region. This should only be called if the region was not recovered from * disk or GII'd from another member. * - * @param regionName - * @param source */ public static void logCreate(String regionName, InternalDistributedMember source) { GRAPH_LOGGER.logTransition(GraphType.REGION, regionName, "create", "created", source, source); diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLoggerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLoggerImpl.java index f238c62..3c87695 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLoggerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLoggerImpl.java @@ -24,9 +24,6 @@ import org.apache.geode.distributed.internal.DistributionConfig; import org.apache.geode.internal.OSProcess; import org.apache.geode.internal.sequencelog.io.OutputStreamAppender; -/** - * - */ public class SequenceLoggerImpl implements SequenceLogger { private static final SequenceLoggerImpl INSTANCE; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/Transition.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/Transition.java index 1506de1..b7643ca 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/Transition.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/Transition.java @@ -14,9 +14,6 @@ */ package org.apache.geode.internal.sequencelog; -/** - * - */ public class Transition { private final long timestamp; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java index 0bbda18..09838fd 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java @@ -18,9 +18,6 @@ import java.util.regex.Pattern; import org.apache.geode.internal.sequencelog.GraphType; -/** - * - */ public interface Filter { boolean accept(GraphType graphType, String name, String edgeName, String source, String dest); diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GemfireLogConverter.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GemfireLogConverter.java index 669f441..0df9039 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GemfireLogConverter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GemfireLogConverter.java @@ -40,9 +40,6 @@ import org.apache.geode.internal.sequencelog.Transition; */ public class GemfireLogConverter { - /** - * - */ private static final Pattern DATE_PATTERN = Pattern.compile("(\\d\\d\\d\\d)/(\\d\\d)/(\\d\\d) (\\d\\d):(\\d\\d):(\\d\\d).(\\d\\d\\d)"); private static final Pattern ALL = Pattern.compile(".*"); @@ -71,10 +68,6 @@ public class GemfireLogConverter { } } - /** - * @param args - * @throws IOException - */ public static void main(String[] args) throws IOException { if (args.length == 0) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GraphReader.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GraphReader.java index e9e4e65..784d4cc 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GraphReader.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/GraphReader.java @@ -24,9 +24,6 @@ import org.apache.geode.internal.Version; import org.apache.geode.internal.sequencelog.GraphType; import org.apache.geode.internal.sequencelog.model.GraphSet; -/** - * - */ public class GraphReader { private File[] files; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/InputStreamReader.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/InputStreamReader.java index 3af7d24..2270314 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/InputStreamReader.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/InputStreamReader.java @@ -25,9 +25,6 @@ import java.util.regex.Pattern; import org.apache.geode.internal.sequencelog.GraphType; import org.apache.geode.internal.sequencelog.model.GraphReaderCallback; -/** - * - */ public class InputStreamReader { private DataInputStream input; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Graph.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Graph.java index 1cd40e0..672d852 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Graph.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Graph.java @@ -45,11 +45,6 @@ public class Graph { /** * Add an edge to this graph. * - * @param timestamp - * @param edgeName - * @param source - * @param dest - * @param isFromPattern */ public void addEdge(long timestamp, String edgeName, String state, String source, String dest, boolean isFromPattern) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphID.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphID.java index b8359fc..12de6fd 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphID.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphID.java @@ -18,9 +18,6 @@ import java.io.Serializable; import org.apache.geode.internal.sequencelog.GraphType; -/** - * - */ public class GraphID implements Comparable<GraphID>, Serializable { public final GraphType type; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java index b644677..c4bec36 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java @@ -18,9 +18,6 @@ import java.util.regex.Pattern; import org.apache.geode.internal.sequencelog.GraphType; -/** - * - */ public interface GraphReaderCallback { void addEdge(long timestamp, GraphType graphType, String graphName, String edgeName, String state, diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphSet.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphSet.java index b060b4b..87d9c20 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphSet.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphSet.java @@ -26,9 +26,6 @@ import java.util.regex.Pattern; import org.apache.geode.internal.sequencelog.GraphType; -/** - * - */ public class GraphSet implements GraphReaderCallback { private Map<GraphID, Graph> graphs = new HashMap<GraphID, Graph>(); private long maxTime = Long.MIN_VALUE; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Vertex.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Vertex.java index 47482c5..dce57aa 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Vertex.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/Vertex.java @@ -16,9 +16,6 @@ package org.apache.geode.internal.sequencelog.model; import java.util.SortedMap; -/** - * - */ public class Vertex implements Comparable<Vertex> { private final Graph graph; diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/visualization/text/TextDisplay.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/visualization/text/TextDisplay.java index 153427c..522bf59 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/visualization/text/TextDisplay.java +++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/visualization/text/TextDisplay.java @@ -25,15 +25,8 @@ import org.apache.geode.internal.sequencelog.io.Filter; import org.apache.geode.internal.sequencelog.io.InputStreamReader; import org.apache.geode.internal.sequencelog.model.GraphReaderCallback; -/** - * - */ public class TextDisplay { - /** - * @param args - * @throws IOException - */ public static void main(String[] args) throws IOException { File[] files; if (args.length > 0) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java index 46524c9..fe40555 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java +++ b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java @@ -420,7 +420,6 @@ public abstract class NativeCalls { * Linux impls create temporary timespec object and marshals that for invoking native api. * Shouldn't be used if to be called too many times, instead jni implementation is more desirable. * - * @param clock_id * @return nanosecond precision performance counter. */ public long nanoTime(int clock_id) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java index 67d4e07..69adc26 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java @@ -608,7 +608,6 @@ public class NativeCallsJNAImpl { * Get the file store type of a path. for example, /dev/sdd1(store name) /w2-gst-dev40d(mount * point) ext4(type) * - * @param path * @return file store type */ public String getFileStoreType(final String path) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/size/CachingSingleObjectSizer.java b/geode-core/src/main/java/org/apache/geode/internal/size/CachingSingleObjectSizer.java index 8ee3483..9e9870c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/size/CachingSingleObjectSizer.java +++ b/geode-core/src/main/java/org/apache/geode/internal/size/CachingSingleObjectSizer.java @@ -18,9 +18,6 @@ import java.util.Map; import org.apache.geode.internal.util.concurrent.CopyOnWriteWeakHashMap; -/** - * - */ public class CachingSingleObjectSizer implements SingleObjectSizer { private final Map<Class, Long> sizeCache = new CopyOnWriteWeakHashMap<Class, Long>(); private final SingleObjectSizer wrappedSizer; diff --git a/geode-core/src/main/java/org/apache/geode/internal/size/ObjectTraverser.java b/geode-core/src/main/java/org/apache/geode/internal/size/ObjectTraverser.java index c352608..0a98269 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/size/ObjectTraverser.java +++ b/geode-core/src/main/java/org/apache/geode/internal/size/ObjectTraverser.java @@ -39,8 +39,6 @@ public class ObjectTraverser { * @param visitor a visitor to visit each node * @param includeStatics if true, the first time we see a new object type, we will visit all of * the static fields. - * @throws IllegalArgumentException - * @throws IllegalAccessException */ public static void breadthFirstSearch(Object root, Visitor visitor, boolean includeStatics) throws IllegalArgumentException, IllegalAccessException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/size/SingleObjectSizer.java b/geode-core/src/main/java/org/apache/geode/internal/size/SingleObjectSizer.java index 43260e2..69bc97b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/size/SingleObjectSizer.java +++ b/geode-core/src/main/java/org/apache/geode/internal/size/SingleObjectSizer.java @@ -20,7 +20,6 @@ public interface SingleObjectSizer { * Returns the size of the object, WITHOUT descending into child objects includes primatives and * object references. * - * @param object */ long sizeof(Object object); diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandler.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandler.java index 089d34b..f4d0432 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandler.java +++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandler.java @@ -89,7 +89,6 @@ public class StatArchiveHandler implements SampleHandler { /** * Initializes the stat archiver with nanosTimeStamp. * - * @param nanosTimeStamp */ public void initialize(long nanosTimeStamp) { changeArchiveFile(false, nanosTimeStamp); @@ -99,7 +98,6 @@ public class StatArchiveHandler implements SampleHandler { /** * Closes any {@link StatArchiveWriter} currently in use by this handler. * - * @throws GemFireException */ public void close() throws GemFireException { synchronized (this) { @@ -266,7 +264,6 @@ public class StatArchiveHandler implements SampleHandler { * {@link StatArchiveHandlerConfig#getArchiveDiskSpaceLimit() disk space limit}. * * @param newFile the new archive file to use or "" to disable archiving - * @param nanosTimeStamp */ protected void changeArchiveFile(File newFile, long nanosTimeStamp) { changeArchiveFile(newFile, true, nanosTimeStamp); @@ -291,7 +288,6 @@ public class StatArchiveHandler implements SampleHandler { * @param resetHandler true if the handler should reset itself with the SampleCollector in order * to receive allocation notifications about all resource types and instances * - * @param nanosTimeStamp */ private void changeArchiveFile(boolean resetHandler, long nanosTimeStamp) { changeArchiveFile(this.config.getArchiveFileName(), resetHandler, nanosTimeStamp); @@ -309,9 +305,6 @@ public class StatArchiveHandler implements SampleHandler { * removing and re-adding itself in order to receive allocation notifications about all resource * types and instances. * - * @param newFile - * @param resetHandler - * @param nanosTimeStamp */ private void changeArchiveFile(File newFile, boolean resetHandler, long nanosTimeStamp) { final boolean isDebugEnabled_STATISTICS = logger.isTraceEnabled(LogMarker.STATISTICS_VERBOSE); diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/Buffers.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/Buffers.java index 41b9546..abb7fdb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/tcp/Buffers.java +++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/Buffers.java @@ -23,9 +23,6 @@ import java.util.concurrent.ConcurrentLinkedQueue; import org.apache.geode.distributed.internal.DMStats; import org.apache.geode.internal.Assert; -/** - * - */ public class Buffers { /** * A list of soft references to byte buffers. diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/ConnectionTable.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/ConnectionTable.java index 693e4f1..82613cb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/tcp/ConnectionTable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/ConnectionTable.java @@ -324,7 +324,6 @@ public class ConnectionTable { * @param ackSAThreshold the ms ack-severe_alert-threshold, or zero * @return the Connection, or null if someone else already created or closed it * @throws IOException if unable to connect - * @throws DistributedSystemDisconnectedException */ private Connection handleNewPendingConnection(DistributedMember id, boolean sharedResource, boolean preserveOrder, Map m, PendingConnection pc, long startTime, long ackThreshold, @@ -414,7 +413,6 @@ public class ConnectionTable { * @param ackSATimeout the ms ack-severe-alert-threshold, or zero * @return the new Connection, or null if an error * @throws IOException if unable to create the connection - * @throws DistributedSystemDisconnectedException */ private Connection getSharedConnection(DistributedMember id, boolean scheduleTimeout, boolean preserveOrder, long startTime, long ackTimeout, long ackSATimeout) @@ -482,7 +480,6 @@ public class ConnectionTable { * @param ackSATimeout the ms ack-severe-alert-threshold, or zero * @return the connection, or null if an error * @throws IOException if the connection could not be created - * @throws DistributedSystemDisconnectedException */ Connection getThreadOwnedConnection(DistributedMember id, long startTime, long ackTimeout, long ackSATimeout) throws IOException, DistributedSystemDisconnectedException { @@ -617,7 +614,6 @@ public class ConnectionTable { * @param ackSATimeout the ms ack-severe-alert-threshold, or zero * @return the new Connection, or null if a problem * @throws java.io.IOException if the connection could not be created - * @throws DistributedSystemDisconnectedException */ protected Connection get(DistributedMember id, boolean preserveOrder, long startTime, long ackTimeout, long ackSATimeout) @@ -1213,7 +1209,6 @@ public class ConnectionTable { * @param ackTimeout the ms ack-wait-threshold, or zero * @param ackSATimeout the ms ack-severe-alert-threshold, or zero * @return the new connection - * @throws IOException */ public synchronized Connection waitForConnect(MembershipManager mgr, long startTime, long ackTimeout, long ackSATimeout) throws IOException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgReader.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgReader.java index 458ee52..45c9e98 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgReader.java +++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgReader.java @@ -62,9 +62,6 @@ public abstract class MsgReader { * Block until you can read a message. Returns null if the message was a message chunk. * * @return the message, or null if we only received a chunk of the message - * @throws ClassNotFoundException - * @throws IOException - * @throws InterruptedException */ public DistributionMessage readMessage(Header header) throws IOException, ClassNotFoundException, InterruptedException { diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java index b77e275..8830fa5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java +++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java @@ -204,9 +204,6 @@ public class MsgStreamer extends OutputStream /** * set connections to be "in use" and schedule alert tasks * - * @param startTime - * @param ackTimeout - * @param ackSDTimeout */ public void reserveConnections(long startTime, long ackTimeout, long ackSDTimeout) { for (Iterator it = cons.iterator(); it.hasNext();) { diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/LogFileUtils.java b/geode-core/src/main/java/org/apache/geode/internal/util/LogFileUtils.java index 4aae88c..7e071f0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/util/LogFileUtils.java +++ b/geode-core/src/main/java/org/apache/geode/internal/util/LogFileUtils.java @@ -12,9 +12,6 @@ * or implied. See the License for the specific language governing permissions and limitations under * the License. */ -/** - * - */ package org.apache.geode.internal.util; import java.io.File; diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/VersionedArrayList.java b/geode-core/src/main/java/org/apache/geode/internal/util/VersionedArrayList.java index 0cb00b2..7bc962c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/util/VersionedArrayList.java +++ b/geode-core/src/main/java/org/apache/geode/internal/util/VersionedArrayList.java @@ -58,7 +58,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab /** * Constructor. * - * @param size */ public VersionedArrayList(int size) { this.list = new ArrayList<Node>(size); @@ -76,7 +75,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab * ensure that the iterator of the list doesn't get ConcurrentModificationException. * * @see java.util.ConcurrentModificationException - * @param obj */ public synchronized void add(Node obj) { @@ -122,7 +120,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab /** * Returns the size of the list. * - * @return int */ public synchronized int size() { return this.list.size(); @@ -131,7 +128,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab /** * Returns true if obj is present in the list otherwise false. * - * @param obj * @return true if obj is present in the list */ public boolean contains(Node obj) { @@ -147,8 +143,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab /** * Returns Object at index i. * - * @param i - * @return Object */ public Object get(int i) { final List<Node> l; @@ -161,8 +155,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab /** * Returns the index of Object if present, else -1. * - * @param obj - * @return int */ public int indexOf(Object obj) { final List<Node> l; @@ -175,7 +167,6 @@ public class VersionedArrayList implements DataSerializable, Versionable, Iterab /** * Returns a copy of the arraylist contained. * - * @return ArrayList */ public Set<Node> getListCopy() { final List<Node> l; diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/ReentrantSemaphore.java b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/ReentrantSemaphore.java index 868b4bf..fcd4f94 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/ReentrantSemaphore.java +++ b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/ReentrantSemaphore.java @@ -37,9 +37,6 @@ import java.util.concurrent.TimeUnit; public class ReentrantSemaphore extends Semaphore { private final ThreadLocal<Integer> holdCount = new ThreadLocal<Integer>(); - /** - * @param permits - */ public ReentrantSemaphore(int permits) { super(permits); } diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableCountDownLatch.java b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableCountDownLatch.java index 83f93ff..6336404 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableCountDownLatch.java +++ b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableCountDownLatch.java @@ -55,9 +55,6 @@ public class StoppableCountDownLatch { this.stopper = stopper; } - /** - * @throws InterruptedException - */ public void await() throws InterruptedException { for (;;) { stopper.checkCancelInProgress(null); diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantLock.java b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantLock.java index dcf0d64..5c4b0e0 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantLock.java +++ b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantLock.java @@ -79,9 +79,6 @@ public class StoppableReentrantLock { } // for } - /** - * @throws InterruptedException - */ public void lockInterruptibly() throws InterruptedException { for (;;) { stopper.checkCancelInProgress(null); @@ -101,7 +98,6 @@ public class StoppableReentrantLock { /** * @param timeoutMs how long to wait in milliseconds * @return true if the lock was acquired - * @throws InterruptedException */ public boolean tryLock(long timeoutMs) throws InterruptedException { stopper.checkCancelInProgress(null); diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantReadWriteLock.java b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantReadWriteLock.java index 8c3814a..9b376f2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantReadWriteLock.java +++ b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/StoppableReentrantReadWriteLock.java @@ -115,9 +115,6 @@ public class StoppableReentrantReadWriteLock implements /* ReadWriteLock, */ jav } } - /** - * @throws InterruptedException - */ public void lockInterruptibly() throws InterruptedException { for (;;) { stopper.checkCancelInProgress(null); @@ -137,7 +134,6 @@ public class StoppableReentrantReadWriteLock implements /* ReadWriteLock, */ jav /** * @param timeout how long to wait * @return true if the lock was acquired - * @throws InterruptedException */ public boolean tryLock(long timeout) throws InterruptedException { stopper.checkCancelInProgress(null); @@ -172,7 +168,6 @@ public class StoppableReentrantReadWriteLock implements /* ReadWriteLock, */ jav * Create a new instance * * @param lock the underlying lock - * @param stopper */ public StoppableWriteLock(ReadWriteLock lock, CancelCriterion stopper) { this.lock = lock.writeLock(); @@ -196,9 +191,6 @@ public class StoppableReentrantReadWriteLock implements /* ReadWriteLock, */ jav } } - /** - * @throws InterruptedException - */ public void lockInterruptibly() throws InterruptedException { for (;;) { stopper.checkCancelInProgress(null); @@ -218,15 +210,12 @@ public class StoppableReentrantReadWriteLock implements /* ReadWriteLock, */ jav /** * @param timeout how long to wait * @return true if the lock was required - * @throws InterruptedException */ public boolean tryLock(long timeout) throws InterruptedException { stopper.checkCancelInProgress(null); return lock.tryLock(timeout, TimeUnit.MILLISECONDS); } - /** - */ public void unlock() { lock.unlock(); } -- To stop receiving notification emails like this one, please contact prhomb...@apache.org.