Skip to content

Commit

Permalink
[WFLY-8038] Undertow subsystem tests should only register socket-bind…
Browse files Browse the repository at this point in the history
…ing caps once
  • Loading branch information
bstansberry committed Feb 7, 2017
1 parent f5063ad commit 01b78a7
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 37 deletions.
Expand Up @@ -49,7 +49,8 @@ public static void setProperty() {


public static void testRuntime(KernelServices mainServices, final String virtualHostName, int flag) throws Exception { public static void testRuntime(KernelServices mainServices, final String virtualHostName, int flag) throws Exception {
if (!mainServices.isSuccessfulBoot()) { if (!mainServices.isSuccessfulBoot()) {
Assert.fail(mainServices.getBootError().toString()); Throwable t = mainServices.getBootError();
Assert.fail("Boot unsuccessful: " + (t != null ? t.toString() : "no boot error provided"));
} }
ServiceController<FilterService> connectionLimiter = (ServiceController<FilterService>) mainServices.getContainer() ServiceController<FilterService> connectionLimiter = (ServiceController<FilterService>) mainServices.getContainer()
.getService(UndertowService.FILTER.append("limit-connections")); .getService(UndertowService.FILTER.append("limit-connections"));
Expand Down
Expand Up @@ -42,7 +42,6 @@
import org.jboss.as.domain.management.security.SecurityRealmService; import org.jboss.as.domain.management.security.SecurityRealmService;
import org.jboss.as.naming.deployment.ContextNames; import org.jboss.as.naming.deployment.ContextNames;
import org.jboss.as.naming.service.NamingStoreService; import org.jboss.as.naming.service.NamingStoreService;
import org.jboss.as.network.SocketBinding;
import org.jboss.as.remoting.HttpListenerRegistryService; import org.jboss.as.remoting.HttpListenerRegistryService;
import org.jboss.as.server.Services; import org.jboss.as.server.Services;
import org.jboss.as.server.moduleservice.ServiceModuleLoader; import org.jboss.as.server.moduleservice.ServiceModuleLoader;
Expand Down Expand Up @@ -149,10 +148,6 @@ protected void initializeExtraSubystemsAndModel(ExtensionRegistry extensionRegis
XnioWorker.class); XnioWorker.class);
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_BUFFER_POOL_CAPABILITY, capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_BUFFER_POOL_CAPABILITY,
ListenerResourceDefinition.BUFFER_POOL.getDefaultValue().asString()), Pool.class); ListenerResourceDefinition.BUFFER_POOL.getDefaultValue().asString()), Pool.class);
for (String entry : sockets.keySet()) {
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.SOCKET_CAPABILITY, entry),
SocketBinding.class);
}
registerServiceCapabilities(capabilityRegistry, capabilities); registerServiceCapabilities(capabilityRegistry, capabilities);


} }
Expand Down
Expand Up @@ -43,7 +43,6 @@
import org.jboss.as.domain.management.security.SecurityRealmService; import org.jboss.as.domain.management.security.SecurityRealmService;
import org.jboss.as.naming.deployment.ContextNames; import org.jboss.as.naming.deployment.ContextNames;
import org.jboss.as.naming.service.NamingStoreService; import org.jboss.as.naming.service.NamingStoreService;
import org.jboss.as.network.SocketBinding;
import org.jboss.as.remoting.HttpListenerRegistryService; import org.jboss.as.remoting.HttpListenerRegistryService;
import org.jboss.as.server.Services; import org.jboss.as.server.Services;
import org.jboss.as.server.moduleservice.ServiceModuleLoader; import org.jboss.as.server.moduleservice.ServiceModuleLoader;
Expand Down Expand Up @@ -212,16 +211,22 @@ protected RunningMode getRunningMode() {
return RunningMode.ADMIN_ONLY; return RunningMode.ADMIN_ONLY;
} }


@Override
protected void setupController(ControllerInitializer controllerInitializer) {
super.setupController(controllerInitializer);

for (Map.Entry<String, Integer> entry : sockets.entrySet()) {
controllerInitializer.addSocketBinding(entry.getKey(), entry.getValue());
}
}

@Override @Override
protected void initializeExtraSubystemsAndModel(ExtensionRegistry extensionRegistry, Resource rootResource, ManagementResourceRegistration rootRegistration, RuntimeCapabilityRegistry capabilityRegistry) { protected void initializeExtraSubystemsAndModel(ExtensionRegistry extensionRegistry, Resource rootResource, ManagementResourceRegistration rootRegistration, RuntimeCapabilityRegistry capabilityRegistry) {
super.initializeExtraSubystemsAndModel(extensionRegistry, rootResource, rootRegistration, capabilityRegistry); super.initializeExtraSubystemsAndModel(extensionRegistry, rootResource, rootRegistration, capabilityRegistry);
Map<String, Class> capabilities = new HashMap<>(); Map<String, Class> capabilities = new HashMap<>();
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_WORKER_CAPABILITY, ListenerResourceDefinition.WORKER.getDefaultValue().asString()), XnioWorker.class); capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_WORKER_CAPABILITY, ListenerResourceDefinition.WORKER.getDefaultValue().asString()), XnioWorker.class);
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_WORKER_CAPABILITY, "non-default"), XnioWorker.class); capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_WORKER_CAPABILITY, "non-default"), XnioWorker.class);
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_BUFFER_POOL_CAPABILITY, ListenerResourceDefinition.BUFFER_POOL.getDefaultValue().asString()), Pool.class); capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_BUFFER_POOL_CAPABILITY, ListenerResourceDefinition.BUFFER_POOL.getDefaultValue().asString()), Pool.class);
for (String entry : sockets.keySet()) {
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.SOCKET_CAPABILITY, entry), SocketBinding.class);
}
registerServiceCapabilities(capabilityRegistry, capabilities); registerServiceCapabilities(capabilityRegistry, capabilities);


} }
Expand All @@ -239,15 +244,6 @@ protected RunningMode getRunningMode() {
return RunningMode.NORMAL; return RunningMode.NORMAL;
} }


