ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [07/10] incubator-ignite git commit: GG-9900 - Portable marshaller refactoring
Date Thu, 12 Mar 2015 05:04:29 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f7f9e658/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
index 2e09ca8..a6a32c9 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
@@ -162,8 +162,8 @@ public class GridStreamerExecutionRequest implements Message {
 
         switch (writer.state()) {
             case 0:
-//                if (!writer.writeByteArray("batchBytes", batchBytes))
-//                    return false;
+                if (!writer.writeByteBuffer("batchBytes", batchBytes))
+                    return false;
 
                 writer.incrementState();
 
@@ -217,7 +217,7 @@ public class GridStreamerExecutionRequest implements Message {
 
         switch (reader.state()) {
             case 0:
-//                batchBytes = reader.readByteArray("batchBytes");
+                batchBytes = reader.readByteBuffer("batchBytes");
 
                 if (!reader.isLastRead())
                     return false;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f7f9e658/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
index fdaa002..6b47957 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
@@ -87,8 +87,8 @@ public class GridStreamerResponse implements Message {
 
         switch (writer.state()) {
             case 0:
-//                if (!writer.writeByteArray("errBytes", errBytes))
-//                    return false;
+                if (!writer.writeByteBuffer("errBytes", errBytes))
+                    return false;
 
                 writer.incrementState();
 
@@ -112,7 +112,7 @@ public class GridStreamerResponse implements Message {
 
         switch (reader.state()) {
             case 0:
-//                errBytes = reader.readByteArray("errBytes");
+                errBytes = reader.readByteBuffer("errBytes");
 
                 if (!reader.isLastRead())
                     return false;


Mime
View raw message