| /*========================================================================= |
| * Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved. |
| * This product is protected by U.S. and international copyright |
| * and intellectual property laws. Pivotal products are covered by |
| * one or more patents listed at http://www.pivotal.io/patents. |
| *========================================================================= |
| */ |
| package com.gemstone.gemfire.internal.cache.tier.sockets; |
| |
| import java.io.File; |
| import java.net.InetSocketAddress; |
| import java.net.URISyntaxException; |
| import java.net.URL; |
| import java.util.Enumeration; |
| import java.util.Iterator; |
| import java.util.LinkedList; |
| import java.util.Properties; |
| |
| import com.gemstone.gemfire.cache.AttributesFactory; |
| import com.gemstone.gemfire.cache.Cache; |
| import com.gemstone.gemfire.cache.CacheFactory; |
| import com.gemstone.gemfire.cache.DataPolicy; |
| import com.gemstone.gemfire.cache.Declarable; |
| import com.gemstone.gemfire.cache.EntryEvent; |
| import com.gemstone.gemfire.cache.RegionAttributes; |
| import com.gemstone.gemfire.cache.Scope; |
| import com.gemstone.gemfire.cache.client.ClientCache; |
| import com.gemstone.gemfire.cache.client.ClientCacheFactory; |
| import com.gemstone.gemfire.cache.client.ClientRegionShortcut; |
| import com.gemstone.gemfire.cache.client.Pool; |
| import com.gemstone.gemfire.cache.client.PoolManager; |
| import com.gemstone.gemfire.cache.client.internal.PoolImpl; |
| import com.gemstone.gemfire.cache.query.CqEvent; |
| import com.gemstone.gemfire.cache.util.BridgeServer; |
| import com.gemstone.gemfire.cache.util.CacheListenerAdapter; |
| import com.gemstone.gemfire.cache.util.CqListenerAdapter; |
| import com.gemstone.gemfire.distributed.DistributedSystem; |
| import com.gemstone.gemfire.distributed.internal.DistributionConfig; |
| import com.gemstone.gemfire.internal.AvailablePort; |
| import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; |
| import com.gemstone.gemfire.internal.cache.PoolFactoryImpl; |
| import com.gemstone.gemfire.internal.cache.PoolFactoryImpl.PoolAttributes; |
| import com.gemstone.gemfire.internal.i18n.LocalizedStrings; |
| |
| import dunit.DistributedTestCase; |
| /** |
| * |
| * @author Yogesh Mahajan |
| * |
| */ |
| public class CacheServerTestUtil extends DistributedTestCase |
| { |
| private static Cache cache = null; |
| private static ExpectedException expected; |
| |
| private static PoolImpl pool = null; |
| |
| protected final static int TYPE_CREATE = 0; |
| protected final static int TYPE_UPDATE = 1; |
| protected final static int TYPE_INVALIDATE = 2; |
| protected final static int TYPE_DESTROY = 3; |
| |
| public CacheServerTestUtil(String name) { |
| super(name); |
| } |
| |
| |
| |
| // public static void createCacheClient(Properties props, String regionName) |
| // throws Exception { |
| // createCacheClient(props, regionName, getClientProperties(), Boolean.FALSE); |
| // } |
| public static void createCacheClient(Pool poolAttr, String regionName) |
| throws Exception { |
| createCacheClient(poolAttr, regionName, getClientProperties(), Boolean.FALSE); |
| } |
| |
| // public static void createCacheClient(Properties props, String regionName, |
| // Properties dsProperties) throws Exception { |
| // createCacheClient(props, regionName, dsProperties, Boolean.FALSE); |
| // } |
| public static void createCacheClient(Pool poolAttr, String regionName, |
| Properties dsProperties) throws Exception { |
| createCacheClient(poolAttr, regionName, dsProperties, Boolean.FALSE); |
| } |
| |
| // public static void createCacheClient(Properties props, String regionName, |
| // Properties dsProperties, Boolean addControlListener) throws Exception { |
| // new CacheServerTestUtil("temp").createCache(dsProperties); |
| // BridgeWriter writer = new BridgeWriter(); |
| // writer.init(props); |
| // AttributesFactory factory = new AttributesFactory(); |
| // factory.setScope(Scope.LOCAL); |
| // factory.setCacheWriter(writer); |
| // if (addControlListener.booleanValue()) { |
| // factory.addCacheListener(new ControlListener()); |
| // } |
| // RegionAttributes attrs = factory.create(); |
| // cache.createRegion(regionName, attrs); |
| // pool = (PoolImpl)writer.getConnectionProxy(); |
| // } |
| |
| public static void createClientCache(Pool poolAttr, String regionName) throws Exception { |
| createClientCache(poolAttr, regionName, getClientProperties()); |
| } |
| |
| public static void createClientCache(Pool poolAttr, String regionName, |
| Properties dsProperties) throws Exception { |
| ClientCacheFactory ccf = new ClientCacheFactory(dsProperties); |
| if (poolAttr != null) { |
| ccf |
| .setPoolFreeConnectionTimeout(poolAttr.getFreeConnectionTimeout()) |
| .setPoolLoadConditioningInterval(poolAttr.getLoadConditioningInterval()) |
| .setPoolSocketBufferSize(poolAttr.getSocketBufferSize()) |
| .setPoolMinConnections(poolAttr.getMinConnections()) |
| .setPoolMaxConnections(poolAttr.getMaxConnections()) |
| .setPoolIdleTimeout(poolAttr.getIdleTimeout()) |
| .setPoolPingInterval(poolAttr.getPingInterval()) |
| .setPoolStatisticInterval(poolAttr.getStatisticInterval()) |
| .setPoolRetryAttempts(poolAttr.getRetryAttempts()) |
| .setPoolThreadLocalConnections(poolAttr.getThreadLocalConnections()) |
| .setPoolReadTimeout(poolAttr.getReadTimeout()) |
| .setPoolSubscriptionEnabled(poolAttr.getSubscriptionEnabled()) |
| .setPoolPRSingleHopEnabled(poolAttr.getPRSingleHopEnabled()) |
| .setPoolSubscriptionRedundancy(poolAttr.getSubscriptionRedundancy()) |
| .setPoolSubscriptionMessageTrackingTimeout(poolAttr.getSubscriptionMessageTrackingTimeout()) |
| .setPoolSubscriptionAckInterval(poolAttr.getSubscriptionAckInterval()) |
| .setPoolServerGroup(poolAttr.getServerGroup()) |
| .setPoolMultiuserAuthentication(poolAttr.getMultiuserAuthentication()); |
| for (InetSocketAddress locator: poolAttr.getLocators()) { |
| ccf.addPoolLocator(locator.getHostName(), locator.getPort()); |
| } |
| for (InetSocketAddress server: poolAttr.getServers()) { |
| ccf.addPoolServer(server.getHostName(), server.getPort()); |
| } |
| } |
| new CacheServerTestUtil("temp").createClientCache(dsProperties, ccf); |
| ClientCache cc = (ClientCache)cache; |
| cc.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY).create(regionName); |
| pool = (PoolImpl)((GemFireCacheImpl)cc).getDefaultPool(); |
| } |
| |
| |
| |
| public static void createPool(PoolAttributes poolAttr) throws Exception { |
| Properties props = new Properties(); |
| props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0"); |
| props.setProperty(DistributionConfig.LOCATORS_NAME, ""); |
| |
| DistributedSystem ds = new CacheServerTestUtil("tmp").getSystem(props);; |
| |
| PoolFactoryImpl pf = (PoolFactoryImpl)PoolManager.createFactory(); |
| pf.init(poolAttr); |
| PoolImpl p = (PoolImpl)pf.create("CacheServerTestUtil"); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.LOCAL); |
| factory.setPoolName(p.getName()); |
| |
| RegionAttributes attrs = factory.create(); |
| pool = p; |
| } |
| |
| |
| |
| |
| |
| |
| |
| public static void createCacheClient(Pool poolAttr, String regionName, |
| Properties dsProperties, Boolean addControlListener) throws Exception { |
| createCacheClient(poolAttr, regionName, dsProperties, addControlListener, null); |
| } |
| |
| public static void createCacheClient(Pool poolAttr, String regionName, |
| Properties dsProperties, Boolean addControlListener, Properties javaSystemProperties) throws Exception { |
| new CacheServerTestUtil("temp").createCache(dsProperties); |
| addExpectedException("java.net.ConnectException||java.net.SocketException"); |
| |
| if (javaSystemProperties != null && javaSystemProperties.size() > 0) { |
| Enumeration e = javaSystemProperties.propertyNames(); |
| |
| while (e.hasMoreElements()) { |
| String key = (String) e.nextElement(); |
| System.setProperty(key, javaSystemProperties.getProperty(key)); |
| } |
| } |
| |
| PoolFactoryImpl pf = (PoolFactoryImpl)PoolManager.createFactory(); |
| pf.init(poolAttr); |
| PoolImpl p = (PoolImpl)pf.create("CacheServerTestUtil"); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.LOCAL); |
| factory.setPoolName(p.getName()); |
| if (addControlListener.booleanValue()) { |
| factory.addCacheListener(new ControlListener()); |
| } |
| RegionAttributes attrs = factory.create(); |
| cache.createRegion(regionName, attrs); |
| pool = p; |
| } |
| |
| public static void unsetJavaSystemProperties(Properties javaSystemProperties) { |
| if (javaSystemProperties != null && javaSystemProperties.size() > 0) { |
| Enumeration e = javaSystemProperties.propertyNames(); |
| |
| while (e.hasMoreElements()) { |
| String key = (String) e.nextElement(); |
| System.clearProperty(key); |
| } |
| } |
| } |
| |
| public static void createCacheClient(Pool poolAttr, String regionName1, |
| String regionName2) throws Exception |
| { |
| new CacheServerTestUtil("temp").createCache(getClientProperties()); |
| PoolFactoryImpl pf = (PoolFactoryImpl)PoolManager.createFactory(); |
| pf.init(poolAttr); |
| PoolImpl p = (PoolImpl)pf.create("CacheServerTestUtil"); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.LOCAL); |
| factory.setPoolName(p.getName()); |
| RegionAttributes attrs = factory.create(); |
| cache.createRegion(regionName1, attrs); |
| cache.createRegion(regionName2, attrs); |
| pool = p; |
| } |
| |
| public static void createCacheClientFromXmlN(URL url, String poolName, String durableClientId, int timeout, Boolean addControlListener) { |
| ClientCacheFactory ccf = new ClientCacheFactory(); |
| try { |
| File cacheXmlFile = new File(url.toURI().getPath()); |
| ccf.set("cache-xml-file", cacheXmlFile.toURI().getPath()); |
| |
| } |
| catch (URISyntaxException e) { |
| throw new ExceptionInInitializerError(e); |
| } |
| ccf.set("mcast-port", "0"); |
| ccf.set(DistributionConfig.DURABLE_CLIENT_ID_NAME, durableClientId); |
| ccf.set(DistributionConfig.DURABLE_CLIENT_TIMEOUT_NAME, String.valueOf(timeout)); |
| ccf.set("log-file", "abs_client_system.log"); |
| ccf.set("log-level", getDUnitLogLevel()); |
| cache = (Cache)ccf.create(); |
| expected = addExpectedException("java.net.ConnectionException||java.net.SocketException"); |
| pool = (PoolImpl)PoolManager.find(poolName); |
| |
| } |
| |
| public static void createCacheClientFromXml(URL url, String poolName, String durableClientId, int timeout, Boolean addControlListener) { |
| ClientCacheFactory ccf = new ClientCacheFactory(); |
| try { |
| File cacheXmlFile = new File(url.toURI().getPath()); |
| ccf.set("cache-xml-file", cacheXmlFile.toURI().getPath()); |
| |
| } |
| catch (URISyntaxException e) { |
| throw new ExceptionInInitializerError(e); |
| } |
| ccf.set("mcast-port", "0"); |
| ccf.set(DistributionConfig.DURABLE_CLIENT_ID_NAME, durableClientId); |
| ccf.set(DistributionConfig.DURABLE_CLIENT_TIMEOUT_NAME, String.valueOf(timeout)); |
| cache = (Cache)ccf.create(); |
| expected = addExpectedException("java.net.ConnectionException||java.net.SocketException"); |
| pool = (PoolImpl)PoolManager.find(poolName); |
| |
| } |
| |
| public static Integer createCacheServerFromXmlN(URL url) { |
| CacheFactory ccf = new CacheFactory(); |
| try { |
| File cacheXmlFile = new File(url.toURI().getPath()); |
| ccf.set("cache-xml-file", cacheXmlFile.toURI().getPath()); |
| ccf.set("mcast-port", "0"); |
| ccf.set("locators", "localhost["+DistributedTestCase.getDUnitLocatorPort()+"]"); |
| ccf.set("log-file", "abs_server_system.log"); |
| ccf.set("log-level", getDUnitLogLevel()); |
| } |
| catch (URISyntaxException e) { |
| throw new ExceptionInInitializerError(e); |
| } |
| cache = ccf.create(); |
| return new Integer(cache.getCacheServers().get(0).getPort()); |
| } |
| |
| public static Integer createCacheServerFromXml(URL url) { |
| CacheFactory ccf = new CacheFactory(); |
| try { |
| File cacheXmlFile = new File(url.toURI().getPath()); |
| ccf.set("cache-xml-file", cacheXmlFile.toURI().getPath()); |
| ccf.set("mcast-port", "0"); |
| ccf.set("locators", "localhost["+DistributedTestCase.getDUnitLocatorPort()+"]"); |
| } |
| catch (URISyntaxException e) { |
| throw new ExceptionInInitializerError(e); |
| } |
| cache = ccf.create(); |
| return new Integer(cache.getCacheServers().get(0).getPort()); |
| } |
| |
| /** |
| * Create client regions each with their own BridgeWriter instance. |
| * @param props |
| * @param regionName1 |
| * @param regionName2 |
| * @throws Exception |
| */ |
| public static void createCacheClients(Pool poolAttr, String regionName1, |
| String regionName2, Properties dsProperties) throws Exception |
| { |
| new CacheServerTestUtil("temp").createCache(dsProperties); |
| |
| // Initialize region1 |
| PoolFactoryImpl pf = (PoolFactoryImpl)PoolManager.createFactory(); |
| pf.init(poolAttr); |
| Pool p = pf.create("CacheServerTestUtil1"); |
| AttributesFactory factory1 = new AttributesFactory(); |
| factory1.setScope(Scope.LOCAL); |
| factory1.setPoolName(p.getName()); |
| cache.createRegion(regionName1, factory1.create()); |
| |
| // Initialize region2 |
| p = pf.create("CacheServerTestUtil2"); |
| AttributesFactory factory2 = new AttributesFactory(); |
| factory2.setScope(Scope.LOCAL); |
| factory2.setPoolName(p.getName()); |
| cache.createRegion(regionName2, factory2.create()); |
| } |
| |
| private static Properties getClientProperties() |
| { |
| Properties props = new Properties(); |
| props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0"); |
| props.setProperty(DistributionConfig.LOCATORS_NAME, ""); |
| return props; |
| } |
| |
| private static Properties getClientProperties(boolean durable) |
| { |
| Properties props = new Properties(); |
| props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0"); |
| props.setProperty(DistributionConfig.LOCATORS_NAME, ""); |
| return props; |
| } |
| |
| public static Integer createCacheServer(String regionName, |
| Boolean notifyBySubscription) throws Exception |
| { |
| Properties props = new Properties(); |
| props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0"); |
| props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost["+DistributedTestCase.getDUnitLocatorPort()+"]"); |
| new CacheServerTestUtil("temp").createCache(props); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.DISTRIBUTED_ACK); |
| factory.setEnableBridgeConflation(true); |
| factory.setDataPolicy(DataPolicy.REPLICATE); |
| RegionAttributes attrs = factory.create(); |
| cache.createRegion(regionName, attrs); |
| BridgeServer server1 = cache.addBridgeServer(); |
| int port = AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET); |
| server1.setPort(port); |
| server1.setNotifyBySubscription(notifyBySubscription.booleanValue()); |
| server1.start(); |
| return new Integer(server1.getPort()); |
| } |
| |
| public static Integer[] createCacheServerReturnPorts(String regionName, |
| Boolean notifyBySubscription) throws Exception |
| { |
| Properties props = new Properties(); |
| // int mcastPort = AvailablePort.getRandomAvailablePort(AvailablePort.JGROUPS); |
| props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0"); |
| props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost["+DistributedTestCase.getDUnitLocatorPort()+"]"); |
| new CacheServerTestUtil("temp").createCache(props); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.DISTRIBUTED_ACK); |
| factory.setEnableBridgeConflation(true); |
| factory.setDataPolicy(DataPolicy.REPLICATE); |
| RegionAttributes attrs = factory.create(); |
| cache.createRegion(regionName, attrs); |
| BridgeServer server1 = cache.addBridgeServer(); |
| int port = AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET); |
| server1.setPort(port); |
| server1.setNotifyBySubscription(notifyBySubscription.booleanValue()); |
| server1.start(); |
| return new Integer[] {port, 0}; |
| } |
| |
| public static Integer createCacheServer(String regionName, |
| Boolean notifyBySubscription, Integer mcastPort) |
| throws Exception { |
| Integer serverPort = new Integer(AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET)); |
| createCacheServer(regionName, notifyBySubscription, mcastPort, serverPort); |
| return serverPort; |
| } |
| |
| public static void createCacheServer(String regionName, |
| Boolean notifyBySubscription, Integer mcastPort, Integer serverPort) |
| throws Exception { |
| Properties props = new Properties(); |
| props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0"); |
| props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost["+DistributedTestCase.getDUnitLocatorPort()+"]"); |
| new CacheServerTestUtil("temp").createCache(props); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.DISTRIBUTED_ACK); |
| factory.setEnableBridgeConflation(true); |
| factory.setDataPolicy(DataPolicy.REPLICATE); |
| RegionAttributes attrs = factory.create(); |
| cache.createRegion(regionName, attrs); |
| BridgeServer server = cache.addBridgeServer(); |
| server.setPort(serverPort.intValue()); |
| server.setNotifyBySubscription(notifyBySubscription.booleanValue()); |
| server.start(); |
| } |
| |
| public static Integer createCacheServer(String regionName1, |
| String regionName2, Boolean notifyBySubscription) throws Exception |
| { |
| new CacheServerTestUtil("temp").createCache(new Properties()); |
| AttributesFactory factory = new AttributesFactory(); |
| factory.setScope(Scope.DISTRIBUTED_ACK); |
| factory.setEnableBridgeConflation(true); |
| factory.setDataPolicy(DataPolicy.REPLICATE); |
| RegionAttributes attrs = factory.create(); |
| if (!regionName1.equals("")) { |
| cache.createRegion(regionName1, attrs); |
| } |
| if (!regionName2.equals("")) { |
| cache.createRegion(regionName2, attrs); |
| } |
| BridgeServer server1 = cache.addBridgeServer(); |
| int port = AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET); |
| server1.setPort(port); |
| server1.setNotifyBySubscription(notifyBySubscription.booleanValue()); |
| server1.start(); |
| return new Integer(server1.getPort()); |
| } |
| |
| private void createCache(Properties props) throws Exception |
| { |
| DistributedSystem ds = getSystem(props); |
| assertNotNull(ds); |
| ds.disconnect(); |
| ds = getSystem(props); |
| cache = CacheFactory.create(ds); |
| assertNotNull(cache); |
| } |
| |
| private void createClientCache(Properties props, ClientCacheFactory ccf) throws Exception |
| { |
| DistributedSystem ds = getSystem(props); |
| assertNotNull(ds); |
| ds.disconnect(); |
| ClientCache cc = ccf.create(); |
| setSystem(props, cc.getDistributedSystem()); |
| cache = (Cache)cc; |
| assertNotNull(cache); |
| expected = addExpectedException("java.net.ConnectionException||java.net.SocketException"); |
| } |
| |
| public static void closeCache() |
| { |
| if (expected != null) { |
| expected.remove(); |
| expected = null; |
| } |
| if (cache != null && !cache.isClosed()) { |
| cache.close(); |
| cache.getDistributedSystem().disconnect(); |
| } |
| } |
| |
| public static void closeCache(boolean keepalive) |
| { |
| if (expected != null) { |
| expected.remove(); |
| expected = null; |
| } |
| if (cache != null && !cache.isClosed()) { |
| cache.close(keepalive); |
| cache.getDistributedSystem().disconnect(); |
| } |
| } |
| |
| public static void clearCacheReference() { |
| cache = null; |
| } |
| |
| public static void setClientCrash(boolean crashOnClose) |
| { |
| com.gemstone.gemfire.cache.client.internal.ConnectionImpl.setTEST_DURABLE_CLIENT_CRASH(crashOnClose); |
| } |
| |
| public static void disconnectClient() |
| { |
| pool.endpointsNetDownForDUnitTest(); |
| } |
| |
| public static void reconnectClient() |
| { |
| if(pool != null) { |
| pool.endpointsNetUpForDUnitTest(); |
| } |
| } |
| |
| public static void stopCacheServers() { |
| Iterator iter = getCache().getBridgeServers().iterator(); |
| if (iter.hasNext()) { |
| BridgeServer server = (BridgeServer) iter.next(); |
| server.stop(); |
| assertFalse(server.isRunning()); |
| } |
| } |
| |
| public static void restartCacheServers() { |
| Iterator iter = getCache().getBridgeServers().iterator(); |
| if (iter.hasNext()) { |
| BridgeServer server = (BridgeServer) iter.next(); |
| try { |
| server.start(); |
| } catch(Exception e) { |
| fail("Unexpected exception", e); |
| } |
| assertTrue(server.isRunning()); |
| } |
| } |
| |
| public static Cache getCache() |
| { |
| return cache; |
| } |
| |
| public static PoolImpl getPool() |
| { |
| return pool; |
| } |
| |
| // public static BridgeWriter getWriter() |
| // { |
| // return writer; |
| // } |
| |
| /** |
| * Disables the shuffling of endpoints for a client |
| * |
| */ |
| public static void disableShufflingOfEndpoints() |
| { |
| System.setProperty("gemfire.PoolImpl.DISABLE_RANDOM", "true"); |
| System.setProperty("gemfire.bridge.disableShufflingOfEndpoints", "true"); |
| } |
| /** |
| * Enables the shuffling of endpoints for a client |
| * @since 5.7 |
| */ |
| public static void enableShufflingOfEndpoints() |
| { |
| System.setProperty("gemfire.PoolImpl.DISABLE_RANDOM", "false"); |
| System.setProperty("gemfire.bridge.disableShufflingOfEndpoints", "false"); |
| } |
| |
| /** |
| * Resets the 'disableShufflingOfEndpoints' flag |
| * |
| */ |
| public static void resetDisableShufflingOfEndpointsFlag() |
| { |
| System.setProperty("gemfire.bridge.disableShufflingOfEndpoints", "false"); |
| } |
| |
| public static class EventWrapper { |
| public final EntryEvent event; |
| public final Object key; |
| public final Object val; |
| public final Object arg; |
| public final int type; |
| public EventWrapper(EntryEvent ee, int type) { |
| this.event = ee; |
| this.key = ee.getKey(); |
| this.val = ee.getNewValue(); |
| this.arg = ee.getCallbackArgument(); |
| this.type = type; |
| } |
| public String toString() { |
| return "EventWrapper: event=" + event + ", type=" + type; |
| } |
| } |
| |
| public static class ControlListener extends CacheListenerAdapter implements Declarable { |
| public final LinkedList events = new LinkedList(); |
| public final Object CONTROL_LOCK = new Object(); |
| |
| //added to test creation of cache from xml |
| @Override |
| public void init(Properties props) { |
| } |
| |
| public boolean waitWhileNotEnoughEvents(long sleepMs, int eventCount) { |
| long maxMillis = System.currentTimeMillis() + sleepMs; |
| synchronized(this.CONTROL_LOCK) { |
| try { |
| while (this.events.size() < eventCount) { |
| long waitMillis = maxMillis - System.currentTimeMillis(); |
| if (waitMillis < 10) { |
| break; |
| } |
| this.CONTROL_LOCK.wait(waitMillis); |
| } // while |
| } catch (InterruptedException abort) { |
| fail("interrupted"); |
| } |
| return !this.events.isEmpty(); |
| } // synchronized |
| } |
| |
| public void afterCreate(EntryEvent e) { |
| synchronized(this.CONTROL_LOCK) { |
| this.events.add(new EventWrapper(e, TYPE_CREATE)); |
| this.CONTROL_LOCK.notifyAll(); |
| } |
| } |
| |
| public void afterUpdate(EntryEvent e) { |
| synchronized(this.CONTROL_LOCK) { |
| this.events.add(new EventWrapper(e, TYPE_UPDATE)); |
| this.CONTROL_LOCK.notifyAll(); |
| } |
| } |
| |
| public void afterInvalidate(EntryEvent e) { |
| synchronized(this.CONTROL_LOCK) { |
| this.events.add(new EventWrapper(e, TYPE_INVALIDATE)); |
| this.CONTROL_LOCK.notifyAll(); |
| } |
| } |
| |
| public void afterDestroy(EntryEvent e) { |
| synchronized(this.CONTROL_LOCK) { |
| this.events.add(new EventWrapper(e, TYPE_DESTROY)); |
| this.CONTROL_LOCK.notifyAll(); |
| } |
| } |
| } |
| |
| public static class ControlCqListener extends CqListenerAdapter { |
| public final LinkedList events = new LinkedList(); |
| public final Object CONTROL_LOCK = new Object(); |
| |
| public boolean waitWhileNotEnoughEvents(long sleepMs, int eventCount) { |
| long maxMillis = System.currentTimeMillis() + sleepMs; |
| synchronized(this.CONTROL_LOCK) { |
| try { |
| while (this.events.size() < eventCount) { |
| long waitMillis = maxMillis - System.currentTimeMillis(); |
| if (waitMillis < 10) { |
| break; |
| } |
| this.CONTROL_LOCK.wait(waitMillis); |
| } // while |
| } catch (InterruptedException abort) { |
| fail("interrupted"); |
| } |
| return !this.events.isEmpty(); |
| } // synchronized |
| } |
| |
| @Override |
| public void onEvent(CqEvent aCqEvent) { |
| synchronized(this.CONTROL_LOCK) { |
| this.events.add(aCqEvent); |
| this.CONTROL_LOCK.notifyAll(); |
| } |
| } |
| } |
| } |
