less logging in dataplugin decoders
This commit is contained in:
parent
db49a6a605
commit
6e69be3186
5 changed files with 0 additions and 34 deletions
|
@ -64,7 +64,6 @@ import com.raytheon.uf.common.dataplugin.radar.util.TiltAngleBin;
|
||||||
import com.raytheon.uf.common.localization.IPathManager;
|
import com.raytheon.uf.common.localization.IPathManager;
|
||||||
import com.raytheon.uf.common.localization.LocalizationContext;
|
import com.raytheon.uf.common.localization.LocalizationContext;
|
||||||
import com.raytheon.uf.common.localization.PathManagerFactory;
|
import com.raytheon.uf.common.localization.PathManagerFactory;
|
||||||
import com.raytheon.uf.common.status.IPerformanceStatusHandler;
|
|
||||||
import com.raytheon.uf.common.status.IUFStatusHandler;
|
import com.raytheon.uf.common.status.IUFStatusHandler;
|
||||||
import com.raytheon.uf.common.status.PerformanceStatus;
|
import com.raytheon.uf.common.status.PerformanceStatus;
|
||||||
import com.raytheon.uf.common.status.UFStatus;
|
import com.raytheon.uf.common.status.UFStatus;
|
||||||
|
@ -152,9 +151,6 @@ public class RadarDecoder {
|
||||||
|
|
||||||
private final String RADAR = "RADAR";
|
private final String RADAR = "RADAR";
|
||||||
|
|
||||||
private final IPerformanceStatusHandler perfLog = PerformanceStatus
|
|
||||||
.getHandler("Radar:");
|
|
||||||
|
|
||||||
public RadarDecoder() throws DecoderException {
|
public RadarDecoder() throws DecoderException {
|
||||||
|
|
||||||
String dir = "";
|
String dir = "";
|
||||||
|
@ -194,9 +190,6 @@ public class RadarDecoder {
|
||||||
// decode the product
|
// decode the product
|
||||||
String arch = new String(messageData, 0, 4);
|
String arch = new String(messageData, 0, 4);
|
||||||
|
|
||||||
ITimer timer = TimeUtil.getTimer();
|
|
||||||
|
|
||||||
timer.start();
|
|
||||||
// for level2 data, this does not happen very often
|
// for level2 data, this does not happen very often
|
||||||
if (LEVEL_TWO_IDENTS.contains(arch)) {
|
if (LEVEL_TWO_IDENTS.contains(arch)) {
|
||||||
decodeLevelTwoData(messageData, recordList);
|
decodeLevelTwoData(messageData, recordList);
|
||||||
|
@ -409,10 +402,6 @@ public class RadarDecoder {
|
||||||
}
|
}
|
||||||
|
|
||||||
finalizeRecord(record);
|
finalizeRecord(record);
|
||||||
|
|
||||||
timer.stop();
|
|
||||||
perfLog.logDuration("Time to Decode", timer.getElapsedTime());
|
|
||||||
|
|
||||||
recordList.add(record);
|
recordList.add(record);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -34,10 +34,7 @@ import com.raytheon.edex.plugin.sfcobs.decoder.ISfcObsDecoder;
|
||||||
import com.raytheon.edex.plugin.sfcobs.decoder.SfcObsDecoderFactory;
|
import com.raytheon.edex.plugin.sfcobs.decoder.SfcObsDecoderFactory;
|
||||||
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
||||||
import com.raytheon.uf.common.dataplugin.sfcobs.ObsCommon;
|
import com.raytheon.uf.common.dataplugin.sfcobs.ObsCommon;
|
||||||
import com.raytheon.uf.common.status.IPerformanceStatusHandler;
|
|
||||||
import com.raytheon.uf.common.status.PerformanceStatus;
|
|
||||||
import com.raytheon.uf.common.time.util.ITimer;
|
import com.raytheon.uf.common.time.util.ITimer;
|
||||||
import com.raytheon.uf.common.time.util.TimeUtil;
|
|
||||||
import com.raytheon.uf.common.wmo.WMOHeader;
|
import com.raytheon.uf.common.wmo.WMOHeader;
|
||||||
import com.raytheon.uf.common.wmo.WMOTimeParser;
|
import com.raytheon.uf.common.wmo.WMOTimeParser;
|
||||||
import com.raytheon.uf.edex.decodertools.core.DecoderTools;
|
import com.raytheon.uf.edex.decodertools.core.DecoderTools;
|
||||||
|
@ -85,9 +82,6 @@ public class SfcObsDecoder extends AbstractDecoder {
|
||||||
// Name of the plugin controlling this decoder.
|
// Name of the plugin controlling this decoder.
|
||||||
public static final String PLUGIN_NAME = "sfcobs";
|
public static final String PLUGIN_NAME = "sfcobs";
|
||||||
|
|
||||||
private final IPerformanceStatusHandler perfLog = PerformanceStatus
|
|
||||||
.getHandler("SfcObs:");
|
|
||||||
|
|
||||||
/** The logger */
|
/** The logger */
|
||||||
private final Logger logger = LoggerFactory.getLogger(getClass());
|
private final Logger logger = LoggerFactory.getLogger(getClass());
|
||||||
|
|
||||||
|
@ -135,9 +129,7 @@ public class SfcObsDecoder extends AbstractDecoder {
|
||||||
SfcObsSeparator separator = SfcObsSeparator.separate(data, headers);
|
SfcObsSeparator separator = SfcObsSeparator.separate(data, headers);
|
||||||
List<PluginDataObject> retVal = new ArrayList<PluginDataObject>();
|
List<PluginDataObject> retVal = new ArrayList<PluginDataObject>();
|
||||||
HashMap<String, Boolean> obsMap = new HashMap<String, Boolean>();
|
HashMap<String, Boolean> obsMap = new HashMap<String, Boolean>();
|
||||||
ITimer timer = TimeUtil.getTimer();
|
|
||||||
|
|
||||||
timer.start();
|
|
||||||
while (separator.hasNext()) {
|
while (separator.hasNext()) {
|
||||||
SfcObsDecoderInput input = separator.next();
|
SfcObsDecoderInput input = separator.next();
|
||||||
PluginDataObject report = null;
|
PluginDataObject report = null;
|
||||||
|
@ -177,8 +169,6 @@ public class SfcObsDecoder extends AbstractDecoder {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
timer.stop();
|
|
||||||
perfLog.logDuration("Time to Decode", timer.getElapsedTime());
|
|
||||||
return retVal.toArray(new PluginDataObject[retVal.size()]);
|
return retVal.toArray(new PluginDataObject[retVal.size()]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -158,8 +158,6 @@ public class SHIPSynopticDecoder extends AbstractSynopticDecoder {
|
||||||
clearSectionDecoders();
|
clearSectionDecoders();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
logger.info("<-------" + getReportIdentifier()
|
|
||||||
+ "---------------->");
|
|
||||||
decodeLatitude();
|
decodeLatitude();
|
||||||
decodeLongitude();
|
decodeLongitude();
|
||||||
if (isFixedBuoy) {
|
if (isFixedBuoy) {
|
||||||
|
|
|
@ -28,12 +28,9 @@ import com.raytheon.edex.plugin.AbstractDecoder;
|
||||||
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
import com.raytheon.uf.common.dataplugin.PluginDataObject;
|
||||||
import com.raytheon.uf.common.dataplugin.PluginException;
|
import com.raytheon.uf.common.dataplugin.PluginException;
|
||||||
import com.raytheon.uf.common.dataplugin.redbook.RedbookRecord;
|
import com.raytheon.uf.common.dataplugin.redbook.RedbookRecord;
|
||||||
import com.raytheon.uf.common.status.IPerformanceStatusHandler;
|
|
||||||
import com.raytheon.uf.common.status.IUFStatusHandler;
|
import com.raytheon.uf.common.status.IUFStatusHandler;
|
||||||
import com.raytheon.uf.common.status.PerformanceStatus;
|
import com.raytheon.uf.common.status.PerformanceStatus;
|
||||||
import com.raytheon.uf.common.status.UFStatus;
|
import com.raytheon.uf.common.status.UFStatus;
|
||||||
import com.raytheon.uf.common.time.util.ITimer;
|
|
||||||
import com.raytheon.uf.common.time.util.TimeUtil;
|
|
||||||
import com.raytheon.uf.common.wmo.WMOHeader;
|
import com.raytheon.uf.common.wmo.WMOHeader;
|
||||||
import com.raytheon.uf.edex.database.plugin.PluginFactory;
|
import com.raytheon.uf.edex.database.plugin.PluginFactory;
|
||||||
import com.raytheon.uf.edex.database.query.DatabaseQuery;
|
import com.raytheon.uf.edex.database.query.DatabaseQuery;
|
||||||
|
@ -105,9 +102,6 @@ public class RedbookDecoder extends AbstractDecoder {
|
||||||
private static final IUFStatusHandler logger = UFStatus
|
private static final IUFStatusHandler logger = UFStatus
|
||||||
.getHandler(RedbookDecoder.class);
|
.getHandler(RedbookDecoder.class);
|
||||||
|
|
||||||
private final IPerformanceStatusHandler perfLog = PerformanceStatus
|
|
||||||
.getHandler("Redbook:");
|
|
||||||
|
|
||||||
private String traceId = null;
|
private String traceId = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -139,8 +133,6 @@ public class RedbookDecoder extends AbstractDecoder {
|
||||||
String fileName = (String) headers.get(WMOHeader.INGEST_FILE_NAME);
|
String fileName = (String) headers.get(WMOHeader.INGEST_FILE_NAME);
|
||||||
WMOHeader wmoHeader = new WMOHeader(rawMessage, fileName);
|
WMOHeader wmoHeader = new WMOHeader(rawMessage, fileName);
|
||||||
if (wmoHeader.isValid()) {
|
if (wmoHeader.isValid()) {
|
||||||
ITimer timer = TimeUtil.getTimer();
|
|
||||||
timer.start();
|
|
||||||
|
|
||||||
int start = wmoHeader.getMessageDataStart();
|
int start = wmoHeader.getMessageDataStart();
|
||||||
|
|
||||||
|
@ -167,8 +159,6 @@ public class RedbookDecoder extends AbstractDecoder {
|
||||||
e);
|
e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
timer.stop();
|
|
||||||
perfLog.logDuration("Time to Decode", timer.getElapsedTime());
|
|
||||||
} else {
|
} else {
|
||||||
logger.error(traceId + "- No valid WMO header found in data.");
|
logger.error(traceId + "- No valid WMO header found in data.");
|
||||||
}
|
}
|
||||||
|
|
|
@ -48,7 +48,6 @@ import com.raytheon.uf.common.localization.IPathManager;
|
||||||
import com.raytheon.uf.common.localization.LocalizationFile;
|
import com.raytheon.uf.common.localization.LocalizationFile;
|
||||||
import com.raytheon.uf.common.localization.PathManagerFactory;
|
import com.raytheon.uf.common.localization.PathManagerFactory;
|
||||||
import com.raytheon.uf.common.serialization.SingleTypeJAXBManager;
|
import com.raytheon.uf.common.serialization.SingleTypeJAXBManager;
|
||||||
import com.raytheon.uf.common.status.IPerformanceStatusHandler;
|
|
||||||
import com.raytheon.uf.common.status.IUFStatusHandler;
|
import com.raytheon.uf.common.status.IUFStatusHandler;
|
||||||
import com.raytheon.uf.common.status.PerformanceStatus;
|
import com.raytheon.uf.common.status.PerformanceStatus;
|
||||||
import com.raytheon.uf.common.status.UFStatus;
|
import com.raytheon.uf.common.status.UFStatus;
|
||||||
|
|
Loading…
Add table
Reference in a new issue