[infinispan-commits] Infinispan SVN: r656 - trunk/core/src/main/java/org/infinispan/marshall/exts.

[infinispan-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-08-12 07:57:21 -0400 (Wed, 12 Aug 2009)
New Revision: 656

Modified:
   trunk/core/src/main/java/org/infinispan/marshall/exts/ReplicableCommandExternalizer.java
Log:
use variable-length int write

Modified: trunk/core/src/main/java/org/infinispan/marshall/exts/ReplicableCommandExternalizer.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/marshall/exts/ReplicableCommandExternalizer.java	2009-08-12 11:02:07 UTC (rev 655)
+++ trunk/core/src/main/java/org/infinispan/marshall/exts/ReplicableCommandExternalizer.java	2009-08-12 11:57:21 UTC (rev 656)
@@ -24,6 +24,7 @@
 import org.infinispan.commands.RemoteCommandFactory;
 import org.infinispan.commands.ReplicableCommand;
 import org.infinispan.marshall.Externalizer;
+import org.infinispan.io.UnsignedNumeric;
 
 import java.io.IOException;
 import java.io.ObjectInput;
@@ -47,7 +48,8 @@
       output.writeShort(command.getCommandId());
       Object[] args = command.getParameters();
       int numArgs = (args == null ? 0 : args.length);
-      output.writeInt(numArgs);
+
+      UnsignedNumeric.writeUnsignedInt(output,numArgs);
       for (int i = 0; i < numArgs; i++) {
          output.writeObject(args[i]);
       }
@@ -55,7 +57,7 @@
 
    public Object readObject(ObjectInput input) throws IOException, ClassNotFoundException {
       short methodId = input.readShort();
-      int numArgs = input.readInt();
+      int numArgs = UnsignedNumeric.readUnsignedInt(input);
       Object[] args = null;
       if (numArgs > 0) {
          args = new Object[numArgs];