本文整理汇总了Java中com.owera.xaps.dbi.SyslogFilter类的典型用法代码示例。如果您正苦于以下问题：Java SyslogFilter类的具体用法？Java SyslogFilter怎么用？Java SyslogFilter使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SyslogFilter类属于com.owera.xaps.dbi包，在下文中一共展示了SyslogFilter类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: readSyslog
import com.owera.xaps.dbi.SyslogFilter; //导入依赖的package包/类
private List<SyslogEntry> readSyslog(Date start, Date end, List<Unittype> uts, List<Profile> prs, String unitId, String line) throws SQLException, NoAvailableConnectionException {
Syslog syslog = new Syslog(sysCp, id);
SyslogFilter filter = new SyslogFilter();
filter.setFacility(16); // Only messages from device
if (line == null)
filter.setMessage("MOS Report:");
else
filter.setMessage("MOS Report: Channel " + line);
filter.setUnitId(unitId);
filter.setProfiles(prs);
filter.setUnittypes(uts);
filter.setCollectorTmsStart(start);
filter.setCollectorTmsEnd(end);
filter.setFacilityVersion(swVersion);
return syslog.read(filter, xaps);
}
开发者ID:freeacs，项目名称:dbi，代码行数:17，代码来源:ReportVoipCallGenerator.java
示例2: runImpl
import com.owera.xaps.dbi.SyslogFilter; //导入依赖的package包/类
@Override
public void runImpl() throws Throwable {
Long anHourAgo = System.currentTimeMillis() - 60 * 60000;
logger.info("ActiveDeviceDetectionTask: Will check if some devices scheduled to return before " + new Date(anHourAgo) + " are too late");
Map<String, Long> inactiveUnits = cleanOld(anHourAgo);
logger.info("ActiveDeviceDetectionTask: Have found " + inactiveUnits.size() + " inactive devices");
for (Entry<String, Long> entry : inactiveUnits.entrySet()) {
String unitId = entry.getKey();
Syslog syslog = dbi.getXaps().getSyslog();
SyslogFilter sf = new SyslogFilter();
sf.setCollectorTmsStart(new Date(anHourAgo)); // look for syslog newer than 1 hour
sf.setUnitId(unitId);
boolean active = false;
List<SyslogEntry> entries = syslog.read(sf, dbi.getXaps());
for (SyslogEntry sentry : entries) {
if (sentry.getFacility() < SyslogConstants.FACILITY_SHELL && !sentry.getContent().contains(Heartbeat.MISSING_HEARTBEAT_ID)) {
logger.notice("ActivceDeviceDetection: Found syslog activity for unit " + unitId + " at " + sentry.getCollectorTimestamp() + " : " + sentry.getContent());
active = true;
break;
}
}
if (active) {
SyslogClient.notice(entry.getKey(), "ProvMsg: No provisioning at " + new Date(entry.getValue()) + " (as expected) or since, but device has been active since " + new Date(anHourAgo)
+ ". TR-069 client may have stopped", dbi.getXaps().getSyslog());
logger.notice("ActivceDeviceDetection: Unit " + entry.getKey() + ": No provisioning at " + new Date(entry.getValue()) + " (as expected) or since, but device has been active "
+ new Date(anHourAgo) + ". TR-069 client may have stopped");
} else {
logger.info("ActivceDeviceDetection: Unit " + entry.getKey() + ": No provisioning at " + new Date(entry.getValue()) + " (as expected) or since, but device may be inactive since "
+ new Date(anHourAgo));
}
}
}
开发者ID:freeacs，项目名称:tr069，代码行数:33，代码来源:ActiveDeviceDetectionTask.java
示例3: generateFromSyslog
import com.owera.xaps.dbi.SyslogFilter; //导入依赖的package包/类
public Map<String, Report<RecordVoip>> generateFromSyslog(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs, Group group) throws NoAvailableConnectionException,
SQLException, IOException {
logInfo("VoipReport", null, uts, prs, start, end);
Syslog syslog = new Syslog(sysCp, id);
SyslogFilter filter = new SyslogFilter();
filter.setFacility(16); // Only messages from device
filter.setMessage("^QoS|^ua_: reg failed");
filter.setProfiles(prs);
filter.setUnittypes(uts);
filter.setCollectorTmsStart(start);
filter.setCollectorTmsEnd(end);
filter.setFacilityVersion(swVersion);
Map<String, Unit> unitsInGroup = getUnitsInGroup(group);
List<SyslogEntry> entries = syslog.read(filter, xaps);
Map<String, Report<RecordVoip>> unitReportMap = new HashMap<String, Report<RecordVoip>>();
for (SyslogEntry entry : entries) {
if (entry.getUnittypeName() == null || entry.getProfileName() == null)
continue;
if (group != null && unitsInGroup.get(entry.getUnitId()) == null)
continue;
String unitId = entry.getUnitId();
Report<RecordVoip> report = unitReportMap.get(unitId);
if (report == null) {
report = new Report<RecordVoip>(RecordVoip.class, periodType);
unitReportMap.put(unitId, report);
}
Matcher m = qosChannelPattern.matcher(entry.getContent());
String channel = "0";
if (m.matches())
channel = "" + m.group(1);
if (entry.getFacilityVersion() == null || entry.getFacilityVersion().trim().equals(""))
entry.setFacilityVersion("Unknown");
RecordVoip recordTmp = new RecordVoip(entry.getCollectorTimestamp(), periodType, entry.getUnittypeName(), entry.getProfileName(), entry.getFacilityVersion(), channel);
Key key = recordTmp.getKey();
RecordVoip record = report.getRecord(key);
if (record == null)
record = recordTmp;
try {
parseContentAndPopulateRecord(record, entry.getContent(), entry.getCollectorTimestamp());
report.setRecord(key, record);
} catch (SyslogParseException spe) {
// ignore this record
}
}
logger.info(logPrefix + "VoipReport: Have read " + entries.size() + " rows from syslog, " + unitReportMap.size() + " units are mapped");
return unitReportMap;
}
开发者ID:freeacs，项目名称:dbi，代码行数:49，代码来源:ReportVoipGenerator.java
示例4: generateFromSyslog
import com.owera.xaps.dbi.SyslogFilter; //导入依赖的package包/类
public Map<String, Report<RecordHardware>> generateFromSyslog(PeriodType periodType, Date start, Date end, List<Unittype> uts, List<Profile> prs, Group group)
throws NoAvailableConnectionException, SQLException, IOException {
logInfo("HardwareReport", null, uts, prs, start, end);
Syslog syslog = new Syslog(sysCp, id);
SyslogFilter filter = new SyslogFilter();
filter.setFacility(16); // Only messages from device
filter.setMessage("^Reboot reason|^HW Memory");
filter.setProfiles(prs);
filter.setUnittypes(uts);
filter.setCollectorTmsStart(start);
filter.setCollectorTmsEnd(end);
filter.setFacilityVersion(swVersion);
Map<String, Unit> unitsInGroup = getUnitsInGroup(group);
List<SyslogEntry> entries = syslog.read(filter, xaps);
Map<String, Report<RecordHardware>> unitReportMap = new HashMap<String, Report<RecordHardware>>();
for (SyslogEntry entry : entries) {
String unitId = entry.getUnitId();
if (group != null && unitsInGroup.get(entry.getUnitId()) == null)
continue;
if (unitId == null || unitId.trim().equals(""))
unitId = "Unknown";
String unittypeName = entry.getUnittypeName();
if (unittypeName == null || unittypeName.trim().equals(""))
unittypeName = "Unknown";
String profileName = entry.getProfileName();
if (profileName == null || profileName.trim().equals(""))
profileName = "Unknown";
Report<RecordHardware> report = unitReportMap.get(unitId);
if (report == null) {
report = new Report<RecordHardware>(RecordHardware.class, periodType);
unitReportMap.put(unitId, report);
}
if (entry.getFacilityVersion() == null || entry.getFacilityVersion().trim().equals(""))
entry.setFacilityVersion("Unknown");
RecordHardware recordTmp = new RecordHardware(entry.getCollectorTimestamp(), periodType, unittypeName, profileName, entry.getFacilityVersion());
Key key = recordTmp.getKey();
RecordHardware record = report.getRecord(key);
if (record == null)
record = recordTmp;
try {
parseContentAndPopulateRecord(record, entry.getContent(), entry.getCollectorTimestamp());
report.setRecord(key, record);
} catch (SyslogParseException spe) {
// ignore this record
}
}
logger.info(logPrefix + "HardwareReport: Have read " + entries.size() + " rows from syslog, " + unitReportMap.size() + " units are mapped");
return unitReportMap;
}
开发者ID:freeacs，项目名称:dbi，代码行数:51，代码来源:ReportHardwareGenerator.java
示例5: getSyslogFilter
import com.owera.xaps.dbi.SyslogFilter; //导入依赖的package包/类
public SyslogFilter getSyslogFilter() {
return syslogFilter;
}
开发者ID:freeacs，项目名称:dbi，代码行数:4，代码来源:ReportGenerator.java
示例6: setSyslogFilter
import com.owera.xaps.dbi.SyslogFilter; //导入依赖的package包/类
public void setSyslogFilter(SyslogFilter syslogFilter) {
this.syslogFilter = syslogFilter;
}
开发者ID:freeacs，项目名称:dbi，代码行数:4，代码来源:ReportGenerator.java
注：本文中的com.owera.xaps.dbi.SyslogFilter类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
请发表评论