litesoft

URLs

Explore

Commits

Diff Revisions 819 vs 858 for /trunk/Java/core/Anywhere/src/org/litesoft/bo/views/VoDataProvider.java

		@@ -3,6 +3,7 @@
3	3
4	4		import org.litesoft.bo.views.caching.*;
5	5		import org.litesoft.core.delayed.*;
	6	+	import org.litesoft.core.simpletypes.temporal.*;
6	7		import org.litesoft.core.typeutils.*;
7	8
8	9		public abstract class VoDataProvider<T extends IViewObject> extends AbstractCommonSupport
		@@ -93,6 +94,7 @@
93	94		private static class Poller implements TemporalTriggerManager.AnyResponseListener,
94	95		TimedRunnable
95	96		{
	97	+	private MillisecTimeSource mMillisecTimeSource = MillisecTimeSource.INSTANCE; // TODO: Inject?
96	98		private boolean mPolling = false;
97	99		private boolean mFast = false;
98	100		private int mOutstandingRequests = 0;
		@@ -106,7 +108,7 @@
106	108		{
107	109		if ( mPolling )
108	110		{
109		-	mLastMessageRecieved = now();
	111	+	mLastMessageRecieved = mMillisecTimeSource.now();
110	112		}
111	113		}
112	114		}
		@@ -128,7 +130,7 @@
128	130		{
129	131		mDP = pDP;
130	132		mFast = pFast;
131		-	long zNow = now();
	133	+	long zNow = mMillisecTimeSource.now();
132	134		mLastMessageRecieved = zNow; // fool our self!
133	135		long zDesiredOnOrAfter = zNow + getPollDelay();
134	136		if ( mPolling )
		@@ -154,7 +156,7 @@
154	156		return null;
155	157		}
156	158
157		-	long zNow = now();
	159	+	long zNow = mMillisecTimeSource.now();
158	160		long zPollDelay = getPollDelay();
159	161		long zDesiredOnOrAfter = mLastMessageRecieved + zPollDelay;
160	162
		@@ -173,11 +175,6 @@
173	175		return (mNextPollOnOrAfter = zDesiredOnOrAfter);
174	176		}
175	177
176		-	private long now()
177		-	{
178		-	return Timestamps.now().getTime();
179		-	}
180		-
181	178		private long getPollDelay()
182	179		{
183	180		return mFast ? FAST_POLLING_DELAY : SLOW_POLLING_DELAY;

View View this file contents

History View the full history

Feeds

Commits for /trunk/Java/core/Anywhere/src/org/litesoft/bo/views/VoDataProvider.java