[jboss-cvs] contrib/varia/src/main/org/jboss/web/loadbalancer Loadbalancer.java

[Thomas P. <tp...@us...>]

  User: tpeuss  
  Date: 04/03/07 04:47:23

  Modified:    varia/src/main/org/jboss/web/loadbalancer Loadbalancer.java
  Log:
  Added a WeightedLeastConnectionScheduler. It routes requests to the node with the least
  connections. It takes a lbFactor into account. The node with the higher lbFactor gets more
  requests.
  
  Revision  Changes    Path
  1.9       +8 -2      contrib/varia/src/main/org/jboss/web/loadbalancer/Loadbalancer.java
  
  Index: Loadbalancer.java
  ===================================================================
  RCS file: /cvsroot/jboss/contrib/varia/src/main/org/jboss/web/loadbalancer/Loadbalancer.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- Loadbalancer.java	21 Dec 2003 15:19:35 -0000	1.8
  +++ Loadbalancer.java	7 Mar 2004 12:47:22 -0000	1.9
  @@ -40,7 +40,7 @@
    * @jmx:mbean name="jboss.web.loadbalancer: service=Loadbalancer"
    *
    * @author Thomas Peuss <jb...@pe...>
  - * @version $Revision: 1.8 $
  + * @version $Revision: 1.9 $
    */
   public class Loadbalancer
       implements LoadbalancerMBean
  @@ -255,7 +255,12 @@
           {
             // GO
             long t1=System.currentTimeMillis();
  +          schedRequest.getHost().incCurrentConnections();
  +
             schedRequest.getClient().executeMethod(schedRequest.getMethod());
  +
  +          schedRequest.getHost().decCurrentConnections();
  +
             long t2=System.currentTimeMillis();
             schedRequest.getHost().addRequest((int)(t2-t1));
             break;
  @@ -264,6 +269,7 @@
           {
             try
             {
  +            schedRequest.getHost().decCurrentConnections();
               schedRequest.getMethod().recycle();
             }
             catch (Exception e)
  @@ -418,4 +424,4 @@
     {
       return connectionManager.getConnectionsInUse();
     }
  -}
  \ No newline at end of file
  +}