|
@@ -105,26 +105,31 @@ function cacheLogs() {
|
|
|
let n = 200
|
|
|
let messlist = value.messlist
|
|
|
if (value.id !== -1 && port !== -1) {
|
|
|
- logger.info(`~~~缓存日志${value.id}`)
|
|
|
- try {
|
|
|
- var logPath = "./logs" + port
|
|
|
- logger.info(`访问-日志相对目录:${logPath}`)
|
|
|
- const directoryPath = path.resolve(logPath);
|
|
|
- file.checkPathSync(directoryPath)
|
|
|
- file.getLastFile(logPath, 5, async (fileNameList, _) => {
|
|
|
- logger.info('-----文件:', fileNameList);
|
|
|
- let result = await file.getLatestLogEntries(logPath, fileNameList.reverse(), n);
|
|
|
- if (messlist.length === 0) {
|
|
|
- value.messlist = result
|
|
|
- } else {
|
|
|
- if (messlist[0] !== result[0]) {
|
|
|
+ new Promise((resolve, reject) => {
|
|
|
+ logger.info(`~~~缓存日志${value.id}`)
|
|
|
+ try {
|
|
|
+ var logPath = "./logs" + port
|
|
|
+ logger.info(`访问-日志相对目录:${logPath}`)
|
|
|
+ const directoryPath = path.resolve(logPath);
|
|
|
+ file.checkPathSync(directoryPath)
|
|
|
+ file.getLastFile(logPath, 5, async (fileNameList, _) => {
|
|
|
+ logger.info('-----文件:', fileNameList);
|
|
|
+ let result = await file.getLatestLogEntries(logPath, fileNameList.reverse(), n);
|
|
|
+ if (messlist.length === 0) {
|
|
|
value.messlist = result
|
|
|
+ } else {
|
|
|
+ if (messlist[0] !== result[0]) {
|
|
|
+ value.messlist = result
|
|
|
+ }
|
|
|
}
|
|
|
- }
|
|
|
- });
|
|
|
- } catch (e) {
|
|
|
- logger.info('异步缓存日志异常~~', e);
|
|
|
- }
|
|
|
+ });
|
|
|
+ } catch (e) {
|
|
|
+ logger.info('异步缓存日志异常~~', e);
|
|
|
+ }
|
|
|
+ resolve()
|
|
|
+ }).then(r => {
|
|
|
+ logger.info('异步缓存日志异常~~失败');
|
|
|
+ });
|
|
|
}
|
|
|
});
|
|
|
}, intervalInMilliseconds);
|
|
@@ -145,7 +150,7 @@ function cachePredictorState() {
|
|
|
var accUrl = "http://127.0.0.1:" + port
|
|
|
http.request_get(`${accUrl}/predictor_state`, {...config.headers})
|
|
|
.then((data) => {
|
|
|
- let result = JSON.parse(data);
|
|
|
+ let result = JSON.parse(data);
|
|
|
if (predictorState.length === 0) {
|
|
|
value.predictorState = result
|
|
|
} else {
|