http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionInvocationTargetException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionInvocationTargetException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionInvocationTargetException.java index 1171c17..54517d4 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionInvocationTargetException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionInvocationTargetException.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.HashSet; import java.util.Set; -import com.gemstone.gemfire.cache.execute.FunctionInvocationTargetException; -import com.gemstone.gemfire.distributed.DistributedMember; +import org.apache.geode.cache.execute.FunctionInvocationTargetException; +import org.apache.geode.distributed.DistributedMember; public class InternalFunctionInvocationTargetException extends FunctionInvocationTargetException {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionService.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionService.java index f0ed757..1374636 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionService.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunctionService.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Set; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.client.ClientCache; -import com.gemstone.gemfire.cache.client.ClientCacheFactory; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.execute.Execution; -import com.gemstone.gemfire.cache.execute.internal.FunctionServiceManager; -import com.gemstone.gemfire.internal.cache.AbstractRegion; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.client.ClientCache; +import org.apache.geode.cache.client.ClientCacheFactory; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.execute.Execution; +import org.apache.geode.cache.execute.internal.FunctionServiceManager; +import org.apache.geode.internal.cache.AbstractRegion; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalRegionFunctionContext.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalRegionFunctionContext.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalRegionFunctionContext.java index 90ad79c..2bf8e15 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalRegionFunctionContext.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalRegionFunctionContext.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.PartitionAttributesFactory; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.RegionFunctionContext; -import com.gemstone.gemfire.cache.partition.PartitionRegionHelper; -import com.gemstone.gemfire.internal.cache.LocalDataSet; +import org.apache.geode.cache.PartitionAttributesFactory; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.RegionFunctionContext; +import org.apache.geode.cache.partition.PartitionRegionHelper; +import org.apache.geode.internal.cache.LocalDataSet; /** * Internal interface used to provide for some essential functionality for http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalResultSender.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalResultSender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalResultSender.java index eb3349f..21a5195 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalResultSender.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalResultSender.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; -import com.gemstone.gemfire.cache.execute.ResultSender; +import org.apache.geode.cache.execute.ResultSender; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollector.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollector.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollector.java index b190ae9..826ce93 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollector.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollector.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.distributed.internal.ReplyProcessor21; /** * Extends {@link ResultCollector} interface to provide for methods that are http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollectorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollectorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollectorImpl.java index ce06b78..4893a4b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollectorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/LocalResultCollectorImpl.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; -import com.gemstone.gemfire.cache.execute.Execution; -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.ReplyProcessor21; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.execute.Execution; +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.ReplyProcessor21; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; public final class LocalResultCollectorImpl implements LocalResultCollector { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutor.java index 3912245..5320cdd 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Collections; import java.util.HashMap; @@ -22,24 +22,24 @@ import java.util.HashSet; import java.util.Iterator; import java.util.Set; -import com.gemstone.gemfire.cache.LowMemoryException; -import com.gemstone.gemfire.cache.TransactionDataNotColocatedException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.execute.Execution; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionContext; -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.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.SetUtils; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.control.MemoryThresholds; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.LowMemoryException; +import org.apache.geode.cache.TransactionDataNotColocatedException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.execute.Execution; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionContext; +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.DistributedSystem; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.SetUtils; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.control.MemoryThresholds; +import org.apache.geode.internal.i18n.LocalizedStrings; /** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java index ceecb66..cc4889e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java @@ -15,21 +15,21 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import org.apache.logging.log4j.Logger; -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.cache.query.QueryException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.cache.ForceReattemptException; -import com.gemstone.gemfire.internal.cache.MemberFunctionStreamingMessage; -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.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.cache.ForceReattemptException; +import org.apache.geode.internal.cache.MemberFunctionStreamingMessage; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultWaiter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultWaiter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultWaiter.java index af8c5f3..5ab060a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultWaiter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultWaiter.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.HashMap; import java.util.Set; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.MemberFunctionStreamingMessage; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.MemberFunctionStreamingMessage; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberMappedArgument.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberMappedArgument.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberMappedArgument.java index 001b701..6bfd552 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberMappedArgument.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MemberMappedArgument.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.io.Serializable; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContext.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContext.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContext.java index 43dc087..6723da1 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContext.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContext.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Set; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionContext; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionContext; /** * Context available when called using http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContextImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContextImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContextImpl.java index dec81a8..f8ee8f2 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContextImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionContextImpl.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Set; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.ResultSender; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.ResultSender; /** * Context available when called using http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionExecutor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionExecutor.java index a9f933a..1604d83 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionExecutor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.HashMap; import java.util.HashSet; @@ -22,28 +22,28 @@ import java.util.Map; import java.util.Random; import java.util.Set; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.LowMemoryException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.TransactionDataNotColocatedException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.execute.Execution; -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.DM; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.SetUtils; -import com.gemstone.gemfire.internal.cache.DistributedRegion; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.control.MemoryThresholds; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.LowMemoryException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.TransactionDataNotColocatedException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.execute.Execution; +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.DM; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.SetUtils; +import org.apache.geode.internal.cache.DistributedRegion; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.control.MemoryThresholds; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionResultWaiter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionResultWaiter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionResultWaiter.java index dfcc90e..47a7a00 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionResultWaiter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/MultiRegionFunctionResultWaiter.java @@ -14,19 +14,19 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.HashMap; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.MemberFunctionStreamingMessage; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.MemberFunctionStreamingMessage; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java index 484b21d..ec4a27a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/NoResult.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.io.Serializable; import java.util.concurrent.TimeUnit; -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.internal.i18n.LocalizedStrings; +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.internal.i18n.LocalizedStrings; /** * A Special ResultCollector implementation. Functions having http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionExecutor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionExecutor.java index 359b7f6..3337e0a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionExecutor.java @@ -15,28 +15,28 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Iterator; import java.util.NoSuchElementException; import java.util.Set; -import com.gemstone.gemfire.cache.LowMemoryException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.TransactionDataRebalancedException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.execute.Execution; -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.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.SetUtils; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.control.MemoryThresholds; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.LowMemoryException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.TransactionDataRebalancedException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.execute.Execution; +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.membership.InternalDistributedMember; +import org.apache.geode.internal.SetUtils; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.control.MemoryThresholds; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * @@ -344,7 +344,7 @@ public class PartitionedRegionFunctionExecutor extends AbstractExecution { return buf.toString(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.execute.AbstractExecution#validateExecution(com.gemstone.gemfire.cache.execute.Function, java.util.Set) + * @see org.apache.geode.internal.cache.execute.AbstractExecution#validateExecution(org.apache.geode.cache.execute.Function, java.util.Set) */ @Override public void validateExecution(Function function, Set targetMembers) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java index 3a3e6e3..e15d401 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java @@ -15,23 +15,23 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Set; import org.apache.logging.log4j.Logger; -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.DM; -import com.gemstone.gemfire.internal.cache.ForceReattemptException; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionedRegionFunctionStreamingMessage; -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.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.DM; +import org.apache.geode.internal.cache.ForceReattemptException; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.partitioned.PartitionedRegionFunctionStreamingMessage; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * ResultSender needs ResultCollector in which to add results one by one. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultWaiter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultWaiter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultWaiter.java index 53eb05b..550e649 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultWaiter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultWaiter.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.HashSet; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionedRegionFunctionStreamingMessage; -import com.gemstone.gemfire.internal.cache.partitioned.PRFunctionStreamingResultCollector; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.partitioned.PartitionedRegionFunctionStreamingMessage; +import org.apache.geode.internal.cache.partitioned.PRFunctionStreamingResultCollector; /** * ResultReciever (which could be resultCollector?)will be instantiated and will be used http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/RegionFunctionContextImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/RegionFunctionContextImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/RegionFunctionContextImpl.java index 302b24e..4052df7 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/RegionFunctionContextImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/RegionFunctionContextImpl.java @@ -15,18 +15,18 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.Execution; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.internal.cache.LocalDataSet; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.Execution; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.internal.cache.LocalDataSet; /** * Context available to data dependent functions. When function is executed http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerFunctionExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerFunctionExecutor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerFunctionExecutor.java index 0cca113..4295898 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerFunctionExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerFunctionExecutor.java @@ -14,26 +14,26 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Set; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.internal.ExecuteFunctionNoAckOp; -import com.gemstone.gemfire.cache.client.internal.ExecuteFunctionOp; -import com.gemstone.gemfire.cache.client.internal.GetFunctionAttributeOp; -import com.gemstone.gemfire.cache.client.internal.PoolImpl; -import com.gemstone.gemfire.cache.client.internal.ProxyCache; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.execute.Execution; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.internal.cache.TXManagerImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.internal.ExecuteFunctionNoAckOp; +import org.apache.geode.cache.client.internal.ExecuteFunctionOp; +import org.apache.geode.cache.client.internal.GetFunctionAttributeOp; +import org.apache.geode.cache.client.internal.PoolImpl; +import org.apache.geode.cache.client.internal.ProxyCache; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.execute.Execution; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.internal.cache.TXManagerImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * * @@ -295,7 +295,7 @@ public class ServerFunctionExecutor extends AbstractExecution { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.execute.AbstractExecution#validateExecution(com.gemstone.gemfire.cache.execute.Function, java.util.Set) + * @see org.apache.geode.internal.cache.execute.AbstractExecution#validateExecution(org.apache.geode.cache.execute.Function, java.util.Set) */ @Override public void validateExecution(Function function, Set targetMembers) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerRegionFunctionExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerRegionFunctionExecutor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerRegionFunctionExecutor.java index 3a445e7..b5bc684 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerRegionFunctionExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerRegionFunctionExecutor.java @@ -15,23 +15,23 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.client.internal.ProxyCache; -import com.gemstone.gemfire.cache.client.internal.ServerRegionProxy; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.execute.Execution; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.TXStateProxyImpl; -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.Region; +import org.apache.geode.cache.client.internal.ProxyCache; +import org.apache.geode.cache.client.internal.ServerRegionProxy; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.execute.Execution; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.TXStateProxyImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; import java.util.Set; @@ -362,7 +362,7 @@ public class ServerRegionFunctionExecutor extends AbstractExecution { return new ServerRegionFunctionExecutor(this, argument); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.execute.AbstractExecution#validateExecution(com.gemstone.gemfire.cache.execute.Function, java.util.Set) + * @see org.apache.geode.internal.cache.execute.AbstractExecution#validateExecution(org.apache.geode.cache.execute.Function, java.util.Set) */ @Override public void validateExecution(Function function, Set targetMembers) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java index 36c79c0..22b3737 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.io.IOException; import java.nio.ByteBuffer; @@ -23,20 +23,20 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.cache.operations.ExecuteFunctionOperationContext; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.cache.tier.Command; -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.ServerConnection; -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.security.AuthorizeRequestPP; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.cache.operations.ExecuteFunctionOperationContext; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.cache.tier.Command; +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.ServerConnection; +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.security.AuthorizeRequestPP; /** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender65.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender65.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender65.java index 5ac75c6..31c3fb4 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender65.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender65.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.io.IOException; import java.util.ArrayList; @@ -22,18 +22,18 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.operations.ExecuteFunctionOperationContext; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.cache.tier.Command; -import com.gemstone.gemfire.internal.cache.tier.sockets.BaseCommand; -import com.gemstone.gemfire.internal.cache.tier.sockets.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.operations.ExecuteFunctionOperationContext; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.cache.tier.Command; +import org.apache.geode.internal.cache.tier.sockets.BaseCommand; +import org.apache.geode.internal.cache.tier.sockets.ChunkedMessage; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; +import org.apache.geode.internal.i18n.LocalizedStrings; +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/internal/cache/execute/StreamingFunctionOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/StreamingFunctionOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/StreamingFunctionOperation.java index 07be79c..ba2fd79 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/StreamingFunctionOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/StreamingFunctionOperation.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute; +package org.apache.geode.internal.cache.execute; import java.util.Collections; import java.util.HashMap; import java.util.Set; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; /** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/execute/util/FindRestEnabledServersFunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/util/FindRestEnabledServersFunction.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/util/FindRestEnabledServersFunction.java index 99a1d6c..793f73c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/util/FindRestEnabledServersFunction.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/util/FindRestEnabledServersFunction.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.execute.util; +package org.apache.geode.internal.cache.execute.util; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.execute.FunctionAdapter; -import com.gemstone.gemfire.cache.execute.FunctionContext; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.InternalEntity; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.execute.FunctionAdapter; +import org.apache.geode.cache.execute.FunctionContext; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.InternalEntity; +import org.apache.geode.internal.cache.GemFireCacheImpl; /** * The FindRestEnabledServersFunction class is a gemfire function that gives details about REST enabled gemfire servers. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extensible.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extensible.java b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extensible.java index a3796d4..c7f38fe 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extensible.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extensible.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.extension; +package org.apache.geode.internal.cache.extension; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheXml; +import org.apache.geode.internal.cache.xmlcache.CacheXml; /** * Provides marker for extensibility and access to {@link ExtensionPoint}. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extension.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extension.java b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extension.java index ced104b..e1d5df6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extension.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/Extension.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.extension; +package org.apache.geode.internal.cache.extension; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheXml; -import com.gemstone.gemfire.internal.cache.xmlcache.XmlGenerator; +import org.apache.geode.cache.Cache; +import org.apache.geode.internal.cache.xmlcache.CacheXml; +import org.apache.geode.internal.cache.xmlcache.XmlGenerator; /** * Interface used for objects wishing to extend and {@link Extensible} object. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/extension/ExtensionPoint.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/ExtensionPoint.java b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/ExtensionPoint.java index 0ecf39a..b9ddd42 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/ExtensionPoint.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/ExtensionPoint.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.extension; +package org.apache.geode.internal.cache.extension; /** * Allows {@link Extensible} objects to add and remove {@link Extension}s. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/extension/SimpleExtensionPoint.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/SimpleExtensionPoint.java b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/SimpleExtensionPoint.java index 2d88808..14c9193 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/extension/SimpleExtensionPoint.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/extension/SimpleExtensionPoint.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.extension; +package org.apache.geode.internal.cache.extension; import java.util.ArrayList; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.internal.util.CollectionUtils; +import org.apache.geode.cache.Cache; +import org.apache.geode.internal.util.CollectionUtils; /** * Simple implementation of {@link ExtensionPoint} for easy integration with http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerMap.java index 8f8be30..1cc4419 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerMap.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; +package org.apache.geode.internal.cache.ha; import java.util.Collection; import java.util.Collections; @@ -23,10 +23,10 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientProxy; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.cache.tier.sockets.CacheClientProxy; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * @since GemFire 5.7 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerRegion.java index db1a783..5bf7065 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerRegion.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; +package org.apache.geode.internal.cache.ha; import java.util.Collection; import java.util.Collections; @@ -23,14 +23,14 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientProxy; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientUpdateMessageImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.HAEventWrapper; +import org.apache.geode.CancelException; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.internal.cache.tier.sockets.CacheClientProxy; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ClientUpdateMessageImpl; +import org.apache.geode.internal.cache.tier.sockets.HAEventWrapper; /** * @since GemFire 5.7 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerWrapper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerWrapper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerWrapper.java index d0b831e..fa73789 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerWrapper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HAContainerWrapper.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; +package org.apache.geode.internal.cache.ha; import java.util.Map; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientProxy; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.CacheClientProxy; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; /** * @since GemFire 5.7 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java index 2b8934e..027a1b5 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java @@ -14,34 +14,34 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; - -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.query.internal.CqQueryVsdStats; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -import com.gemstone.gemfire.cache.util.CacheListenerAdapter; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.*; -import com.gemstone.gemfire.internal.cache.tier.sockets.*; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientUpdateMessageImpl.CqNameToOp; -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.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.concurrent.StoppableCondition; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantLock; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock.StoppableWriteLock; +package org.apache.geode.internal.cache.ha; + +import org.apache.geode.*; +import org.apache.geode.cache.*; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.query.internal.CqQueryVsdStats; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.cache.util.CacheListenerAdapter; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.*; +import org.apache.geode.internal.cache.tier.sockets.*; +import org.apache.geode.internal.cache.tier.sockets.ClientUpdateMessageImpl.CqNameToOp; +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.logging.log4j.LogMarker; +import org.apache.geode.internal.util.concurrent.StoppableCondition; +import org.apache.geode.internal.util.concurrent.StoppableReentrantLock; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock.StoppableWriteLock; import org.apache.logging.log4j.Logger; import java.io.DataInput; @@ -3621,7 +3621,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#fromData(java.io.DataInput) + * @see org.apache.geode.internal.DataSerializableFixedID#fromData(java.io.DataInput) */ public void fromData(DataInput in) throws IOException, ClassNotFoundException { @@ -3632,14 +3632,14 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ public int getDSFID() { return DISPATCHED_AND_CURRENT_EVENTS; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#toData(java.io.DataOutput) + * @see org.apache.geode.internal.DataSerializableFixedID#toData(java.io.DataOutput) */ public void toData(DataOutput out) throws IOException { synchronized (this) { // fix for bug #41621 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueAttributes.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueAttributes.java index c2ff1a0..190132e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueAttributes.java @@ -17,9 +17,9 @@ /** * */ -package com.gemstone.gemfire.internal.cache.ha; +package org.apache.geode.internal.cache.ha; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionConfig; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueStats.java index 150c080..4441748 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueueStats.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; - -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.internal.statistics.StatisticsTypeFactoryImpl; +package org.apache.geode.internal.cache.ha; + +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.internal.statistics.StatisticsTypeFactoryImpl; /** * This class tracks GemFire statistics related to a {@link HARegionQueue}. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java index 4ffb4d8..07e6465 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueRemovalMessage.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; +package org.apache.geode.internal.cache.ha; import java.io.DataInput; import java.io.DataOutput; @@ -26,19 +26,19 @@ import java.util.concurrent.RejectedExecutionException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.PooledDistributionMessage; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.HARegion; -import com.gemstone.gemfire.internal.cache.LocalRegion; -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.DataSerializer; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.PooledDistributionMessage; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.HARegion; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * This message is sent to all the nodes in the DistributedSystem. It contains http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ha/ThreadIdentifier.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/ThreadIdentifier.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/ThreadIdentifier.java index c2f3785..614b09a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/ThreadIdentifier.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/ThreadIdentifier.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.ha; +package org.apache.geode.internal.cache.ha; import java.io.ByteArrayInputStream; import java.io.DataInput; @@ -23,10 +23,10 @@ import java.io.DataOutput; import java.io.IOException; import java.util.Arrays; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.EventID; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.EventID; /** * Class identifying a Thread uniquely across the distributed system. It is http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLessorDepartureHandler.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLessorDepartureHandler.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLessorDepartureHandler.java index fa323e8..cfbb4e3 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLessorDepartureHandler.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLessorDepartureHandler.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; import java.util.Set; import java.util.concurrent.RejectedExecutionException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.locks.DLockBatch; -import com.gemstone.gemfire.distributed.internal.locks.DLockGrantor; -import com.gemstone.gemfire.distributed.internal.locks.DLockLessorDepartureHandler; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.locks.DLockBatch; +import org.apache.geode.distributed.internal.locks.DLockGrantor; +import org.apache.geode.distributed.internal.locks.DLockLessorDepartureHandler; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.logging.LogService; /** * Handles departure of lessor (lease holder) by sending a message asking http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java index 410aa77..8e7a15f 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockBatch.java @@ -15,21 +15,21 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -//import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.TXRegionLockRequestImpl; -import com.gemstone.gemfire.internal.cache.IdentityArrayList; -import com.gemstone.gemfire.distributed.internal.locks.DLockBatch; -import com.gemstone.gemfire.distributed.internal.locks.DLockBatchId; -import com.gemstone.gemfire.distributed.internal.locks.LockGrantorId; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +//import org.apache.geode.cache.Region; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.TXRegionLockRequestImpl; +import org.apache.geode.internal.cache.IdentityArrayList; +import org.apache.geode.distributed.internal.locks.DLockBatch; +import org.apache.geode.distributed.internal.locks.DLockBatchId; +import org.apache.geode.distributed.internal.locks.LockGrantorId; import java.io.*; import java.util.*; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.membership.*; /** * Adapts multiple TXRegionLockRequests to one DLockBatch for DLock to use. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockId.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockId.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockId.java index e6c355e..067ba78 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockId.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockId.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; -import com.gemstone.gemfire.distributed.internal.locks.DLockBatchId; -import com.gemstone.gemfire.distributed.internal.locks.LockGrantorId; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.locks.DLockBatchId; +import org.apache.geode.distributed.internal.locks.LockGrantorId; +import org.apache.geode.distributed.internal.membership.*; /** Specifies a set of keys to try-lock within the scope of a region */ public interface TXLockId extends DLockBatchId { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java index 7ee67c4..3ffaee2 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockIdImpl.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.DataSerializer; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.DataSerializer; import java.io.*; -import com.gemstone.gemfire.distributed.internal.locks.LockGrantorId; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.locks.LockGrantorId; +import org.apache.geode.distributed.internal.membership.*; /** * Identifies a group of transaction locks. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockService.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockService.java index 18c4caa..6a52d48 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockService.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockService.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.distributed.internal.locks.*; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.distributed.internal.locks.*; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockServiceImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockServiceImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockServiceImpl.java index 6ddd2bc..04963e5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockServiceImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockServiceImpl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; import java.util.ArrayList; import java.util.Collections; @@ -24,16 +24,16 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.locks.LockGrantorId; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.locks.LockGrantorId; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock; /** Provides clean separation of implementation from public facade */ public class TXLockServiceImpl extends TXLockService { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockToken.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockToken.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockToken.java index 2d1568e..3d0cada 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockToken.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockToken.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; +package org.apache.geode.internal.cache.locks; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -//import com.gemstone.gemfire.cache.Region; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +//import org.apache.geode.cache.Region; import java.io.*; import org.apache.commons.lang.StringUtils; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java index 8165cea..135e35f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXLockUpdateParticipantsMessage.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache.locks; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.PooledDistributionMessage; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.locks.DLockGrantor; -import com.gemstone.gemfire.distributed.internal.locks.LockGrantorDestroyedException; +package org.apache.geode.internal.cache.locks; +import org.apache.geode.DataSerializer; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.PooledDistributionMessage; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.locks.DLockGrantor; +import org.apache.geode.distributed.internal.locks.LockGrantorDestroyedException; import java.io.*; import java.util.Set; @@ -37,14 +37,14 @@ import java.util.Set; * crashes/departs before or while sending the TXCommitMessage but * after making the reservation for the transaction. * - * @see com.gemstone.gemfire.internal.cache.TXCommitMessage#send(TXLockId) - * @see com.gemstone.gemfire.internal.cache.TXCommitMessage#updateLockMembers - * @see com.gemstone.gemfire.distributed.internal.locks.DLockGrantor#getLockBatch(Object) - * @see com.gemstone.gemfire.distributed.internal.locks.DLockGrantor#updateLockBatch(Object, com.gemstone.gemfire.distributed.internal.locks.DLockBatch) + * @see org.apache.geode.internal.cache.TXCommitMessage#send(TXLockId) + * @see org.apache.geode.internal.cache.TXCommitMessage#updateLockMembers + * @see org.apache.geode.distributed.internal.locks.DLockGrantor#getLockBatch(Object) + * @see org.apache.geode.distributed.internal.locks.DLockGrantor#updateLockBatch(Object, org.apache.geode.distributed.internal.locks.DLockBatch) * @see TXLockBatch#getBatchId * @see TXLessorDepartureHandler * @see TXOriginatorRecoveryProcessor - * @see com.gemstone.gemfire.internal.cache.TXFarSideCMTracker + * @see org.apache.geode.internal.cache.TXFarSideCMTracker * * @since GemFire 4.1.1 */
