ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anovi...@apache.org
Subject [23/50] [abbrv] incubator-ignite git commit: Revert "ignite-nio - Removing message clone"
Date Sun, 15 Feb 2015 10:46:49 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/01689b1d/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
index 38f8e9c..16e2327 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
@@ -59,7 +59,7 @@ public class JobStealingRequest extends MessageAdapter {
         writer.setBuffer(buf);
 
         if (!writer.isTypeWritten()) {
-            if (!writer.writeMessageType(directType()))
+            if (!writer.writeByte(null, directType()))
                 return false;
 
             writer.onTypeWritten();
@@ -67,7 +67,7 @@ public class JobStealingRequest extends MessageAdapter {
 
         switch (writer.state()) {
             case 0:
-                if (!writer.writeField("delta", delta, MessageFieldType.INT))
+                if (!writer.writeInt("delta", delta))
                     return false;
 
                 writer.incrementState();
@@ -83,7 +83,7 @@ public class JobStealingRequest extends MessageAdapter {
 
         switch (readState) {
             case 0:
-                delta = reader.readField("delta", MessageFieldType.INT);
+                delta = reader.readInt("delta");
 
                 if (!reader.isLastRead())
                     return false;


Mime
View raw message