Add ServerLauncherUtils and CacheServerUtils
Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/46c5b971 Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/46c5b971 Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/46c5b971 Branch: refs/heads/feature/GEODE-2632-17 Commit: 46c5b9719ef6b325eb956a208fc752a886f641a4 Parents: 0113201 Author: Kirk Lund <kl...@apache.org> Authored: Fri May 19 14:57:44 2017 -0700 Committer: Kirk Lund <kl...@apache.org> Committed: Wed May 24 16:41:06 2017 -0700 ---------------------------------------------------------------------- .../geode/distributed/ServerLauncherUtils.java | 30 +++++++++++ .../cache/tier/sockets/CacheServerUtils.java | 55 ++++++++++++++++++++ 2 files changed, 85 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/46c5b971/geode-core/src/test/java/org/apache/geode/distributed/ServerLauncherUtils.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/distributed/ServerLauncherUtils.java b/geode-core/src/test/java/org/apache/geode/distributed/ServerLauncherUtils.java new file mode 100644 index 0000000..017e0f5 --- /dev/null +++ b/geode-core/src/test/java/org/apache/geode/distributed/ServerLauncherUtils.java @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance with the License. You may obtain a + * copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License + * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express + * or implied. See the License for the specific language governing permissions and limitations under + * the License. + */ +package org.apache.geode.distributed; + +import org.apache.geode.cache.Cache; + +/** + * Provides tests a way to access non-public state in ServerLauncher + */ +public class ServerLauncherUtils { + + /** + * Returns the Cache from an online in-process ServerLauncher instance + */ + public static Cache getCache(final ServerLauncher serverLauncher) { + return serverLauncher.getCache(); + } +} http://git-wip-us.apache.org/repos/asf/geode/blob/46c5b971/geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/CacheServerUtils.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/CacheServerUtils.java b/geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/CacheServerUtils.java new file mode 100644 index 0000000..8cd7622 --- /dev/null +++ b/geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/CacheServerUtils.java @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance with the License. You may obtain a + * copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License + * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express + * or implied. See the License for the specific language governing permissions and limitations under + * the License. + */ +package org.apache.geode.internal.cache.tier.sockets; + +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.server.CacheServer; +import org.apache.geode.internal.cache.CacheServerImpl; + +import java.util.List; +import java.util.Set; + +/** + * Provides tests a way to access CacheServer, AcceptorImpl and ServerConnection + */ +public class CacheServerUtils { + + /** + * Returns single CacheServer for the specified Cache instance + */ + public static CacheServer getCacheServer(final Cache cache) { + List<CacheServer> cacheServers = cache.getCacheServers(); + CacheServer cacheServer = cacheServers.get(0); + return cacheServer; + } + + /** + * Returns AcceptorImpl for the specified CacheServer instance + */ + public static AcceptorImpl getAcceptorImpl(final CacheServer cacheServer) { + AcceptorImpl acceptor = ((CacheServerImpl) cacheServer).getAcceptor(); + return acceptor; + } + + /** + * Returns single ServerConnection for the specified CacheServer instance + */ + public static ServerConnection getServerConnection(final CacheServer cacheServer) { + AcceptorImpl acceptor = ((CacheServerImpl) cacheServer).getAcceptor(); + Set<ServerConnection> serverConnections = acceptor.getAllServerConnections(); + ServerConnection serverConnection = serverConnections.iterator().next(); // null + return serverConnection; + } +}
