ignite-nio - Removing message clone
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/dd79c9bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dd79c9bf Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dd79c9bf Branch: refs/heads/sprint-1 Commit: dd79c9bfee31281dcbfb1573cca2f3ca41f4b886 Parents: e63ce52 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Sat Feb 14 21:50:02 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Sat Feb 14 21:50:02 2015 -0800 ---------------------------------------------------------------------- .../ignite/internal/GridJobCancelRequest.java | 17 -------- .../ignite/internal/GridJobExecuteRequest.java | 40 ------------------ .../ignite/internal/GridJobExecuteResponse.java | 25 ------------ .../ignite/internal/GridJobSiblingsRequest.java | 17 -------- .../internal/GridJobSiblingsResponse.java | 16 -------- .../ignite/internal/GridTaskCancelRequest.java | 15 ------- .../ignite/internal/GridTaskSessionRequest.java | 18 -------- .../checkpoint/GridCheckpointRequest.java | 17 -------- .../managers/communication/GridIoMessage.java | 23 ----------- .../communication/GridIoUserMessage.java | 24 ----------- .../deployment/GridDeploymentInfoBean.java | 19 --------- .../deployment/GridDeploymentRequest.java | 20 --------- .../deployment/GridDeploymentResponse.java | 17 -------- .../eventstorage/GridEventStorageMessage.java | 26 ------------ .../cache/GridCacheEvictionRequest.java | 20 --------- .../cache/GridCacheEvictionResponse.java | 20 --------- .../processors/cache/GridCacheMessage.java | 13 ------ .../processors/cache/GridCacheValueBytes.java | 14 ------- ...idCacheOptimisticCheckPreparedTxRequest.java | 21 ---------- ...dCacheOptimisticCheckPreparedTxResponse.java | 19 --------- ...CachePessimisticCheckCommittedTxRequest.java | 23 ----------- ...achePessimisticCheckCommittedTxResponse.java | 21 ---------- .../distributed/GridCacheTtlUpdateRequest.java | 22 ---------- .../distributed/GridDistributedBaseMessage.java | 18 -------- .../distributed/GridDistributedLockRequest.java | 37 ----------------- .../GridDistributedLockResponse.java | 22 ---------- .../GridDistributedTxFinishRequest.java | 33 --------------- .../GridDistributedTxFinishResponse.java | 19 --------- .../GridDistributedTxPrepareRequest.java | 36 ---------------- .../GridDistributedTxPrepareResponse.java | 21 ---------- .../GridDistributedUnlockRequest.java | 19 --------- .../dht/GridDhtAffinityAssignmentRequest.java | 15 ------- .../dht/GridDhtAffinityAssignmentResponse.java | 22 ++-------- .../distributed/dht/GridDhtLockRequest.java | 27 ------------ .../distributed/dht/GridDhtLockResponse.java | 22 ---------- .../distributed/dht/GridDhtTxFinishRequest.java | 30 -------------- .../dht/GridDhtTxFinishResponse.java | 17 -------- .../dht/GridDhtTxPrepareRequest.java | 30 -------------- .../dht/GridDhtTxPrepareResponse.java | 23 ----------- .../distributed/dht/GridDhtUnlockRequest.java | 18 -------- .../GridDhtAtomicDeferredUpdateResponse.java | 17 -------- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 43 -------------------- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 23 ----------- .../dht/atomic/GridNearAtomicUpdateRequest.java | 41 ------------------- .../atomic/GridNearAtomicUpdateResponse.java | 33 --------------- .../dht/preloader/GridDhtForceKeysRequest.java | 21 ---------- .../dht/preloader/GridDhtForceKeysResponse.java | 22 ---------- .../GridDhtPartitionDemandMessage.java | 23 ----------- .../preloader/GridDhtPartitionExchangeId.java | 15 ------- .../GridDhtPartitionSupplyMessage.java | 25 ------------ .../GridDhtPartitionsAbstractMessage.java | 12 ------ .../preloader/GridDhtPartitionsFullMessage.java | 19 --------- .../GridDhtPartitionsSingleMessage.java | 18 -------- .../GridDhtPartitionsSingleRequest.java | 14 ------- .../distributed/near/GridNearGetRequest.java | 28 ------------- .../distributed/near/GridNearGetResponse.java | 25 ------------ .../distributed/near/GridNearLockRequest.java | 29 ------------- .../distributed/near/GridNearLockResponse.java | 21 ---------- .../near/GridNearTxFinishRequest.java | 22 ---------- .../near/GridNearTxFinishResponse.java | 20 --------- .../near/GridNearTxPrepareRequest.java | 24 ----------- .../near/GridNearTxPrepareResponse.java | 23 ----------- .../distributed/near/GridNearUnlockRequest.java | 14 ------- .../cache/query/GridCacheQueryRequest.java | 40 ------------------ .../cache/query/GridCacheQueryResponse.java | 25 ------------ .../cache/version/GridCacheVersion.java | 16 -------- .../clock/GridClockDeltaSnapshotMessage.java | 16 -------- .../processors/clock/GridClockDeltaVersion.java | 14 ------- .../continuous/GridContinuousMessage.java | 19 --------- .../dataload/GridDataLoadRequest.java | 24 ----------- .../dataload/GridDataLoadResponse.java | 17 -------- .../processors/igfs/IgfsAckMessage.java | 20 --------- .../internal/processors/igfs/IgfsBlockKey.java | 18 -------- .../processors/igfs/IgfsBlocksMessage.java | 19 --------- .../igfs/IgfsCommunicationMessage.java | 4 -- .../processors/igfs/IgfsDeleteMessage.java | 19 --------- .../processors/igfs/IgfsFileAffinityRange.java | 19 --------- .../igfs/IgfsFragmentizerRequest.java | 18 -------- .../igfs/IgfsFragmentizerResponse.java | 17 -------- .../processors/igfs/IgfsSyncMessage.java | 18 -------- .../handlers/task/GridTaskResultRequest.java | 17 -------- .../handlers/task/GridTaskResultResponse.java | 19 --------- .../streamer/GridStreamerCancelRequest.java | 15 ------- .../streamer/GridStreamerExecutionRequest.java | 21 ---------- .../streamer/GridStreamerResponse.java | 16 -------- .../ignite/internal/util/GridByteArrayList.java | 14 ------- .../ignite/internal/util/GridLongList.java | 14 ------- .../communication/MessageAdapter.java | 36 ++++++++++------ .../jobstealing/JobStealingRequest.java | 15 ------- .../communication/tcp/TcpCommunicationSpi.java | 33 --------------- .../GridCommunicationSendMessageSelfTest.java | 11 ----- .../communication/GridIoManagerSelfTest.java | 11 ----- .../communication/GridTestMessage.java | 11 ----- .../spi/communication/GridTestMessage.java | 22 ---------- 94 files changed, 26 insertions(+), 1960 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java index 3cbd5e1..4f9baff 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java @@ -110,22 +110,6 @@ public class GridJobCancelRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridJobCancelRequest _clone = (GridJobCancelRequest)_msg; - - _clone.sesId = sesId; - _clone.jobId = jobId; - _clone.sys = sys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -161,7 +145,6 @@ public class GridJobCancelRequest 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/GridJobExecuteRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java index eb928ac..4a961a2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java @@ -412,45 +412,6 @@ public class GridJobExecuteRequest extends MessageAdapter implements GridTaskMes } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridJobExecuteRequest _clone = (GridJobExecuteRequest)_msg; - - _clone.subjId = subjId; - _clone.sesId = sesId; - _clone.jobId = jobId; - _clone.jobBytes = jobBytes; - _clone.job = job; - _clone.startTaskTime = startTaskTime; - _clone.timeout = timeout; - _clone.taskName = taskName; - _clone.userVer = userVer; - _clone.taskClsName = taskClsName; - _clone.ldrParticipants = ldrParticipants; - _clone.sesAttrsBytes = sesAttrsBytes; - _clone.sesAttrs = sesAttrs; - _clone.jobAttrsBytes = jobAttrsBytes; - _clone.jobAttrs = jobAttrs; - _clone.cpSpi = cpSpi; - _clone.siblings = siblings; - _clone.siblingsBytes = siblingsBytes; - _clone.createTime = createTime; - _clone.clsLdrId = clsLdrId; - _clone.depMode = depMode; - _clone.dynamicSiblings = dynamicSiblings; - _clone.forceLocDep = forceLocDep; - _clone.sesFullSup = sesFullSup; - _clone.internal = internal; - _clone.top = top; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -594,7 +555,6 @@ public class GridJobExecuteRequest extends MessageAdapter implements GridTaskMes } /** {@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/GridJobExecuteResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java index 499cc58..fb0f72d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java @@ -205,30 +205,6 @@ public class GridJobExecuteResponse extends MessageAdapter implements GridTaskMe } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridJobExecuteResponse _clone = (GridJobExecuteResponse)_msg; - - _clone.nodeId = nodeId; - _clone.sesId = sesId; - _clone.jobId = jobId; - _clone.gridExBytes = gridExBytes; - _clone.gridEx = gridEx; - _clone.resBytes = resBytes; - _clone.res = res; - _clone.jobAttrsBytes = jobAttrsBytes; - _clone.jobAttrs = jobAttrs; - _clone.isCancelled = isCancelled; - _clone.fakeEx = fakeEx; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -288,7 +264,6 @@ public class GridJobExecuteResponse extends MessageAdapter implements GridTaskMe } /** {@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/GridJobSiblingsRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java index d919b50..6ef7102 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java @@ -84,22 +84,6 @@ public class GridJobSiblingsRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridJobSiblingsRequest _clone = (GridJobSiblingsRequest)_msg; - - _clone.sesId = sesId; - _clone.topic = topic; - _clone.topicBytes = topicBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -129,7 +113,6 @@ public class GridJobSiblingsRequest 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/GridJobSiblingsResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java index e463756..77032fc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java @@ -77,21 +77,6 @@ public class GridJobSiblingsResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridJobSiblingsResponse _clone = (GridJobSiblingsResponse)_msg; - - _clone.siblings = siblings; - _clone.siblingsBytes = siblingsBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -115,7 +100,6 @@ public class GridJobSiblingsResponse 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/GridTaskCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java index d0a9afb..2501522 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java @@ -61,20 +61,6 @@ public class GridTaskCancelRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridTaskCancelRequest _clone = (GridTaskCancelRequest)_msg; - - _clone.sesId = sesId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -98,7 +84,6 @@ public class GridTaskCancelRequest 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/GridTaskSessionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java index 09be112..214c2f1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java @@ -98,23 +98,6 @@ public class GridTaskSessionRequest extends MessageAdapter implements GridTaskMe } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridTaskSessionRequest _clone = (GridTaskSessionRequest)_msg; - - _clone.sesId = sesId; - _clone.jobId = jobId; - _clone.attrsBytes = attrsBytes; - _clone.attrs = attrs; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -150,7 +133,6 @@ public class GridTaskSessionRequest extends MessageAdapter implements GridTaskMe } /** {@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/managers/checkpoint/GridCheckpointRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java index e34879b..9962c1f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java @@ -84,22 +84,6 @@ public class GridCheckpointRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridCheckpointRequest _clone = (GridCheckpointRequest)_msg; - - _clone.sesId = sesId; - _clone.key = key; - _clone.cpSpi = cpSpi; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -135,7 +119,6 @@ public class GridCheckpointRequest 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/managers/communication/GridIoMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java index c2ce71c..a74850f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java @@ -179,28 +179,6 @@ public class GridIoMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @SuppressWarnings("RedundantCast") - @Override protected void clone0(MessageAdapter _msg) { - GridIoMessage _clone = (GridIoMessage)_msg; - - _clone.plc = plc; - _clone.topic = topic; - _clone.topicBytes = topicBytes; - _clone.topicOrd = topicOrd; - _clone.ordered = ordered; - _clone.timeout = timeout; - _clone.skipOnTimeout = skipOnTimeout; - _clone.msg = msg != null ? (MessageAdapter)msg.clone() : null; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -260,7 +238,6 @@ public class GridIoMessage 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/managers/communication/GridIoUserMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java index 20a8194..059f836 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java @@ -203,29 +203,6 @@ public class GridIoUserMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridIoUserMessage _clone = (GridIoUserMessage)_msg; - - _clone.body = body; - _clone.bodyBytes = bodyBytes; - _clone.clsLdrId = clsLdrId; - _clone.topic = topic; - _clone.topicBytes = topicBytes; - _clone.depMode = depMode; - _clone.depClsName = depClsName; - _clone.userVer = userVer; - _clone.ldrParties = ldrParties; - _clone.dep = dep; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -285,7 +262,6 @@ public class GridIoUserMessage 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/managers/deployment/GridDeploymentInfoBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java index 3f3b4ed..16ccaab 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java @@ -138,24 +138,6 @@ public class GridDeploymentInfoBean extends MessageAdapter implements GridDeploy } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridDeploymentInfoBean _clone = (GridDeploymentInfoBean)_msg; - - _clone.clsLdrId = clsLdrId; - _clone.depMode = depMode; - _clone.userVer = userVer; - _clone.locDepOwner = locDepOwner; - _clone.participants = participants; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -203,7 +185,6 @@ public class GridDeploymentInfoBean extends MessageAdapter implements GridDeploy } /** {@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/managers/deployment/GridDeploymentRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java index 03338a1..0d2dc9a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java @@ -156,25 +156,6 @@ public class GridDeploymentRequest extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridDeploymentRequest _clone = (GridDeploymentRequest)_msg; - - _clone.resTopic = resTopic; - _clone.resTopicBytes = resTopicBytes; - _clone.rsrcName = rsrcName; - _clone.ldrId = ldrId; - _clone.isUndeploy = isUndeploy; - _clone.nodeIds = nodeIds; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -222,7 +203,6 @@ public class GridDeploymentRequest 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/managers/deployment/GridDeploymentResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java index 0538b3b..093f7d4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java @@ -106,22 +106,6 @@ public class GridDeploymentResponse extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridDeploymentResponse _clone = (GridDeploymentResponse)_msg; - - _clone.success = success; - _clone.errMsg = errMsg; - _clone.byteSrc = byteSrc != null ? (GridByteArrayList)byteSrc.clone() : null; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -157,7 +141,6 @@ public class GridDeploymentResponse 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/managers/eventstorage/GridEventStorageMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java index 2748d75..9c51332 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java @@ -261,31 +261,6 @@ public class GridEventStorageMessage extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridEventStorageMessage _clone = (GridEventStorageMessage)_msg; - - _clone.resTopic = resTopic; - _clone.resTopicBytes = resTopicBytes; - _clone.filter = filter; - _clone.evts = evts; - _clone.evtsBytes = evtsBytes; - _clone.ex = ex; - _clone.exBytes = exBytes; - _clone.clsLdrId = clsLdrId; - _clone.depMode = depMode; - _clone.filterClsName = filterClsName; - _clone.userVer = userVer; - _clone.ldrParties = ldrParties; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -357,7 +332,6 @@ public class GridEventStorageMessage 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/cache/GridCacheEvictionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java index aae0e94..23c1306 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java @@ -140,25 +140,6 @@ public class GridCacheEvictionRequest<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); - - GridCacheEvictionRequest _clone = (GridCacheEvictionRequest)_msg; - - _clone.futId = futId; - _clone.entries = entries; - _clone.entriesBytes = entriesBytes; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -197,7 +178,6 @@ public class GridCacheEvictionRequest<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/GridCacheEvictionResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java index 650b5c9..1e8fe58 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java @@ -129,25 +129,6 @@ public class GridCacheEvictionResponse<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); - - GridCacheEvictionResponse _clone = (GridCacheEvictionResponse)_msg; - - _clone.futId = futId; - _clone.rejectedKeys = rejectedKeys; - _clone.rejectedKeyBytes = rejectedKeyBytes; - _clone.err = err; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -186,7 +167,6 @@ public class GridCacheEvictionResponse<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/GridCacheMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java index 3f95081..839031b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java @@ -646,18 +646,6 @@ public abstract class GridCacheMessage<K, V> extends MessageAdapter { } /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridCacheMessage _clone = (GridCacheMessage)_msg; - - _clone.msgId = msgId; - _clone.depInfo = depInfo != null ? (GridDeploymentInfoBean)depInfo.clone() : null; - _clone.err = err; - _clone.skipPrepare = skipPrepare; - _clone.cacheId = cacheId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -693,7 +681,6 @@ public abstract class GridCacheMessage<K, V> 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/cache/GridCacheValueBytes.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java index 426b1e8..dd30b5a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java @@ -180,20 +180,6 @@ public class GridCacheValueBytes extends MessageAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - GridCacheValueBytes _clone = (GridCacheValueBytes)_msg; - - _clone.bytes = bytes; - _clone.plain = plain; - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheValueBytes.class, this, "len", bytes != null ? bytes.length : -1); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java index 8b30254..d6f175e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java @@ -110,26 +110,6 @@ public class GridCacheOptimisticCheckPreparedTxRequest<K, V> extends GridDistrib } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCacheOptimisticCheckPreparedTxRequest _clone = (GridCacheOptimisticCheckPreparedTxRequest)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.nearXidVer = nearXidVer != null ? (GridCacheVersion)nearXidVer.clone() : null; - _clone.txNum = txNum; - _clone.sys = sys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -180,7 +160,6 @@ public class GridCacheOptimisticCheckPreparedTxRequest<K, V> extends GridDistrib } /** {@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/GridCacheOptimisticCheckPreparedTxResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java index 24a099a..0168398 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java @@ -85,24 +85,6 @@ public class GridCacheOptimisticCheckPreparedTxResponse<K, V> extends GridDistri } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCacheOptimisticCheckPreparedTxResponse _clone = (GridCacheOptimisticCheckPreparedTxResponse)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.success = success; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -141,7 +123,6 @@ public class GridCacheOptimisticCheckPreparedTxResponse<K, V> extends GridDistri } /** {@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/GridCachePessimisticCheckCommittedTxRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxRequest.java index 9d920ba..b25f290 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxRequest.java @@ -140,28 +140,6 @@ public class GridCachePessimisticCheckCommittedTxRequest<K, V> extends GridDistr } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCachePessimisticCheckCommittedTxRequest _clone = (GridCachePessimisticCheckCommittedTxRequest)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.nearXidVer = nearXidVer != null ? (GridCacheVersion)nearXidVer.clone() : null; - _clone.originatingNodeId = originatingNodeId; - _clone.originatingThreadId = originatingThreadId; - _clone.nearOnlyCheck = nearOnlyCheck; - _clone.sys = sys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -224,7 +202,6 @@ public class GridCachePessimisticCheckCommittedTxRequest<K, V> extends GridDistr } /** {@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/GridCachePessimisticCheckCommittedTxResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxResponse.java index bfe1b12..69682cb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePessimisticCheckCommittedTxResponse.java @@ -128,26 +128,6 @@ public class GridCachePessimisticCheckCommittedTxResponse<K, V> extends GridDist } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCachePessimisticCheckCommittedTxResponse _clone = (GridCachePessimisticCheckCommittedTxResponse)_msg; - - _clone.futId = futId; - _clone.miniId = miniId; - _clone.committedTxInfo = committedTxInfo; - _clone.committedTxInfoBytes = committedTxInfoBytes; - _clone.sys = sys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -192,7 +172,6 @@ public class GridCachePessimisticCheckCommittedTxResponse<K, V> extends GridDist } /** {@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/GridCacheTtlUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java index 69b929e..b0aa291 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java @@ -187,12 +187,6 @@ public class GridCacheTtlUpdateRequest<K, V> extends GridCacheMessage<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("CloneDoesntCallSuperClone") - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -310,22 +304,6 @@ public class GridCacheTtlUpdateRequest<K, V> extends GridCacheMessage<K, V> { } /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridCacheTtlUpdateRequest _clone = (GridCacheTtlUpdateRequest)_msg; - - _clone.keys = keys; - _clone.keysBytes = keysBytes; - _clone.vers = vers; - _clone.nearKeys = nearKeys; - _clone.nearKeysBytes = nearKeysBytes; - _clone.nearVers = nearVers; - _clone.ttl = ttl; - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheTtlUpdateRequest.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd79c9bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java index 158ff03..a7d5819 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java @@ -240,23 +240,6 @@ public abstract class GridDistributedBaseMessage<K, V> extends GridCacheMessage< } /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedBaseMessage _clone = (GridDistributedBaseMessage)_msg; - - _clone.ver = ver != null ? (GridCacheVersion)ver.clone() : null; - _clone.candsByIdx = candsByIdx; - _clone.candsByIdxBytes = candsByIdxBytes; - _clone.candsByKey = candsByKey; - _clone.candsByKeyBytes = candsByKeyBytes; - _clone.committedVers = committedVers; - _clone.rolledbackVers = rolledbackVers; - _clone.cnt = cnt; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -307,7 +290,6 @@ public abstract class GridDistributedBaseMessage<K, V> extends GridCacheMessage< } /** {@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/GridDistributedLockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java index 6d4d6f6..e144279 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java @@ -426,42 +426,6 @@ public class GridDistributedLockRequest<K, V> extends GridDistributedBaseMessage } /** {@inheritDoc} */ - @SuppressWarnings({"CloneCallsConstructors", "OverriddenMethodCallDuringObjectConstruction", - "CloneDoesntCallSuperClone"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedLockRequest _clone = (GridDistributedLockRequest)_msg; - - _clone.nodeId = nodeId; - _clone.nearXidVer = nearXidVer != null ? (GridCacheVersion)nearXidVer.clone() : null; - _clone.threadId = threadId; - _clone.futId = futId; - _clone.timeout = timeout; - _clone.isInTx = isInTx; - _clone.isInvalidate = isInvalidate; - _clone.isRead = isRead; - _clone.isolation = isolation; - _clone.keyBytes = keyBytes; - _clone.keys = keys; - _clone.writeEntries = writeEntries; - _clone.writeEntriesBytes = writeEntriesBytes; - _clone.retVals = retVals; - _clone.idx = idx; - _clone.txSize = txSize; - _clone.grpLockKey = grpLockKey; - _clone.grpLockKeyBytes = grpLockKeyBytes; - _clone.partLock = partLock; - _clone.drVersByIdx = drVersByIdx; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -578,7 +542,6 @@ public class GridDistributedLockRequest<K, V> extends GridDistributedBaseMessage } /** {@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/GridDistributedLockResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java index 7ac8041..ee993eb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java @@ -277,27 +277,6 @@ public class GridDistributedLockResponse<K, V> extends GridDistributedBaseMessag } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors", - "OverriddenMethodCallDuringObjectConstruction"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedLockResponse _clone = (GridDistributedLockResponse)_msg; - - _clone.futId = futId; - _clone.err = err; - _clone.errBytes = errBytes; - _clone.valBytes = valBytes; - _clone.vals = vals; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -336,7 +315,6 @@ public class GridDistributedLockResponse<K, V> extends GridDistributedBaseMessag } /** {@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/GridDistributedTxFinishRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java index 5688cfc..30ad331 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java @@ -344,38 +344,6 @@ public class GridDistributedTxFinishRequest<K, V> extends GridDistributedBaseMes } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors", - "OverriddenMethodCallDuringObjectConstruction"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedTxFinishRequest _clone = (GridDistributedTxFinishRequest)_msg; - - _clone.futId = futId; - _clone.threadId = threadId; - _clone.commitVer = commitVer != null ? (GridCacheVersion)commitVer.clone() : null; - _clone.invalidate = invalidate; - _clone.commit = commit; - _clone.syncCommit = syncCommit; - _clone.syncRollback = syncRollback; - _clone.baseVer = baseVer != null ? (GridCacheVersion)baseVer.clone() : null; - _clone.writeEntries = writeEntries; - _clone.writeEntriesBytes = writeEntriesBytes; - _clone.recoveryWrites = recoveryWrites; - _clone.recoveryWritesBytes = recoveryWritesBytes; - _clone.txSize = txSize; - _clone.grpLockKey = grpLockKey; - _clone.grpLockKeyBytes = grpLockKeyBytes; - _clone.sys = sys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -474,7 +442,6 @@ public class GridDistributedTxFinishRequest<K, V> extends GridDistributedBaseMes } /** {@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/GridDistributedTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java index 2d63664..8d21c0e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java @@ -74,24 +74,6 @@ public class GridDistributedTxFinishResponse<K, V> extends GridCacheMessage<K, V } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors", - "OverriddenMethodCallDuringObjectConstruction"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedTxFinishResponse _clone = (GridDistributedTxFinishResponse)_msg; - - _clone.txId = txId != null ? (GridCacheVersion)txId.clone() : null; - _clone.futId = futId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -124,7 +106,6 @@ public class GridDistributedTxFinishResponse<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/GridDistributedTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java index 97b36e6..41a55ba 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java @@ -402,41 +402,6 @@ public class GridDistributedTxPrepareRequest<K, V> extends GridDistributedBaseMe } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors", - "OverriddenMethodCallDuringObjectConstruction"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedTxPrepareRequest _clone = (GridDistributedTxPrepareRequest)_msg; - - _clone.threadId = threadId; - _clone.concurrency = concurrency; - _clone.isolation = isolation; - _clone.commitVer = commitVer != null ? (GridCacheVersion)commitVer.clone() : null; - _clone.timeout = timeout; - _clone.invalidate = invalidate; - _clone.reads = reads; - _clone.readsBytes = readsBytes; - _clone.writes = writes; - _clone.writesBytes = writesBytes; - _clone.dhtVers = dhtVers; - _clone.dhtVersBytes = dhtVersBytes; - _clone.grpLockKey = grpLockKey; - _clone.grpLockKeyBytes = grpLockKeyBytes; - _clone.partLock = partLock; - _clone.txSize = txSize; - _clone.txNodes = txNodes; - _clone.txNodesBytes = txNodesBytes; - _clone.sys = sys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -541,7 +506,6 @@ public class GridDistributedTxPrepareRequest<K, V> extends GridDistributedBaseMe } /** {@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/GridDistributedTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java index 72bd333..c8576a1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java @@ -149,26 +149,6 @@ public class GridDistributedTxPrepareResponse<K, V> extends GridDistributedBaseM } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors", - "OverriddenMethodCallDuringObjectConstruction"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedTxPrepareResponse _clone = (GridDistributedTxPrepareResponse)_msg; - - _clone.cands = cands; - _clone.candsBytes = candsBytes; - _clone.err = err; - _clone.errBytes = errBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -201,7 +181,6 @@ public class GridDistributedTxPrepareResponse<K, V> extends GridDistributedBaseM } /** {@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/GridDistributedUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java index 6d18edb..694c30c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java @@ -115,24 +115,6 @@ public class GridDistributedUnlockRequest<K, V> extends GridDistributedBaseMessa } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors", - "OverriddenMethodCallDuringObjectConstruction"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDistributedUnlockRequest _clone = (GridDistributedUnlockRequest)_msg; - - _clone.keyBytes = keyBytes; - _clone.keys = keys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -159,7 +141,6 @@ public class GridDistributedUnlockRequest<K, V> extends GridDistributedBaseMessa } /** {@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/GridDhtAffinityAssignmentRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java index fde5bdd..7a2d68c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java @@ -67,21 +67,6 @@ public class GridDhtAffinityAssignmentRequest<K, V> extends GridCacheMessage<K, } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtAffinityAssignmentRequest _clone = (GridDhtAffinityAssignmentRequest)_msg; - - _clone.topVer = topVer; - } - - /** {@inheritDoc} */ @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.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/GridDhtAffinityAssignmentResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java index dfff328..ea797f8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java @@ -88,25 +88,9 @@ public class GridDhtAffinityAssignmentResponse<K, V> extends GridCacheMessage<K, return 29; } - /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtAffinityAssignmentResponse _clone = (GridDhtAffinityAssignmentResponse)_msg; - - _clone.topVer = topVer; - _clone.affAssignment = affAssignment; - _clone.affAssignmentBytes = affAssignmentBytes; - } - - /** {@inheritDoc} - * @param ctx*/ + /** + * @param ctx Context. + */ @Override public void prepareMarshal(GridCacheSharedContext<K, V> ctx) throws IgniteCheckedException { super.prepareMarshal(ctx); 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/GridDhtLockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java index ad1538f..342d4b7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java @@ -341,32 +341,6 @@ public class GridDhtLockRequest<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); - - GridDhtLockRequest _clone = (GridDhtLockRequest)_msg; - - _clone.nearKeys = nearKeys; - _clone.nearKeyBytes = nearKeyBytes; - _clone.invalidateEntries = invalidateEntries; - _clone.miniId = miniId; - _clone.owned = owned; - _clone.ownedBytes = ownedBytes; - _clone.topVer = topVer; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - _clone.preloadKeys = preloadKeys; - _clone.accessTtl = accessTtl; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -441,7 +415,6 @@ public class GridDhtLockRequest<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/dht/GridDhtLockResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java index d9c7465..409dbb6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java @@ -199,27 +199,6 @@ public class GridDhtLockResponse<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); - - GridDhtLockResponse _clone = (GridDhtLockResponse)_msg; - - _clone.nearEvicted = nearEvicted; - _clone.nearEvictedBytes = nearEvictedBytes; - _clone.miniId = miniId; - _clone.invalidParts = invalidParts; - _clone.preloadEntries = preloadEntries; - _clone.preloadEntriesBytes = preloadEntriesBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -264,7 +243,6 @@ public class GridDhtLockResponse<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/dht/GridDhtTxFinishRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java index 5d7fc33..28d60ac 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java @@ -348,35 +348,6 @@ public class GridDhtTxFinishRequest<K, V> extends GridDistributedTxFinishRequest } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtTxFinishRequest _clone = (GridDhtTxFinishRequest)_msg; - - _clone.nearNodeId = nearNodeId; - _clone.isolation = isolation; - _clone.nearWrites = nearWrites; - _clone.nearWritesBytes = nearWritesBytes; - _clone.miniId = miniId; - _clone.sysInvalidate = sysInvalidate; - _clone.topVer = topVer; - _clone.pendingVers = pendingVers; - _clone.onePhaseCommit = onePhaseCommit; - _clone.writeVer = writeVer != null ? (GridCacheVersion)writeVer.clone() : null; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - _clone.ttls = ttls != null ? (GridLongList)ttls.clone() : null; - _clone.nearTtls = nearTtls != null ? (GridLongList)nearTtls.clone() : null; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -475,7 +446,6 @@ public class GridDhtTxFinishRequest<K, V> extends GridDistributedTxFinishRequest } /** {@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/GridDhtTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java index 045295e..c2595c8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java @@ -69,22 +69,6 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtTxFinishResponse _clone = (GridDhtTxFinishResponse)_msg; - - _clone.miniId = miniId; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -111,7 +95,6 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon } /** {@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/GridDhtTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java index 6fdbcb2..0439a23 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java @@ -312,35 +312,6 @@ public class GridDhtTxPrepareRequest<K, V> extends GridDistributedTxPrepareReque } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtTxPrepareRequest _clone = (GridDhtTxPrepareRequest)_msg; - - _clone.nearNodeId = nearNodeId; - _clone.futId = futId; - _clone.miniId = miniId; - _clone.topVer = topVer; - _clone.invalidateNearEntries = invalidateNearEntries; - _clone.nearWrites = nearWrites; - _clone.nearWritesBytes = nearWritesBytes; - _clone.owned = owned; - _clone.ownedBytes = ownedBytes; - _clone.nearXidVer = nearXidVer != null ? (GridCacheVersion)nearXidVer.clone() : null; - _clone.last = last; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - _clone.preloadKeys = preloadKeys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -433,7 +404,6 @@ public class GridDhtTxPrepareRequest<K, V> extends GridDistributedTxPrepareReque } /** {@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/GridDhtTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java index 266a536..ca92980 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java @@ -205,28 +205,6 @@ public class GridDhtTxPrepareResponse<K, V> extends GridDistributedTxPrepareResp } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtTxPrepareResponse _clone = (GridDhtTxPrepareResponse)_msg; - - _clone.nearEvicted = nearEvicted; - _clone.nearEvictedBytes = nearEvictedBytes; - _clone.futId = futId; - _clone.miniId = miniId; - _clone.invalidParts = invalidParts; - _clone.preloadEntries = preloadEntries; - _clone.preloadEntriesBytes = preloadEntriesBytes; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -277,7 +255,6 @@ public class GridDhtTxPrepareResponse<K, V> extends GridDistributedTxPrepareResp } /** {@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/GridDhtUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java index 1a0f1af..a9d035f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java @@ -104,23 +104,6 @@ public class GridDhtUnlockRequest<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); - - GridDhtUnlockRequest _clone = (GridDhtUnlockRequest)_msg; - - _clone.nearKeyBytes = nearKeyBytes; - _clone.nearKeys = nearKeys; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -147,7 +130,6 @@ public class GridDhtUnlockRequest<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/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java index c765ed6..f8e60c0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java @@ -73,22 +73,6 @@ public class GridDhtAtomicDeferredUpdateResponse<K, V> extends GridCacheMessage< } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtAtomicDeferredUpdateResponse _clone = (GridDhtAtomicDeferredUpdateResponse)_msg; - - _clone.futVers = futVers; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -115,7 +99,6 @@ public class GridDhtAtomicDeferredUpdateResponse<K, V> extends GridCacheMessage< } /** {@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/GridDhtAtomicUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java index f65de25..7e4413a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java @@ -681,48 +681,6 @@ public class GridDhtAtomicUpdateRequest<K, V> extends GridCacheMessage<K, V> imp } /** {@inheritDoc} */ - @SuppressWarnings({"CloneDoesntCallSuperClone", "CloneCallsConstructors"}) - @Override public MessageAdapter clone() { - throw new UnsupportedOperationException(); - } - - /** {@inheritDoc} */ - @Override protected void clone0(MessageAdapter _msg) { - super.clone0(_msg); - - GridDhtAtomicUpdateRequest _clone = (GridDhtAtomicUpdateRequest)_msg; - - _clone.nodeId = nodeId; - _clone.futVer = futVer != null ? (GridCacheVersion)futVer.clone() : null; - _clone.writeVer = writeVer != null ? (GridCacheVersion)writeVer.clone() : null; - _clone.topVer = topVer; - _clone.keys = keys; - _clone.keyBytes = keyBytes; - _clone.vals = vals; - _clone.valBytes = valBytes; - _clone.drVers = drVers; - _clone.ttls = ttls != null ? (GridLongList)ttls.clone() : null; - _clone.drExpireTimes = drExpireTimes != null ? (GridLongList)drExpireTimes.clone() : null; - _clone.nearTtls = nearTtls != null ? (GridLongList)nearTtls.clone() : null; - _clone.nearExpireTimes = nearExpireTimes != null ? (GridLongList)nearExpireTimes.clone() : null; - _clone.syncMode = syncMode; - _clone.nearKeys = nearKeys; - _clone.nearKeyBytes = nearKeyBytes; - _clone.nearVals = nearVals; - _clone.nearValBytes = nearValBytes; - _clone.forceTransformBackups = forceTransformBackups; - _clone.entryProcessors = entryProcessors; - _clone.entryProcessorsBytes = entryProcessorsBytes; - _clone.nearEntryProcessors = nearEntryProcessors; - _clone.nearEntryProcessorsBytes = nearEntryProcessorsBytes; - _clone.invokeArgs = invokeArgs; - _clone.invokeArgsBytes = invokeArgsBytes; - _clone.subjId = subjId; - _clone.taskNameHash = taskNameHash; - } - - /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -863,7 +821,6 @@ public class GridDhtAtomicUpdateRequest<K, V> extends GridCacheMessage<K, V> imp } /** {@inheritDoc} */ - @SuppressWarnings("all") @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf);
