/*

* Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:

*

*/

package com.nokia.mj.impl.utils.concurrent;

import java.util.Enumeration;

import java.util.Vector;

import com.nokia.mj.impl.installer.utils.InstallerMain;

import com.nokia.mj.impl.utils.DebugUtils;

import j2meunit.framework.Test;

import j2meunit.framework.TestCase;

import j2meunit.framework.TestMethod;

import j2meunit.framework.TestSuite;

/**

 * BufferedReader unit tests.

 */

public class ConcurrentTests extends TestCase implements InstallerMain

{

    private int mMaxThreadId;

    private int mReleaseThreadId;

    private int mNextReleasedThreadId;

    private int mRunningThreadCount;

    private Semaphore mSem;

    private Object mLockEnd;

    // Begin j2meunit test framework setup

    public void installerMain(String[] args)

    {

        createDumperThread(false);

        TestSuite suite = new TestSuite(this.getClass().getName());

        suite.addTest(new ConcurrentTests("testLockBasic", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testLockBasic();

            }

        }));

        suite.addTest(new ConcurrentTests("testLockFair", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testLockFair();

            }

        }));

        suite.addTest(new ConcurrentTests("testLockFair2", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testLockFair2();

            }

        }));

        suite.addTest(new ConcurrentTests("testLockUnFair", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testLockUnFair();

            }

        }));

        suite.addTest(new ConcurrentTests("testLockUnFair2", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testLockUnFair2();

            }

        }));

        suite.addTest(new ConcurrentTests("testLockUnFair3", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testLockUnFair3();

            }

        }));

        suite.addTest(new ConcurrentTests("testCondition1", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testCondition1();

            }

        }));

        suite.addTest(new ConcurrentTests("testCondition10_10", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testCondition10_10();

            }

        }));

        suite.addTest(new ConcurrentTests("testCondition5_10", new TestMethod()

        {

            public void run(TestCase tc)

            {

                ((ConcurrentTests)tc).testCondition5_10();

            }

        }));

        com.nokia.mj.impl.utils.OmjTestRunner.run(suite);

    }

    public ConcurrentTests()

    {

    }

    public ConcurrentTests(String aTestName, TestMethod aTestMethod)

    {

        super(aTestName, aTestMethod);

    }

    private void createDumperThread(boolean doCreate)

    {

        if (doCreate)

        {

            new Thread(new Runnable(){

                public void run()

                {

                    threadSleep(5000);

                }

            }).start();

        }

    }

    public void assertFalse(String aMsg, boolean aCondition)

    {

        assertTrue(aMsg, !aCondition);

    }

    // End j2meunit test framework setup

    protected void setUp()

    {

    }

    protected void tearDown()

    {

    }

    private synchronized void incThreadCount()

    {

        mRunningThreadCount++;

    }

    private synchronized void decThreadCount()

    {

        mRunningThreadCount--;

    }

    private Vector /*String*/ mTrace = new Vector();

    private void trace(String str)

    {

        trace(str, false);

    }

    private void trace(String str, boolean doTrace)

    {

        if (doTrace)

        {

        //System.out.println(str);

        mTrace.addElement(str);

        }

    }

    private void printTrace()

    {

        Enumeration enumer = mTrace.elements();

        while (enumer.hasMoreElements())

        {

            String s = (String)enumer.nextElement();

            System.out.println(s);

        }

        mTrace.removeAllElements();

    }

    // Test cases

    /** LOCK TESTS*/

    private void testLockBasic()

    {

        try

        {

            Semaphore sem = new Semaphore(1, true);

            sem.acquire();

            sem.release();

            sem.acquire();

            sem.release();

            sem.acquire();

            sem.release();

            sem = null;

            Semaphore sem2 = new Semaphore(1, false);

            sem2.acquire();

            sem2.release();

            sem2.acquire();

            sem2.release();

            sem2.acquire();

            sem2.release();

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testLockFair()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 10;

        mMaxThreadId = 10;

        try

        {

            testLock(true);

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testLockFair2()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 5;

        mMaxThreadId = 10;

        try

        {

            testLock(true);

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testLockUnFair()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 10;

        mMaxThreadId = 10;

        try

        {

            testLock(false);

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testLockUnFair2()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 5;

        mMaxThreadId = 10;

        try

        {

            testLock(false);

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testLockUnFair3()

    {

        try

        {

            mSem = new Semaphore(1, false);

            mSem.acquire();

            new Thread(new Runnable()

            {

                public void run()

                {

                    threadSleep(100);

                    mSem.release();

                }

            }).start();

            mSem.acquire();

            mSem.release();

            mSem.acquire();

            new Thread(new Runnable()

            {

                public void run()

                {

                    threadSleep(100);

                    mSem.release();

                }

            }).start();

            mSem.acquire();

            mSem.release();

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private class LockTestThread extends Thread

    {

        private int mId;

        private boolean mCheck;

        private LockTestThread(int id, boolean check)

        {

            mId = id;

            mCheck = check;

        }

        public void run() 

        {

            threadSleep(20);

            trace("run: "+mId);

            incThreadCount();

            if (mId < mMaxThreadId)

            {

                // Need to create additional thread.

                trace("creating new thread: "+mId);

                new LockTestThread(mId+1, mCheck).start();

            }

            if (mReleaseThreadId == mId)

            {

                synchronized (mLockEnd)

                {

                    trace("notify: "+mId);

                    mLockEnd.notify();

                }

            }

            trace("Getting lock: "+mId);

            mSem.acquire();

            trace("Got lock: "+mId);

            if (mCheck)

            {

                String errorTxt = "Incorrect release order. mId: "+ mId + 

                                  ", next: " +mNextReleasedThreadId;

                assertTrue(errorTxt, mNextReleasedThreadId == mId);

            }

            mNextReleasedThreadId++;

            trace("unlock: "+mId);

            mSem.release();

            decThreadCount();

            trace("done: "+mId);

        }

    }

    private void threadSleep(int ms)

    {

        try

        {

            Thread.sleep(ms);

        }

        catch (Exception e)

        {

        }

    }

    private void testLock(boolean isFair) throws Exception

    {

        mSem = new Semaphore(1,isFair);

        mSem.acquire();

        new LockTestThread(1, isFair).start();

        mLockEnd = new Object();

        synchronized (mLockEnd)

        {

            // Wait that all the threads has been started.

            trace("Wait()");

            mLockEnd.wait();

            trace("wait ok()");

        }

        mSem.release();

        trace("unlock after wait");

        for (int i = 0; i < 5; ++i)

        {

            threadSleep(100);

            trace("Woke from sleep.");

            if (mRunningThreadCount == 0)

            {

                break;

            }

        }

        printTrace();

        assertTrue("Threads still running: " + mRunningThreadCount, mRunningThreadCount == 0);

    }

    /** CONDITION TESTS*/

    private ConditionObject mCondition;

    private void testCondition1()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 1;

        mMaxThreadId = 1;

        try

        {

            testCondtion();

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testCondition10_10()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 10;

        mMaxThreadId = 10;

        try

        {

            testCondtion();

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private void testCondition5_10()

    {

        mRunningThreadCount = 0;

        mNextReleasedThreadId = 1;

        mReleaseThreadId = 5;

        mMaxThreadId = 10;

        try

        {

            testCondtion();

        }

        catch (Throwable t)

        {

            assertTrue(t.toString(), false);

            t.printStackTrace();

        }

    }

    private class ConditionTestThread extends Thread

    {

        private int mId;

        private ConditionTestThread(int id)

        {

            mId = id;

        }

        public void run() 

        {

            threadSleep(20);

            trace("run: "+mId);

            incThreadCount();

            if (mReleaseThreadId == mId)

            {

                synchronized (mLockEnd)

                {

                    trace("notify: "+mId);

                    mLockEnd.notify();

                }

                threadSleep(50);

            }

            if (mId < mMaxThreadId)

            {

                // Need to create additional thread.

                trace("creating new thread: "+mId);

                new ConditionTestThread(mId+1).start();