http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java index c917d4d..51ea8e4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.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.HashSet; @@ -24,31 +24,31 @@ 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.Region; -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.FunctionInvocationTargetException; -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.LocalRegion; -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.InternalFunctionInvocationTargetException; -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.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.Region; +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.FunctionInvocationTargetException; +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.LocalRegion; +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.InternalFunctionInvocationTargetException; +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.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; /** * @since GemFire 6.5
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExplicitConnectionSourceImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExplicitConnectionSourceImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExplicitConnectionSourceImpl.java index 7b7c3d7..73c12c6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExplicitConnectionSourceImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExplicitConnectionSourceImpl.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 com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerQueueStatus; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.security.GemFireSecurityException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ServerQueueStatus; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.security.GemFireSecurityException; import org.apache.logging.log4j.Logger; import java.net.InetSocketAddress; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java index 0aaa2ad..259fc76 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.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.HashSet; @@ -24,18 +24,18 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.Region; -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.internal.Version; -import com.gemstone.gemfire.internal.cache.LocalRegion; -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.VersionedObjectList; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.Region; +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.internal.Version; +import org.apache.geode.internal.cache.LocalRegion; +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.VersionedObjectList; +import org.apache.geode.internal.logging.LogService; /** * Does a region getAll on a server @@ -149,7 +149,7 @@ public class GetAllOp { private final Object callback; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetAllOpImpl(String region, List keys, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java index 240aabb..1b72c7a 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java @@ -14,21 +14,21 @@ * 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 org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.internal.cache.BucketServerLocation66; -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 org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.internal.cache.BucketServerLocation66; +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; /** * Retrieves {@link ClientPartitionAdvisor} for the specified PartitionedRegion from http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java index 7f5ba9d..6da0531 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java @@ -14,20 +14,20 @@ * 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.FixedPartitionAttributes; -import com.gemstone.gemfire.cache.client.ServerOperationException; -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 org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.cache.client.ServerOperationException; +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; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java index 6630614..ef1f511 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.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.internal.cache.EntrySnapshot; -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 org.apache.geode.internal.cache.EntrySnapshot; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * does getEntry 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/internal/GetEventValueOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEventValueOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEventValueOp.java index 80bc7a7..7e4ca97 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEventValueOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEventValueOp.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 com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.internal.cache.EventID; -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 org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.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.tier.sockets.Part; /** * Gets (full) value (unlike GetOp, which may get either a full value or a delta @@ -50,7 +50,7 @@ public class GetEventValueOp { static class GetEventValueOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetEventValueOpImpl(EventID event, Object callbackArg) { super(MessageType.REQUEST_EVENT_VALUE, callbackArg != null ? 2 : 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetFunctionAttributeOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetFunctionAttributeOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetFunctionAttributeOp.java index 177ea26..e72976c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetFunctionAttributeOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetFunctionAttributeOp.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; public class GetFunctionAttributeOp { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java index 00f81fd..350df88 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java @@ -14,27 +14,27 @@ * 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.CacheLoaderException; -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.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.Token; -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.logging.LogService; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheLoaderException; +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.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.Token; +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.logging.LogService; /** * Does a region get on a server @@ -120,7 +120,7 @@ public class GetOp { } /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetOpImpl(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/GetPDXEnumByIdOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumByIdOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumByIdOp.java index 7240346..09ef6e4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumByIdOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumByIdOp.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; /** * Retrieve the PDXType, given an integer PDX id, from a server. @@ -42,7 +42,7 @@ public class GetPDXEnumByIdOp { private static class GetPDXEnumByIdOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetPDXEnumByIdOpImpl(int enumId) { super(MessageType.GET_PDX_ENUM_BY_ID, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumsOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumsOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumsOp.java index 748a94f..8c412ca 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumsOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXEnumsOp.java @@ -14,16 +14,16 @@ * 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.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -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.pdx.internal.EnumInfo; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +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.pdx.internal.EnumInfo; /** * Retrieve all known PDX types. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForEnumOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForEnumOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForEnumOp.java index 2185eac..c247e64 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForEnumOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForEnumOp.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 com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -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.pdx.internal.EnumInfo; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +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.pdx.internal.EnumInfo; /** * Retrieve the PDXType, given an integer PDX id, from a server. @@ -47,7 +47,7 @@ public class GetPDXIdForEnumOp { private static class GetPDXIdForEnumOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetPDXIdForEnumOpImpl(EnumInfo ei) { super(MessageType.GET_PDX_ID_FOR_ENUM, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForTypeOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForTypeOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForTypeOp.java index 92dad3d..f1a3f50 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForTypeOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXIdForTypeOp.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 com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -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.pdx.internal.PdxType; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +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.pdx.internal.PdxType; /** * Retrieve the PDXType, given an integer PDX id, from a server. @@ -47,7 +47,7 @@ public class GetPDXIdForTypeOp { private static class GetPDXIdForTypeOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetPDXIdForTypeOpImpl(PdxType type) { super(MessageType.GET_PDX_ID_FOR_TYPE, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypeByIdOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypeByIdOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypeByIdOp.java index 982eb27..48c2f13 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypeByIdOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypeByIdOp.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; /** * Retrieve the PDXType, given an integer PDX id, from a server. @@ -42,7 +42,7 @@ public class GetPDXTypeByIdOp { private static class GetPDXTypeByIdOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public GetPDXTypeByIdOpImpl(int pdxId) { super(MessageType.GET_PDX_TYPE_BY_ID, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypesOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypesOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypesOp.java index 5fa0cc0..8444ef9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypesOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetPDXTypesOp.java @@ -14,16 +14,16 @@ * 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.InternalGemFireError; -import com.gemstone.gemfire.cache.client.ServerOperationException; -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.pdx.internal.PdxType; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.client.ServerOperationException; +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.pdx.internal.PdxType; /** * Retrieve all known PDX types. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/InstantiatorRecoveryListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InstantiatorRecoveryListener.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InstantiatorRecoveryListener.java index 8776863..a34acad 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InstantiatorRecoveryListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InstantiatorRecoveryListener.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,13 +23,13 @@ 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.InternalInstantiator; -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.InternalInstantiator; +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; /** * A listener which will try to resend the instantiators to all servers if the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/InternalPool.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InternalPool.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InternalPool.java index fa27d99..80bacc7 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InternalPool.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InternalPool.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.Map; import java.util.concurrent.ScheduledExecutorService; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.internal.cache.PoolStats; +import org.apache.geode.CancelCriterion; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.internal.cache.PoolStats; /** * The contract between a connection source and a connection pool. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java index 2819ad9..89ca446 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java @@ -14,16 +14,16 @@ * 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.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.EntryEventImpl; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.EntryEventImpl; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.logging.LogService; /** * Does a region invalidate on a server @@ -55,7 +55,7 @@ public class InvalidateOp { private static class InvalidateOpImpl extends AbstractOp { private EntryEventImpl event; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public InvalidateOpImpl(String region, EntryEventImpl event) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java index c30a90a..3bff61d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.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; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.internal.Version; -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.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.cache.client.ServerOperationException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.internal.Version; +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.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.cache.client.ServerOperationException; import java.util.List; import java.util.Set; @@ -52,7 +52,7 @@ public class KeySetOp { private static class KeySetOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public KeySetOpImpl(String region) { super(MessageType.KEY_SET, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/LiveServerPinger.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/LiveServerPinger.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/LiveServerPinger.java index 4dfd79e..43fcbd2 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/LiveServerPinger.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/LiveServerPinger.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.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; @@ -24,10 +24,10 @@ import java.util.concurrent.TimeUnit; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.client.internal.EndpointManager.EndpointListenerAdapter; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.client.internal.EndpointManager.EndpointListenerAdapter; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.logging.LogService; /** * Responsible for pinging live http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallback.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallback.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallback.java index 12ec348..945c559 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallback.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallback.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.List; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallbackAdapter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallbackAdapter.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallbackAdapter.java index 6639e5e..55e5ac6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallbackAdapter.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/LocatorDiscoveryCallbackAdapter.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.List; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/MakePrimaryOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/MakePrimaryOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/MakePrimaryOp.java index 3320aab..6d42dca 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/MakePrimaryOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/MakePrimaryOp.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; /** * Tell a server to become the primary host of a server-to-client queue @@ -42,7 +42,7 @@ public class MakePrimaryOp { private static class MakePrimaryOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public MakePrimaryOpImpl(boolean sentClientReady) { super(MessageType.MAKE_PRIMARY, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/Op.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/Op.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/Op.java index 5247317..7813a0e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/Op.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/Op.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; /** * An operation to perform on a server. Used by http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/OpExecutorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/OpExecutorImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/OpExecutorImpl.java index bbec12f..8f20b2c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/OpExecutorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/OpExecutorImpl.java @@ -14,35 +14,35 @@ * 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.*; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.SynchronizationCommitConflictException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.client.*; -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.QueueManager.QueueConnections; -import com.gemstone.gemfire.cache.client.internal.pooling.ConnectionDestroyedException; -import com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManager; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.FunctionInvocationTargetException; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.PoolManagerImpl; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException; -import com.gemstone.gemfire.internal.cache.TXManagerImpl; -import com.gemstone.gemfire.internal.cache.TXStateProxy; -import com.gemstone.gemfire.internal.cache.execute.InternalFunctionInvocationTargetException; -import com.gemstone.gemfire.internal.cache.tier.BatchException; -import com.gemstone.gemfire.internal.cache.tier.sockets.MessageTooLargeException; -import com.gemstone.gemfire.internal.cache.wan.BatchException70; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.security.AuthenticationRequiredException; -import com.gemstone.gemfire.security.GemFireSecurityException; +import org.apache.geode.*; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.SynchronizationCommitConflictException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.client.*; +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.QueueManager.QueueConnections; +import org.apache.geode.cache.client.internal.pooling.ConnectionDestroyedException; +import org.apache.geode.cache.client.internal.pooling.ConnectionManager; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.FunctionInvocationTargetException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.PoolManagerImpl; +import org.apache.geode.internal.cache.PutAllPartialResultException; +import org.apache.geode.internal.cache.TXManagerImpl; +import org.apache.geode.internal.cache.TXStateProxy; +import org.apache.geode.internal.cache.execute.InternalFunctionInvocationTargetException; +import org.apache.geode.internal.cache.tier.BatchException; +import org.apache.geode.internal.cache.tier.sockets.MessageTooLargeException; +import org.apache.geode.internal.cache.wan.BatchException70; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.security.AuthenticationRequiredException; +import org.apache.geode.security.GemFireSecurityException; import org.apache.logging.log4j.Logger; import java.io.EOFException; @@ -312,7 +312,7 @@ public class OpExecutorImpl implements ExecutablePool { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.OpExecutor#executeOn(com.gemstone.gemfire.distributed.internal.ServerLocation, com.gemstone.gemfire.cache.client.internal.Op) + * @see org.apache.geode.cache.client.internal.OpExecutor#executeOn(org.apache.geode.distributed.internal.ServerLocation, org.apache.geode.cache.client.internal.Op) */ public Object executeOn(ServerLocation server, Op op) { return executeOn(server, op, true,false); @@ -447,7 +447,7 @@ public class OpExecutorImpl implements ExecutablePool { /* * (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ExecutablePool#executeOnPrimary(com.gemstone.gemfire.cache.client.internal.Op) + * @see org.apache.geode.cache.client.internal.ExecutablePool#executeOnPrimary(org.apache.geode.cache.client.internal.Op) */ public Object executeOnPrimary(Op op) { if(queueManager == null) { @@ -512,7 +512,7 @@ public class OpExecutorImpl implements ExecutablePool { /* * (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ExecutablePool#executeOnAllQueueServers(com.gemstone.gemfire.cache.client.internal.Op) + * @see org.apache.geode.cache.client.internal.ExecutablePool#executeOnAllQueueServers(org.apache.geode.cache.client.internal.Op) */ public Object executeOnQueuesAndReturnPrimaryResult(Op op) { if(queueManager == null) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/PdxRegistryRecoveryListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PdxRegistryRecoveryListener.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PdxRegistryRecoveryListener.java index 2d4104c..ef030c7 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PdxRegistryRecoveryListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PdxRegistryRecoveryListener.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; +package org.apache.geode.cache.client.internal; import java.util.concurrent.atomic.AtomicInteger; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.pdx.internal.TypeRegistry; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.pdx.internal.TypeRegistry; /** * A listener which will wipe out the PDX registry on the client side if the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/PingOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PingOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PingOp.java index fbe0186..509eebe 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PingOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PingOp.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.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * Ping a server to see if it is still alive. @@ -46,7 +46,7 @@ public class PingOp { private long startTime; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public PingOpImpl() { super(MessageType.PING, 0); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/PoolImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PoolImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PoolImpl.java index 371098d..1561ef9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PoolImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PoolImpl.java @@ -14,35 +14,35 @@ * 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.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.SubscriptionNotEnabledException; -import com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManager; -import com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManagerImpl; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.internal.DefaultQueryService; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.distributed.PoolCancelledException; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.statistics.DummyStatisticsFactory; -import com.gemstone.gemfire.internal.ScheduledThreadPoolExecutorWithKeepAlive; -import com.gemstone.gemfire.internal.admin.ClientStatsManager; -import com.gemstone.gemfire.internal.cache.*; -import com.gemstone.gemfire.internal.cache.tier.sockets.AcceptorImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +package org.apache.geode.cache.client.internal; + +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.SubscriptionNotEnabledException; +import org.apache.geode.cache.client.internal.pooling.ConnectionManager; +import org.apache.geode.cache.client.internal.pooling.ConnectionManagerImpl; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.internal.DefaultQueryService; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.distributed.PoolCancelledException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.statistics.DummyStatisticsFactory; +import org.apache.geode.internal.ScheduledThreadPoolExecutorWithKeepAlive; +import org.apache.geode.internal.admin.ClientStatsManager; +import org.apache.geode.internal.cache.*; +import org.apache.geode.internal.cache.tier.sockets.AcceptorImpl; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; import java.net.InetSocketAddress; @@ -354,7 +354,7 @@ public class PoolImpl implements InternalPool { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.Pool#getName() + * @see org.apache.geode.cache.Pool#getName() */ public String getName() { return this.name; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/PrimaryAckOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PrimaryAckOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PrimaryAckOp.java index a0459d2..9c9a49a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PrimaryAckOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PrimaryAckOp.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; import java.util.Iterator; import java.util.List; @@ -50,7 +50,7 @@ public class PrimaryAckOp { private static class PrimaryAckOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public PrimaryAckOpImpl(List events) { super(MessageType.PERIODIC_ACK, events.size()); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCache.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCache.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCache.java index 9c7b6ec..703f935 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCache.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCache.java @@ -14,22 +14,22 @@ * 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 com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.client.ClientCache; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.internal.ProxyQueryService; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.PdxInstanceFactory; -import com.gemstone.gemfire.pdx.internal.PdxInstanceFactoryImpl; +import org.apache.geode.CancelCriterion; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.client.ClientCache; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.internal.ProxyQueryService; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.PdxInstanceFactory; +import org.apache.geode.pdx.internal.PdxInstanceFactoryImpl; import java.util.Collections; import java.util.HashSet; @@ -173,7 +173,7 @@ public class ProxyCache implements RegionService { protected class Stopper extends CancelCriterion { /* (non-Javadoc) - * @see com.gemstone.gemfire.CancelCriterion#cancelInProgress() + * @see org.apache.geode.CancelCriterion#cancelInProgress() */ @Override public String cancelInProgress() { @@ -188,7 +188,7 @@ public class ProxyCache implements RegionService { } /* (non-Javadoc) - * @see com.gemstone.gemfire.CancelCriterion#generateCancelledException(java.lang.Throwable) + * @see org.apache.geode.CancelCriterion#generateCancelledException(java.lang.Throwable) */ @Override public RuntimeException generateCancelledException(Throwable e) { @@ -221,7 +221,7 @@ public class ProxyCache implements RegionService { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.RegionService#rootRegions() + * @see org.apache.geode.cache.RegionService#rootRegions() */ public Set<Region<?, ?>> rootRegions() { preOp(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCacheCloseOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCacheCloseOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCacheCloseOp.java index 2747fa8..2d385fa 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCacheCloseOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyCacheCloseOp.java @@ -14,19 +14,19 @@ * 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.Properties; -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.ServerLocation; -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.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; +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.ServerLocation; +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.Message; +import org.apache.geode.internal.cache.tier.sockets.Part; public class ProxyCacheCloseOp { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyRegion.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyRegion.java index 1113927..ca962df 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyRegion.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ProxyRegion.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; @@ -25,28 +25,28 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.locks.Lock; -import com.gemstone.gemfire.cache.AttributesMutator; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheLoaderException; -import com.gemstone.gemfire.cache.CacheStatistics; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryExistsException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.StatisticsDisabledException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.snapshot.RegionSnapshotService; -import com.gemstone.gemfire.internal.cache.snapshot.RegionSnapshotServiceImpl; +import org.apache.geode.cache.AttributesMutator; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheLoaderException; +import org.apache.geode.cache.CacheStatistics; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryExistsException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.snapshot.RegionSnapshotService; +import org.apache.geode.internal.cache.snapshot.RegionSnapshotServiceImpl; /** * A wrapper class over an actual Region instance. This is used when the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java index 112d533..ab0ad58 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.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.HashMap; @@ -28,23 +28,23 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException.PutAllPartialResult; -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.VersionedObjectList; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.CachedDeserializable; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PutAllPartialResultException; +import org.apache.geode.internal.cache.PutAllPartialResultException.PutAllPartialResult; +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.VersionedObjectList; +import org.apache.geode.internal.logging.LogService; /** * Does a region putAll on a server @@ -267,7 +267,7 @@ public class PutAllOp { private ArrayList keys = null; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public PutAllOpImpl(Region region, Map map, EventID eventId, boolean prSingleHopEnabled, boolean skipCallbacks, Object callbackArg) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java index 35760b5..30d1a92 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.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.DataSerializer; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -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.CachedDeserializable; -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.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.versions.VersionTag; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +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.CachedDeserializable; +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.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.versions.VersionTag; +import org.apache.geode.internal.logging.LogService; import java.io.ByteArrayInputStream; import java.io.DataInputStream; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueryOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueryOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueryOp.java index 30c28d5..6b3747e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueryOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueryOp.java @@ -14,24 +14,24 @@ * 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 com.gemstone.gemfire.internal.Version; -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.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.ObjectPartList; -import com.gemstone.gemfire.internal.cache.tier.sockets.Part; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.internal.QueryUtils; -import com.gemstone.gemfire.cache.query.internal.StructImpl; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.SerializationException; -import com.gemstone.gemfire.cache.client.ServerOperationException; +import org.apache.geode.internal.Version; +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.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.ObjectPartList; +import org.apache.geode.internal.cache.tier.sockets.Part; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.internal.QueryUtils; +import org.apache.geode.cache.query.internal.StructImpl; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.SerializationException; +import org.apache.geode.cache.client.ServerOperationException; /** * Does a region query on a server @@ -68,7 +68,7 @@ public class QueryOp { */ protected static class QueryOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public QueryOpImpl(String queryPredicate) { super(MessageType.QUERY, 1); @@ -76,7 +76,7 @@ public class QueryOp { } /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public QueryOpImpl(String queryPredicate, Object[] queryParams) { super(MessageType.QUERY_WITH_PARAMETERS, 2 + queryParams.length); @@ -89,7 +89,7 @@ public class QueryOp { /** * This constructor is used by our subclass CreateCQWithIROpImpl - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ protected QueryOpImpl(int msgType, int numParts) { super(msgType, numParts); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueConnectionImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueConnectionImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueConnectionImpl.java index 40cf58b..f405fca 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueConnectionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueConnectionImpl.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; @@ -26,11 +26,11 @@ import java.util.concurrent.atomic.AtomicReference; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.client.internal.ServerBlackList.FailureTracker; -import com.gemstone.gemfire.cache.client.internal.pooling.ConnectionDestroyedException; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerQueueStatus; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.client.internal.ServerBlackList.FailureTracker; +import org.apache.geode.cache.client.internal.pooling.ConnectionDestroyedException; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.ServerQueueStatus; +import org.apache.geode.internal.logging.LogService; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManager.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManager.java index 436a13b..b4a0c37 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManager.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManager.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.concurrent.ScheduledExecutorService; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.logging.InternalLogWriter; /** * @since GemFire 5.7 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManagerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManagerImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManagerImpl.java index 38ca6b1..b817fc8 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueManagerImpl.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; @@ -38,39 +38,39 @@ import java.util.concurrent.TimeUnit; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.GemFireException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.NoSubscriptionServersAvailableException; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.cache.client.internal.RegisterInterestTracker.RegionInterestEntry; -import com.gemstone.gemfire.cache.client.internal.ServerBlackList.BlackListListener; -import com.gemstone.gemfire.cache.client.internal.ServerBlackList.BlackListListenerAdapter; -import com.gemstone.gemfire.cache.client.internal.ServerBlackList.FailureTracker; -import com.gemstone.gemfire.cache.query.internal.CqStateImpl; -import com.gemstone.gemfire.cache.query.internal.DefaultQueryService; -import com.gemstone.gemfire.cache.query.internal.cq.ClientCQ; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.ClientServerObserver; -import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -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.ServerQueueStatus; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.security.GemFireSecurityException; -import com.gemstone.gemfire.i18n.StringId; +import org.apache.geode.CancelException; +import org.apache.geode.GemFireException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.NoSubscriptionServersAvailableException; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.cache.client.internal.RegisterInterestTracker.RegionInterestEntry; +import org.apache.geode.cache.client.internal.ServerBlackList.BlackListListener; +import org.apache.geode.cache.client.internal.ServerBlackList.BlackListListenerAdapter; +import org.apache.geode.cache.client.internal.ServerBlackList.FailureTracker; +import org.apache.geode.cache.query.internal.CqStateImpl; +import org.apache.geode.cache.query.internal.DefaultQueryService; +import org.apache.geode.cache.query.internal.cq.ClientCQ; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.ClientServerObserver; +import org.apache.geode.internal.cache.ClientServerObserverHolder; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.tier.InterestType; +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.ServerQueueStatus; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.security.GemFireSecurityException; +import org.apache.geode.i18n.StringId; /** * Manages Client Queues. Responsible for creating callback connections and @@ -1384,7 +1384,7 @@ public class QueueManagerImpl implements QueueManager { public Set/* <ServerLocation> */getAllLocations() { HashSet locations = new HashSet(); for (Iterator itr = connectionMap.keySet().iterator(); itr.hasNext();) { - com.gemstone.gemfire.cache.client.internal.Endpoint endpoint = (com.gemstone.gemfire.cache.client.internal.Endpoint) itr.next(); + org.apache.geode.cache.client.internal.Endpoint endpoint = (org.apache.geode.cache.client.internal.Endpoint) itr.next(); locations.add(endpoint.getLocation()); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueState.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueState.java index 4259c5e..76ca2c4 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueState.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueState.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 java.util.concurrent.ScheduledExecutorService; -import com.gemstone.gemfire.internal.cache.EventID; +import org.apache.geode.internal.cache.EventID; public interface QueueState {
