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 <vkuliche...@gridgain.com> Authored: Mon Feb 9 11:05:55 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@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());
