ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [29/51] [abbrv] ignite git commit: ignite-2523 : Removed unnecessary fields from GridDhtAtomicSingleUpdateRequest.
Date Thu, 25 Feb 2016 12:31:28 GMT
ignite-2523 : Removed unnecessary fields from GridDhtAtomicSingleUpdateRequest.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cd07298f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cd07298f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cd07298f

Branch: refs/heads/ignite-2523
Commit: cd07298f31be580b8341e0409b4669376e90f1bd
Parents: 3391c84
Author: Ilya Lantukh <ilantukh@gridgain.com>
Authored: Tue Feb 9 17:46:37 2016 +0300
Committer: Ilya Lantukh <ilantukh@gridgain.com>
Committed: Tue Feb 9 17:46:37 2016 +0300

----------------------------------------------------------------------
 .../GridDhtAtomicSingleUpdateRequest.java       | 79 --------------------
 1 file changed, 79 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/cd07298f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicSingleUpdateRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicSingleUpdateRequest.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicSingleUpdateRequest.java
index c842270..0c0dd19 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicSingleUpdateRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicSingleUpdateRequest.java
@@ -112,69 +112,12 @@ public class GridDhtAtomicSingleUpdateRequest extends GridCacheMessage
implement
     @GridDirectTransient
     private CacheObject locPrevVal;
 
-    /** Keys to update. */
-    @GridToStringInclude
-    @GridDirectCollection(KeyCacheObject.class)
-    private List<KeyCacheObject> keys;
-
-    /** Values to update. */
-    @GridToStringInclude
-    @GridDirectCollection(CacheObject.class)
-    private List<CacheObject> vals;
-
-    /** Previous values. */
-    @GridToStringInclude
-    @GridDirectCollection(CacheObject.class)
-    private List<CacheObject> prevVals;
-
-    /** Conflict versions. */
-    @GridDirectCollection(GridCacheVersion.class)
-    private List<GridCacheVersion> conflictVers;
-
-    /** TTLs. */
-    private GridLongList ttls;
-
-    /** Conflict expire time. */
-    private GridLongList conflictExpireTimes;
-
-    /** Near TTLs. */
-    private GridLongList nearTtls;
-
-    /** Near expire times. */
-    private GridLongList nearExpireTimes;
-
     /** Write synchronization mode. */
     private CacheWriteSynchronizationMode syncMode;
 
-    /** Near cache keys to update. */
-    @GridToStringInclude
-    @GridDirectCollection(KeyCacheObject.class)
-    private List<KeyCacheObject> nearKeys;
-
-    /** Values to update. */
-    @GridToStringInclude
-    @GridDirectCollection(CacheObject.class)
-    private List<CacheObject> nearVals;
-
     /** Force transform backups flag. */
     private boolean forceTransformBackups;
 
-    /** Entry processors. */
-    @GridDirectTransient
-    private List<EntryProcessor<Object, Object, Object>> entryProcessors;
-
-    /** Entry processors bytes. */
-    @GridDirectCollection(byte[].class)
-    private List<byte[]> entryProcessorsBytes;
-
-    /** Near entry processors. */
-    @GridDirectTransient
-    private List<EntryProcessor<Object, Object, Object>> nearEntryProcessors;
-
-    /** Near entry processors bytes. */
-    @GridDirectCollection(byte[].class)
-    private List<byte[]> nearEntryProcessorsBytes;
-
     /** Optional arguments for entry processor. */
     @GridDirectTransient
     private Object[] invokeArgs;
@@ -188,21 +131,10 @@ public class GridDhtAtomicSingleUpdateRequest extends GridCacheMessage
implement
     /** Task name hash. */
     private int taskNameHash;
 
-    /** Partition. */
-    private GridLongList updateCntrs;
-
     /** On response flag. Access should be synced on future. */
     @GridDirectTransient
     private boolean onRes;
 
-    /** */
-    @GridDirectTransient
-    private List<Integer> partIds;
-
-    /** */
-    @GridDirectTransient
-    private List<CacheObject> locPrevVals;
-
     /** Keep binary flag. */
     private boolean keepBinary;
 
@@ -256,17 +188,6 @@ public class GridDhtAtomicSingleUpdateRequest extends GridCacheMessage
implement
         this.invokeArgs = invokeArgs;
         this.addDepInfo = addDepInfo;
         this.keepBinary = keepBinary;
-
-        keys = new ArrayList<>();
-        partIds = new ArrayList<>();
-        locPrevVals = new ArrayList<>();
-
-        if (forceTransformBackups) {
-            entryProcessors = new ArrayList<>();
-            entryProcessorsBytes = new ArrayList<>();
-        }
-        else
-            vals = new ArrayList<>();
     }
 
     /**


Mime
View raw message