summaryrefslogtreecommitdiff
path: root/java/test/Freeze/oldevictor/Client.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/test/Freeze/oldevictor/Client.java')
-rw-r--r--java/test/Freeze/oldevictor/Client.java1618
1 files changed, 809 insertions, 809 deletions
diff --git a/java/test/Freeze/oldevictor/Client.java b/java/test/Freeze/oldevictor/Client.java
index 50927871c5c..befe0e0ff49 100644
--- a/java/test/Freeze/oldevictor/Client.java
+++ b/java/test/Freeze/oldevictor/Client.java
@@ -33,38 +33,38 @@ public class Client
static class ReadThread extends Thread
{
- ReadThread(Test.ServantPrx[] servants)
- {
- _servants = servants;
- }
-
- public void run()
- {
- int loops = 10;
- while(loops-- > 0)
- {
- try
- {
- _servants[0].getValue();
- test(false);
- }
- catch(Ice.ObjectNotExistException e)
- {
- // Expected
- }
- catch(Exception e)
- {
- test(false);
- }
-
- for(int i = 1; i < _servants.length; ++i)
- {
- test(_servants[i].getValue() == i);
- }
- }
- }
-
- private Test.ServantPrx[] _servants;
+ ReadThread(Test.ServantPrx[] servants)
+ {
+ _servants = servants;
+ }
+
+ public void run()
+ {
+ int loops = 10;
+ while(loops-- > 0)
+ {
+ try
+ {
+ _servants[0].getValue();
+ test(false);
+ }
+ catch(Ice.ObjectNotExistException e)
+ {
+ // Expected
+ }
+ catch(Exception e)
+ {
+ test(false);
+ }
+
+ for(int i = 1; i < _servants.length; ++i)
+ {
+ test(_servants[i].getValue() == i);
+ }
+ }
+ }
+
+ private Test.ServantPrx[] _servants;
}
public static final int StateRunning = 0;
@@ -73,268 +73,268 @@ public class Client
static class ReadForeverThread extends Thread
{
- ReadForeverThread(Test.ServantPrx[] servants)
- {
- _servants = servants;
- }
-
- public void
- run()
- {
- for(;;)
- {
- try
- {
- for(int i = 0; i < _servants.length; ++i)
- {
- if(getEvictorState() == StateDeactivated)
- {
- _servants[i].slowGetValue();
- test(false);
- }
- else
- {
- test(_servants[i].slowGetValue() == i);
- }
- }
- }
- catch(Ice.SocketException e)
- {
- //
- // Expected
- //
- test(validEx());
- return;
- }
- catch(Ice.LocalException e)
- {
- System.err.println("Caught unexpected : " + e.toString());
- test(false);
- return;
- }
- catch(Exception e)
- {
- test(false);
- return;
- }
- }
- }
-
- synchronized int
- getEvictorState()
- {
- return _state;
- }
-
- synchronized boolean
- validEx()
- {
- return _state == StateDeactivating || _state == StateDeactivated;
- }
-
- synchronized void
- setEvictorState(int s)
- {
- _state = s;
- }
-
- private Test.ServantPrx[] _servants;
- private int _state = StateRunning;
+ ReadForeverThread(Test.ServantPrx[] servants)
+ {
+ _servants = servants;
+ }
+
+ public void
+ run()
+ {
+ for(;;)
+ {
+ try
+ {
+ for(int i = 0; i < _servants.length; ++i)
+ {
+ if(getEvictorState() == StateDeactivated)
+ {
+ _servants[i].slowGetValue();
+ test(false);
+ }
+ else
+ {
+ test(_servants[i].slowGetValue() == i);
+ }
+ }
+ }
+ catch(Ice.SocketException e)
+ {
+ //
+ // Expected
+ //
+ test(validEx());
+ return;
+ }
+ catch(Ice.LocalException e)
+ {
+ System.err.println("Caught unexpected : " + e.toString());
+ test(false);
+ return;
+ }
+ catch(Exception e)
+ {
+ test(false);
+ return;
+ }
+ }
+ }
+
+ synchronized int
+ getEvictorState()
+ {
+ return _state;
+ }
+
+ synchronized boolean
+ validEx()
+ {
+ return _state == StateDeactivating || _state == StateDeactivated;
+ }
+
+ synchronized void
+ setEvictorState(int s)
+ {
+ _state = s;
+ }
+
+ private Test.ServantPrx[] _servants;
+ private int _state = StateRunning;
}
static class AddForeverThread extends Thread
- {
- AddForeverThread(Test.RemoteEvictorPrx evictor, int prefix)
- {
- _evictor = evictor;
- _prefix = "" + prefix;
- }
-
- public void
- run()
- {
- int index = 0;
-
- for(;;)
- {
- try
- {
- String id = _prefix + "-" + index++;
- if(getEvictorState() == StateDeactivated)
- {
- _evictor.createServant(id, 0);
- test(false);
- }
- else
- {
- _evictor.createServant(id, 0);
- }
- }
- catch(Test.EvictorDeactivatedException e)
- {
- //
- // Expected
- //
- test(validEx());
- return;
- }
- catch(Ice.ObjectNotExistException e)
- {
- //
- // Expected
- //
- test(validEx());
- return;
- }
- catch(Test.AlreadyRegisteredException e)
- {
- System.err.println("Caught unexpected AlreadyRegistedException:" + e.toString());
- System.err.println("index is " + index);
- test(false);
- return;
- }
- catch(Ice.LocalException e)
- {
- System.err.println("Caught unexpected : " + e.toString());
- e.printStackTrace();
- test(false);
- return;
- }
- catch(Exception e)
- {
- e.printStackTrace();
- test(false);
- return;
- }
- }
- }
-
- synchronized int
- getEvictorState()
- {
- return _state;
- }
-
- synchronized boolean
- validEx()
- {
- return _state == StateDeactivating || _state == StateDeactivated;
- }
-
- synchronized void
- setEvictorState(int s)
- {
- _state = s;
- }
-
- private Test.RemoteEvictorPrx _evictor;
- private String _prefix;
- private int _state = StateRunning;
+ {
+ AddForeverThread(Test.RemoteEvictorPrx evictor, int prefix)
+ {
+ _evictor = evictor;
+ _prefix = "" + prefix;
+ }
+
+ public void
+ run()
+ {
+ int index = 0;
+
+ for(;;)
+ {
+ try
+ {
+ String id = _prefix + "-" + index++;
+ if(getEvictorState() == StateDeactivated)
+ {
+ _evictor.createServant(id, 0);
+ test(false);
+ }
+ else
+ {
+ _evictor.createServant(id, 0);
+ }
+ }
+ catch(Test.EvictorDeactivatedException e)
+ {
+ //
+ // Expected
+ //
+ test(validEx());
+ return;
+ }
+ catch(Ice.ObjectNotExistException e)
+ {
+ //
+ // Expected
+ //
+ test(validEx());
+ return;
+ }
+ catch(Test.AlreadyRegisteredException e)
+ {
+ System.err.println("Caught unexpected AlreadyRegistedException:" + e.toString());
+ System.err.println("index is " + index);
+ test(false);
+ return;
+ }
+ catch(Ice.LocalException e)
+ {
+ System.err.println("Caught unexpected : " + e.toString());
+ e.printStackTrace();
+ test(false);
+ return;
+ }
+ catch(Exception e)
+ {
+ e.printStackTrace();
+ test(false);
+ return;
+ }
+ }
+ }
+
+ synchronized int
+ getEvictorState()
+ {
+ return _state;
+ }
+
+ synchronized boolean
+ validEx()
+ {
+ return _state == StateDeactivating || _state == StateDeactivated;
+ }
+
+ synchronized void
+ setEvictorState(int s)
+ {
+ _state = s;
+ }
+
+ private Test.RemoteEvictorPrx _evictor;
+ private String _prefix;
+ private int _state = StateRunning;
}
static class CreateDestroyThread extends Thread
{
- CreateDestroyThread(Test.RemoteEvictorPrx evictor, int id, int size)
- {
- _evictor = evictor;
- _id = "" + id;
- _size = size;
- }
-
- public void
- run()
- {
- try
- {
- int loops = 50;
- while(loops-- > 0)
- {
- for(int i = 0; i < _size; i++)
- {
- String id = "" + i;
- if(id.equals(_id))
- {
- //
- // Create when odd, destroy when even.
- //
-
- if(loops % 2 == 0)
- {
- Test.ServantPrx servant = _evictor.getServant(id);
- servant.destroy();
-
- //
- // Twice
- //
- try
- {
- servant.destroy();
- test(false);
- }
- catch(Ice.ObjectNotExistException e)
- {
- // Expected
- }
- }
- else
- {
- Test.ServantPrx servant = _evictor.createServant(id, i);
-
- //
- // Twice
- //
- try
- {
- servant = _evictor.createServant(id, 0);
- test(false);
- }
- catch(Test.AlreadyRegisteredException e)
- {
- // Expected
- }
- }
- }
- else
- {
- //
- // Just read/write the value
- //
- Test.ServantPrx servant = _evictor.getServant(id);
- try
- {
- int val = servant.getValue();
- test(val == i || val == -i);
- servant.setValue(-val);
- }
- catch(Ice.ObjectNotExistException e)
- {
- // Expected from time to time
- }
- }
- }
- }
- }
- catch(Exception e)
- {
- //
- // Unexpected!
- //
- test(false);
- }
- }
-
- private Test.RemoteEvictorPrx _evictor;
- private String _id;
- private int _size;
+ CreateDestroyThread(Test.RemoteEvictorPrx evictor, int id, int size)
+ {
+ _evictor = evictor;
+ _id = "" + id;
+ _size = size;
+ }
+
+ public void
+ run()
+ {
+ try
+ {
+ int loops = 50;
+ while(loops-- > 0)
+ {
+ for(int i = 0; i < _size; i++)
+ {
+ String id = "" + i;
+ if(id.equals(_id))
+ {
+ //
+ // Create when odd, destroy when even.
+ //
+
+ if(loops % 2 == 0)
+ {
+ Test.ServantPrx servant = _evictor.getServant(id);
+ servant.destroy();
+
+ //
+ // Twice
+ //
+ try
+ {
+ servant.destroy();
+ test(false);
+ }
+ catch(Ice.ObjectNotExistException e)
+ {
+ // Expected
+ }
+ }
+ else
+ {
+ Test.ServantPrx servant = _evictor.createServant(id, i);
+
+ //
+ // Twice
+ //
+ try
+ {
+ servant = _evictor.createServant(id, 0);
+ test(false);
+ }
+ catch(Test.AlreadyRegisteredException e)
+ {
+ // Expected
+ }
+ }
+ }
+ else
+ {
+ //
+ // Just read/write the value
+ //
+ Test.ServantPrx servant = _evictor.getServant(id);
+ try
+ {
+ int val = servant.getValue();
+ test(val == i || val == -i);
+ servant.setValue(-val);
+ }
+ catch(Ice.ObjectNotExistException e)
+ {
+ // Expected from time to time
+ }
+ }
+ }
+ }
+ }
+ catch(Exception e)
+ {
+ //
+ // Unexpected!
+ //
+ test(false);
+ }
+ }
+
+ private Test.RemoteEvictorPrx _evictor;
+ private String _id;
+ private int _size;
}
private static int
run(String[] args, Ice.Communicator communicator)
- throws Test.AlreadyRegisteredException, Test.NotRegisteredException, Test.EvictorDeactivatedException
+ throws Test.AlreadyRegisteredException, Test.NotRegisteredException, Test.EvictorDeactivatedException
{
String ref = "factory:default -p 12010 -t 30000";
Ice.ObjectPrx base = communicator.stringToProxy(ref);
@@ -342,524 +342,524 @@ public class Client
Test.RemoteEvictorFactoryPrx factory = Test.RemoteEvictorFactoryPrxHelper.checkedCast(base);
- System.out.print("testing Freeze Evictor... ");
- System.out.flush();
-
- final int size = 5;
-
- Test.RemoteEvictorPrx evictor = factory.createEvictor("Test");
- evictor.setSize(size);
-
- //
- // Create some servants
- //
- Test.ServantPrx[] servants = new Test.ServantPrx[size];
- for(int i = 0; i < size; i++)
- {
- String id = "" + i;
- servants[i] = evictor.createServant(id, i);
- servants[i].ice_ping();
-
- Test.FacetPrx facet1 = Test.FacetPrxHelper.uncheckedCast(servants[i], "facet1");
- try
- {
- facet1.ice_ping();
- test(false);
- }
- catch(Ice.FacetNotExistException e)
- {
- //
- // Expected
- //
- }
- servants[i].addFacet("facet1", "data");
- facet1.ice_ping();
- facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
- test(facet1 != null);
- facet1.setValue(10 * i);
- facet1.addFacet("facet2", "moreData");
- Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
- test(facet2 != null);
- facet2.setValue(100 * i);
- }
-
- //
- // Evict and verify values.
- //
- evictor.setSize(0);
- evictor.setSize(size);
- for(int i = 0; i < size; i++)
- {
- servants[i].ice_ping();
- test(servants[i].getValue() == i);
- Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
- test(facet1 != null);
- test(facet1.getValue() == 10 * i);
- test(facet1.getData().equals("data"));
- Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
- test(facet2 != null);
- test(facet2.getData().equals("moreData"));
- }
-
- //
- // Mutate servants.
- //
- for(int i = 0; i < size; i++)
- {
- servants[i].setValue(i + 100);
- Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
- test(facet1 != null);
- facet1.setValue(10 * i + 100);
- Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
- test(facet2 != null);
- facet2.setValue(100 * i + 100);
- }
-
- for(int i = 0; i < size; i++)
- {
- test(servants[i].getValue() == i + 100);
- Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
- test(facet1 != null);
- test(facet1.getValue() == 10 * i + 100);
- Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
- test(facet2 != null);
- test(facet2.getValue() == 100 * i + 100);
- }
-
- //
- // Evict and verify values.
- //
- evictor.setSize(0);
- evictor.setSize(size);
- for(int i = 0; i < size; i++)
- {
- test(servants[i].getValue() == i + 100);
- Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
- test(facet1 != null);
- test(facet1.getValue() == 10 * i + 100);
- Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
- test(facet2 != null);
- test(facet2.getValue() == 100 * i + 100);
- }
-
- //
- // Test saving while busy
- //
-
- AMI_Servant_setValueAsyncI setCB = new AMI_Servant_setValueAsyncI();
- for(int i = 0; i < size; i++)
- {
- //
- // Start a mutating operation so that the object is not idle.
- //
- servants[i].setValueAsync_async(setCB, i + 300);
-
- test(servants[i].getValue() == i + 100);
- //
- // This operation modifies the object state but is not saved
- // because the setValueAsync operation is still pending.
- //
- servants[i].setValue(i + 200);
- test(servants[i].getValue() == i + 200);
-
- //
- // Force the response to setValueAsync
- //
- servants[i].releaseAsync();
- test(servants[i].getValue() == i + 300);
- }
-
-
- //
- // Add duplicate facet and catch corresponding exception
- //
- for(int i = 0; i < size; i++)
- {
- try
- {
- servants[i].addFacet("facet1", "foobar");
- test(false);
- }
- catch(Test.AlreadyRegisteredException ex)
- {
- }
- }
-
- //
- // Remove a facet that does not exist
- //
- try
- {
- servants[0].removeFacet("facet3");
- test(false);
- }
- catch(Test.NotRegisteredException ex)
- {
- }
-
- //
- // Remove all facets
- //
- for(int i = 0; i < size; i++)
- {
- servants[i].removeFacet("facet1");
- servants[i].removeFacet("facet2");
- }
-
- evictor.setSize(0);
- evictor.setSize(size);
-
- //
- // Destroy servants and verify ObjectNotExistException.
- //
- for(int i = 0; i < size; i++)
- {
- servants[i].destroy();
- try
- {
- servants[i].getValue();
- test(false);
- }
- catch(Ice.ObjectNotExistException ex)
- {
- // Expected
- }
-
- try
- {
- servants[i].ice_ping();
- test(false);
- }
- catch(Ice.ObjectNotExistException ex)
- {
- // Expected
- }
-
- }
-
- //
- // Allocate space for size servants.
- //
- servants = new Test.ServantPrx[size];
-
- //
- // Recreate servants, set transient value
- //
- for(int i = 0; i < size; i++)
- {
- String id = "" + i;
- servants[i] = evictor.createServant(id, i);
- servants[i].setTransientValue(i);
- }
-
- //
- // Evict
- //
- evictor.saveNow();
- evictor.setSize(0);
- evictor.setSize(size);
-
- //
- // Check the transient value
- //
- for(int i = 0; i < size; i++)
- {
- test(servants[i].getTransientValue() == -1);
- }
+ System.out.print("testing Freeze Evictor... ");
+ System.out.flush();
+
+ final int size = 5;
+
+ Test.RemoteEvictorPrx evictor = factory.createEvictor("Test");
+ evictor.setSize(size);
+
+ //
+ // Create some servants
+ //
+ Test.ServantPrx[] servants = new Test.ServantPrx[size];
+ for(int i = 0; i < size; i++)
+ {
+ String id = "" + i;
+ servants[i] = evictor.createServant(id, i);
+ servants[i].ice_ping();
+
+ Test.FacetPrx facet1 = Test.FacetPrxHelper.uncheckedCast(servants[i], "facet1");
+ try
+ {
+ facet1.ice_ping();
+ test(false);
+ }
+ catch(Ice.FacetNotExistException e)
+ {
+ //
+ // Expected
+ //
+ }
+ servants[i].addFacet("facet1", "data");
+ facet1.ice_ping();
+ facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
+ test(facet1 != null);
+ facet1.setValue(10 * i);
+ facet1.addFacet("facet2", "moreData");
+ Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
+ test(facet2 != null);
+ facet2.setValue(100 * i);
+ }
+
+ //
+ // Evict and verify values.
+ //
+ evictor.setSize(0);
+ evictor.setSize(size);
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].ice_ping();
+ test(servants[i].getValue() == i);
+ Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
+ test(facet1 != null);
+ test(facet1.getValue() == 10 * i);
+ test(facet1.getData().equals("data"));
+ Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
+ test(facet2 != null);
+ test(facet2.getData().equals("moreData"));
+ }
+
+ //
+ // Mutate servants.
+ //
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].setValue(i + 100);
+ Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
+ test(facet1 != null);
+ facet1.setValue(10 * i + 100);
+ Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
+ test(facet2 != null);
+ facet2.setValue(100 * i + 100);
+ }
+
+ for(int i = 0; i < size; i++)
+ {
+ test(servants[i].getValue() == i + 100);
+ Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
+ test(facet1 != null);
+ test(facet1.getValue() == 10 * i + 100);
+ Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
+ test(facet2 != null);
+ test(facet2.getValue() == 100 * i + 100);
+ }
+
+ //
+ // Evict and verify values.
+ //
+ evictor.setSize(0);
+ evictor.setSize(size);
+ for(int i = 0; i < size; i++)
+ {
+ test(servants[i].getValue() == i + 100);
+ Test.FacetPrx facet1 = Test.FacetPrxHelper.checkedCast(servants[i], "facet1");
+ test(facet1 != null);
+ test(facet1.getValue() == 10 * i + 100);
+ Test.FacetPrx facet2 = Test.FacetPrxHelper.checkedCast(facet1, "facet2");
+ test(facet2 != null);
+ test(facet2.getValue() == 100 * i + 100);
+ }
+
+ //
+ // Test saving while busy
+ //
+
+ AMI_Servant_setValueAsyncI setCB = new AMI_Servant_setValueAsyncI();
+ for(int i = 0; i < size; i++)
+ {
+ //
+ // Start a mutating operation so that the object is not idle.
+ //
+ servants[i].setValueAsync_async(setCB, i + 300);
+
+ test(servants[i].getValue() == i + 100);
+ //
+ // This operation modifies the object state but is not saved
+ // because the setValueAsync operation is still pending.
+ //
+ servants[i].setValue(i + 200);
+ test(servants[i].getValue() == i + 200);
+
+ //
+ // Force the response to setValueAsync
+ //
+ servants[i].releaseAsync();
+ test(servants[i].getValue() == i + 300);
+ }
+
+
+ //
+ // Add duplicate facet and catch corresponding exception
+ //
+ for(int i = 0; i < size; i++)
+ {
+ try
+ {
+ servants[i].addFacet("facet1", "foobar");
+ test(false);
+ }
+ catch(Test.AlreadyRegisteredException ex)
+ {
+ }
+ }
+
+ //
+ // Remove a facet that does not exist
+ //
+ try
+ {
+ servants[0].removeFacet("facet3");
+ test(false);
+ }
+ catch(Test.NotRegisteredException ex)
+ {
+ }
+
+ //
+ // Remove all facets
+ //
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].removeFacet("facet1");
+ servants[i].removeFacet("facet2");
+ }
+
+ evictor.setSize(0);
+ evictor.setSize(size);
+
+ //
+ // Destroy servants and verify ObjectNotExistException.
+ //
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].destroy();
+ try
+ {
+ servants[i].getValue();
+ test(false);
+ }
+ catch(Ice.ObjectNotExistException ex)
+ {
+ // Expected
+ }
+
+ try
+ {
+ servants[i].ice_ping();
+ test(false);
+ }
+ catch(Ice.ObjectNotExistException ex)
+ {
+ // Expected
+ }
+
+ }
+
+ //
+ // Allocate space for size servants.
+ //
+ servants = new Test.ServantPrx[size];
+
+ //
+ // Recreate servants, set transient value
+ //
+ for(int i = 0; i < size; i++)
+ {
+ String id = "" + i;
+ servants[i] = evictor.createServant(id, i);
+ servants[i].setTransientValue(i);
+ }
+
+ //
+ // Evict
+ //
+ evictor.saveNow();
+ evictor.setSize(0);
+ evictor.setSize(size);
+
+ //
+ // Check the transient value
+ //
+ for(int i = 0; i < size; i++)
+ {
+ test(servants[i].getTransientValue() == -1);
+ }
- //
- // Now with keep
- //
- for(int i = 0; i < size; i++)
- {
- servants[i].keepInCache();
- servants[i].keepInCache();
- servants[i].setTransientValue(i);
- }
- evictor.saveNow();
- evictor.setSize(0);
- evictor.setSize(size);
-
- //
- // Check the transient value
- //
- for(int i = 0; i < size; i++)
- {
- test(servants[i].getTransientValue() == i);
- }
-
- //
- // Again, after one release
- //
- for(int i = 0; i < size; i++)
- {
- servants[i].release();
- }
- evictor.saveNow();
- evictor.setSize(0);
- evictor.setSize(size);
- for(int i = 0; i < size; i++)
- {
- test(servants[i].getTransientValue() == i);
- }
-
- //
- // Again, after a second release
- //
- for(int i = 0; i < size; i++)
- {
- servants[i].release();
- }
- evictor.saveNow();
- evictor.setSize(0);
- evictor.setSize(size);
-
- for(int i = 0; i < size; i++)
- {
- test(servants[i].getTransientValue() == -1);
- }
-
- //
- // Release one more time
- //
- for(int i = 0; i < size; i++)
- {
- try
- {
- servants[i].release();
- test(false);
- }
- catch(Test.NotRegisteredException e)
- {
- // Expected
- }
- }
-
- //
- // Deactivate and recreate evictor, to ensure that servants
- // are restored properly after database close and reopen.
- //
- evictor.deactivate();
- evictor = factory.createEvictor("Test");
- evictor.setSize(size);
- for(int i = 0; i < size; i++)
- {
- String id = "" + i;
- servants[i] = evictor.getServant(id);
- test(servants[i].getValue() == i);
- }
-
-
- //
- // Test concurrent lookups with a smaller evictor
- // size and one missing servant
- //
- evictor.setSize(size / 2);
- servants[0].destroy();
-
- {
- int threadCount = size * 2;
-
- Thread[] threads = new Thread[threadCount];
- for(int i = 0; i < threadCount; i++)
- {
- threads[i] = new ReadThread(servants);
- threads[i].start();
- }
-
- for(int i = 0; i < threadCount; i++)
- {
- for(;;)
- {
- try
- {
- threads[i].join(0);
- break;
- }
- catch(InterruptedException e)
- {
- }
- }
- }
- }
-
- //
- // Clean up.
- //
- evictor.destroyAllServants("");
- evictor.destroyAllServants("facet1");
- evictor.destroyAllServants("facet2");
-
- //
- // CreateDestroy threads
- //
- {
- int threadCount = size;;
-
- Thread[] threads = new Thread[threadCount];
- for(int i = 0; i < threadCount; i++)
- {
- threads[i] = new CreateDestroyThread(evictor, i, size);
- threads[i].start();
- }
-
- for(int i = 0; i < threadCount; i++)
- {
- for(;;)
- {
- try
- {
- threads[i].join(0);
- break;
- }
- catch(InterruptedException e)
- {
- }
- }
- }
-
- //
- // Verify all destroyed
- //
- for(int i = 0; i < size; i++)
- {
- try
- {
- servants[i].getValue();
- test(false);
- }
- catch(Ice.ObjectNotExistException e)
- {
- // Expected
- }
- }
- }
-
- //
- // Recreate servants.
- //
- servants = new Test.ServantPrx[size];
- for(int i = 0; i < size; i++)
- {
- String id = "" + i;
- servants[i] = evictor.createServant(id, i);
- }
-
- //
- // Deactivate in the middle of remote AMD operations
- // (really testing Ice here)
- //
- {
- int threadCount = size;
-
- Thread[] threads = new Thread[threadCount];
- for(int i = 0; i < threadCount; i++)
- {
- threads[i] = new ReadForeverThread(servants);
- threads[i].start();
- }
-
- try
- {
- Thread.currentThread().sleep(500);
- }
- catch(InterruptedException e)
- {
- }
-
- for(int i = 0; i < threadCount; i++)
- {
- ReadForeverThread t = (ReadForeverThread)threads[i];
- t.setEvictorState(StateDeactivating);
- }
- evictor.deactivate();
- for(int i = 0; i < threadCount; i++)
- {
- ReadForeverThread t = (ReadForeverThread)threads[i];
- t.setEvictorState(StateDeactivated);
- }
-
- for(int i = 0; i < threadCount; i++)
- {
- for(;;)
- {
- try
- {
- threads[i].join(0);
- break;
- }
- catch(InterruptedException e)
- {
- }
- }
- }
- }
-
- //
- // Resurrect
- //
- evictor = factory.createEvictor("Test");
- evictor.destroyAllServants("");
-
- //
- // Deactivate in the middle of adds
- //
- {
- int threadCount = size;
-
- Thread[] threads = new Thread[threadCount];
- for(int i = 0; i < threadCount; i++)
- {
- threads[i] = new AddForeverThread(evictor, i);
- threads[i].start();
- }
-
- try
- {
- Thread.currentThread().sleep(500);
- }
- catch(InterruptedException e)
- {
- }
-
- for(int i = 0; i < threadCount; i++)
- {
- AddForeverThread t = (AddForeverThread)threads[i];
- t.setEvictorState(StateDeactivating);
- }
- evictor.deactivate();
- for(int i = 0; i < threadCount; i++)
- {
- AddForeverThread t = (AddForeverThread)threads[i];
- t.setEvictorState(StateDeactivated);
- }
-
- for(int i = 0; i < threadCount; i++)
- {
- for(;;)
- {
- try
- {
- threads[i].join(0);
- break;
- }
- catch(InterruptedException e)
- {
- }
- }
- }
- }
-
-
- //
- // Clean up.
- //
- evictor = factory.createEvictor("Test");
- evictor.destroyAllServants("");
- evictor.deactivate();
-
-
- System.out.println("ok");
+ //
+ // Now with keep
+ //
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].keepInCache();
+ servants[i].keepInCache();
+ servants[i].setTransientValue(i);
+ }
+ evictor.saveNow();
+ evictor.setSize(0);
+ evictor.setSize(size);
+
+ //
+ // Check the transient value
+ //
+ for(int i = 0; i < size; i++)
+ {
+ test(servants[i].getTransientValue() == i);
+ }
+
+ //
+ // Again, after one release
+ //
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].release();
+ }
+ evictor.saveNow();
+ evictor.setSize(0);
+ evictor.setSize(size);
+ for(int i = 0; i < size; i++)
+ {
+ test(servants[i].getTransientValue() == i);
+ }
+
+ //
+ // Again, after a second release
+ //
+ for(int i = 0; i < size; i++)
+ {
+ servants[i].release();
+ }
+ evictor.saveNow();
+ evictor.setSize(0);
+ evictor.setSize(size);
+
+ for(int i = 0; i < size; i++)
+ {
+ test(servants[i].getTransientValue() == -1);
+ }
+
+ //
+ // Release one more time
+ //
+ for(int i = 0; i < size; i++)
+ {
+ try
+ {
+ servants[i].release();
+ test(false);
+ }
+ catch(Test.NotRegisteredException e)
+ {
+ // Expected
+ }
+ }
+
+ //
+ // Deactivate and recreate evictor, to ensure that servants
+ // are restored properly after database close and reopen.
+ //
+ evictor.deactivate();
+ evictor = factory.createEvictor("Test");
+ evictor.setSize(size);
+ for(int i = 0; i < size; i++)
+ {
+ String id = "" + i;
+ servants[i] = evictor.getServant(id);
+ test(servants[i].getValue() == i);
+ }
+
+
+ //
+ // Test concurrent lookups with a smaller evictor
+ // size and one missing servant
+ //
+ evictor.setSize(size / 2);
+ servants[0].destroy();
+
+ {
+ int threadCount = size * 2;
+
+ Thread[] threads = new Thread[threadCount];
+ for(int i = 0; i < threadCount; i++)
+ {
+ threads[i] = new ReadThread(servants);
+ threads[i].start();
+ }
+
+ for(int i = 0; i < threadCount; i++)
+ {
+ for(;;)
+ {
+ try
+ {
+ threads[i].join(0);
+ break;
+ }
+ catch(InterruptedException e)
+ {
+ }
+ }
+ }
+ }
+
+ //
+ // Clean up.
+ //
+ evictor.destroyAllServants("");
+ evictor.destroyAllServants("facet1");
+ evictor.destroyAllServants("facet2");
+
+ //
+ // CreateDestroy threads
+ //
+ {
+ int threadCount = size;;
+
+ Thread[] threads = new Thread[threadCount];
+ for(int i = 0; i < threadCount; i++)
+ {
+ threads[i] = new CreateDestroyThread(evictor, i, size);
+ threads[i].start();
+ }
+
+ for(int i = 0; i < threadCount; i++)
+ {
+ for(;;)
+ {
+ try
+ {
+ threads[i].join(0);
+ break;
+ }
+ catch(InterruptedException e)
+ {
+ }
+ }
+ }
+
+ //
+ // Verify all destroyed
+ //
+ for(int i = 0; i < size; i++)
+ {
+ try
+ {
+ servants[i].getValue();
+ test(false);
+ }
+ catch(Ice.ObjectNotExistException e)
+ {
+ // Expected
+ }
+ }
+ }
+
+ //
+ // Recreate servants.
+ //
+ servants = new Test.ServantPrx[size];
+ for(int i = 0; i < size; i++)
+ {
+ String id = "" + i;
+ servants[i] = evictor.createServant(id, i);
+ }
+
+ //
+ // Deactivate in the middle of remote AMD operations
+ // (really testing Ice here)
+ //
+ {
+ int threadCount = size;
+
+ Thread[] threads = new Thread[threadCount];
+ for(int i = 0; i < threadCount; i++)
+ {
+ threads[i] = new ReadForeverThread(servants);
+ threads[i].start();
+ }
+
+ try
+ {
+ Thread.currentThread().sleep(500);
+ }
+ catch(InterruptedException e)
+ {
+ }
+
+ for(int i = 0; i < threadCount; i++)
+ {
+ ReadForeverThread t = (ReadForeverThread)threads[i];
+ t.setEvictorState(StateDeactivating);
+ }
+ evictor.deactivate();
+ for(int i = 0; i < threadCount; i++)
+ {
+ ReadForeverThread t = (ReadForeverThread)threads[i];
+ t.setEvictorState(StateDeactivated);
+ }
+
+ for(int i = 0; i < threadCount; i++)
+ {
+ for(;;)
+ {
+ try
+ {
+ threads[i].join(0);
+ break;
+ }
+ catch(InterruptedException e)
+ {
+ }
+ }
+ }
+ }
+
+ //
+ // Resurrect
+ //
+ evictor = factory.createEvictor("Test");
+ evictor.destroyAllServants("");
+
+ //
+ // Deactivate in the middle of adds
+ //
+ {
+ int threadCount = size;
+
+ Thread[] threads = new Thread[threadCount];
+ for(int i = 0; i < threadCount; i++)
+ {
+ threads[i] = new AddForeverThread(evictor, i);
+ threads[i].start();
+ }
+
+ try
+ {
+ Thread.currentThread().sleep(500);
+ }
+ catch(InterruptedException e)
+ {
+ }
+
+ for(int i = 0; i < threadCount; i++)
+ {
+ AddForeverThread t = (AddForeverThread)threads[i];
+ t.setEvictorState(StateDeactivating);
+ }
+ evictor.deactivate();
+ for(int i = 0; i < threadCount; i++)
+ {
+ AddForeverThread t = (AddForeverThread)threads[i];
+ t.setEvictorState(StateDeactivated);
+ }
+
+ for(int i = 0; i < threadCount; i++)
+ {
+ for(;;)
+ {
+ try
+ {
+ threads[i].join(0);
+ break;
+ }
+ catch(InterruptedException e)
+ {
+ }
+ }
+ }
+ }
+
+
+ //
+ // Clean up.
+ //
+ evictor = factory.createEvictor("Test");
+ evictor.destroyAllServants("");
+ evictor.deactivate();
+
+
+ System.out.println("ok");
factory.shutdown();
@@ -882,21 +882,21 @@ public class Client
ex.printStackTrace();
status = 1;
}
- catch(Test.AlreadyRegisteredException ex)
- {
- ex.printStackTrace();
+ catch(Test.AlreadyRegisteredException ex)
+ {
+ ex.printStackTrace();
status = 1;
- }
- catch(Test.NotRegisteredException ex)
- {
- ex.printStackTrace();
+ }
+ catch(Test.NotRegisteredException ex)
+ {
+ ex.printStackTrace();
status = 1;
- }
- catch(Test.EvictorDeactivatedException ex)
- {
- ex.printStackTrace();
+ }
+ catch(Test.EvictorDeactivatedException ex)
+ {
+ ex.printStackTrace();
status = 1;
- }
+ }
if(communicator != null)
{
@@ -911,7 +911,7 @@ public class Client
}
}
- System.gc();
+ System.gc();
System.exit(status);
}
}
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 12:57:35 +0000