http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java index de6e6e8..c732be5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java @@ -178,28 +178,6 @@ public class GridDhtAtomicUpdateResponse<K, V> extends GridCacheMessage<K, V> im } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtAtomicUpdateResponse _clone = (GridDhtAtomicUpdateResponse)_msg; - - _clone.futVer = futVer != null ? (GridCacheVersion)futVer.clone() : null; - _clone.failedKeys = failedKeys; - _clone.failedKeysBytes = failedKeysBytes; - _clone.err = err; - _clone.errBytes = errBytes; - _clone.nearEvicted = nearEvicted; - _clone.nearEvictedBytes = nearEvictedBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -244,7 +222,6 @@ public class GridDhtAtomicUpdateResponse<K, V> extends GridCacheMessage<K, V> im } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java index 41c8d42..c206264 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java @@ -543,46 +543,6 @@ public class GridNearAtomicUpdateRequest<K, V> extends GridCacheMessage<K, V> im } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearAtomicUpdateRequest _clone = (GridNearAtomicUpdateRequest)_msg; - - _clone.nodeId = nodeId; - _clone.futVer = futVer != null ? (GridCacheVersion)futVer.clone() : null; - _clone.fastMap = fastMap; - _clone.updateVer = updateVer != null ? (GridCacheVersion)updateVer.clone() : null; - _clone.topVer = topVer; - _clone.syncMode = syncMode; - _clone.op = op; - _clone.keys = keys; - _clone.keyBytes = keyBytes; - _clone.vals = vals; - _clone.valBytes = valBytes; - _clone.invokeArgs = invokeArgs; - _clone.invokeArgsBytes = invokeArgsBytes; - _clone.drVers = drVers; - _clone.drTtls = drTtls != null ? (GridLongList)drTtls.clone() : null; - _clone.drExpireTimes = drExpireTimes != null ? (GridLongList)drExpireTimes.clone() : null; - _clone.retval = retval; - _clone.expiryPlc = expiryPlc; - _clone.expiryPlcBytes = expiryPlcBytes; - _clone.filter = filter; - _clone.filterBytes = filterBytes; - _clone.hasPrimary = hasPrimary; - _clone.forceTransformBackups = forceTransformBackups; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -717,7 +677,6 @@ public class GridNearAtomicUpdateRequest<K, V> extends GridCacheMessage<K, V> im } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java index b5f1ebe..468861b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java @@ -418,38 +418,6 @@ public class GridNearAtomicUpdateResponse<K, V> extends GridCacheMessage<K, V> i } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearAtomicUpdateResponse _clone = (GridNearAtomicUpdateResponse)_msg; - - _clone.nodeId = nodeId; - _clone.futVer = futVer != null ? (GridCacheVersion)futVer.clone() : null; - _clone.err = err; - _clone.errBytes = errBytes; - _clone.retVal = retVal; - _clone.retValBytes = retValBytes; - _clone.failedKeys = failedKeys; - _clone.failedKeysBytes = failedKeysBytes; - _clone.remapKeys = remapKeys; - _clone.remapKeysBytes = remapKeysBytes; - _clone.nearValsIdxs = nearValsIdxs; - _clone.nearSkipIdxs = nearSkipIdxs; - _clone.nearVals = nearVals; - _clone.nearValBytes = nearValBytes; - _clone.nearVer = nearVer != null ? (GridCacheVersion)nearVer.clone() : null; - _clone.nearTtls = nearTtls != null ? (GridLongList)nearTtls.clone() : null; - _clone.nearExpireTimes = nearExpireTimes != null ? (GridLongList)nearExpireTimes.clone() : null; - } - - /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -536,7 +504,6 @@ public class GridNearAtomicUpdateResponse<K, V> extends GridCacheMessage<K, V> i } /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java index 06e44fe..387c027 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java @@ -162,26 +162,6 @@ public class GridDhtForceKeysRequest<K, V> extends GridCacheMessage<K, V> implem } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtForceKeysRequest _clone = (GridDhtForceKeysRequest)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.keyBytes = keyBytes; - _clone.keys = keys; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -226,7 +206,6 @@ public class GridDhtForceKeysRequest<K, V> extends GridCacheMessage<K, V> implem } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java index 11ff1cf..a20ce51 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java @@ -165,27 +165,6 @@ public class GridDhtForceKeysResponse<K, V> extends GridCacheMessage<K, V> imple } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtForceKeysResponse _clone = (GridDhtForceKeysResponse)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.missedKeyBytes = missedKeyBytes; - _clone.missedKeys = missedKeys; - _clone.infos = infos; - _clone.infosBytes = infosBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -230,7 +209,6 @@ public class GridDhtForceKeysResponse<K, V> extends GridCacheMessage<K, V> imple } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java index a737d3d..25d5d19 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java @@ -190,28 +190,6 @@ public class GridDhtPartitionDemandMessage<K, V> extends GridCacheMessage<K, V> } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtPartitionDemandMessage _clone = (GridDhtPartitionDemandMessage)_msg; - - _clone.updateSeq = updateSeq; - _clone.parts = parts; - _clone.topic = topic; - _clone.topicBytes = topicBytes; - _clone.timeout = timeout; - _clone.workerId = workerId; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -268,7 +246,6 @@ public class GridDhtPartitionDemandMessage<K, V> extends GridCacheMessage<K, V> } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java index 5cf1748..b942b57 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java @@ -220,21 +220,6 @@ public class GridDhtPartitionExchangeId extends MessageAdapter implements Compar } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridDhtPartitionExchangeId _clone = (GridDhtPartitionExchangeId)_msg; - - _clone.nodeId = nodeId; - _clone.evt = evt; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionExchangeId.class, this, "nodeId", U.id8(nodeId), http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java index 29b19ca..d703186 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java @@ -273,30 +273,6 @@ public class GridDhtPartitionSupplyMessage<K, V> extends GridCacheMessage<K, V> } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtPartitionSupplyMessage _clone = (GridDhtPartitionSupplyMessage)_msg; - - _clone.workerId = workerId; - _clone.updateSeq = updateSeq; - _clone.ack = ack; - _clone.last = last; - _clone.missed = missed; - _clone.infos = infos; - _clone.infoBytesMap = infoBytesMap; - _clone.infoBytes = infoBytes; - _clone.msgSize = msgSize; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -353,7 +329,6 @@ public class GridDhtPartitionSupplyMessage<K, V> extends GridCacheMessage<K, V> } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java index 147488e..60bea32 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java @@ -75,17 +75,6 @@ abstract class GridDhtPartitionsAbstractMessage<K, V> extends GridCacheMessage<K } /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtPartitionsAbstractMessage _clone = (GridDhtPartitionsAbstractMessage)_msg; - - _clone.exchId = exchId != null ? (GridDhtPartitionExchangeId)exchId.clone() : null; - _clone.lastVer = lastVer != null ? (GridCacheVersion)lastVer.clone() : null; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -118,7 +107,6 @@ abstract class GridDhtPartitionsAbstractMessage<K, V> extends GridCacheMessage<K } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java index 83957d9..d4b8a14 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java @@ -116,24 +116,6 @@ public class GridDhtPartitionsFullMessage<K, V> extends GridDhtPartitionsAbstrac } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtPartitionsFullMessage _clone = (GridDhtPartitionsFullMessage)_msg; - - _clone.parts = parts; - _clone.partsBytes = partsBytes; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -166,7 +148,6 @@ public class GridDhtPartitionsFullMessage<K, V> extends GridDhtPartitionsAbstrac } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java index 05160f1..0c477c1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java @@ -95,23 +95,6 @@ public class GridDhtPartitionsSingleMessage<K, V> extends GridDhtPartitionsAbstr } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtPartitionsSingleMessage _clone = (GridDhtPartitionsSingleMessage)_msg; - - _clone.parts = parts; - _clone.partsBytes = partsBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -138,7 +121,6 @@ public class GridDhtPartitionsSingleMessage<K, V> extends GridDhtPartitionsAbstr } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java index ee94c8a..2599c95 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java @@ -45,19 +45,6 @@ public class GridDhtPartitionsSingleRequest<K, V> extends GridDhtPartitionsAbstr } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -75,7 +62,6 @@ public class GridDhtPartitionsSingleRequest<K, V> extends GridDhtPartitionsAbstr } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java index a77fcf6..44ef152 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java @@ -239,33 +239,6 @@ public class GridNearGetRequest<K, V> extends GridCacheMessage<K, V> implements } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearGetRequest _clone = (GridNearGetRequest)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.ver = ver != null ? (GridCacheVersion)ver.clone() : null; - _clone.keys = keys; - _clone.reload = reload; - _clone.readThrough = readThrough; - _clone.skipVals = skipVals; - _clone.keyBytes = keyBytes; - _clone.topVer = topVer; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - _clone.accessTtl = accessTtl; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -352,7 +325,6 @@ public class GridNearGetRequest<K, V> extends GridCacheMessage<K, V> implements } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java index 3f831e9..3518915 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java @@ -200,30 +200,6 @@ public class GridNearGetResponse<K, V> extends GridCacheMessage<K, V> implements } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearGetResponse _clone = (GridNearGetResponse)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.ver = ver != null ? (GridCacheVersion)ver.clone() : null; - _clone.entries = entries; - _clone.entriesBytes = entriesBytes; - _clone.invalidParts = invalidParts; - _clone.topVer = topVer; - _clone.err = err; - _clone.errBytes = errBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -286,7 +262,6 @@ public class GridNearGetResponse<K, V> extends GridCacheMessage<K, V> implements } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java index e3091fd..98ebb4f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java @@ -331,34 +331,6 @@ public class GridNearLockRequest<K, V> extends GridDistributedLockRequest<K, V> } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearLockRequest _clone = (GridNearLockRequest)_msg; - - _clone.topVer = topVer; - _clone.miniId = miniId; - _clone.filterBytes = filterBytes; - _clone.filter = filter; - _clone.implicitTx = implicitTx; - _clone.implicitSingleTx = implicitSingleTx; - _clone.onePhaseCommit = onePhaseCommit; - _clone.dhtVers = dhtVers; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - _clone.hasTransforms = hasTransforms; - _clone.syncCommit = syncCommit; - _clone.accessTtl = accessTtl; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -451,7 +423,6 @@ public class GridNearLockRequest<K, V> extends GridDistributedLockRequest<K, V> } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java index 710054a..8919465 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java @@ -181,26 +181,6 @@ public class GridNearLockResponse<K, V> extends GridDistributedLockResponse<K, V } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearLockResponse _clone = (GridNearLockResponse)_msg; - - _clone.pending = pending; - _clone.miniId = miniId; - _clone.dhtVers = dhtVers; - _clone.mappedVers = mappedVers; - _clone.filterRes = filterRes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -251,7 +231,6 @@ public class GridNearLockResponse<K, V> extends GridDistributedLockResponse<K, V } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java index eed072d..6cb1fb9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java @@ -158,27 +158,6 @@ public class GridNearTxFinishRequest<K, V> extends GridDistributedTxFinishReques } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearTxFinishRequest _clone = (GridNearTxFinishRequest)_msg; - - _clone.miniId = miniId; - _clone.explicitLock = explicitLock; - _clone.storeEnabled = storeEnabled; - _clone.topVer = topVer; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -235,7 +214,6 @@ public class GridNearTxFinishRequest<K, V> extends GridDistributedTxFinishReques } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java index cc52c16..0c8b7c2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java @@ -114,25 +114,6 @@ public class GridNearTxFinishResponse<K, V> extends GridDistributedTxFinishRespo } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearTxFinishResponse _clone = (GridNearTxFinishResponse)_msg; - - _clone.err = err; - _clone.errBytes = errBytes; - _clone.miniId = miniId; - _clone.nearThreadId = nearThreadId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -171,7 +152,6 @@ public class GridNearTxFinishResponse<K, V> extends GridDistributedTxFinishRespo } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java index b72e809..3f5780e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java @@ -216,29 +216,6 @@ public class GridNearTxPrepareRequest<K, V> extends GridDistributedTxPrepareRequ } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearTxPrepareRequest _clone = (GridNearTxPrepareRequest)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.near = near; - _clone.topVer = topVer; - _clone.last = last; - _clone.lastBackups = lastBackups; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -307,7 +284,6 @@ public class GridNearTxPrepareRequest<K, V> extends GridDistributedTxPrepareRequ } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java index ff692a6..9c4ef78 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java @@ -224,28 +224,6 @@ public class GridNearTxPrepareResponse<K, V> extends GridDistributedTxPrepareRes } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridNearTxPrepareResponse _clone = (GridNearTxPrepareResponse)_msg; - - _clone.pending = pending; - _clone.futId = futId; - _clone.miniId = miniId; - _clone.dhtVer = dhtVer != null ? (GridCacheVersion)dhtVer.clone() : null; - _clone.invalidParts = invalidParts; - _clone.ownedVals = ownedVals; - _clone.ownedValsBytes = ownedValsBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -302,7 +280,6 @@ public class GridNearTxPrepareResponse<K, V> extends GridDistributedTxPrepareRes } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java index 7f6afaf..266bf97 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java @@ -47,19 +47,6 @@ public class GridNearUnlockRequest<K, V> extends GridDistributedUnlockRequest<K, } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -77,7 +64,6 @@ public class GridNearUnlockRequest<K, V> extends GridDistributedUnlockRequest<K, } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java index ea30154..eda408c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java @@ -441,45 +441,6 @@ public class GridCacheQueryRequest<K, V> extends GridCacheMessage<K, V> implemen } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCacheQueryRequest _clone = (GridCacheQueryRequest)_msg; - - _clone.id = id; - _clone.cacheName = cacheName; - _clone.type = type; - _clone.fields = fields; - _clone.clause = clause; - _clone.clsName = clsName; - _clone.keyValFilter = keyValFilter; - _clone.keyValFilterBytes = keyValFilterBytes; - _clone.prjFilter = prjFilter; - _clone.prjFilterBytes = prjFilterBytes; - _clone.rdc = rdc; - _clone.rdcBytes = rdcBytes; - _clone.trans = trans; - _clone.transBytes = transBytes; - _clone.args = args; - _clone.argsBytes = argsBytes; - _clone.pageSize = pageSize; - _clone.incBackups = incBackups; - _clone.cancel = cancel; - _clone.incMeta = incMeta; - _clone.all = all; - _clone.keepPortable = keepPortable; - _clone.subjId = subjId; - _clone.taskHash = taskHash; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -614,7 +575,6 @@ public class GridCacheQueryRequest<K, V> extends GridCacheMessage<K, V> implemen } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java index 1b157f8..a82a0a1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java @@ -202,30 +202,6 @@ public class GridCacheQueryResponse<K, V> extends GridCacheMessage<K, V> impleme } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCacheQueryResponse _clone = (GridCacheQueryResponse)_msg; - - _clone.finished = finished; - _clone.reqId = reqId; - _clone.err = err; - _clone.errBytes = errBytes; - _clone.fields = fields; - _clone.metaDataBytes = metaDataBytes; - _clone.metadata = metadata; - _clone.dataBytes = dataBytes; - _clone.data = data; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -282,7 +258,6 @@ public class GridCacheQueryResponse<K, V> extends GridCacheMessage<K, V> impleme } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java index b35677f..53e43e2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java @@ -341,22 +341,6 @@ public class GridCacheVersion extends MessageAdapter implements Comparable<GridC } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridCacheVersion _clone = (GridCacheVersion)_msg; - - _clone.topVer = topVer; - _clone.nodeOrderDrId = nodeOrderDrId; - _clone.globalTime = globalTime; - _clone.order = order; - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheVersion.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java index 7e00107..73bb5ff 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java @@ -72,21 +72,6 @@ public class GridClockDeltaSnapshotMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridClockDeltaSnapshotMessage _clone = (GridClockDeltaSnapshotMessage)_msg; - - _clone.snapVer = snapVer != null ? (GridClockDeltaVersion)snapVer.clone() : null; - _clone.deltas = deltas; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -116,7 +101,6 @@ public class GridClockDeltaSnapshotMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java index 309a7c4..60448f2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java @@ -173,20 +173,6 @@ public class GridClockDeltaVersion extends MessageAdapter implements Comparable< } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridClockDeltaVersion _clone = (GridClockDeltaVersion)_msg; - - _clone.ver = ver; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridClockDeltaVersion.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java index 07ebf4a..325bcb9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java @@ -131,24 +131,6 @@ public class GridContinuousMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridContinuousMessage _clone = (GridContinuousMessage)_msg; - - _clone.type = type; - _clone.routineId = routineId; - _clone.data = data; - _clone.dataBytes = dataBytes; - _clone.futId = futId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -190,7 +172,6 @@ public class GridContinuousMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java index 31a9732..3ab6f2b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java @@ -439,28 +439,4 @@ public class GridDataLoadRequest extends MessageAdapter { @Override public byte directType() { return 62; } - - /** {@inheritDoc} */ - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridDataLoadRequest _clone = (GridDataLoadRequest)_msg; - - _clone.reqId = reqId; - _clone.resTopicBytes = resTopicBytes; - _clone.cacheName = cacheName; - _clone.updaterBytes = updaterBytes; - _clone.colBytes = colBytes; - _clone.ignoreDepOwnership = ignoreDepOwnership; - _clone.skipStore = skipStore; - _clone.depMode = depMode; - _clone.sampleClsName = sampleClsName; - _clone.userVer = userVer; - _clone.ldrParticipants = ldrParticipants; - _clone.clsLdrId = clsLdrId; - _clone.forceLocDep = forceLocDep; - } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java index 1e70d59..9308157 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java @@ -83,22 +83,6 @@ public class GridDataLoadResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridDataLoadResponse _clone = (GridDataLoadResponse)_msg; - - _clone.reqId = reqId; - _clone.errBytes = errBytes; - _clone.forceLocDep = forceLocDep; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -134,7 +118,6 @@ public class GridDataLoadResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java index bb4416c..d8c0dde 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java @@ -103,25 +103,6 @@ public class IgfsAckMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - IgfsAckMessage _clone = (IgfsAckMessage)_msg; - - _clone.fileId = fileId; - _clone.id = id; - _clone.err = err; - _clone.errBytes = errBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -160,7 +141,6 @@ public class IgfsAckMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java index cc0bc07..692992c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java @@ -158,23 +158,6 @@ public final class IgfsBlockKey extends MessageAdapter implements Externalizable } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - IgfsBlockKey _clone = (IgfsBlockKey)_msg; - - _clone.fileId = fileId; - _clone.blockId = blockId; - _clone.affKey = affKey; - _clone.evictExclude = evictExclude; - } - - /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -216,7 +199,6 @@ public final class IgfsBlockKey extends MessageAdapter implements Externalizable } /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java index 0c4960a..204ae7a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java @@ -84,24 +84,6 @@ public class IgfsBlocksMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - IgfsBlocksMessage _clone = (IgfsBlocksMessage)_msg; - - _clone.fileId = fileId; - _clone.id = id; - _clone.blocks = blocks; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -140,7 +122,6 @@ public class IgfsBlocksMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java index 08b8713..4e00704 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java @@ -31,10 +31,6 @@ public abstract class IgfsCommunicationMessage extends MessageAdapter { /** */ private static final long serialVersionUID = 0L; - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - } - /** * @param marsh Marshaller. * @throws IgniteCheckedException In case of error. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java index 7f87da3..24b887f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java @@ -107,24 +107,6 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - IgfsDeleteMessage _clone = (IgfsDeleteMessage)_msg; - - _clone.id = id; - _clone.err = err; - _clone.errBytes = errBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -157,7 +139,6 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java index 5eef175..2b9aaae 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java @@ -263,24 +263,6 @@ public class IgfsFileAffinityRange extends MessageAdapter implements Externaliza } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - IgfsFileAffinityRange _clone = (IgfsFileAffinityRange)_msg; - - _clone.affKey = affKey; - _clone.status = status; - _clone.startOff = startOff; - _clone.endOff = endOff; - _clone.done = done; - } - - /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -328,7 +310,6 @@ public class IgfsFileAffinityRange extends MessageAdapter implements Externaliza } /** {@inheritDoc} */ - @SuppressWarnings("fallthrough") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java index 21a3cf1..dc12d21 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java @@ -79,23 +79,6 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - IgfsFragmentizerRequest _clone = (IgfsFragmentizerRequest)_msg; - - _clone.fileId = fileId; - _clone.fragmentRanges = fragmentRanges; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -128,7 +111,6 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java index 01dfa70..7ab4e02 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java @@ -55,22 +55,6 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - IgfsFragmentizerResponse _clone = (IgfsFragmentizerResponse)_msg; - - _clone.fileId = fileId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -97,7 +81,6 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java index dc0ff29..e4123d0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java @@ -72,23 +72,6 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - IgfsSyncMessage _clone = (IgfsSyncMessage)_msg; - - _clone.order = order; - _clone.res = res; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -121,7 +104,6 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java index c4bbc09..8369828 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java @@ -99,22 +99,6 @@ public class GridTaskResultRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridTaskResultRequest _clone = (GridTaskResultRequest)_msg; - - _clone.taskId = taskId; - _clone.topic = topic; - _clone.topicBytes = topicBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -144,7 +128,6 @@ public class GridTaskResultRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java index ce0bd41..68f5afa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java @@ -117,24 +117,6 @@ public class GridTaskResultResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridTaskResultResponse _clone = (GridTaskResultResponse)_msg; - - _clone.res = res; - _clone.resBytes = resBytes; - _clone.finished = finished; - _clone.found = found; - _clone.err = err; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -176,7 +158,6 @@ public class GridTaskResultResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java index 2c8b7db..2fbdd68 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java @@ -55,20 +55,6 @@ public class GridStreamerCancelRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridStreamerCancelRequest _clone = (GridStreamerCancelRequest)_msg; - - _clone.cancelledFutId = cancelledFutId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -92,7 +78,6 @@ public class GridStreamerCancelRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java index c526858..be731d3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java @@ -150,26 +150,6 @@ public class GridStreamerExecutionRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridStreamerExecutionRequest _clone = (GridStreamerExecutionRequest)_msg; - - _clone.forceLocDep = forceLocDep; - _clone.batchBytes = batchBytes; - _clone.depMode = depMode; - _clone.sampleClsName = sampleClsName; - _clone.userVer = userVer; - _clone.ldrParticipants = ldrParticipants; - _clone.clsLdrId = clsLdrId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -229,7 +209,6 @@ public class GridStreamerExecutionRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java index 78883aa..ff41bc9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java @@ -75,21 +75,6 @@ public class GridStreamerResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridStreamerResponse _clone = (GridStreamerResponse)_msg; - - _clone.futId = futId; - _clone.errBytes = errBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -119,7 +104,6 @@ public class GridStreamerResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java index 3399082..84b07a4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java @@ -467,20 +467,6 @@ public class GridByteArrayList extends MessageAdapter implements Externalizable } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridByteArrayList _clone = (GridByteArrayList)_msg; - - _clone.data = data; - _clone.size = size; - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridByteArrayList.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java index 2b89232..8a9fc6c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java @@ -563,18 +563,4 @@ public class GridLongList extends MessageAdapter implements Externalizable { @Override public byte directType() { return 85; } - - /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridLongList _clone = (GridLongList)_msg; - - _clone.arr = arr; - _clone.idx = idx; - } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java index c31c2e9..2b3cfc4 100644 --- a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java @@ -23,7 +23,7 @@ import java.nio.*; /** * Base class for all communication messages. */ -public abstract class MessageAdapter implements Serializable, Cloneable { +public abstract class MessageAdapter implements Serializable { /** Message reader. */ protected MessageReader reader; @@ -64,17 +64,6 @@ public abstract class MessageAdapter implements Serializable, Cloneable { */ public abstract byte directType(); - /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntDeclareCloneNotSupportedException") - @Override public abstract MessageAdapter clone(); - - /** - * Clones all fields of the provided message to this message. - * - * @param msg Message to clone from. - */ - protected abstract void clone0(MessageAdapter msg); - /** * Defines whether recovery for this message should be skipped. * @@ -85,49 +74,70 @@ public abstract class MessageAdapter implements Serializable, Cloneable { } /** - * TODO + * Enum representing possible field types. */ public enum Type { + /** Byte. */ BYTE, + /** Short. */ SHORT, + /** Integer. */ INT, + /** Long. */ LONG, + /** Float. */ FLOAT, + /** Double. */ DOUBLE, + /** Character. */ CHAR, + /** Boolean. */ BOOLEAN, + /** Byte array. */ BYTE_ARR, + /** Short array. */ SHORT_ARR, + /** Integer array. */ INT_ARR, + /** Long array. */ LONG_ARR, + /** Float array. */ FLOAT_ARR, + /** Double array. */ DOUBLE_ARR, + /** Character array. */ CHAR_ARR, + /** Boolean array. */ BOOLEAN_ARR, + /** String. */ STRING, + /** Bit set. */ BIT_SET, + /** UUID. */ UUID, + /** Ignite UUID. */ IGNITE_UUID, + /** Message. */ MSG } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java index c49df8f..16e2327 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java @@ -55,20 +55,6 @@ public class JobStealingRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - JobStealingRequest _clone = (JobStealingRequest)_msg; - - _clone.delta = delta; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -92,7 +78,6 @@ public class JobStealingRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index 6ddb15b..959d094 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -3079,17 +3079,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter msg) { - // No-op. - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(HandshakeMessage.class, this); } @@ -3155,17 +3144,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter msg) { - // No-op. - } - - /** {@inheritDoc} */ @Override public boolean skipRecovery() { return true; } @@ -3239,17 +3217,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - // No-op. - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(NodeIdMessage.class, this); }
