Skip to content

Commit

Permalink
Merge CMSEngine.loadSubsystems() into initSubsystems()
Browse files Browse the repository at this point in the history
  • Loading branch information
edewata committed Jan 20, 2024
1 parent 9cf0957 commit aee01f4
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 30 deletions.
4 changes: 2 additions & 2 deletions base/ca/src/main/java/org/dogtagpki/server/ca/CAEngine.java
Original file line number Diff line number Diff line change
Expand Up @@ -793,6 +793,8 @@ public void startSerialNumberUpdateTask() throws Exception {
@Override
public void initSubsystems() throws Exception {

super.initSubsystems();

CertificateAuthority hostCA = getCA();

CAEngineConfig engineConfig = getConfig();
Expand Down Expand Up @@ -909,8 +911,6 @@ public void initSubsystems() throws Exception {
initCRLPublisher();
initPublisherProcessor();
}

super.initSubsystems();
}

@Override
Expand Down
44 changes: 16 additions & 28 deletions base/server/src/main/java/com/netscape/cmscore/apps/CMSEngine.java
Original file line number Diff line number Diff line change
Expand Up @@ -879,8 +879,6 @@ public void initSecurityDomain() throws Exception {
public void init() throws Exception {

logger.info("Initializing " + name + " subsystem");

loadSubsystems();
initSubsystems();

// The ports must be configured here to avoid problems
Expand Down Expand Up @@ -968,23 +966,33 @@ public void setSubsystemEnabled(String id, boolean enabled) {
si.enabled = enabled;
}

public void initSubsystem(Subsystem subsystem, ConfigStore subsystemConfig) throws Exception {

if (subsystem instanceof SelfTestSubsystem) {
// skip SelfTestSubsystem during installation
if (isPreOpMode()) return;
}

subsystem.init(subsystemConfig);
}

/**
* load subsystems
*/
protected void loadSubsystems() throws Exception {
public void initSubsystems() throws Exception {

subsystemInfos.clear();
subsystems.clear();

SubsystemsConfig subsystemsConfig = mConfig.getSubsystemsConfig();

for (String subsystemNumber : subsystemsConfig.getSubsystemNames()) {
SubsystemConfig subsystemConfig = subsystemsConfig.getSubsystemConfig(subsystemNumber);
String id = subsystemConfig.getID();
logger.info("CMSEngine: Loading " + id + " subsystem");
SubsystemConfig subsystemInfoConfig = subsystemsConfig.getSubsystemConfig(subsystemNumber);
String id = subsystemInfoConfig.getID();
logger.info("CMSEngine: Initializing " + id + " subsystem");

String className = subsystemConfig.getClassName();
boolean enabled = subsystemConfig.isEnabled();
String className = subsystemInfoConfig.getClassName();
boolean enabled = subsystemInfoConfig.isEnabled();

Subsystem subsystem = (Subsystem) Class.forName(className).getDeclaredConstructor().newInstance();
subsystem.setCMSEngine(this);
Expand All @@ -995,26 +1003,6 @@ protected void loadSubsystems() throws Exception {

subsystems.put(id, subsystem);
subsystemInfos.put(id, subsystemInfo);
}
}

public void initSubsystem(Subsystem subsystem, ConfigStore subsystemConfig) throws Exception {

if (subsystem instanceof SelfTestSubsystem) {
// skip SelfTestSubsystem during installation
if (isPreOpMode()) return;
}

subsystem.init(subsystemConfig);
}

public void initSubsystems() throws Exception {

for (String id : subsystems.keySet()) {
logger.info("CMSEngine: Initializing " + id + " subsystem");

Subsystem subsystem = subsystems.get(id);
SubsystemInfo subsystemInfo = subsystemInfos.get(id);

if (subsystemInfo.updateIdOnInit) {
subsystem.setId(id);
Expand Down

0 comments on commit aee01f4

Please sign in to comment.