You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by rm...@apache.org on 2017/06/14 13:54:28 UTC
tomee git commit: TOMEE-2044 filling Registry class with pools
Repository: tomee
Updated Branches:
refs/heads/master e756f0c75 -> 7708df488
TOMEE-2044 filling Registry class with pools
Project: http://git-wip-us.apache.org/repos/asf/tomee/repo
Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/7708df48
Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/7708df48
Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/7708df48
Branch: refs/heads/master
Commit: 7708df488f9f3acb83eaca0f39c985b52ef31844
Parents: e756f0c
Author: rmannibucau <rm...@apache.org>
Authored: Wed Jun 14 15:54:22 2017 +0200
Committer: rmannibucau <rm...@apache.org>
Committed: Wed Jun 14 15:54:22 2017 +0200
----------------------------------------------------------------------
.../org/apache/openejb/server/ServicePool.java | 26 ++++++++++++++++++--
1 file changed, 24 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tomee/blob/7708df48/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java
----------------------------------------------------------------------
diff --git a/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java b/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java
index 66e415b..d3219c3 100644
--- a/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java
+++ b/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java
@@ -183,6 +183,28 @@ public class ServicePool extends ServerServiceFilter {
}
@Override
+ public void start() throws ServiceException {
+ final Registry registry = SystemInstance.get().getComponent(Registry.class);
+ if (registry == null) {
+ return;
+ }
+ synchronized (registry) {
+ registry.pools.add(this);
+ }
+ }
+
+ @Override
+ public void stop() throws ServiceException {
+ final Registry registry = SystemInstance.get().getComponent(Registry.class);
+ if (registry == null) {
+ return;
+ }
+ synchronized (registry) {
+ registry.pools.remove(this);
+ }
+ }
+
+ @Override
public void service(final InputStream in, final OutputStream out) throws ServiceException, IOException {
}
@@ -364,8 +386,8 @@ public class ServicePool extends ServerServiceFilter {
public static class Registry {
private final Collection<ServicePool> pools = new ArrayList<>();
- public Collection<ServicePool> getPools() {
- return pools;
+ public synchronized Collection<ServicePool> getPools() {
+ return new ArrayList<>(pools);
}
}
}