diff --git a/cave/com.raytheon.uf.viz.alertviz/src/com/raytheon/uf/viz/alertviz/ConfigContext.java b/cave/com.raytheon.uf.viz.alertviz/src/com/raytheon/uf/viz/alertviz/ConfigContext.java index 30c7ed8129..8842f8fc9b 100644 --- a/cave/com.raytheon.uf.viz.alertviz/src/com/raytheon/uf/viz/alertviz/ConfigContext.java +++ b/cave/com.raytheon.uf.viz.alertviz/src/com/raytheon/uf/viz/alertviz/ConfigContext.java @@ -1,14 +1,52 @@ +/** + * This software was developed and / or modified by Raytheon Company, + * pursuant to Contract DG133W-05-CQ-1067 with the US Government. + * + * U.S. EXPORT CONTROLLED TECHNICAL DATA + * This software product contains export-restricted data whose + * export/transfer/disclosure is restricted by U.S. law. Dissemination + * to non-U.S. persons whether in the United States or abroad requires + * an export license or other authorization. + * + * Contractor Name: Raytheon Company + * Contractor Address: 6825 Pine Street, Suite 340 + * Mail Stop B8 + * Omaha, NE 68106 + * 402.291.0100 + * + * See the AWIPS II Master Rights File ("Master Rights File.pdf") for + * further licensing information. + **/ package com.raytheon.uf.viz.alertviz; -import java.io.File; - +import com.raytheon.uf.common.localization.IPathManager; import com.raytheon.uf.common.localization.LocalizationContext; import com.raytheon.uf.common.localization.LocalizationContext.LocalizationLevel; +/** + * Class for managing configuration context. + * + *
+ * + * SOFTWARE HISTORY + * Date Ticket# Engineer Description + * ------------ ---------- ----------- -------------------------- + * Apr 09 2015 4346 rferrel Added {@link #ALERTVIZ_DIR} and {@link #XML_EXT}. + * + *+ * + * @author + * @version 1.0 + */ public class ConfigContext implements Comparable
* SOFTWARE HISTORY - * Date Ticket# Engineer Description - * ------------ ---------- ----------- -------------------------- - * Jun 2, 2008 njensen Initial creation + * Date Ticket# Engineer Description + * ------------ ---------- ----------- -------------------------- + * Jun 02, 2008 njensen Initial creation + * Apr 20, 2015 4027 randerso Remove unused TextProductsTemplates path and added + * Tests path for GFE formatter auto tests * ** @@ -67,9 +70,9 @@ public class FormatterScriptFactory { GfePyIncludeUtil.getHeadlineIncludePath(), GfePyIncludeUtil.getTextUtilitiesIncludePath(), GfePyIncludeUtil.getTextProductsIncludePath(), - GfePyIncludeUtil.getTextProductsTemplatesIncludePath(), GfePyIncludeUtil.getUtilitiesIncludePath(), - GfePyIncludeUtil.getCombinationsIncludePath()); + GfePyIncludeUtil.getCombinationsIncludePath(), + GfeCavePyIncludeUtil.getTestsIncludePath()); return new FormatterScript(runnerPath, include, FormatterScript.class.getClassLoader()); diff --git a/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/FormatterUtil.java b/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/FormatterUtil.java index 9cb65090f9..74e651fa61 100644 --- a/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/FormatterUtil.java +++ b/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/FormatterUtil.java @@ -22,6 +22,7 @@ package com.raytheon.viz.gfe.textformatter; import java.text.SimpleDateFormat; import java.util.TimeZone; +import com.raytheon.uf.common.activetable.ActiveTableMode; import com.raytheon.uf.common.status.IUFStatusHandler; import com.raytheon.uf.common.status.UFStatus; import com.raytheon.uf.common.time.SimulatedTime; @@ -36,13 +37,15 @@ import com.raytheon.viz.gfe.tasks.TaskManager; * *
* SOFTWARE HISTORY - * Date Ticket# Engineer Description - * ------------ ---------- ----------- -------------------------- - * Sep 8, 2008 njensen Initial creation - * Jan 15, 2010 3395 ryu Fix "issued by" functionality - * Sep 05, 2013 2329 randerso Removed save of combinations file - * Feb 12, 2014 2591 randerso Passed dataMgr instance to FormatterUtil.runFormatterScript - * Removed call to TextProductManager.reloadModule + * Date Ticket# Engineer Description + * ------------ ---------- ----------- -------------------------- + * Sep 8, 2008 njensen Initial creation + * Jan 15, 2010 3395 ryu Fix "issued by" functionality + * Sep 05, 2013 2329 randerso Removed save of combinations file + * Feb 12, 2014 2591 randerso Passed dataMgr instance to FormatterUtil.runFormatterScript + * Removed call to TextProductManager.reloadModule + * Apr 20, 2015 4027 randerso Renamed ProductStateEnum with an initial capital + * Fixed hard coded active table mode in runFormatterScript * ** @@ -79,8 +82,12 @@ public class FormatterUtil { String vtecMode, TextProductFinishListener finish) { int testMode = 0; - if (dataMgr.getOpMode().equals(CAVEMode.TEST)) { + ActiveTableMode atMode = ActiveTableMode.OPERATIONAL; + CAVEMode caveMode = dataMgr.getOpMode(); + if (caveMode.equals(CAVEMode.TEST)) { testMode = 1; + } else if (caveMode.equals(CAVEMode.PRACTICE)) { + atMode = ActiveTableMode.PRACTICE; } String shortVtec = null; @@ -103,7 +110,6 @@ public class FormatterUtil { String varDict = productMgr.getVarDict(productName, dataMgr, dbId); if (varDict != null) { - // run the formatter with the normal active table String time = null; if (!SimulatedTime.getSystemTime().isRealTime()) { SimpleDateFormat gmtFormatter = new SimpleDateFormat( @@ -113,11 +119,11 @@ public class FormatterUtil { time = gmtFormatter.format(SimulatedTime.getSystemTime() .getTime()); } - runFormatterScript(name, shortVtec, dbId, varDict, "Operational", + runFormatterScript(name, shortVtec, dbId, varDict, atMode.name(), time, testMode, finish); } else { finish.textProductFinished("Formatter canceled", - ConfigData.productStateEnum.Finished); + ConfigData.ProductStateEnum.Finished); } } @@ -128,7 +134,7 @@ public class FormatterUtil { varDict, vtecActiveTable, drtTime, testMode, finish); // Thread thread = new Thread(formatter); // thread.start(); - finish.textProductQueued(); + finish.textProductQueued(ConfigData.ProductStateEnum.Queued); TaskManager.getInstance().queueFormatter(formatter); } diff --git a/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/TextFormatter.java b/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/TextFormatter.java index fb0b91ff11..b7b5bddabc 100644 --- a/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/TextFormatter.java +++ b/cave/com.raytheon.viz.gfe/src/com/raytheon/viz/gfe/textformatter/TextFormatter.java @@ -35,7 +35,7 @@ import com.raytheon.uf.common.time.util.TimeUtil; import com.raytheon.uf.viz.core.VizApp; import com.raytheon.viz.gfe.core.DataManager; import com.raytheon.viz.gfe.dialogs.formatterlauncher.ConfigData; -import com.raytheon.viz.gfe.dialogs.formatterlauncher.ConfigData.productStateEnum; +import com.raytheon.viz.gfe.dialogs.formatterlauncher.ConfigData.ProductStateEnum; import com.raytheon.viz.gfe.sampler.SamplerGridSliceCache; import com.raytheon.viz.gfe.tasks.AbstractGfeTask; @@ -46,13 +46,14 @@ import com.raytheon.viz.gfe.tasks.AbstractGfeTask; * *
* SOFTWARE HISTORY - * Date Ticket# Engineer Description - * ------------ ---------- ----------- -------------------------- - * May 29, 2008 njensen Initial creation - * Oct 15, 2008 njensen Split python running to - * non-UI thread - * Dec 1, 2010 6130 ryu Set proper state and invoke callback - * May 29, 2014 2841 randerso Handle failure to queue due to pending limit + * Date Ticket# Engineer Description + * ------------ ---------- ----------- -------------------------- + * May 29, 2008 njensen Initial creation + * Oct 15, 2008 njensen Split python running to + * non-UI thread + * Dec 1, 2010 6130 ryu Set proper state and invoke callback + * May 29, 2014 2841 randerso Handle failure to queue due to pending limit + * Apr 20, 2015 4027 randerso Renamed ProductStateEnum with an initial capital * ** @@ -73,7 +74,7 @@ public class TextFormatter extends AbstractGfeTask { private HashMap
etnOverride
is less than or equal to the last ETN
+ * used by this site or any of its partners will be reported.
+ * Else, all significant errors will be reported back.
+ * @param etnOverride
+ * Allows the user to influence the next ETN assigned by using
+ * this value unless it is less than or equal to the last ETN
+ * used by this site or one of its partners.
+ * @param mode
+ * Indicates which active table to query
+ * @return The next ETN in sequence, given the office and phensig.
+ * @throws VizException
+ * If an error occurred sending the request to the server.
+ */
+ public static GetNextEtnResponse getNextEtn(String office, String phensig,
+ boolean lockEtn, boolean performISC, boolean reportOnlyConflict,
+ Integer etnOverride, ActiveTableMode mode) throws VizException {
+ return VtecUtil.getNextEtn(office, phensig, lockEtn, performISC,
+ reportOnlyConflict, etnOverride, mode);
+ }
+
/**
* Reads through a GFE VTEC product and returns VTEC lines with NEW action
* codes that need to be assigned an ETN.
diff --git a/cave/com.raytheon.viz.ghg/src/com/raytheon/viz/ghg/monitor/data/GhgData.java b/cave/com.raytheon.viz.ghg/src/com/raytheon/viz/ghg/monitor/data/GhgData.java
index d2bcada5b8..a991e4ecf9 100644
--- a/cave/com.raytheon.viz.ghg/src/com/raytheon/viz/ghg/monitor/data/GhgData.java
+++ b/cave/com.raytheon.viz.ghg/src/com/raytheon/viz/ghg/monitor/data/GhgData.java
@@ -48,6 +48,7 @@ import com.raytheon.viz.ghg.monitor.data.GhgConfigData.SelectionEnum;
* ------------ ---------- ----------- --------------------------
* 25 MAR 2008 N/A lvenable Initial creation
* 30 JUL 2010 6721 mpduff WFO now from officeid column.
+ * 28 APR 2015 4027 randerso Expunged Calendar from ActiveTableRecord
*
*
*
@@ -234,13 +235,13 @@ public class GhgData implements ComparableetnOverride
is less than or equal to the last ETN
+ * used by this site or any of its partners will be reported.
+ * Else, all significant errors will be reported back.
+ * @param etnOverride
+ * Allows the user to influence the next ETN assigned by using
+ * this value unless it is less than or equal to the last ETN
+ * used by this site or one of its partners.
+ * @param mode
+ * Indicates which active table to query
+ * @return The next ETN in sequence, given the office and phensig.
+ * @throws VizException
+ * If an error occurs while submitting or processing the remote
+ * request.
+ */
+ public static GetNextEtnResponse getNextEtn(String office, String phensig,
+ boolean lockEtn, boolean performISC, boolean reportOnlyConflict,
+ Integer etnOverride, ActiveTableMode mode) throws VizException {
+ Date currentTime = SimulatedTime.getSystemTime().getTime();
+ GetNextEtnRequest req = new GetNextEtnRequest(office, mode, phensig,
+ currentTime, lockEtn, performISC, reportOnlyConflict,
etnOverride);
GetNextEtnResponse resp = (GetNextEtnResponse) ThriftClient
@@ -197,6 +245,13 @@ public class VtecUtil {
return rval;
}
+ /**
+ * Parse a VTEC message
+ *
+ * @param message
+ * the message
+ * @return the parsed VtecObject
+ */
public static VtecObject parseMessage(String message) {
VtecObject rval = null;
Matcher m = VTEC_REGEX.matcher(message);
@@ -215,7 +270,7 @@ public class VtecUtil {
*
* @param message
* the message to modify
- * @param obj
+ * @param vtec
* new VTEC for the message
*
* @return the modified message
diff --git a/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/gis/WatchUtil.java b/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/gis/WatchUtil.java
index 757367d682..eeb8e77e25 100644
--- a/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/gis/WatchUtil.java
+++ b/cave/com.raytheon.viz.warngen/src/com/raytheon/viz/warngen/gis/WatchUtil.java
@@ -85,6 +85,7 @@ import com.vividsolutions.jts.geom.Polygon;
* /missing (part of state, state abbreviation) which resulted from
* extension of a watch to counties which are of same/different fe_area.
* Sep 25, 2014 ASM #16783 D. Friedman Do not use VTEC action to determine Watch uniqueness.
+ * Apr 28, 2015 RODO #4027 randerso Expunged Calendar from ActiveTableRecord
*
*
* @author jsanchez
@@ -324,12 +325,12 @@ public class WatchUtil {
* fixed the underlying system. request.addConstraint("act", new
* RequestConstraint("CAN", ConstraintType.NOT_EQUALS));
*/
- if (action != WarningAction.CAN && action != WarningAction.EXP) {
+ if ((action != WarningAction.CAN) && (action != WarningAction.EXP)) {
ActiveTableRecord record = entityClass.newInstance();
- record.setIssueTime((Calendar) result.get(ISSUE_TIME_FIELD));
- record.setStartTime((Calendar) result.get(START_TIME_FIELD));
- record.setEndTime((Calendar) result.get(END_TIME_FIELD));
- record.setEndTime((Calendar) result.get(END_TIME_FIELD));
+ record.setIssueTime((Date) result.get(ISSUE_TIME_FIELD));
+ record.setStartTime((Date) result.get(START_TIME_FIELD));
+ record.setEndTime((Date) result.get(END_TIME_FIELD));
+ record.setEndTime((Date) result.get(END_TIME_FIELD));
record.setUgcZone(String.valueOf(result.get(UGC_ZONE_FIELD)));
record.setPhensig(String.valueOf(result.get(PHEN_SIG_FIELD)));
record.setEtn(String.valueOf(result.get(ETN)));
@@ -348,10 +349,12 @@ public class WatchUtil {
}
}
- // remove ActiveTableRecord from records whose etn, ugcZone, and phensig is same as
- // canceled or expired.
+ /*
+ * remove ActiveTableRecord from records whose etn, ugcZone, and phensig
+ * is same as canceled or expired.
+ */
String etn, ugczone, phensig;
- for (Pair+ * + * SOFTWARE HISTORY + * + * Date Ticket# Engineer Description + * ------------ ---------- ----------- -------------------------- + * Apr 09, 2015 #4383 dgilling Initial creation + * + *+ * + * @author dgilling + * @version 1.0 + */ + +public final class ISCRoutingConfig { + + private final Collection
* @@ -36,6 +36,7 @@ import com.raytheon.uf.common.serialization.comm.IServerRequest; * Feb 14, 2011 rjpeter Initial creation * Oct 21, 2013 #1843 dgilling Add performISC and reportConflictOnly * fields, proper constructors. + * Apr 28, 2015 #4027 randerso Expunged Calendar from ActiveTableRecord * ** @@ -55,7 +56,7 @@ public class GetNextEtnRequest implements IServerRequest { private String phensig; @DynamicSerializeElement - private Calendar currentTime; + private Date currentTime; @DynamicSerializeElement private boolean lockEtn; @@ -84,7 +85,7 @@ public class GetNextEtnRequest implements IServerRequest { * The phenomenon and significance of the hazard concatenated * with a '.' (e.g., TO.W or DU.Y) * @param currentTime - *
Calendar
representing time (needed for DRT mode).
+ * Date
representing time (needed for DRT mode).
* @param lockEtn
* Whether or not to request an exclusive ETN--if true, this will
* cause the server to increment its running ETN sequence to the
@@ -95,7 +96,7 @@ public class GetNextEtnRequest implements IServerRequest {
* GetNextEtnRequest.
*/
public GetNextEtnRequest(String siteID, ActiveTableMode mode,
- String phensig, Calendar currentTime, boolean lockEtn) {
+ String phensig, Date currentTime, boolean lockEtn) {
this(siteID, mode, phensig, currentTime, lockEtn, false, false, null);
}
@@ -110,7 +111,7 @@ public class GetNextEtnRequest implements IServerRequest {
* The phenomenon and significance of the hazard concatenated
* with a '.' (e.g., TO.W or DU.Y)
* @param currentTime
- * Calendar
representing time (needed for DRT mode).
+ * Date
representing time (needed for DRT mode).
* @param lockEtn
* Whether or not to request an exclusive ETN--if true, this will
* cause the server to increment its running ETN sequence to the
@@ -123,7 +124,7 @@ public class GetNextEtnRequest implements IServerRequest {
* Whether or not to collaborate with neighboring sites to
* determine the next ETN. See {@link
* GetNextEtnUtil#getNextEtnFromPartners(String, ActiveTableMode,
- * String, Calendar, List+ * TODO this class can be deleted when no decoders are using it. + * + ** @@ -105,9 +106,10 @@ public class SatelliteRecord extends PersistablePluginDataObject implements public static final String SAT_DATASET_NAME = DataStoreFactory.DEF_DATASET_NAME; /** - * The attribute name for a value that will be used to "fill" undefined - * data. + * @deprecated {@link IDataRecord#setFillValue(Number)} should be used to + * store the fill value. */ + @Deprecated public static final String SAT_FILL_VALUE = "_FillValue"; /** @@ -116,10 +118,17 @@ public class SatelliteRecord extends PersistablePluginDataObject implements public static final String SAT_ADD_OFFSET = "add_offset"; /** - * The attribute name for the data scale factor value.. + * The attribute name for the data scale factor value. */ public static final String SAT_SCALE_FACTOR = "scale_factor"; + /** + * Byte/Short/Int satellite data is assumed to be unsigned. If this + * attribute is present on the {@link IDataRecord} and the value is + * {@link Boolean#TRUE} then the data is treated as signed data. + */ + public static final String SAT_SIGNED_FLAG = "signed"; + /** * The source of the data - NESDIS */ diff --git a/edexOsgi/com.raytheon.uf.edex.activetable/src/com/raytheon/uf/edex/activetable/ActiveTable.java b/edexOsgi/com.raytheon.uf.edex.activetable/src/com/raytheon/uf/edex/activetable/ActiveTable.java index a4347cf47c..774b3514b8 100644 --- a/edexOsgi/com.raytheon.uf.edex.activetable/src/com/raytheon/uf/edex/activetable/ActiveTable.java +++ b/edexOsgi/com.raytheon.uf.edex.activetable/src/com/raytheon/uf/edex/activetable/ActiveTable.java @@ -28,6 +28,7 @@ import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Set; +import java.util.TimeZone; import jep.JepException; @@ -108,6 +109,8 @@ import com.raytheon.uf.edex.database.query.DatabaseQuery; * Feb 23, 2015 4127 dgilling Use cluster locking to only allow 1 active * table write at a time. * Mar 04, 2015 4129 randerso Pass active table change logger to ingestAt and/or MergeVTEC + * Apr 28, 2015 #4027 randerso Expunged Calendar from ActiveTableRecord, + * fixed next ETN query to query for >= Jan 1 * * * @@ -447,7 +450,7 @@ public class ActiveTable { @SuppressWarnings("unchecked") private static List* * SOFTWARE HISTORY * @@ -41,6 +43,7 @@ import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement; * Jun 27, 2012 798 jkorman Initial creation * Nov 14, 2013 2393 bclement use datastore factory in * getStorageRecord() + * Apr 15, 2014 4388 bsteffen Deprecate * ** @@ -48,6 +51,7 @@ import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement; * @version 1.0 */ @DynamicSerialize +@Deprecated public class SatelliteMessageData { private static final int DATA_DIMS = 2; diff --git a/edexOsgi/com.raytheon.uf.common.dataplugin.satellite/src/com/raytheon/uf/common/dataplugin/satellite/SatelliteRecord.java b/edexOsgi/com.raytheon.uf.common.dataplugin.satellite/src/com/raytheon/uf/common/dataplugin/satellite/SatelliteRecord.java index 6820f642cf..feab6943a7 100644 --- a/edexOsgi/com.raytheon.uf.common.dataplugin.satellite/src/com/raytheon/uf/common/dataplugin/satellite/SatelliteRecord.java +++ b/edexOsgi/com.raytheon.uf.common.dataplugin.satellite/src/com/raytheon/uf/common/dataplugin/satellite/SatelliteRecord.java @@ -74,6 +74,7 @@ import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement; * PluginDataObject. * Aug 30, 2013 2298 rjpeter Make getPluginName abstract * Jun 11, 2014 2061 bsteffen Remove IDecoderGettable + * Apr 15, 2014 4388 bsteffen Deprecate SAT_FILL_VALUE * *
Calendar
representing time to perform search from
+ * Date
representing time to perform search from
* (needed for DRT mode).
* @return The last ETN assigned to the particular site and phensig
* combination, or null
if no ETNs have been assigned
* to this combination.
*/
public static Integer getLastUsedEtn(String siteId, ActiveTableMode mode,
- String phensig, Calendar currentTime) {
+ String phensig, Date currentTime) {
Integer lastEtn = null;
ListCalendar
representing time (needed for DRT mode).
+ * Date
representing time (needed for DRT mode).
* @param isLock
* Whether or not to return a unique ETN--one that has not and
* cannot be used by any other requestor.
@@ -142,7 +145,7 @@ public final class GetNextEtnUtil {
* and any hosts that couldn't be contacted during this process.
*/
public static GetNextEtnResponse getNextEtn(String siteId,
- ActiveTableMode mode, String phensig, Calendar currentTime,
+ ActiveTableMode mode, String phensig, Date currentTime,
boolean isLock, boolean performISC, boolean reportConflictOnly,
Integer etnOverride) {
SortedMapCalendar
representing time (needed for DRT mode).
+ * Date
representing time (needed for DRT mode).
* @param isLock
* Whether or not to actually obtain the cluster task lock. Not
* needed if only determining a preliminary ETN. Required to be
@@ -284,7 +287,7 @@ public final class GetNextEtnUtil {
* @return The next ETN to be used in sequence.
*/
public static int lockAndGetNextEtn(String siteId, ActiveTableMode mode,
- String phensig, Calendar currentTime, boolean isLock,
+ String phensig, Date currentTime, boolean isLock,
Integer etnOverride) {
String lockName = getEtnClusterLockName(siteId, mode);
ClusterTask ct = null;
@@ -306,7 +309,9 @@ public final class GetNextEtnUtil {
int sysNextEtn = -1;
if (etnOverride == null) {
- String year = Integer.toString(currentTime.get(Calendar.YEAR));
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy");
+ sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
+ String year = sdf.format(currentTime);
String eInfo = ct.getExtraInfo();
statusHandler.info("ClusterTask Lock info: " + eInfo);
@@ -342,16 +347,20 @@ public final class GetNextEtnUtil {
* @param phensig
* The phenomenon and significance combination (e.g., TO.W or
* DU.Y).
- * @param year
- * Year the next ETN is effective for.
+ * @param currentTime
+ * Date
used to determine year for ETN.
* @param nextEtn
* The ETN to persist.
*/
public static void setNextEtnAndUnlock(String siteId, ActiveTableMode mode,
- String phensig, int year, int nextEtn) {
+ String phensig, Date currentTime, int nextEtn) {
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy");
+ sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
+ String year = sdf.format(currentTime);
+
String lockName = getEtnClusterLockName(siteId, mode);
- ClusterLockUtils.updateExtraInfo(lockName, phensig,
- Integer.toString(year) + ":" + nextEtn);
+ ClusterLockUtils.updateExtraInfo(lockName, phensig, year + ":"
+ + nextEtn);
ClusterLockUtils.unlock(lockName, phensig);
statusHandler.info("Unlocking::[nextEtn = " + nextEtn + "]");
}
@@ -369,20 +378,19 @@ public final class GetNextEtnUtil {
* The phenomenon and significance combination (e.g., TO.W or
* DU.Y).
* @param currentTime
- * Calendar
representing time (needed for DRT mode).
+ * Date
representing time (needed for DRT mode).
* @param isLock
* Whether or not to return a unique ETN--one that has not and
* cannot be used by any other requestor.
* @return The next ETN to be used in sequence.
*/
public static Integer getNextEtnFromLocal(String siteId,
- ActiveTableMode mode, String phensig, Calendar currentTime,
+ ActiveTableMode mode, String phensig, Date currentTime,
boolean isLock) {
int nextEtn = lockAndGetNextEtn(siteId, mode, phensig, currentTime,
isLock, null);
if (isLock) {
- setNextEtnAndUnlock(siteId, mode, phensig,
- currentTime.get(Calendar.YEAR), nextEtn);
+ setNextEtnAndUnlock(siteId, mode, phensig, currentTime, nextEtn);
}
return nextEtn;
}
@@ -405,7 +413,7 @@ public final class GetNextEtnUtil {
* The phenomenon and significance combination (e.g., TO.W or
* DU.Y).
* @param currentTime
- * Calendar
representing time (needed for DRT mode).
+ * Date
representing time (needed for DRT mode).
* @param hostsToQuery
* The remote hosts to query. This should also include the local
* EDEX instance initiating this operation.
@@ -424,7 +432,7 @@ public final class GetNextEtnUtil {
* @throws UnknownHostException
*/
public static GetNextEtnResponse getNextEtnFromPartners(String siteId,
- ActiveTableMode mode, String phensig, Calendar currentTime,
+ ActiveTableMode mode, String phensig, Date currentTime,
SortedMap