http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/ClientNotReadyException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ClientNotReadyException.java b/geode-core/src/main/java/org/apache/geode/cache/client/ClientNotReadyException.java index eebc36f..388ff4a 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ClientNotReadyException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ClientNotReadyException.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.cache.OperationAbortedException; +import org.apache.geode.cache.OperationAbortedException; /** * A <code>ClientNotReadyException</code> indicates a client attempted to invoke - * the {@link com.gemstone.gemfire.cache.Cache#readyForEvents} + * the {@link org.apache.geode.cache.Cache#readyForEvents} * method, but failed. * <p>This exception was moved from the <code>util</code> package in 5.7. *
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionFactory.java b/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionFactory.java index 3141d47..d57ac05 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionFactory.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionFactory.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.cache.AttributesFactory; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheListener; -import com.gemstone.gemfire.cache.CustomExpiry; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.ExpirationAttributes; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.compression.Compressor; +import org.apache.geode.cache.AttributesFactory; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheListener; +import org.apache.geode.cache.CustomExpiry; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.ExpirationAttributes; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.compression.Compressor; /** * A factory for constructing {@link ClientCache client cache} {@link Region http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionShortcut.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionShortcut.java b/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionShortcut.java index cb04d74..415bd1b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionShortcut.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ClientRegionShortcut.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.cache.*; +import org.apache.geode.cache.*; /** * Each enum represents a predefined {@link RegionAttributes} in a {@link ClientCache}. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableLocatorsException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableLocatorsException.java b/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableLocatorsException.java index 0967a8c..7397f17 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableLocatorsException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableLocatorsException.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableServersException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableServersException.java b/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableServersException.java index 0c3f0e5..e5d9e4e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableServersException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/NoAvailableServersException.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/Pool.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/Pool.java b/geode-core/src/main/java/org/apache/geode/cache/client/Pool.java index 14f20ab..9955a06 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/Pool.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/Pool.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; import java.net.InetSocketAddress; import java.util.Properties; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.RegionFactory; -import com.gemstone.gemfire.cache.query.QueryService; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.RegionFactory; +import org.apache.geode.cache.query.QueryService; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/PoolFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/PoolFactory.java b/geode-core/src/main/java/org/apache/geode/cache/client/PoolFactory.java index 4d9588b..aeaa44a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/PoolFactory.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/PoolFactory.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.cache.server.CacheServer; -import com.gemstone.gemfire.cache.*; // for javadocs -import com.gemstone.gemfire.cache.query.*; // for javadocs +import org.apache.geode.cache.server.CacheServer; +import org.apache.geode.cache.*; // for javadocs +import org.apache.geode.cache.query.*; // for javadocs /** @@ -432,7 +432,7 @@ public interface PoolFactory { * By default setPRSingleHopEnabled is <code>true</code> * in which case the client is aware of the location of partitions on servers hosting * {@link Region regions} with - * {@link com.gemstone.gemfire.cache.DataPolicy#PARTITION}. + * {@link org.apache.geode.cache.DataPolicy#PARTITION}. * Using this information, the client routes the client cache operations * directly to the server which is hosting the required partition for the * cache operation using a single network hop. @@ -445,9 +445,9 @@ public interface PoolFactory { * to go to the required partition for that cache operation. * The client will use fewer network connections to the servers. * <p> - * Caution: for {@link com.gemstone.gemfire.cache.DataPolicy#PARTITION partition} regions + * Caution: for {@link org.apache.geode.cache.DataPolicy#PARTITION partition} regions * with - * {@link com.gemstone.gemfire.cache.PartitionAttributesFactory#setLocalMaxMemory(int) local-max-memory} + * {@link org.apache.geode.cache.PartitionAttributesFactory#setLocalMaxMemory(int) local-max-memory} * equal to zero, no cache operations mentioned above will be routed to those * servers as they do not host any partitions. * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/PoolManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/PoolManager.java b/geode-core/src/main/java/org/apache/geode/cache/client/PoolManager.java index de125a2..614f936 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/PoolManager.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/PoolManager.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; import java.util.Map; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.PoolManagerImpl; -import com.gemstone.gemfire.distributed.DistributedSystem; // for javadocs +import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.PoolManagerImpl; +import org.apache.geode.distributed.DistributedSystem; // for javadocs /** * Manages creation and access to {@link Pool connection pools} for clients. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/ServerConnectivityException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ServerConnectivityException.java b/geode-core/src/main/java/org/apache/geode/cache/client/ServerConnectivityException.java index 545bfe0..2abb81e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ServerConnectivityException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ServerConnectivityException.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.GemFireException; +import org.apache.geode.GemFireException; /** * A generic exception indicating that a failure has happened while communicating http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/ServerOperationException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ServerOperationException.java b/geode-core/src/main/java/org/apache/geode/cache/client/ServerOperationException.java index e18a8b2..e48dee8 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ServerOperationException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ServerOperationException.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.InternalDistributedSystem; /** * An exception indicating that a failure has happened on the server http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/ServerRefusedConnectionException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ServerRefusedConnectionException.java b/geode-core/src/main/java/org/apache/geode/cache/client/ServerRefusedConnectionException.java index 363942d..0370d9b 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ServerRefusedConnectionException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ServerRefusedConnectionException.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.cache.OperationAbortedException; -import com.gemstone.gemfire.distributed.DistributedMember; +import org.apache.geode.cache.OperationAbortedException; +import org.apache.geode.distributed.DistributedMember; /** * A <code>ServerRefusedConnectionException</code> indicates a client attempted http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/SubscriptionNotEnabledException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/SubscriptionNotEnabledException.java b/geode-core/src/main/java/org/apache/geode/cache/client/SubscriptionNotEnabledException.java index b099528..f655336 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/SubscriptionNotEnabledException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/SubscriptionNotEnabledException.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client; +package org.apache.geode.cache.client; -import com.gemstone.gemfire.cache.Region; +import org.apache.geode.cache.Region; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/AbstractOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AbstractOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AbstractOp.java index f93620e..1d7d4fc 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AbstractOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AbstractOp.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.io.ByteArrayInputStream; import java.io.DataInputStream; @@ -22,22 +22,22 @@ import java.net.SocketTimeoutException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CacheServerImpl; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException; -import com.gemstone.gemfire.internal.cache.TXManagerImpl; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.CacheServerImpl; +import org.apache.geode.internal.cache.PutAllPartialResultException; +import org.apache.geode.internal.cache.TXManagerImpl; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * Represents an operation that can be performed in a client by sending @@ -370,7 +370,7 @@ public abstract class AbstractOp implements Op { protected boolean timedOut; /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.Op#attempt(com.gemstone.gemfire.cache.client.internal.Connection) + * @see org.apache.geode.cache.client.internal.Op#attempt(org.apache.geode.cache.client.internal.Connection) */ public Object attempt(Connection cnx) throws Exception { this.failed = true; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXEnumOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXEnumOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXEnumOp.java index 59ed8f2..14121cb 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXEnumOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXEnumOp.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.pdx.internal.EnumInfo; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.pdx.internal.EnumInfo; /** * Push a PDX Enum id to other servers. @@ -44,7 +44,7 @@ public class AddPDXEnumOp { private static class AddPdxEnumOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public AddPdxEnumOpImpl(int id, EnumInfo ei) { super(MessageType.ADD_PDX_ENUM, 2); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXTypeOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXTypeOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXTypeOp.java index b7eece8..e6b74a9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXTypeOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AddPDXTypeOp.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.pdx.internal.PdxType; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.pdx.internal.PdxType; /** * Add a PdxType to a server. @@ -44,7 +44,7 @@ public class AddPDXTypeOp { private static class AddPDXTypeOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public AddPDXTypeOpImpl(int id, PdxType type) { super(MessageType.ADD_PDX_TYPE, 2); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/AuthenticateUserOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AuthenticateUserOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AuthenticateUserOp.java index 27f77ff..dc04cd7 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AuthenticateUserOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AuthenticateUserOp.java @@ -17,34 +17,34 @@ /** * */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.HandShake; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.cache.tier.sockets.command.PutUserCredentials; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.security.AuthenticationFailedException; -import com.gemstone.gemfire.security.AuthenticationRequiredException; -import com.gemstone.gemfire.security.NotAuthorizedException; +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.HandShake; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.cache.tier.sockets.command.PutUserCredentials; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.security.AuthenticationFailedException; +import org.apache.geode.security.AuthenticationRequiredException; +import org.apache.geode.security.NotAuthorizedException; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.util.Properties; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; /** * Authenticates this client (or a user) on a server. This op ideally should get http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/AutoConnectionSourceImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AutoConnectionSourceImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AutoConnectionSourceImpl.java index 66c84e4..04de6b5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/AutoConnectionSourceImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/AutoConnectionSourceImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.io.IOException; import java.net.ConnectException; @@ -36,26 +36,26 @@ import java.util.concurrent.atomic.AtomicReference; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.client.NoAvailableLocatorsException; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.cache.client.internal.locator.ClientConnectionRequest; -import com.gemstone.gemfire.cache.client.internal.locator.ClientConnectionResponse; -import com.gemstone.gemfire.cache.client.internal.locator.ClientReplacementRequest; -import com.gemstone.gemfire.cache.client.internal.locator.GetAllServersRequest; -import com.gemstone.gemfire.cache.client.internal.locator.GetAllServersResponse; -import com.gemstone.gemfire.cache.client.internal.locator.LocatorListRequest; -import com.gemstone.gemfire.cache.client.internal.locator.LocatorListResponse; -import com.gemstone.gemfire.cache.client.internal.locator.QueueConnectionRequest; -import com.gemstone.gemfire.cache.client.internal.locator.QueueConnectionResponse; -import com.gemstone.gemfire.cache.client.internal.locator.ServerLocationRequest; -import com.gemstone.gemfire.cache.client.internal.locator.ServerLocationResponse; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.distributed.internal.tcpserver.TcpClient; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.net.*; +import org.apache.geode.cache.client.NoAvailableLocatorsException; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.cache.client.internal.locator.ClientConnectionRequest; +import org.apache.geode.cache.client.internal.locator.ClientConnectionResponse; +import org.apache.geode.cache.client.internal.locator.ClientReplacementRequest; +import org.apache.geode.cache.client.internal.locator.GetAllServersRequest; +import org.apache.geode.cache.client.internal.locator.GetAllServersResponse; +import org.apache.geode.cache.client.internal.locator.LocatorListRequest; +import org.apache.geode.cache.client.internal.locator.LocatorListResponse; +import org.apache.geode.cache.client.internal.locator.QueueConnectionRequest; +import org.apache.geode.cache.client.internal.locator.QueueConnectionResponse; +import org.apache.geode.cache.client.internal.locator.ServerLocationRequest; +import org.apache.geode.cache.client.internal.locator.ServerLocationResponse; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.distributed.internal.tcpserver.TcpClient; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.net.*; /** * A connection source which uses locators to find http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/CacheServerLoadMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/CacheServerLoadMessage.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/CacheServerLoadMessage.java index 31550b4..ae6cd2b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/CacheServerLoadMessage.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/CacheServerLoadMessage.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.io.DataInput; import java.io.DataOutput; @@ -22,15 +22,15 @@ import java.io.IOException; import java.util.ArrayList; import java.util.List; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.server.ServerLoad; -import com.gemstone.gemfire.distributed.Locator; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalLocator; -import com.gemstone.gemfire.distributed.internal.SerialDistributionMessage; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.distributed.internal.ServerLocator; -import com.gemstone.gemfire.internal.InternalDataSerializer; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.server.ServerLoad; +import org.apache.geode.distributed.Locator; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalLocator; +import org.apache.geode.distributed.internal.SerialDistributionMessage; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.distributed.internal.ServerLocator; +import org.apache.geode.internal.InternalDataSerializer; /** * A message from a server to a locator to update the locator http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java index c576f85..7d8944f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.EventID; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.EventID; /** * Does a region clear (or create) on a server @@ -68,7 +68,7 @@ public class ClearOp { private static class ClearOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public ClearOpImpl(String region, EventID eventId, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java index 4005b78..c863d46 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; - -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +package org.apache.geode.cache.client.internal; + +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; import org.apache.logging.log4j.Logger; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientPartitionAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientPartitionAdvisor.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientPartitionAdvisor.java index c8a523d..d7ac2c0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientPartitionAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientPartitionAdvisor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.ArrayList; import java.util.Collections; @@ -28,16 +28,16 @@ import java.util.concurrent.ConcurrentMap; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.cache.FixedPartitionAttributes; -import com.gemstone.gemfire.cache.PartitionResolver; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.ClassPathLoader; -import com.gemstone.gemfire.internal.cache.BucketServerLocation66; -import com.gemstone.gemfire.internal.cache.FixedPartitionAttributesImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.cache.PartitionResolver; +import org.apache.geode.cache.Region; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.ClassPathLoader; +import org.apache.geode.internal.cache.BucketServerLocation66; +import org.apache.geode.internal.cache.FixedPartitionAttributesImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * Stores the information such as partition attributes and meta data details http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientRegionFactoryImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientRegionFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientRegionFactoryImpl.java index bba2d75..02edbda 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientRegionFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientRegionFactoryImpl.java @@ -14,26 +14,26 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.cache.AttributesFactory; -import com.gemstone.gemfire.cache.CacheListener; -import com.gemstone.gemfire.cache.CustomExpiry; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.ExpirationAttributes; -import com.gemstone.gemfire.cache.InterestPolicy; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.SubscriptionAttributes; -import com.gemstone.gemfire.cache.client.ClientRegionFactory; -import com.gemstone.gemfire.cache.client.ClientRegionShortcut; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.compression.Compressor; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.UserSpecifiedRegionAttributes; +import org.apache.geode.cache.AttributesFactory; +import org.apache.geode.cache.CacheListener; +import org.apache.geode.cache.CustomExpiry; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.ExpirationAttributes; +import org.apache.geode.cache.InterestPolicy; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.SubscriptionAttributes; +import org.apache.geode.cache.client.ClientRegionFactory; +import org.apache.geode.cache.client.ClientRegionShortcut; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.compression.Compressor; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.UserSpecifiedRegionAttributes; /** * The distributed system will always default to a loner on a client. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientUpdater.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientUpdater.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientUpdater.java index 93b02c4..25bb69f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientUpdater.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientUpdater.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/CloseConnectionOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/CloseConnectionOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/CloseConnectionOp.java index 2845ef9..e4d2510 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/CloseConnectionOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/CloseConnectionOp.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.io.EOFException; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * Tell a server that a connection is being closed @@ -48,7 +48,7 @@ public class CloseConnectionOp { private static class CloseConnectionOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public CloseConnectionOpImpl(boolean keepAlive) { super(MessageType.CLOSE_CONNECTION, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/CommitOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/CommitOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/CommitOp.java index e694a49..4f0098f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/CommitOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/CommitOp.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.TXCommitMessage; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.TXCommitMessage; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * Does a commit on a server @@ -47,7 +47,7 @@ public class CommitOp { private TXCommitMessage tXCommitMessageResponse = null; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public CommitOpImpl(int txId) { super(MessageType.COMMIT, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/Connection.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/Connection.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/Connection.java index 5037135..a00cbb4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/Connection.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/Connection.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.io.InputStream; import java.io.OutputStream; @@ -22,8 +22,8 @@ import java.net.Socket; import java.net.SocketException; import java.nio.ByteBuffer; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerQueueStatus; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.ServerQueueStatus; /** * Represents a connection from a client to a server. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactory.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactory.java index 248420f..272ae7e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactory.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactory.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.Set; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.security.GemFireSecurityException; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.security.GemFireSecurityException; /** * A factory for creating new connections. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactoryImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactoryImpl.java index a72b49e..b6460eb 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionFactoryImpl.java @@ -14,28 +14,28 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.GatewayConfigurationException; -import com.gemstone.gemfire.cache.client.ServerRefusedConnectionException; -import com.gemstone.gemfire.cache.client.internal.ServerBlackList.FailureTracker; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.net.SocketCreator; -import com.gemstone.gemfire.internal.cache.tier.Acceptor; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientUpdater; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.HandShake; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.net.SocketCreatorFactory; -import com.gemstone.gemfire.internal.security.SecurableCommunicationChannel; -import com.gemstone.gemfire.internal.security.SecurableComponent; -import com.gemstone.gemfire.security.GemFireSecurityException; +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.cache.GatewayConfigurationException; +import org.apache.geode.cache.client.ServerRefusedConnectionException; +import org.apache.geode.cache.client.internal.ServerBlackList.FailureTracker; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.net.SocketCreator; +import org.apache.geode.internal.cache.tier.Acceptor; +import org.apache.geode.internal.cache.tier.sockets.CacheClientUpdater; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.HandShake; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.net.SocketCreatorFactory; +import org.apache.geode.internal.security.SecurableCommunicationChannel; +import org.apache.geode.internal.security.SecurableComponent; +import org.apache.geode.security.GemFireSecurityException; import org.apache.logging.log4j.Logger; import java.util.HashSet; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionImpl.java index fbd36c2..1c9b2be 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.io.IOException; import java.io.InputStream; @@ -26,23 +26,23 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.ForcedDisconnectException; -import com.gemstone.gemfire.cache.client.internal.ExecuteFunctionOp.ExecuteFunctionOpImpl; -import com.gemstone.gemfire.cache.client.internal.ExecuteRegionFunctionOp.ExecuteRegionFunctionOpImpl; -import com.gemstone.gemfire.cache.client.internal.ExecuteRegionFunctionSingleHopOp.ExecuteRegionFunctionSingleHopOpImpl; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.net.SocketCreator; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.HandShake; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerQueueStatus; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.ForcedDisconnectException; +import org.apache.geode.cache.client.internal.ExecuteFunctionOp.ExecuteFunctionOpImpl; +import org.apache.geode.cache.client.internal.ExecuteRegionFunctionOp.ExecuteRegionFunctionOpImpl; +import org.apache.geode.cache.client.internal.ExecuteRegionFunctionSingleHopOp.ExecuteRegionFunctionSingleHopOpImpl; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.net.SocketCreator; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.tier.sockets.HandShake; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; +import org.apache.geode.internal.cache.tier.sockets.ServerQueueStatus; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * A single client to server connection. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionSource.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionSource.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionSource.java index 4230f62..cd867c8 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionSource.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionSource.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionStats.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionStats.java index 6aaae2d..c5e4fac 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionStats.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionStats.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; - -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.StatisticsType; -import com.gemstone.gemfire.StatisticsTypeFactory; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; -import com.gemstone.gemfire.internal.cache.PoolStats; -import com.gemstone.gemfire.internal.cache.tier.sockets.MessageStats; +package org.apache.geode.cache.client.internal; + +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.StatisticsType; +import org.apache.geode.StatisticsTypeFactory; +import org.apache.geode.distributed.internal.DistributionStats; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.internal.cache.PoolStats; +import org.apache.geode.internal.cache.tier.sockets.MessageStats; /** * Stats for a client to server {@link Connection} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java index 6200f3e..9cd7be1 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * Does a region containsKey on a server @@ -53,7 +53,7 @@ public class ContainsKeyOp { private final MODE mode; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public ContainsKeyOpImpl(String region, Object key, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/DataSerializerRecoveryListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DataSerializerRecoveryListener.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DataSerializerRecoveryListener.java index 4333b0e..754bdcb 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DataSerializerRecoveryListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DataSerializerRecoveryListener.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.ScheduledExecutorService; @@ -23,14 +23,14 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.InternalDataSerializer.SerializerAttributesHolder; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.CancelException; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.InternalDataSerializer.SerializerAttributesHolder; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; public class DataSerializerRecoveryListener extends EndpointManager.EndpointListenerAdapter { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java index ab9b2d1..2587ab6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java @@ -14,26 +14,26 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.client.AllConnectionsInUseException; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.EntryEventImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.client.AllConnectionsInUseException; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.EntryEventImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * Does a region destroy on a server @@ -146,7 +146,7 @@ public class DestroyOp { private Object callbackArg; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public DestroyOpImpl(LocalRegion region, Object key, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java index fa13609..4bafa63 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.EventID; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.EventID; /** * Does a region destroyRegion (or create) on a server @@ -66,7 +66,7 @@ public class DestroyRegionOp { private static class DestroyRegionOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public DestroyRegionOpImpl(String region, EventID eventId, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/Endpoint.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/Endpoint.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/Endpoint.java index 0048244..a1155d6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/Endpoint.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/Endpoint.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; /** * Represents a server. Keeps track of information about the specific server http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManager.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManager.java index 9d88670..6fb43da 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManager.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManager.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.Map; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.ServerLocation; /** * The endpoint manager keeps track of which servers we http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManagerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManagerImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManagerImpl.java index 111cec6..3f3d725 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/EndpointManagerImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.ArrayList; import java.util.Collections; @@ -26,16 +26,16 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.client.PoolManager; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.statistics.DummyStatisticsFactory; -import com.gemstone.gemfire.internal.cache.PoolStats; -import com.gemstone.gemfire.internal.cache.tier.InternalClientMembership; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelCriterion; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.client.PoolManager; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.statistics.DummyStatisticsFactory; +import org.apache.geode.internal.cache.PoolStats; +import org.apache.geode.internal.cache.tier.InternalClientMembership; +import org.apache.geode.internal.logging.LogService; /** * @@ -60,7 +60,7 @@ public class EndpointManagerImpl implements EndpointManager { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.EndpointManager#referenceEndpoint(com.gemstone.gemfire.distributed.internal.ServerLocation) + * @see org.apache.geode.cache.client.internal.EndpointManager#referenceEndpoint(org.apache.geode.distributed.internal.ServerLocation) */ public Endpoint referenceEndpoint(ServerLocation server, DistributedMember memberId) { //logger.warn("REFENDPOINT server:"+server+" memberId:"+memberId); @@ -94,7 +94,7 @@ public class EndpointManagerImpl implements EndpointManager { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.EndpointManager#serverCrashed(com.gemstone.gemfire.cache.client.internal.Endpoint) + * @see org.apache.geode.cache.client.internal.EndpointManager#serverCrashed(org.apache.geode.cache.client.internal.Endpoint) */ public void serverCrashed(Endpoint endpoint) { removeEndpoint(endpoint, true); @@ -161,14 +161,14 @@ public class EndpointManagerImpl implements EndpointManager { /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.EndpointManager#getEndpointMap() + * @see org.apache.geode.cache.client.internal.EndpointManager#getEndpointMap() */ public Map<ServerLocation, Endpoint> getEndpointMap() { return endpointMap; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.EndpointManager#close() + * @see org.apache.geode.cache.client.internal.EndpointManager#close() */ public synchronized void close() { for(Iterator<ConnectionStats> itr = statMap.values().iterator(); itr.hasNext(); ) { @@ -182,14 +182,14 @@ public class EndpointManagerImpl implements EndpointManager { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.EndpointManager#addListener(com.gemstone.gemfire.cache.client.internal.EndpointManagerImpl.EndpointListener) + * @see org.apache.geode.cache.client.internal.EndpointManager#addListener(org.apache.geode.cache.client.internal.EndpointManagerImpl.EndpointListener) */ public void addListener(EndpointManager.EndpointListener listener) { this.listener.addListener(listener); } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.EndpointManager#removeListener(com.gemstone.gemfire.cache.client.internal.EndpointManagerImpl.EndpointListener) + * @see org.apache.geode.cache.client.internal.EndpointManager#removeListener(org.apache.geode.cache.client.internal.EndpointManagerImpl.EndpointListener) */ public void removeListener(EndpointManager.EndpointListener listener) { this.listener.removeListener(listener); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecutablePool.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecutablePool.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecutablePool.java index aeea0b9..6c6d232 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecutablePool.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecutablePool.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.cache.NoSubscriptionServersAvailableException; -import com.gemstone.gemfire.cache.client.SubscriptionNotEnabledException; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.cache.NoSubscriptionServersAvailableException; +import org.apache.geode.cache.client.SubscriptionNotEnabledException; +import org.apache.geode.distributed.internal.ServerLocation; /** * Provides methods to execute AbstractOp instances on a client pool. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionHelper.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionHelper.java index 46d6162..993b2cf 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionHelper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionHelper.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; public class ExecuteFunctionHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionNoAckOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionNoAckOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionNoAckOp.java index 705f892..d142eb5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionNoAckOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionNoAckOp.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.Arrays; import java.util.Iterator; @@ -22,19 +22,19 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.execute.AbstractExecution; -import com.gemstone.gemfire.internal.cache.execute.MemberMappedArgument; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.execute.AbstractExecution; +import org.apache.geode.internal.cache.execute.MemberMappedArgument; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Does a Execution of function on server (possibly without region/cache) @@ -144,7 +144,7 @@ public class ExecuteFunctionNoAckOp { private static final int MSG_PARTS = 6; /** - * @throws com.gemstone.gemfire.SerializationException + * @throws org.apache.geode.SerializationException * if serialization fails */ public ExecuteFunctionNoAckOpImpl(Function function, Object args, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionOp.java index 105638a..6597b68 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteFunctionOp.java @@ -14,30 +14,30 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; - -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.execute.AbstractExecution; -import com.gemstone.gemfire.internal.cache.execute.FunctionStats; -import com.gemstone.gemfire.internal.cache.execute.InternalFunctionException; -import com.gemstone.gemfire.internal.cache.execute.InternalFunctionInvocationTargetException; -import com.gemstone.gemfire.internal.cache.execute.MemberMappedArgument; -import com.gemstone.gemfire.internal.cache.execute.ServerFunctionExecutor; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +package org.apache.geode.cache.client.internal; + +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.execute.AbstractExecution; +import org.apache.geode.internal.cache.execute.FunctionStats; +import org.apache.geode.internal.cache.execute.InternalFunctionException; +import org.apache.geode.internal.cache.execute.InternalFunctionInvocationTargetException; +import org.apache.geode.internal.cache.execute.MemberMappedArgument; +import org.apache.geode.internal.cache.execute.ServerFunctionExecutor; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; import java.util.ArrayList; import java.util.Arrays; @@ -399,7 +399,7 @@ public class ExecuteFunctionOp { private static final int MSG_PARTS = 6; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public ExecuteFunctionOpImpl(Function function, Object args, MemberMappedArgument memberMappedArg, byte hasResult, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java index 732d9c1..cd08e6d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java @@ -14,25 +14,25 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.execute.AbstractExecution; -import com.gemstone.gemfire.internal.cache.execute.MemberMappedArgument; -import com.gemstone.gemfire.internal.cache.execute.ServerRegionFunctionExecutor; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.execute.AbstractExecution; +import org.apache.geode.internal.cache.execute.MemberMappedArgument; +import org.apache.geode.internal.cache.execute.ServerRegionFunctionExecutor; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Does a Execution of function on server region @@ -105,7 +105,7 @@ public class ExecuteRegionFunctionNoAckOp { private final boolean executeOnBucketSet ; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public ExecuteRegionFunctionNoAckOpImpl(String region, Function function, ServerRegionFunctionExecutor serverRegionExecutor, byte hasResult) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java index 0260f77..ae08ac0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.ArrayList; import java.util.HashSet; @@ -23,30 +23,30 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.cache.client.internal.ExecuteRegionFunctionSingleHopOp.ExecuteRegionFunctionSingleHopOpImpl; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.FunctionInvocationTargetException; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.execute.AbstractExecution; -import com.gemstone.gemfire.internal.cache.execute.BucketMovedException; -import com.gemstone.gemfire.internal.cache.execute.FunctionStats; -import com.gemstone.gemfire.internal.cache.execute.InternalFunctionException; -import com.gemstone.gemfire.internal.cache.execute.MemberMappedArgument; -import com.gemstone.gemfire.internal.cache.execute.InternalFunctionInvocationTargetException; -import com.gemstone.gemfire.internal.cache.execute.ServerRegionFunctionExecutor; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.cache.client.internal.ExecuteRegionFunctionSingleHopOp.ExecuteRegionFunctionSingleHopOpImpl; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.FunctionInvocationTargetException; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.execute.AbstractExecution; +import org.apache.geode.internal.cache.execute.BucketMovedException; +import org.apache.geode.internal.cache.execute.FunctionStats; +import org.apache.geode.internal.cache.execute.InternalFunctionException; +import org.apache.geode.internal.cache.execute.MemberMappedArgument; +import org.apache.geode.internal.cache.execute.InternalFunctionInvocationTargetException; +import org.apache.geode.internal.cache.execute.ServerRegionFunctionExecutor; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.internal.logging.LogService; /** * Does a Execution of function on server region.<br>
