diff options
Diffstat (limited to 'java/test/Freeze/oldevictor/Client.java')
| -rw-r--r-- | java/test/Freeze/oldevictor/Client.java | 916 |
1 files changed, 0 insertions, 916 deletions
diff --git a/java/test/Freeze/oldevictor/Client.java b/java/test/Freeze/oldevictor/Client.java deleted file mode 100644 index f30b38e2e29..00000000000 --- a/java/test/Freeze/oldevictor/Client.java +++ /dev/null @@ -1,916 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2009 ZeroC, Inc. All rights reserved. -// -// This copy of Ice is licensed to you under the terms described in the -// ICE_LICENSE file included in this distribution. -// -// ********************************************************************** - -package test.Freeze.oldevictor; -import test.Freeze.oldevictor.Test.*; -import java.io.PrintWriter; - -public class Client extends test.Util.Application -{ - private static void - test(boolean b) - { - if(!b) - { - throw new RuntimeException(); - } - } - - private static class AMI_Servant_setValueAsyncI extends AMI_Servant_setValueAsync - { - public void - ice_response() - { - } - - public void - ice_exception(Ice.LocalException ex) - { - } - } - - static class ReadThread extends Thread - { - ReadThread(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 ServantPrx[] _servants; - } - - public static final int StateRunning = 0; - public static final int StateDeactivating = 1; - public static final int StateDeactivated = 2; - - static class ReadForeverThread extends Thread - { - ReadForeverThread(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()); - 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 ServantPrx[] _servants; - private int _state = StateRunning; - } - - - static class AddForeverThread extends Thread - { - AddForeverThread(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(EvictorDeactivatedException e) - { - // - // Expected - // - test(validEx()); - return; - } - catch(Ice.ObjectNotExistException e) - { - // - // Expected - // - test(validEx()); - return; - } - catch(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 RemoteEvictorPrx _evictor; - private String _prefix; - private int _state = StateRunning; - } - - - static class CreateDestroyThread extends Thread - { - CreateDestroyThread(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) - { - ServantPrx servant = _evictor.getServant(id); - servant.destroy(); - - // - // Twice - // - try - { - servant.destroy(); - test(false); - } - catch(Ice.ObjectNotExistException e) - { - // Expected - } - } - else - { - ServantPrx servant = _evictor.createServant(id, i); - - // - // Twice - // - try - { - servant = _evictor.createServant(id, 0); - test(false); - } - catch(AlreadyRegisteredException e) - { - // Expected - } - } - } - else - { - // - // Just read/write the value - // - 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 RemoteEvictorPrx _evictor; - private String _id; - private int _size; - } - - private int - run(String[] args, PrintWriter out) - throws AlreadyRegisteredException, NotRegisteredException, EvictorDeactivatedException - { - String ref = "factory:default -p 12010"; - Ice.ObjectPrx base = communicator().stringToProxy(ref); - test(base != null); - RemoteEvictorFactoryPrx factory = RemoteEvictorFactoryPrxHelper.checkedCast(base); - - - out.print("testing Freeze Evictor... "); - out.flush(); - - final int size = 5; - - RemoteEvictorPrx evictor = factory.createEvictor("Test"); - evictor.setSize(size); - - // - // Create some servants - // - ServantPrx[] servants = new ServantPrx[size]; - for(int i = 0; i < size; i++) - { - String id = "" + i; - servants[i] = evictor.createServant(id, i); - servants[i].ice_ping(); - - FacetPrx facet1 = 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 = FacetPrxHelper.checkedCast(servants[i], "facet1"); - test(facet1 != null); - facet1.setValue(10 * i); - facet1.addFacet("facet2", "moreData"); - FacetPrx facet2 = 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); - FacetPrx facet1 = FacetPrxHelper.checkedCast(servants[i], "facet1"); - test(facet1 != null); - test(facet1.getValue() == 10 * i); - test(facet1.getData().equals("data")); - FacetPrx facet2 = 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); - FacetPrx facet1 = FacetPrxHelper.checkedCast(servants[i], "facet1"); - test(facet1 != null); - facet1.setValue(10 * i + 100); - FacetPrx facet2 = 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); - FacetPrx facet1 = FacetPrxHelper.checkedCast(servants[i], "facet1"); - test(facet1 != null); - test(facet1.getValue() == 10 * i + 100); - FacetPrx facet2 = 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); - FacetPrx facet1 = FacetPrxHelper.checkedCast(servants[i], "facet1"); - test(facet1 != null); - test(facet1.getValue() == 10 * i + 100); - FacetPrx facet2 = 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(AlreadyRegisteredException ex) - { - } - } - - // - // Remove a facet that does not exist - // - try - { - servants[0].removeFacet("facet3"); - test(false); - } - catch(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 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(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 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(); - - - out.println("ok"); - - factory.shutdown(); - - return 0; - } - - public int - run(String[] args) - { - PrintWriter out = getWriter(); - int status = 0; - try - { - status = run(args, out); - } - catch(AlreadyRegisteredException ex) - { - ex.printStackTrace(out); - status = 1; - } - catch(NotRegisteredException ex) - { - ex.printStackTrace(out); - status = 1; - } - catch(EvictorDeactivatedException ex) - { - ex.printStackTrace(out); - status = 1; - } - return status; - } - - protected Ice.InitializationData getInitData(Ice.StringSeqHolder argsH) - { - Ice.InitializationData initData = new Ice.InitializationData(); - initData.properties = Ice.Util.createProperties(argsH); - initData.properties.setProperty("Ice.Package.Test", "test.Freeze.oldevictor"); - return initData; - } - - public static void main(String[] args) - { - Client c = new Client(); - int status = c.main("Client", args); - - System.gc(); - System.exit(status); - } -} |