IGNITE-141 - Marshallers refactoring

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

Branch: refs/heads/ignite-141
Commit: df281a3f00004c422c25eea95a3b76df4701f476
Parents: 20284ad
Author: Valentin Kulichenko <vkuliche...@gridgain.com>
Authored: Thu Mar 5 14:00:52 2015 -0800
Committer: Valentin Kulichenko <vkuliche...@gridgain.com>
Committed: Thu Mar 5 14:00:52 2015 -0800

----------------------------------------------------------------------
 .../cache/affinity/rendezvous/CacheRendezvousAffinityFunction.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/df281a3f/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/CacheRendezvousAffinityFunction.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/CacheRendezvousAffinityFunction.java
 
b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/CacheRendezvousAffinityFunction.java
index de0d819..ac0ac5e 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/CacheRendezvousAffinityFunction.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/CacheRendezvousAffinityFunction.java
@@ -293,8 +293,8 @@ public class CacheRendezvousAffinityFunction implements 
CacheAffinityFunction, E
 
                 byte[] nodeHashBytes = 
ignite.configuration().getMarshaller().marshal(nodeHash);
 
-                out.write(nodeHashBytes, 0, nodeHashBytes.length); // Avoid 
IOException.
                 out.write(U.intToBytes(part), 0, 4); // Avoid IOException.
+                out.write(nodeHashBytes, 0, nodeHashBytes.length); // Avoid 
IOException.
 
                 d.reset();
 

Reply via email to