justinwwhuang commented on code in PR #9912:
URL: https://github.com/apache/inlong/pull/9912#discussion_r1546267058
##########
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java:
##########
@@ -213,6 +214,44 @@ private void
dealWithConfigQueue(BlockingQueue<ConfigResult> queue) {
}
}
+ private void checkModules() {
+ LOGGER.info("check modules start");
+ currentModules.values().forEach((module) -> {
+ LOGGER.info("check module current state {} {}", module.getName(),
module.getState());
+ switch (module.getState()) {
+ case NEW:
+ if (downloadModule(module)) {
+ saveModuleState(module.getId(),
ModuleStateEnum.DOWNLOADED);
+ } else {
+ LOGGER.error("download module {} failed, keep state in
new", module.getName());
+ }
+ break;
+ case DOWNLOADED:
+ if (isPackageDownloaded(module)) {
+ installModule(module);
+ saveModuleState(module.getId(),
ModuleStateEnum.INSTALLED);
+ } else {
+ LOGGER.info("check module {} package failed, change
stated to new, will download package again",
+ module.getName());
+ saveModuleState(module.getId(), ModuleStateEnum.NEW);
+ }
+ break;
+ case INSTALLED:
+ if (!isProcessAllStarted(module)) {
+ LOGGER.info("module {} process not all started try to
start", module.getName());
+ if (!startModule(module)) {
+ LOGGER.info("start module {} failed, change state
to downloaded", module.getState());
+ saveModuleState(module.getId(),
ModuleStateEnum.DOWNLOADED);
+ }
+ }
+ break;
Review Comment:
It's already fast enough. Many online process guards are done every 5 minutes
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
