[jboss-cvs] JBossAS SVN: r60166 - trunk/cluster/src/main/org/jboss/ha/framework/server.

[jboss-cvs-commits at lists.jboss.org]

Author: jerrygauth
Date: 2007-02-01 14:20:46 -0500 (Thu, 01 Feb 2007)
New Revision: 60166

Modified:
   trunk/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java
Log:
JBAS-3515

Modified: trunk/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java
===================================================================
--- trunk/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java	2007-02-01 19:17:07 UTC (rev 60165)
+++ trunk/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java	2007-02-01 19:20:46 UTC (rev 60166)
@@ -92,6 +92,7 @@
               AsynchEventHandler.AsynchEventProcessor,
               ClusterPartitionMBean
 {
+   private static final byte EOF_VALUE   = -1;
    private static final byte NULL_VALUE   = 0;
    private static final byte SERIALIZABLE_VALUE = 1;
    // TODO add Streamable support
@@ -547,6 +548,8 @@
       else
       {
          mvos.writeObject(new StateStreamEnd());
+         mvos.flush();
+         mvos.close();
       }
       
    }
@@ -554,9 +557,14 @@
    private void setStateInternal(InputStream stream) throws IOException, ClassNotFoundException
    {
       byte type = (byte) stream.read();
-         
-      if (type == NULL_VALUE)
+      
+      if (type == EOF_VALUE)
       {
+         log.debug("serviceState stream is empty");
+         return;
+      }
+      else if (type == NULL_VALUE)
+      {
          log.debug("serviceState is null");
          return;
       }