litesoft

URLs

Explore

Commits

Diff Revisions 949 vs 950 for /trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/nonpublic/SavedEventsExpectingResponseTracker.java

		@@ -1,45 +1,45 @@
1		-	// This Source Code is in the Public Domain per: http://unlicense.org
2		-	package org.litesoft.GWT.eventbus.client.nonpublic;
3		-
4		-	import org.litesoft.GWT.eventbus.client.*;
5		-	import org.litesoft.logger.*;
6		-
7		-	import java.util.*;
8		-
9		-	public class SavedEventsExpectingResponseTracker {
10		-	private Map mPendingAckPeerInterestToEvents = new HashMap();
11		-	private Logger mLogger;
12		-
13		-	public SavedEventsExpectingResponseTracker( Logger pLogger ) {
14		-	mLogger = pLogger;
15		-	}
16		-
17		-	private void LLadd( EventPackage pPackage ) {
18		-	String name = pPackage.getSourceName();
19		-	EventPackage[] newList, curList = (EventPackage[]) mPendingAckPeerInterestToEvents.get( name );
20		-	if ( curList == null ) {
21		-	newList = new EventPackage[]{pPackage};
22		-	} else {
23		-	newList = new EventPackage[curList.length + 1];
24		-	int i = 0;
25		-	for (; i < curList.length; i++ ) {
26		-	newList[i] = curList[i];
27		-	}
28		-	newList[i] = pPackage;
29		-	}
30		-	mPendingAckPeerInterestToEvents.put( name, newList );
31		-	}
32		-
33		-	public void add( EventPackage pPackage ) {
34		-	mLogger.trace.log( "(EventExpectingResponse):", pPackage );
35		-	LLadd( pPackage );
36		-	}
37		-
38		-	public void clear() {
39		-	mPendingAckPeerInterestToEvents.clear();
40		-	}
41		-
42		-	public EventPackage[] getAndReleaseEventsFor( String pName ) {
43		-	return (EventPackage[]) mPendingAckPeerInterestToEvents.remove( pName );
44		-	}
45		-	}
	1	+	// This Source Code is in the Public Domain per: http://unlicense.org
	2	+	package org.litesoft.GWT.eventbus.client.nonpublic;
	3	+
	4	+	import org.litesoft.GWT.eventbus.client.*;
	5	+	import org.litesoft.logger.*;
	6	+
	7	+	import java.util.*;
	8	+
	9	+	public class SavedEventsExpectingResponseTracker {
	10	+	private Map mPendingAckPeerInterestToEvents = new HashMap();
	11	+	private Logger mLogger;
	12	+
	13	+	public SavedEventsExpectingResponseTracker( Logger pLogger ) {
	14	+	mLogger = pLogger;
	15	+	}
	16	+
	17	+	private void LLadd( EventPackage pPackage ) {
	18	+	String name = pPackage.getSourceName();
	19	+	EventPackage[] newList, curList = (EventPackage[]) mPendingAckPeerInterestToEvents.get( name );
	20	+	if ( curList == null ) {
	21	+	newList = new EventPackage[]{pPackage};
	22	+	} else {
	23	+	newList = new EventPackage[curList.length + 1];
	24	+	int i = 0;
	25	+	for (; i < curList.length; i++ ) {
	26	+	newList[i] = curList[i];
	27	+	}
	28	+	newList[i] = pPackage;
	29	+	}
	30	+	mPendingAckPeerInterestToEvents.put( name, newList );
	31	+	}
	32	+
	33	+	public void add( EventPackage pPackage ) {
	34	+	mLogger.trace.log( "(EventExpectingResponse):", pPackage );
	35	+	LLadd( pPackage );
	36	+	}
	37	+
	38	+	public void clear() {
	39	+	mPendingAckPeerInterestToEvents.clear();
	40	+	}
	41	+
	42	+	public EventPackage[] getAndReleaseEventsFor( String pName ) {
	43	+	return (EventPackage[]) mPendingAckPeerInterestToEvents.remove( pName );
	44	+	}
	45	+	}

View View this file contents

History View the full history

Feeds

Commits for /trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/nonpublic/SavedEventsExpectingResponseTracker.java