You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2015/10/15 23:35:49 UTC
[26/38] incubator-geode git commit: GEODE-243: remove deprecated
Bridge feature
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterDataSerializersOp.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterDataSerializersOp.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterDataSerializersOp.java
index c3ab84b..d06107d 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterDataSerializersOp.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterDataSerializersOp.java
@@ -12,8 +12,8 @@ import java.io.IOException;
import com.gemstone.gemfire.DataSerializer;
import com.gemstone.gemfire.SerializationException;
import com.gemstone.gemfire.internal.InternalDataSerializer.SerializerAttributesHolder;
-import com.gemstone.gemfire.internal.cache.BridgeObserver;
-import com.gemstone.gemfire.internal.cache.BridgeObserverHolder;
+import com.gemstone.gemfire.internal.cache.ClientServerObserver;
+import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder;
import com.gemstone.gemfire.internal.cache.EventID;
import com.gemstone.gemfire.internal.cache.tier.MessageType;
import com.gemstone.gemfire.internal.cache.tier.sockets.Message;
@@ -61,7 +61,7 @@ public class RegisterDataSerializersOp {
getMessage().addBytesPart(eventId.calcBytes());
// // CALLBACK FOR TESTING PURPOSE ONLY ////
if (PoolImpl.IS_INSTANTIATOR_CALLBACK) {
- BridgeObserver bo = BridgeObserverHolder.getInstance();
+ ClientServerObserver bo = ClientServerObserverHolder.getInstance();
bo.beforeSendingToServer(eventId);
}
}
@@ -85,7 +85,7 @@ public class RegisterDataSerializersOp {
getMessage().addBytesPart(eventId.calcBytes());
// // CALLBACK FOR TESTING PURPOSE ONLY ////
if (PoolImpl.IS_INSTANTIATOR_CALLBACK) {
- BridgeObserver bo = BridgeObserverHolder.getInstance();
+ ClientServerObserver bo = ClientServerObserverHolder.getInstance();
bo.beforeSendingToServer(eventId);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterInstantiatorsOp.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterInstantiatorsOp.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterInstantiatorsOp.java
index f3c9f03..8e7515d 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterInstantiatorsOp.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/RegisterInstantiatorsOp.java
@@ -12,8 +12,8 @@ import java.io.IOException;
import com.gemstone.gemfire.Instantiator;
import com.gemstone.gemfire.SerializationException;
import com.gemstone.gemfire.internal.InternalInstantiator.InstantiatorAttributesHolder;
-import com.gemstone.gemfire.internal.cache.BridgeObserver;
-import com.gemstone.gemfire.internal.cache.BridgeObserverHolder;
+import com.gemstone.gemfire.internal.cache.ClientServerObserver;
+import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder;
import com.gemstone.gemfire.internal.cache.EventID;
import com.gemstone.gemfire.internal.cache.tier.MessageType;
import com.gemstone.gemfire.internal.cache.tier.sockets.Message;
@@ -87,7 +87,7 @@ public class RegisterInstantiatorsOp {
getMessage().addBytesPart(eventId.calcBytes());
// // // CALLBACK FOR TESTING PURPOSE ONLY ////
if (PoolImpl.IS_INSTANTIATOR_CALLBACK) {
- BridgeObserver bo = BridgeObserverHolder.getInstance();
+ ClientServerObserver bo = ClientServerObserverHolder.getInstance();
bo.beforeSendingToServer(eventId);
}
}
@@ -128,7 +128,7 @@ public class RegisterInstantiatorsOp {
getMessage().addBytesPart(eventId.calcBytes());
// // // CALLBACK FOR TESTING PURPOSE ONLY ////
if (PoolImpl.IS_INSTANTIATOR_CALLBACK) {
- BridgeObserver bo = BridgeObserverHolder.getInstance();
+ ClientServerObserver bo = ClientServerObserverHolder.getInstance();
bo.beforeSendingToServer(eventId);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ServerRegionProxy.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ServerRegionProxy.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ServerRegionProxy.java
index 7670ef9..b10a38b 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ServerRegionProxy.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ServerRegionProxy.java
@@ -27,13 +27,10 @@ import com.gemstone.gemfire.cache.client.PoolManager;
import com.gemstone.gemfire.cache.client.internal.ContainsKeyOp.MODE;
import com.gemstone.gemfire.cache.execute.Function;
import com.gemstone.gemfire.cache.execute.ResultCollector;
-import com.gemstone.gemfire.cache.util.BridgeClient;
-import com.gemstone.gemfire.cache.util.BridgeLoader;
-import com.gemstone.gemfire.cache.util.BridgeWriter;
import com.gemstone.gemfire.distributed.internal.ServerLocation;
import com.gemstone.gemfire.internal.cache.AbstractRegion;
-import com.gemstone.gemfire.internal.cache.BridgeObserver;
-import com.gemstone.gemfire.internal.cache.BridgeObserverHolder;
+import com.gemstone.gemfire.internal.cache.ClientServerObserver;
+import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder;
import com.gemstone.gemfire.internal.cache.EntryEventImpl;
import com.gemstone.gemfire.internal.cache.EventID;
import com.gemstone.gemfire.internal.cache.LocalRegion;
@@ -87,37 +84,8 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc
private static InternalPool calcPool(Region r) {
String poolName = r.getAttributes().getPoolName();
if (poolName == null || "".equals(poolName)) {
- final CacheLoader cl = r.getAttributes().getCacheLoader();
- final CacheWriter cw = r.getAttributes().getCacheWriter();
- if (AbstractRegion.isBridgeLoader(cl) || AbstractRegion.isBridgeWriter(cw)) {
- Object loaderPool = null;
- Object writerPool = null;
- if (AbstractRegion.isBridgeLoader(cl)) {
- if (cl instanceof BridgeLoader) {
- loaderPool = ((BridgeLoader)cl).getConnectionProxy();
- } else {
- loaderPool = ((BridgeClient)cl).getConnectionProxy();
- }
- }
- if (AbstractRegion.isBridgeWriter(cw)) {
- writerPool = ((BridgeWriter)cw).getConnectionProxy();
- }
- if (loaderPool != writerPool && loaderPool != null && writerPool != null) {
- throw new IllegalStateException("The region " + r.getFullPath()
- + " has a BridgeLoader and a BridgeWriter/BridgeClient "
- + " that are configured with different connection pools. "
- + " This is not allowed. Instead create a single BridgeClient and install it as both the loader and the writer."
- + " loaderPool="+loaderPool + " writerPool=" + writerPool);
- }
- InternalPool result = (InternalPool)loaderPool;
- if (result == null) {
- result = (InternalPool)writerPool;
- }
- return result;
- } else {
- throw new IllegalStateException("The region " + r.getFullPath()
- + " did not have a client pool configured.");
- }
+ throw new IllegalStateException("The region " + r.getFullPath()
+ + " did not have a client pool configured.");
} else {
InternalPool pool = (InternalPool)PoolManager.find(poolName);
if (pool == null) {
@@ -400,7 +368,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc
interestType, policy, isDurable, receiveUpdatesAsInvalidates, regionDataPolicy);
//////// TEST PURPOSE ONLY ///////////
if (PoolImpl.AFTER_REGISTER_CALLBACK_FLAG) {
- BridgeObserver bo = BridgeObserverHolder.getInstance();
+ ClientServerObserver bo = ClientServerObserverHolder.getInstance();
bo.afterInterestRegistration();
}
/////////////////////////////////////////
@@ -594,7 +562,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc
finished = true;
//////// TEST PURPOSE ONLY ///////////
if (PoolImpl.AFTER_REGISTER_CALLBACK_FLAG) {
- BridgeObserver bo = BridgeObserverHolder.getInstance();
+ ClientServerObserver bo = ClientServerObserverHolder.getInstance();
bo.afterInterestRegistration();
}
/////////////////////////////////////////
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/execute/internal/FunctionServiceManager.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/execute/internal/FunctionServiceManager.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/execute/internal/FunctionServiceManager.java
index afb8b05..af73acc 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/execute/internal/FunctionServiceManager.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/execute/internal/FunctionServiceManager.java
@@ -422,8 +422,7 @@ public final class FunctionServiceManager {
*/
private final boolean isClientRegion(Region region) {
LocalRegion localRegion = (LocalRegion) region;
- return (localRegion.hasServerProxy() || AbstractRegion.isBridgeLoader(localRegion.getCacheLoader()) || AbstractRegion
- .isBridgeWriter(localRegion.getCacheWriter()));
+ return localRegion.hasServerProxy();
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerLoadProbe.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerLoadProbe.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerLoadProbe.java
index de67c9b..f6e802f 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerLoadProbe.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerLoadProbe.java
@@ -11,8 +11,8 @@ import com.gemstone.gemfire.cache.CacheCallback;
/**
- * A load probe is installed in a bridge server to measure the load on the
- * bridge server for balancing load between multiple bridge servers.
+ * A load probe is installed in a cache server to measure the load on the
+ * cache server for balancing load between multiple cache servers.
*
* <p>
* The getLoad method will be called once per poll interval see
@@ -37,7 +37,7 @@ import com.gemstone.gemfire.cache.CacheCallback;
* Because cache servers can be stopped, reconfigured, and restarted, the open
* and close methods on this callback can be called several times. If the same
* callback object is installed on multiple cache servers, open and close will
- * be called once for each bridge server.
+ * be called once for each cache server.
* </p>
*
* @author dsmith
@@ -53,13 +53,13 @@ public interface ServerLoadProbe extends CacheCallback {
*/
ServerLoad getLoad(ServerMetrics metrics);
- /** Signals that a bridge server
+ /** Signals that a cache server
* using this load probe has been started.
*/
void open();
/**
- * Signals that a bridge server
+ * Signals that a cache server
* using this load probe has been closed.
*/
void close();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerMetrics.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerMetrics.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerMetrics.java
index eb977aa..d4559c8 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerMetrics.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/ServerMetrics.java
@@ -9,7 +9,7 @@ package com.gemstone.gemfire.cache.server;
/**
- * Metrics about the resource usage for a bridge server.
+ * Metrics about the resource usage for a cache server.
* These metrics are provided to the {@link ServerLoadProbe} for
* use in calculating the load on the server.
* @author dsmith
@@ -19,23 +19,23 @@ package com.gemstone.gemfire.cache.server;
public interface ServerMetrics {
/**
* Get the number of open connections
- * for this bridge server.
+ * for this cache server.
*/
int getConnectionCount();
/** Get the number of clients connected to this
- * bridge server.
+ * cache server.
*/
int getClientCount();
/**
* Get the number of client subscription connections hosted on this
- * bridge server.
+ * cache server.
*/
int getSubscriptionConnectionCount();
/**
- * Get the max connections for this bridge server.
+ * Get the max connections for this cache server.
*/
int getMaxConnections();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/internal/LoadMonitor.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/internal/LoadMonitor.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/internal/LoadMonitor.java
index 6210f60..129ba2c 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/internal/LoadMonitor.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/server/internal/LoadMonitor.java
@@ -14,12 +14,12 @@ import org.apache.logging.log4j.Logger;
import com.gemstone.gemfire.CancelException;
import com.gemstone.gemfire.SystemFailure;
-import com.gemstone.gemfire.cache.client.internal.BridgeServerLoadMessage;
+import com.gemstone.gemfire.cache.client.internal.CacheServerLoadMessage;
import com.gemstone.gemfire.cache.server.ServerLoad;
import com.gemstone.gemfire.cache.server.ServerLoadProbe;
import com.gemstone.gemfire.distributed.internal.ServerLocation;
import com.gemstone.gemfire.distributed.internal.membership.MembershipManager;
-import com.gemstone.gemfire.internal.cache.BridgeServerAdvisor;
+import com.gemstone.gemfire.internal.cache.CacheServerAdvisor;
import com.gemstone.gemfire.internal.cache.tier.Acceptor;
import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerStats;
import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID;
@@ -41,14 +41,14 @@ public class LoadMonitor implements ConnectionListener {
private final ServerLoadProbe probe;
private final ServerMetricsImpl metrics;
- protected final BridgeServerAdvisor advisor;
+ protected final CacheServerAdvisor advisor;
protected ServerLocation location;
private final PollingThread pollingThread;
protected volatile ServerLoad lastLoad;
protected CacheServerStats stats;
public LoadMonitor(ServerLoadProbe probe, int maxConnections,
- long pollInterval, int forceUpdateFrequency, BridgeServerAdvisor advisor) {
+ long pollInterval, int forceUpdateFrequency, CacheServerAdvisor advisor) {
this.probe = probe;
this.metrics = new ServerMetricsImpl(maxConnections);
this.pollingThread = new PollingThread(pollInterval, forceUpdateFrequency);
@@ -195,8 +195,8 @@ public class LoadMonitor implements ConnectionListener {
stats.setLoad(load);
if (locators != null) {
- BridgeServerLoadMessage message =
- new BridgeServerLoadMessage(load, location, myClientIds);
+ CacheServerLoadMessage message =
+ new CacheServerLoadMessage(load, location, myClientIds);
message.setRecipients(locators);
MembershipManager mgr = advisor.getDistributionManager().getMembershipManager();
if (mgr == null || !mgr.isBeingSick()) { // test hook
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeClient.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeClient.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeClient.java
deleted file mode 100644
index 184e8bc..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeClient.java
+++ /dev/null
@@ -1,156 +0,0 @@
-/*=========================================================================
- * 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.cache.util;
-
-import java.util.Properties;
-
-import com.gemstone.gemfire.SystemFailure;
-import com.gemstone.gemfire.cache.AttributesFactory;
-import com.gemstone.gemfire.cache.CacheLoader;
-import com.gemstone.gemfire.cache.CacheLoaderException;
-import com.gemstone.gemfire.cache.CacheWriter;
-import com.gemstone.gemfire.cache.LoaderHelper;
-import com.gemstone.gemfire.cache.Region;
-
-/**
- * This class combines the BridgeWriter and BridgeLoader functionality into one
- * class, sharing BridgeServer connections, optimizing the number
- * of connections required when using a BridgeWriter and BridgeLoader separately.
- * <p>
- * When a BridgeClient is declared in cache.xml
- * it can be installed as either a cache-loader or as a cache-writer
- * and it will automatically be installed as both the loader and writer
- * for that region.
- * This allows a single instance to be declared in XML and used as both
- * the cache-loader and cache-writer thus reducing the number of connections to the server.
- *
- * <p>
- * For configuration details please see the {@link com.gemstone.gemfire.cache.util.BridgeWriter} and
- * the {@link com.gemstone.gemfire.cache.util.BridgeLoader}.
- *
- * @author Mitch Thomas
- * @since 5.0.1
- * @see com.gemstone.gemfire.cache.util.BridgeLoader
- * @see com.gemstone.gemfire.cache.util.BridgeWriter
- * @see com.gemstone.gemfire.cache.util.BridgeServer
- * @deprecated as of 5.7 use {@link com.gemstone.gemfire.cache.client pools} instead.
- */
-@Deprecated
-public class BridgeClient extends BridgeWriter implements CacheLoader
-{
-
- private final BridgeLoader loader = new BridgeLoader();
-
- public Object load(LoaderHelper helper) throws CacheLoaderException
- {
- return this.loader.load(helper);
- }
-
- /**
- * Ensure that the BridgeLoader class gets loaded.
- *
- * @see SystemFailure#loadEmergencyClasses()
- */
- public static void loadEmergencyClasses() {
- BridgeLoader.loadEmergencyClasses();
- }
-
- @Override
- public void close()
- {
- try {
- this.loader.close();
- } finally {
- super.close();
- }
- }
-
- /**
- * Returns true if this <code>BridgeClient</code> has been closed.
- */
- @Override
- public boolean isClosed() {
- return super.isClosed();
- }
-
- /**
- * Notify the BridgeClient that the given Region will begin delivering events to this BridgeClient.
- * This method effects the behavior of {@link #close()} and allows a single instance of BridgeClient
- * to be safely shared with multiple Regions.
- *
- * This is called internally when the BridgeClient is added to a Region
- * via {@link AttributesFactory#setCacheWriter(CacheWriter)}}
- *
- * @param r
- * the Region which will begin use this BridgeWriter.
- *
- * @see #detach(Region)
- * @see #close()
- */
- @Override
- public void attach(Region r)
- {
- try {
- this.loader.attach(r);
- } finally {
- super.attach(r);
- }
- }
-
- /**
- * Notify the BridgeClient that the given region is no longer relevant.
- * This method is used internally during Region {@link Region#destroyRegion() destruction} and {@link Region#close() closure}.
- * This method effects the behavor of {@link #close()} and allows a single instance of BridgeClient
- * to be safely shared with multiple Regions.
- *
- * @see #attach(Region)
- * @see #close()
- * @param r
- * the Region which will no longer use this BridgeWriter
- */
- @Override
- public void detach(Region r)
- {
- try {
- this.loader.detach(r);
- } finally {
- super.detach(r);
- }
- }
-
- @Override
- public void init(BridgeWriter bridgeWriter)
- {
- super.init(bridgeWriter);
- this.loader.init(this);
- }
-
- @Override
- public void init(Properties p)
- {
- super.init(p);
- this.loader.init(this);
- }
-
- /**
- * Return the internally maintained BridgeLoader
- * @return the internal BridgeLoader
- */
- public BridgeLoader getBridgeLoader() {
- return this.loader;
- }
-
- /**
- * Returns a string description of the BridgeClient
- */
- @Override
- public String toString()
- {
- return "BridgeClient#" + System.identityHashCode(this) + " connected to " + this.proxy;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeLoader.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeLoader.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeLoader.java
deleted file mode 100644
index 58c5862..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeLoader.java
+++ /dev/null
@@ -1,607 +0,0 @@
-/*=========================================================================
- * 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.cache.util;
-
-import java.util.Properties;
-import java.util.concurrent.atomic.AtomicInteger;
-
-import com.gemstone.gemfire.SystemFailure;
-import com.gemstone.gemfire.cache.AttributesFactory;
-import com.gemstone.gemfire.cache.AttributesMutator;
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheLoader;
-import com.gemstone.gemfire.cache.CacheLoaderException;
-import com.gemstone.gemfire.cache.Declarable;
-import com.gemstone.gemfire.cache.LoaderHelper;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.client.internal.BridgePoolImpl;
-import com.gemstone.gemfire.cache.client.internal.ServerProxy;
-import com.gemstone.gemfire.cache.query.SelectResults;
-import com.gemstone.gemfire.internal.cache.tier.ConnectionProxy;
-import com.gemstone.gemfire.internal.i18n.LocalizedStrings;
-
-/**
- * A <code>CacheLoader</code> that loads data from one or more remote
- * <code>cacheserver</code> processes. This allows for a hierarchical caching
- * scheme in which one cache ('client' cache) delegates a request to another
- * cache ('server' cache) when it cannot find the data locally.
- *
- *
- * When using the <code>BridgeLoader</code>, at least two GemFire Caches must
- * be running in a client/server mode (they should not be part of the same
- * distributed system).
- *
- * The 'server' cache must be running a gemfire <code>cacheserver</code>
- * process, while the 'client' cache must have a <code>BridgeLoader</code>
- * installed in one or more of its <code>Regions</code>. If a
- * <code>BridgeLoader</code> is defined in a client <code>Region</code>,
- * there must also be a <code>Region</code> defined in the 'server' cache with
- * the same exact name.
- *
- * <p>
- *
- * The <code>BridgeLoader</code> performs <code>get()</code> operations on
- * the remote server cache, and does not provide the distribution behavior that
- * can be enabled by using a <code>DISTRIBUTED</code> or
- * <code>DISTRIBUTED_NO_ACK</code> <code>Region</code>. This mechanism is
- * designed as a more targeted alternative to netSearch, in which the 'client'
- * cache completely delegates the loading of the data to the 'server' cache if
- * it is not yet cached in the client. This directed behavior enables a remote
- * network <code>get()</code> operation to be performed much more efficiently
- * in a scenario where there is a hierarchical cache topology. Updates and
- * invalidation remain local, in fact the <code>Regions</code> that are used
- * for this loosely coupled cache may even be <code>LOCAL</code> in scope.
- *
- * The <code>BridgeLoader</code> may be used to configure caches with
- * multi-layer hierarchies.
- *
- *
- * <p>
- * <b>Load Balancing: </b>
- * <p>
- * The <code>BridgeLoader</code> supports these load balancing mechanisms
- * (specified by the <code>LBPolicy</code> config attribute):
- * <p>
- * <ul>
- * <li><b>Sticky </b> <br>
- * In this mode, the client loader picks the first server from the list of
- * servers and establishes a connection to it. Once this connection has been
- * established, every request from that particular 'client' cache is sent on
- * that connection. If requests time out or produce exceptions, the
- * <code>BridgeLoader</code> picks another server and then sends further
- * requests to that server. This achieves a level of load balancing by
- * redirecting requests away from servers that produce timeouts.</li>
- *
- * <li><b>RandomSticky </b> <br>
- * The behavior is the same as Sticky, however the initial assignment of the
- * connection is randomly selected from the list of servers.</li>
- *
- * <li><b>RoundRobin </b> <br>
- * In this mode, the client establishes connections to all the servers in the
- * server list and then randomly picks a server for each given request. For the
- * next request, it picks the next server in the list.</li>
- *
- * <li><b>Random </b>: <br>
- * In this mode, the edge establishes connections to all the servers in the
- * server list and then randomly picks a server for every request.</li>
- *
- *
- * </ul>
- *
- * <p>
- * <b>Failover: </b>
- * <p>
- *
- * If a remote server cache throws an exception or times out, the client will
- * retry based on the configured <code>retryCount</code> parameter. If the
- * <code>retryCount</code> is exceeded, the server in question will be added
- * to a failed server list, and the client will select another server to connect
- * to. The servers in the failed server list will be periodically pinged with an
- * intelligent ping that ensures cache health. If a server is determined to be
- * healthy again, it will be promoted back to the healthy server list. The time
- * period between failed server pings is configurable via the
- * <code>retryInterval</code> parameter.
- *
- * <p>
- * <b>Configuration: </b>
- * <p>
- * The <code>BridgeLoader</code> is configurable declaratively or
- * programmatically. Declarative configuration is achieved through defining the
- * configuration parameters in a <code>cache.xml</code> file. Programmatic
- * configuration may be achieved by first instantiating a
- * <code>BridgeLoader</code> object and subsequently calling
- * {@link #init(Properties)}with a <code>Properties</code> object containing
- * each desired parameter and value.
- * <p>
- * <b>The supported parameters are: </b>
- * <p>
- * <ul>
- * <li><b>endpoints </b> (required) <br>
- * A comma delimited list of logical names, hostnames, and ports of 'server'
- * caches to connect to <br>
- * The endpoints parameter follows this syntax:
- * logicalName=host:port,logicalName2=host2:port2,.... <br>
- * Example:
- *
- * <pre>
- *<code>
- * <parameter name="endpoints">
- * <string>MyPrimaryServer=hostsrv:40404,MySecondary=hostsrv2:40404</string>
- * </parameter>
- * </code>
- *</pre>
- *
- * </li>
- * <li><b>readTimeout </b> (optional: default 10000) <br>
- * A millisecond value representing the amount of time to wait for a response
- * from a cache server. <br>
- * Example:
- *
- * <pre>
- *<code>
- * <parameter name="readTimeout">
- * <string>5000</string>
- * </parameter>
- * </code>
- *</pre>
- * </li>
- *
- * <li><b>retryAttempts </b> (optional: default 5)<br>
- * The number of times to retry a request after timeout/exception. <br>
- * Example:
- *
- * <pre>
- *<code>
- * <parameter name="retryAttempts">
- * <string>5</string>
- * </parameter>
- * </code>
- *</pre>
- *
- * </li>
- * <li><b>retryInterval </b> (optional: default 10000) <br>
- * A millisecond value representing the amount of time to wait between attempts
- * by the <code>ServerMonitor</code> to ping living servers to verify that
- * they are still alive and dead servers to verify that they are still dead.
- * <br>
- * Example:</li>
- *
- * <pre>
- *<code>
- * <parameter name="retryInterval">
- * <string>10000</string>
- * </parameter>
- * </code>
- *</pre>
- *
- * <li><b>LBPolicy </b> (optional: default "Sticky") <br>
- * A String value representing the load balancing policy to use. See above for
- * more details. <br>
- * Options are:
- * <ul>
- * <li>"Sticky"</li>
- * <li>"RandomSticky"</li>
- * <li>"RoundRobin"</li>
- * <li>"Random"</li>
- * </ul>
- * Example:
- *
- * <pre>
- *<code>
- * <parameter name="LBPolicy">
- * <string>Sticky</string>
- * </parameter>
- * </code>
- *</pre>
- *
- * </li>
- * <li><b>connectionsPerServer </b> (optional: default 1)<br>
- * The number of initial connections created to each time it is
- * determined to be alive.
- * The minimum of <code>0</code> causes no initial connections to be created (they are only created on demand).
- * <br>
- * Example:
- *
- * <pre>
- *<code>
- * <parameter name="connectionsPerServer">
- * <string>10</string>
- * </parameter>
- * </code>
- *</pre>
- *
- * </li>
- * <li><b>socketBufferSize </b> (optional: default 32768) <br>
- * The size of the socket buffers in bytes. <br>
- * Example:
- *
- * <pre>
- *<code>
- * <parameter name="socketBufferSize">
- * <string>32768</string>
- * </parameter>
- * </code>
- *</pre>
- *
- * </li>
- * </ul>
- *
- * <p>
- *
- * If you are using a <code>cache.xml</code> file to create a
- * <code>Region</code> declaratively, you can include the following
- * <cache-loader> definition to associate a <code>BridgeLoader</code>
- * with a <code>Region</code> (default values shown for optional parameters):
- *
- * <pre>
- *
- * <cache-loader>
- * <class-name>com.gemstone.gemfire.cache.util.BridgeLoader</class-name>
- * <parameter name="endpoints">
- * <string>MyHost=ninja.gemstone.com:40404</string>
- * </parameter>
- * <parameter name="readTimeout">
- * <string>10000</string>
- * </parameter>
- * <parameter name="retryAttempts">
- * <string>5</string>
- * </parameter>
- * <parameter name="retryInterval">
- * <string>10000</string>
- * </parameter>
- * <parameter name="LBPolicy">
- * <string>Sticky</string>
- * </parameter>
- * <parameter name="socketBufferSize">
- * <string>32768</string>
- * </parameter>
- * </parameter>
- * </cache-loader>
- * </pre>
- *
- * @since 2.0.2
- * @author Greg Passmore
- * @deprecated as of 5.7 use {@link com.gemstone.gemfire.cache.client pools} instead.
- */
-
-@Deprecated
-public class BridgeLoader implements CacheLoader, Declarable
-{
- ConnectionProxy proxy = null; // package access for
- // tests/com/gemstone/gemfire/cache/util/BridgeHelper
-
- private Properties properties;
-
- public BridgeLoader() { }
-
- /**
- * Creates a loader from an existing <code>BridgeWriter</code>. This
- * method reuses the existing <code>BridgeWriter</code>'s proxy.
- *
- * @param bw
- * The existing <code>BridgeWriter</code>
- *
- * @since 5.7
- */
- public BridgeLoader(BridgeWriter bw) {
- init(bw);
- }
-
- private volatile boolean isClosed = false;
-
- private final AtomicInteger refCount = new AtomicInteger();
-
- /**
- * Initializes the loader with supplied config parameters. If instantiating
- * the loader programmatically, this method must be called with a
- * <code>Properties</code> object that at a minimum contains the 'endpoints'
- * parameter before the loader can be used. If a LicenseException is thrown
- * during initialization the BridgeLoader will trhow IllegalStateExceptions
- * until properly initialized.
- *
- * @param p
- * configuration data such as 'endpoint' definitions
- * @throws IllegalStateException if the loader is already initialized
- */
- public void init(Properties p)
- {
- if (this.proxy != null) throw new IllegalStateException(LocalizedStrings.BridgeLoader_ALREADY_INITIALIZED.toLocalizedString());
- this.properties = p;
- if (Boolean.getBoolean("skipConnection")) {
- // used by hydra when generating XML via RegionAttributesCreation
- return;
- }
- this.proxy = BridgePoolImpl.create(properties, false/*useByBridgeWriter*/);
- }
-
- /**
- * Initializes this loader from an existing <code>BridgeLoader</code>.
- * This method reuses the existing <code>BridgeLoader</code>'s connections
- * to the server.
- *
- * @param bridgeLoader The existing <code>BridgeLoader</code>
- * @throws IllegalStateException if the loader is already initialized
- *
- * @since 4.2
- */
- public void init(BridgeLoader bridgeLoader)
- {
- if (this.proxy != null) throw new IllegalStateException(LocalizedStrings.BridgeLoader_ALREADY_INITIALIZED.toLocalizedString());
- ConnectionProxy p = bridgeLoader.proxy;
- p.reuse();
- this.proxy = p;
- }
-
- /**
- * Initializes this loader from an existing <code>BridgeWriter</code>. This
- * method reuses the existing <code>BridgeWriter</code>'s proxy.
- *
- * @param bridgeWriter
- * The existing <code>BridgeWriter</code>
- * @throws IllegalStateException if the loader is already initialized
- *
- * @since 5.7
- */
- public void init(BridgeWriter bridgeWriter)
- {
- if (this.proxy != null) throw new IllegalStateException("Already initialized");
- ConnectionProxy p = bridgeWriter.proxy;
- p.reuse();
- this.proxy = p;
- }
-
- /**
- * Ensure that the ConnectionProxyImpl class gets loaded.
- *
- * @see SystemFailure#loadEmergencyClasses()
- */
- public static void loadEmergencyClasses() {
- BridgePoolImpl.loadEmergencyClasses();
- }
-
- /**
- * Called when the region containing this <code>BridgeLoader</code> is
- * destroyed, when the {@link Cache}is closed, or when a callback is removed
- * from a region using an {@link AttributesMutator}
- *
- * Closes connections to {@link BridgeServer}s when all {@link Region}s are
- * finished using this BridgeLoader,
- *
- * @see #detach(Region)
- * @see #attach(Region)
- */
- public void close() {
- if (this.refCount.get() <= 0) {
- this.isClosed = true;
- proxy.close();
- }
- }
-
- /**
- * Returns true if this <code>BridgeLoader</code> has been closed.
- */
- public boolean isClosed() {
- return this.isClosed;
- }
-
- /**
- * For speed optimizations, a connection to a server may be assigned to the
- * calling thread when load is called. When the application thread is done
- * doing its work it should invoke the BridgeLoader close method. This frees
- * up the connection assigned to the application thread.
- */
- public void release()
- {
- proxy.release();
- }
-
- /**
- * This method should be invoked when the BridgeLoader mechanism is to be shut
- * down explicitly , outside of closing the cache.
- */
- public void terminate()
- {
- this.isClosed = true;
- proxy.terminate();
- }
-
- // removed checkForTransaction
-
- /**
- * This method is invoked implicitly when an object requested on the client
- * cache cannot be found. The server cache will attempt to be contacted, and
- * if no server cache is available (or healthy) a CacheLoaderException will
- * be thrown.
- *
- */
- public Object load(LoaderHelper helper) throws CacheLoaderException
- {
- throw new IllegalStateException("this method should not be called");
- }
-
- private void checkClosed() {
- String reason = this.proxy.getCancelCriterion().cancelInProgress();
- if(reason != null) {
- throw new BridgeWriterException("The BridgeWriter has been closed: " + reason);
- }
-
- if (this.isClosed) {
- throw new CacheLoaderException(LocalizedStrings.BridgeLoader_THE_BRIDGELOADER_HAS_BEEN_CLOSED.toLocalizedString());
- }
- if (this.proxy != null && !this.proxy.isOpen()) {
- throw new CacheLoaderException(LocalizedStrings.BridgeLoader_THE_BRIDGELOADER_HAS_BEEN_CLOSED.toLocalizedString());
- }
- }
-
- /**
- * Invoke a query on the cache server.
- * @deprecated use {@link Region#query} instead
- */
- @Deprecated
- public SelectResults query(String queryStr) throws CacheLoaderException {
- ServerProxy sp = new ServerProxy((BridgePoolImpl)this.proxy);
- return sp.query(queryStr, null);
- }
-
- /**
- * Returns the retry interval in use. Retry interval refers to the interval at
- * which dead servers are attempted to be reconnected. Internal use only.
- */
- public int getRetryInterval()
- {
- return proxy.getRetryInterval();
- }
-
- /**
- * Returns the read timeout being used to time out requests to the server
- * Internal use only.
- */
- public int getReadTimeout()
- {
- return proxy.getReadTimeout();
- }
-
- /**
- * Returns the number of times the bridge loader tries to get data on
- * encountering certain types of exceptions. Internal use only
- */
- public int getRetryAttempts()
- {
- return this.proxy.getRetryAttempts();
- }
-
- /**
- * Returns the load balancing policy being used by the bridge loader Internal
- * use only
- */
- public String getLBPolicy()
- {
- return proxy.getLBPolicy();
- }
-
- /**
- * Returns the properties that defined this <code>BridgeWriter</code>.
- *
- * @return the properties that defined this <code>BridgeWriter</code>
- *
- * @since 4.2
- */
- public Properties getProperties()
- {
- return this.properties;
- }
-
- /**
- * Returns the <code>ConnectionProxy</code> associated with this
- * <code>BridgeLoader</code>.
- *
- * For internal use only.
- *
- * @return the <code>ConnectionProxy</code> associated with this
- * <code>BridgeLoader</code>
- */
- public Object/*ConnectionProxy*/ getConnectionProxy()
- {
- return proxy;
- }
-
- /**
- * Add an <code>Endpoint</code> to the known <code>Endpoint</code>s.
- *
- * @param name The name of the endpoint to add
- * @param host The host name or ip address of the endpoint to add
- * @param port The port of the endpoint to add
- *
- * @throws EndpointExistsException if the <code>Endpoint</code> to be
- * added already exists.
- *
- * @since 5.0.2
- */
- public void addEndpoint(String name, String host, int port)
- throws EndpointExistsException {
- this.proxy.addEndpoint(name, host, port);
- }
-
- /**
- * Remove an <code>Endpoint</code> from the dead <code>Endpoint</code>s.
- * The specified <code>Endpoint</code> must be dead.
- *
- * @param name The name of the endpoint to remove
- * @param host The host name or ip address of the endpoint to remove
- * @param port The port of the endpoint to remove
- *
- * @throws EndpointDoesNotExistException if the <code>Endpoint</code> to be
- * removed doesn't exist.
- *
- * @throws EndpointInUseException if the <code>Endpoint</code> to be removed
- * contains <code>Connection</code>s
- *
- * @since 5.0.2
- */
- public void removeEndpoint(String name, String host, int port)
- throws EndpointDoesNotExistException, EndpointInUseException {
- this.proxy.removeEndpoint(name, host, port);
- }
-
- // removed handleException
-
- // removed getExceptionMessage
-
- /**
- * Returns a brief description of this <code>BridgeLoader</code>
- *
- * @since 4.0
- */
- @Override
- public String toString()
- {
- return LocalizedStrings.BridgeLoader_BRIDGELOADER_CONNECTED_TO_0.toLocalizedString(this.proxy);
- }
-
- /**
- * Notify the BridgeLoader that the given region is no longer relevant. This
- * method is used internally during Region
- * {@link Region#destroyRegion() destruction}and
- * {@link Region#close() closure}. This method effects the behavor of
- * {@link #close()}.
- *
- * @param r
- * the Region which will no longer use this BridgeLoader
- * @see #close()
- * @see #attach(Region)
- * @since 4.3
- */
- public void detach(Region r)
- {
- this.refCount.decrementAndGet();
- }
-
- /**
- * Notify the BridgeLoader that the given Region will begin calling
- * {@link #load(LoaderHelper)}.
- *
- * This method affects the behavior of {@link #close()}.
- *
- * This is called internally when the BridgeLoader is added to a Region via
- * {@link AttributesFactory#setCacheLoader(CacheLoader)}
- *
- * @param r
- * the Region which will begin use this BridgeWriter.
- * @since 4.3
- *
- * @see #detach(Region)
- * @see #close()
- */
- public void attach(Region r)
- {
- checkClosed();
- this.refCount.incrementAndGet();
- }
-
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembership.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembership.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembership.java
deleted file mode 100755
index fdb718d..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembership.java
+++ /dev/null
@@ -1,55 +0,0 @@
-/*=========================================================================
- * Copyright (c) 2002-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
- * more patents listed at http://www.pivotal.io/patents.
- *=========================================================================
- */
-package com.gemstone.gemfire.cache.util;
-
-import com.gemstone.gemfire.internal.cache.tier.InternalBridgeMembership;
-
-/**
- * Provides utility methods for registering and unregistering
- * BridgeMembershipListeners in this process.
- *
- * @author Kirk Lund
- * @since 4.2.1
- * @deprecated see com.gemstone.gemfire.management.membership.ClientMembership
- */
-public final class BridgeMembership {
-
- private BridgeMembership() {}
-
- /**
- * Registers a {@link BridgeMembershipListener} for notification of
- * connection changes for BridgeServers and bridge clients.
- * @param listener a BridgeMembershipListener to be registered
- */
- public static void registerBridgeMembershipListener(BridgeMembershipListener listener) {
- InternalBridgeMembership.registerBridgeMembershipListener(listener);
- }
-
- /**
- * Removes registration of a previously registered {@link
- * BridgeMembershipListener}.
- * @param listener a BridgeMembershipListener to be unregistered
- */
- public static void unregisterBridgeMembershipListener(BridgeMembershipListener listener) {
- InternalBridgeMembership.unregisterBridgeMembershipListener(listener);
- }
-
- /**
- * Returns an array of all the currently registered
- * <code>BridgeMembershipListener</code>s. Modifications to the returned
- * array will not effect the registration of these listeners.
- * @return the registered <code>BridgeMembershipListener</code>s; an empty
- * array if no listeners
- */
- public static BridgeMembershipListener[] getBridgeMembershipListeners() {
- return InternalBridgeMembership.getBridgeMembershipListeners();
- }
-
-
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipEvent.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipEvent.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipEvent.java
deleted file mode 100755
index b9d205e..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipEvent.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/*=========================================================================
- * Copyright (c) 2002-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
- * more patents listed at http://www.pivotal.io/patents.
- *=========================================================================
- */
-package com.gemstone.gemfire.cache.util;
-
-import com.gemstone.gemfire.management.membership.ClientMembershipEvent;
-
-/**
- * An event delivered to a {@link BridgeMembershipListener} when this
- * process detects connection changes to BridgeServers or bridge clients.
- *
- * @author Kirk Lund
- * @since 4.2.1
- * @deprecated see com.gemstone.gemfire.management.membership.ClientMembershipEvent
- */
-public interface BridgeMembershipEvent extends ClientMembershipEvent {
-
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListener.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListener.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListener.java
deleted file mode 100755
index d0e6196..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListener.java
+++ /dev/null
@@ -1,41 +0,0 @@
-/*=========================================================================
- * Copyright (c) 2002-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
- * more patents listed at http://www.pivotal.io/patents.
- *=========================================================================
- */
- package com.gemstone.gemfire.cache.util;
-
-/**
- * A listener whose callback methods are invoked when this process
- * detects connection changes to BridgeServers or bridge clients.
- *
- * @see BridgeMembership#registerBridgeMembershipListener
- *
- * @author Kirk Lund
- * @since 4.2.1
- * @deprecated see com.gemstone.gemfire.management.membership.ClientMembershipListener
- */
-public interface BridgeMembershipListener{
-
- /**
- * Invoked when a client has connected to this process or when this
- * process has connected to a BridgeServer.
- */
- public void memberJoined(BridgeMembershipEvent event);
-
- /**
- * Invoked when a client has gracefully disconnected from this process
- * or when this process has gracefully disconnected from a BridgeServer.
- */
- public void memberLeft(BridgeMembershipEvent event);
-
- /**
- * Invoked when a client has unexpectedly disconnected from this process
- * or when this process has unexpectedly disconnected from a BridgeServer.
- */
- public void memberCrashed(BridgeMembershipEvent event);
-
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListenerAdapter.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListenerAdapter.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListenerAdapter.java
deleted file mode 100755
index 3ce2721..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeMembershipListenerAdapter.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*=========================================================================
- * Copyright (c) 2002-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
- * more patents listed at http://www.pivotal.io/patents.
- *=========================================================================
- */
-
-package com.gemstone.gemfire.cache.util;
-
-/**
- * Utility class that implements all methods in
- * <code>BridgeMembershipListener</code> with empty implementations.
- * Applications can subclass this class and only override the methods for
- * the events of interest.
- *
- * @author Kirk Lund
- * @since 4.2.1
- * @deprecated see com.gemstone.gemfire.management.membership.ClientMembershipListenerAdapter
- */
-public abstract class BridgeMembershipListenerAdapter
-implements BridgeMembershipListener {
-
- /**
- * Invoked when a client has connected to this process or when this
- * process has connected to a BridgeServer.
- */
- public void memberJoined(BridgeMembershipEvent event) {}
-
- /**
- * Invoked when a client has gracefully disconnected from this process
- * or when this process has gracefully disconnected from a BridgeServer.
- */
- public void memberLeft(BridgeMembershipEvent event) {}
-
- /**
- * Invoked when a client has unexpectedly disconnected from this process
- * or when this process has unexpectedly disconnected from a BridgeServer.
- */
- public void memberCrashed(BridgeMembershipEvent event) {}
-
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/2eb4e175/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeServer.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeServer.java b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeServer.java
deleted file mode 100644
index ad77071..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/util/BridgeServer.java
+++ /dev/null
@@ -1,442 +0,0 @@
-/*=========================================================================
- * 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.cache.util;
-
-import java.io.IOException;
-import java.util.Set;
-
-import com.gemstone.gemfire.cache.ClientSession;
-import com.gemstone.gemfire.distributed.DistributedMember;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.server.CacheServer;
-import com.gemstone.gemfire.cache.server.ClientSubscriptionConfig;
-import com.gemstone.gemfire.cache.server.ServerLoadProbe;
-import com.gemstone.gemfire.cache.server.internal.ConnectionCountProbe;
-
-/**
- * A cache bridge server that serves the contents of a
- * <code>Cache</code> to VMs in another distributed system via a
- * socket. A bridge server is used in conjunction with a
- * client {@link Pool} to connect two regions
- * that reside in different distributed systems.
- *
- * @see com.gemstone.gemfire.cache.Cache#addBridgeServer
- * @see com.gemstone.gemfire.cache.Cache#getBridgeServers
- *
- * @since 2.0.2
- * @deprecated as of 5.7 used {@link CacheServer} instead.
- */
-@Deprecated
-public interface BridgeServer {
-
- /** The default port on which a <Code>BridgeServer</code> is
- * configured to serve. */
- public static final int DEFAULT_PORT = 40404;
-
- /**
- * The default number of sockets accepted by a BridgeServer.
- * When the maximum is reached the server will stop accepting new connections.
- * Current value: 800
- * @since 5.7
- */
- public static final int DEFAULT_MAX_CONNECTIONS = 800;
- // Value derived from common file descriptor limits for Unix sytems (1024)...
-
- /**
- * The default limit to the maximum number of server threads that can be
- * created to service client requests. Once this number of threads exist then
- * connections must share the same thread to service their request. A selector
- * is used to detect client connection requests and dispatch them to the thread
- * pool.
- * The default of <code>0</code> causes a thread to be bound to every connection
- * and to be dedicated to detecting client requests on that connection. A selector
- * is not used in this default mode.
- * Current value: 0
- * @since 5.7
- */
- public static final int DEFAULT_MAX_THREADS = 0;
-
- /** The default notify-by-subscription value which tells the
- * <Code>BridgeServer</code> whether or not to notify clients
- * based on key subscription. */
- public static final boolean DEFAULT_NOTIFY_BY_SUBSCRIPTION = true;
-
- /**
- * The default socket buffer size for socket buffers from the server
- * to the client.
- */
- public static final int DEFAULT_SOCKET_BUFFER_SIZE = 32768;
-
- /**
- * The default maximum amount of time between client pings. This value
- * is used by the <code>ClientHealthMonitor</code> to determine the
- * health of this <code>BridgeServer</code>'s clients.
- */
- public static final int DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS = 60000;
-
- /**
- * The default maximum number of messages that can be enqueued in a
- * client-queue.
- */
- public static final int DEFAULT_MAXIMUM_MESSAGE_COUNT = 230000;
-
- /**
- * The default time (in seconds ) after which a message in the client queue
- * will expire.
- */
- public static final int DEFAULT_MESSAGE_TIME_TO_LIVE = 180;
-
- /**
- * The default list of server groups a server belongs to.
- * The current default is an empty list.
- * @since 5.7
- */
- public static final String[] DEFAULT_GROUPS = new String[0];
-
- /**
- * The default load balancing probe. The default load balancing
- * probe reports the connections counts of this server.
- * @since 5.7
- *
- */
- public static final ServerLoadProbe DEFAULT_LOAD_PROBE = new ConnectionCountProbe();
-
- /**
- * The default frequency at which to poll the load probe for the load
- * on this server. Defaults to 5000 (5 seconds).
- * @since 5.7
- */
- public static final long DEFAULT_LOAD_POLL_INTERVAL = 5000;
-
- /**
- * The default ip address or host name that the server's socket will
- * listen on for client connections.
- * The current default is an empty string.
- * @since 5.7
- */
- public static final String DEFAULT_BIND_ADDRESS = "";
-
- /**
- * The default ip address or host name that will be given to clients
- * as the host this server is listening on.
- * The current default is an empty string.
- * @since 5.7
- */
- public static final String DEFAULT_HOSTNAME_FOR_CLIENTS = "";
-
- /**
- * Returns the port on which this server listens for clients.
- */
- public int getPort();
-
- /**
- * Sets the port on which this server listens for clients.
- *
- * @throws IllegalStateException
- * If this server is running
- */
- public void setPort(int port);
-
- /**
- * Returns a string representing the ip address or host name that this server
- * will listen on.
- * @return the ip address or host name that this server is to listen on
- * @see #DEFAULT_BIND_ADDRESS
- * @since 5.7
- */
- public String getBindAddress();
- /**
- * Sets the ip address or host name that this server is to listen on for
- * client connections.
- * <p>Setting a specific bind address will cause the server to always
- * use this address and ignore any address specified by "server-bind-address"
- * or "bind-address" in the <code>gemfire.properties</code> file
- * (see {@link com.gemstone.gemfire.distributed.DistributedSystem}
- * for a description of these properties).
- * <p> The value <code>""</code> does not override the <code>gemfire.properties</code>.
- * It will cause the local machine's default address to be listened on if the
- * properties file does not specify and address.
- * If you wish to override the properties and want to have your server bind to all local
- * addresses then use this bind address <code>"0.0.0.0"</code>.
- * <p> A <code>null</code> value will be treated the same as the default <code>""</code>.
- * @param address the ip address or host name that this server is to listen on
- * @see #DEFAULT_BIND_ADDRESS
- * @since 5.7
- */
- public void setBindAddress(String address);
- /**
- * Returns a string representing the ip address or host name that server locators
- * will tell clients that this server is listening on.
- * @return the ip address or host name to give to clients so they can connect
- * to this server
- * @see #DEFAULT_HOSTNAME_FOR_CLIENTS
- * @since 5.7
- */
- public String getHostnameForClients();
- /**
- * Sets the ip address or host name that this server is to listen on for
- * client connections.
- * <p>Setting a specific hostname-for-clients will cause server locators
- * to use this value when telling clients how to connect to this server.
- * This is useful in the case where the server may refer to itself with one
- * hostname, but the clients need to use a different hostname to find the
- * server.
- * <p> The value <code>""</code> causes the <code>bind-address</code> to be given to clients.
- * <p> A <code>null</code> value will be treated the same as the default <code>""</code>.
- * @param name the ip address or host name that will be given to clients
- * so they can connect to this server
- * @see #DEFAULT_HOSTNAME_FOR_CLIENTS
- * @since 5.7
- */
- public void setHostnameForClients(String name);
- /**
- * Sets whether or not this server should notify clients based on
- * key subscription.
- *
- * If false, then an update to any key on the server causes an update to
- * be sent to all clients. This update does not push the actual data to the
- * clients. Instead, it causes the client to locally invalidate or destroy
- * the corresponding entry. The next time the client requests the key, it
- * goes to the server for the value.
- *
- * If true, then an update to any key on the server causes an update to be
- * sent to only those clients who have registered interest in that key. Other
- * clients are not notified of the change. In addition, the actual value is
- * pushed to the client. The client does not need to request the new value
- * from the server.
- *
- * @since 4.2
- * @deprecated as of 6.0.1. This method is no more in use, by default
- * notifyBySubscription attribute is set to true.
- */
- @Deprecated
- public void setNotifyBySubscription(boolean b);
-
- /**
- * Answers whether or not this server should notify clients based on
- * key subscription.
- *
- * @since 4.2
- * @deprecated as of 6.0.1. This method is no more in use, by default
- * notifyBySubscription attribute is set to true.
- */
- @Deprecated
- public boolean getNotifyBySubscription();
-
- /**
- * Sets the buffer size in bytes of the socket connection for this
- * <code>BridgeServer</code>. The default is 32768 bytes.
- *
- * @param socketBufferSize The size in bytes of the socket buffer
- *
- * @since 4.2.1
- */
- public void setSocketBufferSize(int socketBufferSize);
-
- /**
- * Returns the configured buffer size of the socket connection for this
- * <code>BridgeServer</code>. The default is 32768 bytes.
- * @return the configured buffer size of the socket connection for this
- * <code>BridgeServer</code>
- *
- * @since 4.2.1
- */
- public int getSocketBufferSize();
-
- /**
- * Sets the maximum amount of time between client pings. This value is
- * used by the <code>ClientHealthMonitor</code> to determine the health
- * of this <code>BridgeServer</code>'s clients. The default is 60000 ms.
- *
- * @param maximumTimeBetweenPings The maximum amount of time between client
- * pings
- *
- * @since 4.2.3
- */
- public void setMaximumTimeBetweenPings(int maximumTimeBetweenPings);
-
- /**
- * Returns the maximum amount of time between client pings. This value is
- * used by the <code>ClientHealthMonitor</code> to determine the health
- * of this <code>BridgeServer</code>'s clients. The default is 60000 ms.
- * @return the maximum amount of time between client pings.
- *
- * @since 4.2.3
- */
- public int getMaximumTimeBetweenPings();
-
- /**
- * Starts this server. Once the server is running, its
- * configuration cannot be changed.
- *
- * @throws IOException
- * If an error occurs while starting the server
- */
- public void start() throws IOException;
-
- /**
- * Returns whether or not this server is running
- */
- public boolean isRunning();
-
- /**
- * Stops this server. Note that the
- * <code>BridgeServer</code> can be reconfigured and restarted if
- * desired.
- */
- public void stop();
-
- /**
- * Returns the maximum allowed client connections
- */
- public int getMaxConnections();
-
- /**
- * Sets the maxium number of client connections allowed.
- * When the maximum is reached the server will stop accepting
- * connections.
- *
- * @see #DEFAULT_MAX_CONNECTIONS
- */
- public void setMaxConnections(int maxCons);
-
- /**
- * Returns the maxium number of threads allowed in this server to service
- * client requests.
- * The default of <code>0</code> causes the server to dedicate a thread for
- * every client connection.
- * @since 5.1
- */
- public int getMaxThreads();
-
- /**
- * Sets the maxium number of threads allowed in this server to service
- * client requests.
- * The default of <code>0</code> causes the server to dedicate a thread for
- * every client connection.
- *
- * @see #DEFAULT_MAX_THREADS
- * @since 5.1
- */
- public void setMaxThreads(int maxThreads);
-
- /**
- * Returns the maximum number of messages that can be enqueued in a
- * client-queue.
- */
- public int getMaximumMessageCount();
-
- /**
- * Sets maximum number of messages that can be enqueued in a client-queue.
- *
- * @see #DEFAULT_MAXIMUM_MESSAGE_COUNT
- */
- public void setMaximumMessageCount(int maxMessageCount);
-
- /**
- * Returns the time (in seconds ) after which a message in the client queue
- * will expire.
- */
- public int getMessageTimeToLive();
-
- /**
- * Sets the time (in seconds ) after which a message in the client queue
- * will expire.Expiry settings are applicable for the secondary queues only
- * This setting has no impact on the primary queue.
- *
- * @see #DEFAULT_MESSAGE_TIME_TO_LIVE
- */
- public void setMessageTimeToLive(int messageTimeToLive);
-
- /**
- * Returns the <code>ClientSession</code> associated with the
- * <code>DistributedMember</code>
- * @return the <code>ClientSession</code> associated with the
- * <code>DistributedMember</code>
- * @since 5.6
- */
- public ClientSession getClientSession(DistributedMember member);
-
- /**
- * Returns the <code>ClientSession</code> associated with the
- * durable client id
- * @return the <code>ClientSession</code> associated with the
- * durable
- * @since 5.6
- */
- public ClientSession getClientSession(String durableClientId);
-
- /**
- * Returns a set of all <code>ClientSession</code>s
- * @return a set of all <code>ClientSession</code>s
- */
- public Set getAllClientSessions();
-
- /**
- * Sets the list of server groups this cache server will belong to.
- * By default cache servers belong to the default global server group
- * which all cache servers always belong to.
- * @param groups possibly empty array of <code>String</code> where each string
- * is a server groups that this cache server will be a member of.
- * @see #DEFAULT_GROUPS
- * @since 5.7
- */
- public void setGroups(String[] groups);
- /**
- * Returns the list of server groups that this cache server belongs to.
- * @return a possibly empty array of <code>String</code>s where
- * each string is a server group. Modifying this array will not change the
- * server groups that this cache server belongs to.
- * @since 5.7
- */
- public String[] getGroups();
-
- /**
- * Get the load probe for this cache server. See
- * {@link ServerLoadProbe} for details on the load probe.
- * @return the load probe used by this cache
- * server.
- * @since 5.7
- */
- public ServerLoadProbe getLoadProbe();
-
- /**
- * Set the load probe for this cache server. See
- * {@link ServerLoadProbe} for details on how to implement
- * a load probe.
- * @param loadProbe the load probe to use for
- * this cache server.
- * @since 5.7
- */
- public void setLoadProbe(ServerLoadProbe loadProbe);
-
- /**
- * Get the frequency in milliseconds to poll the load probe on this cache
- * server.
- *
- * @return the frequency in milliseconds that we will poll the load probe.
- */
- public long getLoadPollInterval();
-
- /**
- * Set the frequency in milliseconds to poll the load probe on this cache
- * server
- * @param loadPollInterval the frequency in milliseconds to poll
- * the load probe. Must be greater than 0.
- */
- public void setLoadPollInterval(long loadPollInterval);
-
- /**
- * Get the ClientSubscriptionConfig for this cache server. See
- * {@link ClientSubscriptionConfig} for details on the client subscription configuration.
- *
- * @return ClientSubscriptionConfig
- * @since 5.7
- */
- public ClientSubscriptionConfig getClientSubscriptionConfig();
-}