[jboss-remoting-commits] JBoss Remoting SVN: r4968 - remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast.

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

Author: ron.sigal at jboss.com
Date: 2009-04-11 21:44:36 -0400 (Sat, 11 Apr 2009)
New Revision: 4968

Modified:
   remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java
   remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetectorMBean.java
Log:
JBREM-1099: Added bufferSize attribute.

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java	2009-04-09 19:02:54 UTC (rev 4967)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java	2009-04-12 01:44:36 UTC (rev 4968)
@@ -59,6 +59,7 @@
    private int port = 2410;
    private MulticastSocket socket;
    private Listener listener = new Listener("Remoting Multicast Detector - Listener Thread: " + threadCounter++);
+   private int bufferSize = 10000;
 
 
    /**
@@ -137,6 +138,17 @@
       this.port = port;
    }
 
+
+   public int getBufferSize()
+   {
+      return bufferSize;
+   }
+
+   public void setBufferSize(int bufferSize)
+   {
+      this.bufferSize = bufferSize;
+   }
+   
    /**
     * called by MBeanServer to start the mbean lifecycle
     *
@@ -347,7 +359,8 @@
 
       public void run()
       {
-         byte[] buf = new byte[4000];
+         log.debug("using bufferSize: " + bufferSize);
+         byte[] buf = new byte[bufferSize];
          DatagramPacket p = new DatagramPacket(buf, 0, buf.length);
          //p.setAddress(addr);
          //p.setPort(port);

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetectorMBean.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetectorMBean.java	2009-04-09 19:02:54 UTC (rev 4967)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetectorMBean.java	2009-04-12 01:44:36 UTC (rev 4968)
@@ -84,5 +84,15 @@
     * @param defaultIP The IP that is used to broadcast detection messages on via multicast.
     */
    void setDefaultIP(String defaultIP);
+   
+   /**
+    * @return The size of the byte array in the DatagramPacket.
+    */
+   int getBufferSize();
+   
+   /**
+    * @param bufferSize The size of the byte array in the DatagramPacket.
+    */
+   void setBufferSize(int bufferSize);
 
 }