ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [19/50] [abbrv] incubator-ignite git commit: IGNITE-61 - Direct marshalling
Date Tue, 10 Feb 2015 08:36:30 GMT
IGNITE-61 - Direct marshalling


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

Branch: refs/heads/ignite-138
Commit: 4e434848b9fd26ef78b0210f622ffd0ffd332f64
Parents: 2a6aa9f
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Mon Feb 9 11:05:55 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Mon Feb 9 11:05:55 2015 -0800

----------------------------------------------------------------------
 .../ignite/internal/processors/rest/TestBinaryClient.java   | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4e434848/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/TestBinaryClient.java
----------------------------------------------------------------------
diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/TestBinaryClient.java
b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/TestBinaryClient.java
index fd7cbd7..d34f421 100644
--- a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/TestBinaryClient.java
+++ b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/TestBinaryClient.java
@@ -92,14 +92,15 @@ final class TestBinaryClient {
             sock.getOutputStream().write(GridMemcachedMessage.IGNITE_HANDSHAKE_FLAG);
             sock.getOutputStream().write(req.rawBytes());
 
-            byte[] buf = new byte[1];
+            byte[] buf = new byte[2];
 
             // Wait for handshake response.
             int read = input.read(buf);
 
-            assert read == 1 : read;
+            assert read == 2 : read;
 
-            assert buf[0] == GridClientHandshakeResponse.OK.resultCode() :
+            assert buf[0] == GridMemcachedMessage.IGNITE_HANDSHAKE_RES_FLAG;
+            assert buf[1] == GridClientHandshakeResponse.OK.resultCode() :
                 "Client handshake failed [code=" + buf[0] + ']';
         }
         catch (IOException e) {
@@ -275,8 +276,6 @@ final class TestBinaryClient {
 
         ByteBuffer slice = res.slice();
 
-        slice.order(ByteOrder.LITTLE_ENDIAN);
-
         slice.put((byte)0x90);
         slice.putInt(res.remaining() - 5);
         slice.putLong(msg.requestId());


Mime
View raw message