// This Source Code is in the Public Domain per: http://litesoft.org/License.txt
package org.litesoft.orsup.transact.nonpublic;

import org.litesoft.orsup.transact.*;

public class SucceededTransactionCommitListenerManagerImpl implements SucceededTransactionCommitListenerManagerInternalExtension
{
    private SucceededTransactionCommitListener[] mListeners = SucceededTransactionCommitListener.EMPTY_ARRAY;

    @Override
    public synchronized SucceededTransactionCommitListener[] getListeners()
    {
        return (mListeners.length == 0) ? mListeners : mListeners.clone();
    }

    @Override
    public synchronized void addListener( SucceededTransactionCommitListener pListener )
    {
        if ( pListener != null )
        {
            int zCurLen = mListeners.length;
            if ( zCurLen == 0 )
            {
                mListeners = new SucceededTransactionCommitListener[]{pListener};
            }
            else if ( -1 == findTransaction( pListener ) )
            {
                SucceededTransactionCommitListener[] zListeners = new SucceededTransactionCommitListener[zCurLen + 1];
                System.arraycopy( mListeners, 0, zListeners, 1, zCurLen );
                zListeners[0] = pListener;
                mListeners = zListeners;
            }
        }
    }

    @Override
    public synchronized boolean removeListeners( Class<? extends SucceededTransactionCommitListener> pListenerClass )
    {
        boolean rv = false;
        for ( int at; -1 != (at = findListener( pListenerClass )); )
        {
            rv = true;
            removeListener( at );
        }
        return rv;
    }

    @Override
    public synchronized boolean removeListener( SucceededTransactionCommitListener pListener )
    {
        int at = findTransaction( pListener );
        if ( at != -1 )
        {
            removeListener( at );
            return true;
        }
        return false;
    }

    @Override
    public synchronized void clearListeners()
    {
        mListeners = SucceededTransactionCommitListener.EMPTY_ARRAY;
    }

    @Override
    public synchronized SucceededTransactionCommitListener[] getRawTransactionCommitListenersArray()
    {
        return mListeners;
    }

    private int findListener( Class<? extends SucceededTransactionCommitListener> pListenerClass )
    {
        if ( pListenerClass != null )
        {
            for ( int i = mListeners.length; --i >= 0; )
            {
                if ( pListenerClass == mListeners[i].getClass() )
                {
                    return i;
                }
            }
        }
        return -1;
    }

    private int findTransaction( SucceededTransactionCommitListener pListener )
    {
        if ( pListener != null )
        {
            for ( int i = mListeners.length; --i >= 0; )
            {
                if ( pListener == mListeners[i] )
                {
                    return i;
                }
            }
        }
        return -1;
    }

    private void removeListener( int pIndex )
    {
        int ndxTo, curLength = mListeners.length;
        if ( curLength <= 1 )
        {
            mListeners = SucceededTransactionCommitListener.EMPTY_ARRAY;
            return;
        }
        SucceededTransactionCommitListener[] newAFs = new SucceededTransactionCommitListener[curLength - 1];
        for ( int ndxFrom = ndxTo = 0; ndxFrom < mListeners.length; ndxFrom++ )
        {
            if ( ndxFrom != pIndex )
            {
                newAFs[ndxTo++] = mListeners[ndxFrom];
            }
        }
        mListeners = newAFs;
    }
}