Removed Freeze.UseNonmutating

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);
-    }
-}