jdk-sandbox: comparison jdk/test/java/rmi/dgc/retryDirtyCalls/RetryDirtyCalls.java

equal deleted inserted replaced

-:33a1639d64a5
+:bda219d843f6
 /*
 * Copyright 1999 Sun Microsystems, Inc.  All Rights Reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 /**
 * Return this object.  The need for this method is explained below.
 */
 public Self getSelf() {
-	return this;
+return this;
 }
 public void unreferenced() {
-	synchronized (this) {
+synchronized (this) {
-	    unreferenced = true;
+unreferenced = true;
-	    notifyAll();
+notifyAll();
-	}
+}
 }
 public static void main(String[] args) {
-	System.err.println("\nRegression test for bug 4268258\n");
+System.err.println("\nRegression test for bug 4268258\n");
-	/*
+/*
-	 * Set properties to tweak DGC behavior so that this test will execute
+* Set properties to tweak DGC behavior so that this test will execute
-	 * quickly: set the granted lease duration to 10 seconds, the interval
+* quickly: set the granted lease duration to 10 seconds, the interval
-	 * that leases are checked to 3 seconds.
+* that leases are checked to 3 seconds.
-	 */
+*/
-	System.setProperty("java.rmi.dgc.leaseValue", "10000");
+System.setProperty("java.rmi.dgc.leaseValue", "10000");
-	System.setProperty("sun.rmi.dgc.checkInterval", "3000");
+System.setProperty("sun.rmi.dgc.checkInterval", "3000");
-	/*
+/*
-	 * Make idle connections time out almost instantly (0.1 seconds) so
+* Make idle connections time out almost instantly (0.1 seconds) so
-	 * that the DGC implementation will have to make a new connection for
+* that the DGC implementation will have to make a new connection for
-	 * each dirty call, thus going through the socket factory, where we
+* each dirty call, thus going through the socket factory, where we
-	 * can easily cause the operation to fail.
+* can easily cause the operation to fail.
-	 */
+*/
-	System.setProperty("sun.rmi.transport.connectionTimeout", "100");
+System.setProperty("sun.rmi.transport.connectionTimeout", "100");
-	RetryDirtyCalls impl = new RetryDirtyCalls();
+RetryDirtyCalls impl = new RetryDirtyCalls();
-	try {
+try {
-	    TestSF sf = new TestSF();
+TestSF sf = new TestSF();
-	    RMISocketFactory.setSocketFactory(sf);
+RMISocketFactory.setSocketFactory(sf);
-	    /*
+/*
-	     * The stub returned by UnicastRemoteObject.exportObject() does
+* The stub returned by UnicastRemoteObject.exportObject() does
-	     * not participate in DGC, but it does allow us to invoke a method
+* not participate in DGC, but it does allow us to invoke a method
-	     * on the remote object through RMI.  Therefore, we invoke the
+* on the remote object through RMI.  Therefore, we invoke the
-	     * getSelf() method through RMI, which returns an equivalent stub
+* getSelf() method through RMI, which returns an equivalent stub
-	     * that does participate in DGC.
+* that does participate in DGC.
-	     */
+*/
-	    Self stub = (Self) UnicastRemoteObject.exportObject(impl);
+Self stub = (Self) UnicastRemoteObject.exportObject(impl);
-	    Self dgcStub = stub.getSelf();
+Self dgcStub = stub.getSelf();
-	    stub = null;		// in case 4114579 has been fixed
+stub = null;                // in case 4114579 has been fixed
-	    /*
+/*
-	     * Set the socket factory to cause 3 connections attempts in a row
+* Set the socket factory to cause 3 connections attempts in a row
-	     * to fail before allowing a connection to succeed, expecting the
+* to fail before allowing a connection to succeed, expecting the
-	     * client-side DGC implementation to make at least four attempts.
+* client-side DGC implementation to make at least four attempts.
-	     */
+*/
-	    final int FLAKE_FACTOR = 3;
+final int FLAKE_FACTOR = 3;
-	    sf.setFlakeFactor(FLAKE_FACTOR);
+sf.setFlakeFactor(FLAKE_FACTOR);
-	    long deadline = System.currentTimeMillis() + TIMEOUT;
+long deadline = System.currentTimeMillis() + TIMEOUT;
-	    boolean unreferenced;
+boolean unreferenced;
-	    synchronized (impl) {
+synchronized (impl) {
-		while (!(unreferenced = impl.unreferenced)) {
+while (!(unreferenced = impl.unreferenced)) {
-		    long timeToWait = deadline - System.currentTimeMillis();
+long timeToWait = deadline - System.currentTimeMillis();
-		    if (timeToWait > 0) {
+if (timeToWait > 0) {
-			impl.wait(timeToWait);
+impl.wait(timeToWait);
-		    } else {
+} else {
-			break;
+break;
-		    }
+}
-		}
+}
-	    }
+}
-	    if (unreferenced) {
+if (unreferenced) {
-		throw new RuntimeException("remote object unreferenced");
+throw new RuntimeException("remote object unreferenced");
-	    }
+}
-	    int createCount = sf.getCreateCount();
+int createCount = sf.getCreateCount();
-	    if (createCount == 0) {
+if (createCount == 0) {
-		throw new RuntimeException("test socket factory never used");
+throw new RuntimeException("test socket factory never used");
-	    } else if (createCount < (FLAKE_FACTOR + 3)) {
+} else if (createCount < (FLAKE_FACTOR + 3)) {
-		/*
+/*
-		 * The unreferenced method was not invoked for some reason,
+* The unreferenced method was not invoked for some reason,
-		 * but the dirty calls were clearly not retried well enough.
+* but the dirty calls were clearly not retried well enough.
-		 */
+*/
-		throw new RuntimeException(
+throw new RuntimeException(
-		    "test failed because dirty calls not retried enough, " +
+"test failed because dirty calls not retried enough, " +
-		    "but remote object not unreferenced");
+"but remote object not unreferenced");
-	    }
+}
-	    System.err.println(
+System.err.println(
-		"TEST PASSED: remote object not unreferenced");
+"TEST PASSED: remote object not unreferenced");
-	} catch (Exception e) {
+} catch (Exception e) {
-	    e.printStackTrace();
+e.printStackTrace();
-	    throw new RuntimeException("TEST FAILED: " + e.toString());
+throw new RuntimeException("TEST FAILED: " + e.toString());
-	} finally {
+} finally {
-	    /*
+/*
-	     * When all is said and done, try to unexport the remote object
+* When all is said and done, try to unexport the remote object
-	     * so that the VM has a chance to exit.
+* so that the VM has a chance to exit.
-	     */
+*/
-	    try {
+try {
-		UnicastRemoteObject.unexportObject(impl, true);
+UnicastRemoteObject.unexportObject(impl, true);
-	    } catch (Exception e) {
+} catch (Exception e) {
-	    }
+}
-	}
+}
 }
 }
 class TestSF extends RMISocketFactory {
 private int flakeState = 0;
 private int createCount = 0;
 public synchronized void setFlakeFactor(int newFlakeFactor) {
-	flakeFactor = newFlakeFactor;
+flakeFactor = newFlakeFactor;
 }
 public synchronized int getCreateCount() {
-	return createCount;
+return createCount;
 }
 public synchronized Socket createSocket(String host, int port)
-	throws IOException
+throws IOException
 {
-	createCount++;
+createCount++;
-	if (++flakeState > flakeFactor) {
+if (++flakeState > flakeFactor) {
-	    flakeState = 0;
+flakeState = 0;
-	}
+}
-	if (flakeState == 0) {
+if (flakeState == 0) {
-	    return new Socket(host, port);
+return new Socket(host, port);
-	} else {
+} else {
-	    throw new IOException("random network failure");
+throw new IOException("random network failure");
-	}
+}
 }
 public ServerSocket createServerSocket(int port) throws IOException {
-	return new ServerSocket(port);
+return new ServerSocket(port);
 }
 }

changeset 309	bda219d843f6
parent 2	90ce3da70b43
child 715	f16baef3a20e