Examples of net.jini.lease.LeaseRenewalService

net.jini.lease.LeaseRenewalService
Interface to the lease renewal service. The interface is not a remote interface; each implementation of the renewal service exports proxy objects that implement the LeaseRenewalService interface that use an implementation-specific protocol to communicate with the actual remote server. All of the proxy methods obey normal RMI remote interface semantics. Two proxy objects are equal if they are proxies for the same renewal service. Every method invocation (on both a LeaseRenewalService and any LeaseRenewalSet it has created) is atomic with respect to other invocations. @author Sun Microsystems, Inc. @see LeaseRenewalSet


  // Announce where we are in the test
  logger.log(Level.FINE, "RenewalTimeTest: In run() method.");


  // grab the ever popular LRS
  LeaseRenewalService lrs = getLRS();


  // create a renewal set
  logger.log(Level.FINE, "Creating renewal set with lease duration of " +
        "Lease.FOREVER.");
  long renewSetDur = Lease.FOREVER;
  LeaseRenewalSet set = lrs.createLeaseRenewalSet(renewSetDur);
  set = prepareSet(set);
  lrm.renewFor(prepareLease(set.getRenewalSetLease()), renewSetDur, null);


  // create a test lease to be managed
  logger.log(Level.FINE, "Creating the lease to be managed.");

