src/org/objectweb/cjdbc/controller/loadbalancer/policies/errorchecking/ErrorCheckingRandom.java

説明を見る。

package org.objectweb.cjdbc.controller.loadbalancer.policies.errorchecking;

import java.util.ArrayList;
import java.util.Random;

import org.objectweb.cjdbc.controller.backend.DatabaseBackend;

public class ErrorCheckingRandom extends ErrorCheckingPolicy
{
  private Random random = new Random();

  public ErrorCheckingRandom(int numberOfNodes)
  {
    super(ErrorCheckingPolicy.RANDOM, numberOfNodes);
  }

  public ArrayList getBackends(ArrayList backends)
    throws ErrorCheckingException
  {
    int size = backends.size();

    if (nbOfNodes == size)
      return backends;
    else if (nbOfNodes > size)
      throw new ErrorCheckingException(
        "Asking for more backends ("
          + nbOfNodes
          + ") than available ("
          + size
          + ")");

    ArrayList result = new ArrayList(nbOfNodes);
    ArrayList clonedList = new ArrayList(size);
    for (int i = 0; i < size; i++)
    { // Take all enabled backends
      DatabaseBackend db = (DatabaseBackend) backends.get(i);
      if (db.isReadEnabled() || db.isWriteEnabled())
        clonedList.add(db);
    }

    int clonedSize = clonedList.size();

    if (nbOfNodes == clonedSize)
      return backends;
    else if (nbOfNodes > clonedSize)
      throw new ErrorCheckingException(
        "Asking for more backends ("
          + nbOfNodes
          + ") than available ("
          + clonedSize
          + ")");

    // Pickup the nodes randomly
    for (int i = 0; i < nbOfNodes; i++)
      result.add(clonedList.remove(random.nextInt(clonedSize)));

    return result;
  }

  public String getInformation()
  {
    return "Error checking using " + nbOfNodes + " nodes choosen randomly";
  }
}

---