ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [18/50] [abbrv] incubator-ignite git commit: ignite-65 Generated code
Date Tue, 27 Jan 2015 13:34:48 GMT
ignite-65 Generated code


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

Branch: refs/heads/ignite-6
Commit: 80131b7a086d0aa5e6ff0664998eb15af95f4deb
Parents: a78e88a
Author: avinogradov <avinogradov@gridgain.com>
Authored: Mon Jan 26 16:51:21 2015 +0300
Committer: avinogradov <avinogradov@gridgain.com>
Committed: Mon Jan 26 16:51:21 2015 +0300

----------------------------------------------------------------------
 .../ignite/internal/GridJobExecuteRequest.java  | 52 ++++++++++----------
 1 file changed, 27 insertions(+), 25 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/80131b7a/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 1a1eea6..091a1d0 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
@@ -429,6 +429,7 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
     @Override protected void clone0(GridTcpCommunicationMessageAdapter _msg) {
         GridJobExecuteRequest _clone = (GridJobExecuteRequest)_msg;
 
+        _clone.subjId = subjId;
         _clone.sesId = sesId;
         _clone.jobId = jobId;
         _clone.jobBytes = jobBytes;
@@ -446,8 +447,8 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
         _clone.cpSpi = cpSpi;
         _clone.siblings = siblings;
         _clone.siblingsBytes = siblingsBytes;
-        _clone.createTime = createTime;
         _clone.createTime0 = createTime0;
+        _clone.createTime = createTime;
         _clone.clsLdrId = clsLdrId;
         _clone.depMode = depMode;
         _clone.dynamicSiblings = dynamicSiblings;
@@ -455,7 +456,6 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
         _clone.sesFullSup = sesFullSup;
         _clone.internal = internal;
         _clone.top = top;
-        _clone.subjId = subjId;
     }
 
     /** {@inheritDoc} */
@@ -600,24 +600,30 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
                 commState.idx++;
 
             case 16:
-                if (!commState.putString(taskClsName))
+                if (!commState.putUuid(subjId))
                     return false;
 
                 commState.idx++;
 
             case 17:
-                if (!commState.putString(taskName))
+                if (!commState.putString(taskClsName))
                     return false;
 
                 commState.idx++;
 
             case 18:
-                if (!commState.putLong(timeout))
+                if (!commState.putString(taskName))
                     return false;
 
                 commState.idx++;
 
             case 19:
+                if (!commState.putLong(timeout))
+                    return false;
+
+                commState.idx++;
+
+            case 20:
                 if (top != null) {
                     if (commState.it == null) {
                         if (!commState.putInt(top.size()))
@@ -644,17 +650,12 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 commState.idx++;
 
-            case 20:
+            case 21:
                 if (!commState.putString(userVer))
                     return false;
 
                 commState.idx++;
 
-            case 21:
-                if (!commState.putUuid(subjId))
-                    return false;
-
-                commState.idx++;
         }
 
         return true;
@@ -768,7 +769,7 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 if (commState.readSize >= 0) {
                     if (ldrParticipants == null)
-                        ldrParticipants = U.newHashMap(commState.readSize);
+                        ldrParticipants = new HashMap<>(commState.readSize, 1.0f);
 
                     for (int i = commState.readItems; i < commState.readSize; i++) {
                         if (!commState.keyDone) {
@@ -847,6 +848,16 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
                 commState.idx++;
 
             case 16:
+                UUID subjId0 = commState.getUuid();
+
+                if (subjId0 == UUID_NOT_READ)
+                    return false;
+
+                subjId = subjId0;
+
+                commState.idx++;
+
+            case 17:
                 String taskClsName0 = commState.getString();
 
                 if (taskClsName0 == STR_NOT_READ)
@@ -856,7 +867,7 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 commState.idx++;
 
-            case 17:
+            case 18:
                 String taskName0 = commState.getString();
 
                 if (taskName0 == STR_NOT_READ)
@@ -866,7 +877,7 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 commState.idx++;
 
-            case 18:
+            case 19:
                 if (buf.remaining() < 8)
                     return false;
 
@@ -874,7 +885,7 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 commState.idx++;
 
-            case 19:
+            case 20:
                 if (commState.readSize == -1) {
                     if (buf.remaining() < 4)
                         return false;
@@ -903,7 +914,7 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 commState.idx++;
 
-            case 20:
+            case 21:
                 String userVer0 = commState.getString();
 
                 if (userVer0 == STR_NOT_READ)
@@ -913,15 +924,6 @@ public class GridJobExecuteRequest extends GridTcpCommunicationMessageAdapter
im
 
                 commState.idx++;
 
-            case 21:
-                UUID subjId0 = commState.getUuid();
-
-                if (subjId0 == UUID_NOT_READ)
-                    return false;
-
-                subjId = subjId0;
-
-                commState.idx++;
         }
 
         return true;


Mime
View raw message