xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Issue #2448 fix scheduling for start/stop of subscription.

Browse source 
Former-commit-id: de110d3747096601a122f64cc5d6037823213e92
This commit is contained in:
Dave Hladky 2013-11-12 10:58:50 -06:00
parent 0dbc31b756
commit b6f1468b7e
2 changed files with 21 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/src/com/raytheon/uf/edex/datadelivery/bandwidth/util/BandwidthDaoUtil.java
View file

@ -72,6 +72,7 @@ import com.raytheon.uf.edex.datadelivery.bandwidth.retrieval.RetrievalStatus;
* Oct 10, 2013 1797 bgonzale Refactored registry Time objects. * Oct 10, 2013 1797 bgonzale Refactored registry Time objects.
* Oct 30, 2013 2448 dhladky Fixed pulling data before and after activePeriod starting and ending. * Oct 30, 2013 2448 dhladky Fixed pulling data before and after activePeriod starting and ending.
* Nov 5, 2013 2521 dhladky Fixed DataSetMetaData update failures for URL's in pointdata. * Nov 5, 2013 2521 dhladky Fixed DataSetMetaData update failures for URL's in pointdata.
* Nov 12, 2013 2448 dhladky Fixed stop/start subscription scheduling problem.
* *
* </pre> * </pre>
* *
@ -236,6 +237,7 @@ public class BandwidthDaoUtil<T extends Time, C extends Coverage> {
subscriptionStart.set(Calendar.HOUR_OF_DAY, cycle); subscriptionStart.set(Calendar.HOUR_OF_DAY, cycle);
for (Integer minute : minutes) { for (Integer minute : minutes) {
subscriptionStart.set(Calendar.MINUTE, minute); subscriptionStart.set(Calendar.MINUTE, minute);
// Check for nonsense
if (subscriptionStart.after(subscriptionEnd)) { if (subscriptionStart.after(subscriptionEnd)) {
break outerloop; break outerloop;
} }
@ -243,14 +245,25 @@ public class BandwidthDaoUtil<T extends Time, C extends Coverage> {
Calendar time = TimeUtil.newCalendar(); Calendar time = TimeUtil.newCalendar();
time.setTimeInMillis(subscriptionStart time.setTimeInMillis(subscriptionStart
.getTimeInMillis()); .getTimeInMillis());
// Last check for time window, this checks fine grain by hour and minute /**
if (activePeriodStart != null && activePeriodEnd != null) { * Fine grain check by hour and minute, for subscription(start/end),
if (time.after(activePeriodEnd) || time.before(activePeriodStart)) { * activePeriod(start/end)
// discard this retrieval time, outside activePeriod window **/
// Subscription Start and End time first
if (subscriptionStart != null && subscriptionEnd != null) {
if (time.after(subscriptionEnd) || time.before(subscriptionStart)) {
// don't schedule this retrieval time, outside subscription window
continue; continue;
} }
} }
// Check Active Period Second
if (activePeriodStart != null && activePeriodEnd != null) {
if (time.after(activePeriodEnd) || time.before(activePeriodStart)) {
// don't schedule this retrieval time, outside activePeriod window
continue;
}
}
subscriptionTimes.add(time); subscriptionTimes.add(time);
} }
} }

5
edexOsgi/com.raytheon.uf.edex.datadelivery.retrieval/src/com/raytheon/uf/edex/datadelivery/retrieval/util/ConnectionUtil.java
View file

@ -23,7 +23,6 @@ import java.io.File;
import java.io.FileNotFoundException; import java.io.FileNotFoundException;
import java.io.IOException; import java.io.IOException;
import com.raytheon.edex.colormap.ColorMapManager;
import com.raytheon.uf.common.comm.ProxyConfiguration; import com.raytheon.uf.common.comm.ProxyConfiguration;
import com.raytheon.uf.common.comm.ProxyUtil; import com.raytheon.uf.common.comm.ProxyUtil;
import com.raytheon.uf.common.localization.IPathManager; import com.raytheon.uf.common.localization.IPathManager;
@ -47,6 +46,7 @@ import dods.dap.DConnect;
* Apr 01, 2013 1786 mpduff Pulled proxy settings out to util class. * Apr 01, 2013 1786 mpduff Pulled proxy settings out to util class.
* May 12, 2013 753 dhladky Expanded for use with other connection types * May 12, 2013 753 dhladky Expanded for use with other connection types
* Aug 30, 2013 2314 mpduff Added null checks. * Aug 30, 2013 2314 mpduff Added null checks.
* Nov 12, 2013 * dhladky Fixed copy paste error
* </pre> * </pre>
* *
* @author djohnson * @author djohnson
@ -54,8 +54,9 @@ import dods.dap.DConnect;
*/ */
public class ConnectionUtil { public class ConnectionUtil {
private static final IUFStatusHandler statusHandler = UFStatus private static final IUFStatusHandler statusHandler = UFStatus
.getHandler(ColorMapManager.class); .getHandler(ConnectionUtil.class);
private static final String PROXY_PROPERTIES_FILE = "datadelivery" private static final String PROXY_PROPERTIES_FILE = "datadelivery"
+ File.separator + "proxy.properties"; + File.separator + "proxy.properties";