// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.eventbus.client.nonpublic;

import java.util.*;

import org.litesoft.GWT.eventbus.client.*;
import org.litesoft.logger.*;

public class SavedEventsExpectingResponseTracker
{
    private Map mPendingAckPeerInterestToEvents = new HashMap();
    private Logger mLogger;

    public SavedEventsExpectingResponseTracker( Logger pLogger )
    {
        mLogger = pLogger;
    }

    private void LLadd( EventPackage pPackage )
    {
        String name = pPackage.getSourceName();
        EventPackage[] newList, curList = (EventPackage[]) mPendingAckPeerInterestToEvents.get( name );
        if ( curList == null )
        {
            newList = new EventPackage[]{pPackage};
        }
        else
        {
            newList = new EventPackage[curList.length + 1];
            int i = 0;
            for ( ; i < curList.length; i++ )
            {
                newList[i] = curList[i];
            }
            newList[i] = pPackage;
        }
        mPendingAckPeerInterestToEvents.put( name, newList );
    }

    public void add( EventPackage pPackage )
    {
        mLogger.trace.log( "(EventExpectingResponse):", pPackage );
        LLadd( pPackage );
    }

    public void clear()
    {
        mPendingAckPeerInterestToEvents.clear();
    }

    public EventPackage[] getAndReleaseEventsFor( String pName )
    {
        return (EventPackage[]) mPendingAckPeerInterestToEvents.remove( pName );
    }
}