@Override
protected void setupController(ControllerInitializer controllerInitializer) {
super.setupController(controllerInitializer);

for (Map.Entry<String, Integer> entry : sockets.entrySet()) {
controllerInitializer.addSocketBinding(entry.getKey(), entry.getValue());
}
}

@Override @Override
protected void addExtraServices(ServiceTarget target) { protected void addExtraServices(ServiceTarget target) {
super.addExtraServices(target); super.addExtraServices(target);
Expand Down
Expand Up @@ -32,6 +32,9 @@


import javax.net.ssl.SSLContext; import javax.net.ssl.SSLContext;


import io.undertow.predicate.Predicates;
import io.undertow.server.HttpHandler;
import io.undertow.server.handlers.PathHandler;
import org.jboss.as.controller.ControlledProcessStateService; import org.jboss.as.controller.ControlledProcessStateService;
import org.jboss.as.controller.RunningMode; import org.jboss.as.controller.RunningMode;
import org.jboss.as.controller.capability.registry.RuntimeCapabilityRegistry; import org.jboss.as.controller.capability.registry.RuntimeCapabilityRegistry;
Expand All @@ -42,7 +45,6 @@
import org.jboss.as.domain.management.security.SecurityRealmService; import org.jboss.as.domain.management.security.SecurityRealmService;
import org.jboss.as.naming.deployment.ContextNames; import org.jboss.as.naming.deployment.ContextNames;
import org.jboss.as.naming.service.NamingStoreService; import org.jboss.as.naming.service.NamingStoreService;
import org.jboss.as.network.SocketBinding;
import org.jboss.as.remoting.HttpListenerRegistryService; import org.jboss.as.remoting.HttpListenerRegistryService;
import org.jboss.as.server.Services; import org.jboss.as.server.Services;
import org.jboss.as.server.moduleservice.ServiceModuleLoader; import org.jboss.as.server.moduleservice.ServiceModuleLoader;
Expand All @@ -66,10 +68,6 @@
import org.xnio.Pool; import org.xnio.Pool;
import org.xnio.XnioWorker; import org.xnio.XnioWorker;


import io.undertow.predicate.Predicates;
import io.undertow.server.HttpHandler;
import io.undertow.server.handlers.PathHandler;

/** /**
* This is the barebone test example that tests subsystem * This is the barebone test example that tests subsystem
* *
Expand Down Expand Up @@ -155,6 +153,15 @@ protected RunningMode getRunningMode() {
return RunningMode.ADMIN_ONLY; return RunningMode.ADMIN_ONLY;
} }


@Override
protected void setupController(ControllerInitializer controllerInitializer) {
super.setupController(controllerInitializer);

for (Map.Entry<String, Integer> entry : sockets.entrySet()) {
controllerInitializer.addSocketBinding(entry.getKey(), entry.getValue());
}
}

@Override @Override
protected void initializeExtraSubystemsAndModel(ExtensionRegistry extensionRegistry, Resource rootResource, protected void initializeExtraSubystemsAndModel(ExtensionRegistry extensionRegistry, Resource rootResource,
ManagementResourceRegistration rootRegistration, RuntimeCapabilityRegistry capabilityRegistry) { ManagementResourceRegistration rootRegistration, RuntimeCapabilityRegistry capabilityRegistry) {
Expand All @@ -166,10 +173,6 @@ protected void initializeExtraSubystemsAndModel(ExtensionRegistry extensionRegis
XnioWorker.class); XnioWorker.class);
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_BUFFER_POOL_CAPABILITY, capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.IO_BUFFER_POOL_CAPABILITY,
ListenerResourceDefinition.BUFFER_POOL.getDefaultValue().asString()), Pool.class); ListenerResourceDefinition.BUFFER_POOL.getDefaultValue().asString()), Pool.class);
for (String entry : sockets.keySet()) {
capabilities.put(buildDynamicCapabilityName(ListenerResourceDefinition.SOCKET_CAPABILITY, entry),
SocketBinding.class);
}
capabilities.put(buildDynamicCapabilityName("org.wildfly.security.http-authentication-factory", "elytron-factory"), HttpAuthenticationFactory.class); capabilities.put(buildDynamicCapabilityName("org.wildfly.security.http-authentication-factory", "elytron-factory"), HttpAuthenticationFactory.class);
capabilities.put(buildDynamicCapabilityName("org.wildfly.security.ssl-context", "TestContext"), SSLContext.class); capabilities.put(buildDynamicCapabilityName("org.wildfly.security.ssl-context", "TestContext"), SSLContext.class);
capabilities.put(buildDynamicCapabilityName("org.wildfly.security.ssl-context", "my-ssl-context"), SSLContext.class); capabilities.put(buildDynamicCapabilityName("org.wildfly.security.ssl-context", "my-ssl-context"), SSLContext.class);
Expand All @@ -191,15 +194,6 @@ protected RunningMode getRunningMode() {
return RunningMode.NORMAL; return RunningMode.NORMAL;
} }


@Override
protected void setupController(ControllerInitializer controllerInitializer) {
super.setupController(controllerInitializer);

for (Map.Entry<String, Integer> entry : sockets.entrySet()) {
controllerInitializer.addSocketBinding(entry.getKey(), entry.getValue());
}
}

@Override @Override
protected void addExtraServices(ServiceTarget target) { protected void addExtraServices(ServiceTarget target) {
super.addExtraServices(target); super.addExtraServices(target);
Expand Down

0 comments on commit 01b78a7

Please sign in to comment.