View Full Code Here


  // Announce where we are in the test
  logger.log(Level.FINE, "AssocExpWarnTest: In run() method.");


  // Create two renewal sets with a lease of forever
  LeaseRenewalService lrs = getLRS();
  logger.log(Level.FINE, "Creating the lease renewal set #1 " +
        "with duration of Lease.FOREVER");
  LeaseRenewalSet set01 = lrs.createLeaseRenewalSet(Lease.FOREVER);
  set01 = prepareSet(set01);
  
  logger.log(Level.FINE, "Creating the lease renewal set #2 with " +
        "duration of Lease.FOREVER");
  LeaseRenewalSet set02 = lrs.createLeaseRenewalSet(Lease.FOREVER);
  set02 = prepareSet(set02);
  
  // create a set with a lease of 30 milliseconds
  logger.log(Level.FINE, "Creating the lease renewal set #3 with " +
        "duration of " + renewSetDur + " milliseconds.");
  LeaseRenewalSet set03 = lrs.createLeaseRenewalSet(renewSetDur);
  set03 = prepareSet(set03);
  
  // register listener to receive expiration warning events
  long minWarning = renewSetDur / 3;
  logger.log(Level.FINE, "Registering listener for expiration" +

View Full Code Here


  // Announce where we are in the test
  logger.log(Level.FINE, "DurationExpirationTest: In run() method.");


  // grab the ever popular LRS
  LeaseRenewalService lrs = getLRS();


  // create a renewal set
  long renewSetDur = Lease.FOREVER;
  LeaseRenewalSet set = lrs.createLeaseRenewalSet(renewSetDur);
  set = prepareSet(set);
  lrm.renewFor(prepareLease(set.getRenewalSetLease()), renewSetDur, null);
  logger.log(Level.FINE, "Created renewal set with lease duration of " +
        "Lease.FOREVER.");

View Full Code Here

  logger.log(Level.FINE, "LeaseRenewalTest: In run() method.");


  // get a lease renewal set w/ duration for as long as we can
  logger.log(Level.FINE, "Creating the lease renewal set with duration" +
        " of Lease.FOREVER");
  LeaseRenewalService lrs = getLRS();
  LeaseRenewalSet set = lrs.createLeaseRenewalSet(Lease.FOREVER);
  set = prepareSet(set);
  lrm.renewFor(prepareLease(set.getRenewalSetLease()), Lease.FOREVER, null);


  // register listener to receive events
  logger.log(Level.FINE, "Registering listener for renewal failure" +

View Full Code Here

  logger.log(Level.FINE, "EventIDFailSetTest: In run() method.");


  // get a lease renewal set w/ duration for as long as we can
  logger.log(Level.FINE, "Creating the lease renewal set with duration" +
        " of Lease.FOREVER");
  LeaseRenewalService lrs = getLRS();
  LeaseRenewalSet set = lrs.createLeaseRenewalSet(Lease.FOREVER);
  set = prepareSet(set);
  lrm.renewFor(prepareLease(set.getRenewalSetLease()), Lease.FOREVER, null);


  // register a listener to receive renewal failure events
  logger.log(Level.FINE, "Registering listener to receive " +

View Full Code Here


  // Announce where we are in the test
  logger.log(Level.FINE, "EventSequenceTest: In run() method.");


  // grab the ever popular LRS
  LeaseRenewalService lrs = getLRS();


  // create all required renewal sets and register listener
  for (int i = 0; i < NUMBER_OF_RENEWAL_SETS; ++i) {
      logger.log(Level.FINE, "Creating renewal set #" + i + 
            " with lease" + " duration of " + 
            renewSetDur + " milliseconds.");
      renewalSet[i] = prepareSet(lrs.createLeaseRenewalSet(renewSetDur));
      lrm.renewFor(prepareLease(renewalSet[i].getRenewalSetLease()), 
       renewSetDur,
       null);


      // register listener to receive events
      logger.log(Level.FINE, "Registering listener for warning events.");
      logger.log(Level.FINE, "minWarning = " + minWarning + ".");
      renewalSet[i].setExpirationWarningListener(rrl, minWarning, 
                   null);


  }


  // wait until the renewal set leases have expired
  rstUtil.waitForRemoteEvents(rrl, NUMBER_OF_RENEWAL_SETS,
            renewSetDur * 2);


  // Ensure that we received the correct number of events
  RemoteEvent[] events = rrl.getEvents();
  if (events.length < 1) {
      String message = "Listener did not receive any events.\n" +
    "Should have received exactly " + NUMBER_OF_RENEWAL_SETS;
      throw new TestException(message);
  } else if (events.length != NUMBER_OF_RENEWAL_SETS) {
      String message = "Listener received " + events.length +
    " events.\n" + "Should have received exactly " + 
    NUMBER_OF_RENEWAL_SETS;
      throw new TestException(message);
  }


  /* create a sorted collection of the event set.
     the assumption here is that the events need not arrive 
     in order, but we are assuming a reliable network so they
     all must arrive. */
  TreeSet sequenceSet = new TreeSet();


  for (int i = 0; i < events.length; ++i) {
      sequenceSet.add(new Long(events[i].getSequenceNumber()));
  }


  // assert that each sequence is in order with no gaps
  Iterator iter = sequenceSet.iterator();
  Long previousLong = (Long) iter.next();
  while (iter.hasNext()) {
      Long nextLong = (Long) iter.next();
      logger.log(Level.FINE, "previousID = " + previousLong + 
            " nextID = " + nextLong);
      long delta = nextLong.longValue() - previousLong.longValue();
      if (delta != 1) {
    String message = "Event sequence numbers are not" +
        " strictly increasing for WarningExpirationEvents.";
    throw new TestException(message);
      }


      previousLong = nextLong;
  }


  // clear the listener so we can reuse it
  rrl.clear();


  // create a new set
  LeaseRenewalSet set  = lrs.createLeaseRenewalSet(Lease.FOREVER);
  set = prepareSet(set);
  lrm.renewFor(prepareLease(set.getRenewalSetLease()), Lease.FOREVER, null);
  logger.log(Level.FINE, "Created renewal set with lease" +
        "duration of Lease.FOREVER.");

View Full Code Here


  // Announce where we are in the test
  logger.log(Level.FINE, "EventSequenceWarnTest: In run() method.");


  // grab the ever popular LRS
  LeaseRenewalService lrs = getLRS();


  // create a renewal set for the requested duration
  logger.log(Level.FINE, "Creating renewal set w/ duration = " +
        renewSetDur + " milliseconds.");
  LeaseRenewalSet set = lrs.createLeaseRenewalSet(renewSetDur);
  set = prepareSet(set);


  // register listener #1 to receive events
  logger.log(Level.FINE, "Registering listener #1 for warning events.");
  logger.log(Level.FINE, "minWarning = " + minWarning + ".");

View Full Code Here


  // Announce where we are in the test
  logger.log(Level.FINE, "EventIDWarnTest: In run() method.");


  // Create three renewal sets with a lease of 40000 milliseconds
  LeaseRenewalService lrs = getLRS();
  logger.log(Level.FINE, "Creating the lease renewal set with duration" +
        " of " + renewSetDur + " milliseconds");
  LeaseRenewalSet set01 = lrs.createLeaseRenewalSet(renewSetDur);
  set01 = prepareSet(set01);
  lrm.renewFor(prepareLease(set01.getRenewalSetLease()), renewSetDur, null);
  
  logger.log(Level.FINE, "Creating the lease renewal set with duration" +
        " of " + renewSetDur + " milliseconds");
  LeaseRenewalSet set02 = lrs.createLeaseRenewalSet(renewSetDur);
  set02 = prepareSet(set02);
  lrm.renewFor(prepareLease(set02.getRenewalSetLease()), renewSetDur, null);


  logger.log(Level.FINE, "Creating the lease renewal set with duration" +
        " of " + renewSetDur + " milliseconds");
  LeaseRenewalSet set03 = lrs.createLeaseRenewalSet(renewSetDur);
  set03 = prepareSet(set03);
  lrm.renewFor(prepareLease(set03.getRenewalSetLease()), renewSetDur, null);
  
  // register the listener to receive expiration events
  logger.log(Level.FINE, "Registering listener to receive " +

View Full Code Here


  // Announce where we are in the test
  logger.log(Level.FINE, "EventRegistrationTest: In run() method.");


  // grab the ever popular LRS
  LeaseRenewalService lrs = getLRS();


  // create all required renewal sets
  long renewSetDur = Lease.FOREVER;
  for (int i = 0; i < NUMBER_OF_RENEWAL_SETS; ++i) {
      logger.log(Level.FINE, "Creating renewal set #" + i + 
            " with lease duration of Lease.FOREVER.");
      renewalSet[i] = prepareSet(lrs.createLeaseRenewalSet(renewSetDur));
      lrm.renewFor(prepareLease(renewalSet[i].getRenewalSetLease()), renewSetDur,
       null);
  }


  // create all required RemoteListeners

View Full Code Here

  
  // IllegalArgumentException should be thrown with arg of -99
  logger.log(Level.FINE, "Creating the lease renewal set with " + 
             "-99 duration.");
  try {
      LeaseRenewalService lrs = getLRS();
      LeaseRenewalSet set = lrs.createLeaseRenewalSet(-99);
      set = prepareSet(set);
      String message = "IllegalArgumentException expected from\n";
      message += "createLeaseRenewalSet(-99)";
      throw new TestException(message);
  } catch (IllegalArgumentException ex) {
      // we passed so just continue
      logger.log(Level.FINE, "Caught IllegalArgumentException as " +
            "expected.");
  }
  
  // No exception thrown for Lease.ANY argument
  logger.log(Level.FINE, "Creating the lease renewal set with " + 
             "Lease.ANY duration.");
  try {
      LeaseRenewalService lrs = getLRS();
      LeaseRenewalSet set = lrs.createLeaseRenewalSet(Lease.ANY);
      set = prepareSet(set);
      // we passed so just continue
      logger.log(Level.FINE, "Caught no exceptions as expected.");
  } catch (IllegalArgumentException ex) {
      String message = "IllegalArgumentException caught from\n";
      message += "createLeaseRenewalSet(Lease.ANY)";
      throw new TestException(message, ex);
  }


  // No exception thrown for Lease.FOREVER argument
  logger.log(Level.FINE, "Creating the lease renewal set with " + 
        "Lease.FOREVER duration.");
  try {
      LeaseRenewalService lrs = getLRS();
      LeaseRenewalSet set = lrs.createLeaseRenewalSet(Lease.FOREVER);
      set = prepareSet(set);
      // we passed so just continue
      logger.log(Level.FINE, "Caught no exceptions as expected.");
  } catch (IllegalArgumentException ex) {
      String message = "IllegalArgumentException caught from\n";
      message += "createLeaseRenewalSet(Lease.FOREVER)";
      throw new TestException(message, ex);
  }


  // No exception thrown for argument value of 0
  logger.log(Level.FINE, "Creating the lease renewal set with " + 
        "0 duration.");
  try {
      LeaseRenewalService lrs = getLRS();
      LeaseRenewalSet set = lrs.createLeaseRenewalSet(0);
      set = prepareSet(set);
      // we passed so just continue
      logger.log(Level.FINE, "Caught no exceptions as expected.");
  } catch (IllegalArgumentException ex) {
      String message = "IllegalArgumentException caught from\n";
      message += "createLeaseRenewalSet(0)";
      throw new TestException(message, ex);
  }


  // No exception thrown for argument value of 1
  logger.log(Level.FINE, "Creating the lease renewal set with " + 
        "1 duration.");
  try {
      LeaseRenewalService lrs = getLRS();
      LeaseRenewalSet set = lrs.createLeaseRenewalSet(1);
      set = prepareSet(set);
      // we passed so just continue
      logger.log(Level.FINE, "Caught no exceptions as expected.");
  } catch (IllegalArgumentException ex) {
      String message = "IllegalArgumentException caught from\n";

View Full Code Here

0 1 2 3 4 5 6 7 8

TOP

Related Classes of net.jini.lease.LeaseRenewalService

com.sun.jini.test.impl.norm.AddRenewRemoveTest

com.sun.jini.test.impl.norm.BatchRenewTest

com.sun.jini.test.impl.norm.ExpiredLeaseTest

com.sun.jini.test.impl.norm.GetLeasesTest

com.sun.jini.test.impl.norm.LeaseExpirationTest

com.sun.jini.test.impl.norm.RemoveExactlyOneTest

com.sun.jini.test.impl.norm.RenewalFailureTest

com.sun.jini.test.impl.norm.RenewAtTest

com.sun.jini.test.spec.renewalservice.AddRemoveTest

com.sun.jini.test.spec.renewalservice.AssocExpWarnSetTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.