http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueStateImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueStateImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueStateImpl.java index 22e58f6..e387a69 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueStateImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/QueueStateImpl.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.Iterator; @@ -28,18 +28,18 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.internal.cache.ClientServerObserver; -import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.internal.cache.ClientServerObserver; +import org.apache.geode.internal.cache.ClientServerObserverHolder; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.logging.LogService; public class QueueStateImpl implements QueueState { private static final Logger logger = LogService.getLogger();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ReadyForEventsOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ReadyForEventsOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ReadyForEventsOp.java index b516fd7..a2983e2 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ReadyForEventsOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ReadyForEventsOp.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; /** * Tells the server we are ready to receive server-to-client events @@ -43,7 +43,7 @@ public class ReadyForEventsOp { private static class ReadyForEventsOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public ReadyForEventsOpImpl() { super(MessageType.CLIENT_READY, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterDataSerializersOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterDataSerializersOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterDataSerializersOp.java index 869ad64..72b8b1b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterDataSerializersOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterDataSerializersOp.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.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SerializationException; -import com.gemstone.gemfire.internal.InternalDataSerializer.SerializerAttributesHolder; -import com.gemstone.gemfire.internal.cache.ClientServerObserver; -import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.util.BlobHelper; +import org.apache.geode.DataSerializer; +import org.apache.geode.SerializationException; +import org.apache.geode.internal.InternalDataSerializer.SerializerAttributesHolder; +import org.apache.geode.internal.cache.ClientServerObserver; +import org.apache.geode.internal.cache.ClientServerObserverHolder; +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.util.BlobHelper; public class RegisterDataSerializersOp { @@ -51,7 +51,7 @@ public class RegisterDataSerializersOp { private static class RegisterDataSerializersOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public RegisterDataSerializersOpImpl(DataSerializer[] dataSerializers, EventID eventId) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInstantiatorsOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInstantiatorsOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInstantiatorsOp.java index d7a6fa5..aa53dfc 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInstantiatorsOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInstantiatorsOp.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.io.IOException; -import com.gemstone.gemfire.Instantiator; -import com.gemstone.gemfire.SerializationException; -import com.gemstone.gemfire.internal.InternalInstantiator.InstantiatorAttributesHolder; -import com.gemstone.gemfire.internal.cache.ClientServerObserver; -import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.util.BlobHelper; +import org.apache.geode.Instantiator; +import org.apache.geode.SerializationException; +import org.apache.geode.internal.InternalInstantiator.InstantiatorAttributesHolder; +import org.apache.geode.internal.cache.ClientServerObserver; +import org.apache.geode.internal.cache.ClientServerObserverHolder; +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.util.BlobHelper; /** * Register a bunch of instantiators on a server @@ -74,7 +74,7 @@ public class RegisterInstantiatorsOp { private static class RegisterInstantiatorsOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public RegisterInstantiatorsOpImpl(Instantiator[] instantiators, EventID eventId) { @@ -101,7 +101,7 @@ public class RegisterInstantiatorsOp { } /** - * @throws com.gemstone.gemfire.SerializationException + * @throws org.apache.geode.SerializationException * if serialization fails */ public RegisterInstantiatorsOpImpl(Object[] holders, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java index 9497407..e043cbd 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.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.List; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.client.internal.RegisterInterestOp.RegisterInterestOpImpl; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.MessageType; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.client.internal.RegisterInterestOp.RegisterInterestOpImpl; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.MessageType; /** * Does a region registerInterestList on a server @@ -110,7 +110,7 @@ public class RegisterInterestListOp { private static class RegisterInterestListOpImpl extends RegisterInterestOpImpl { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public RegisterInterestListOpImpl(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/RegisterInterestOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java index b790064..8bf45c5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.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 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.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.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.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.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.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.distributed.internal.ServerLocation; import java.util.ArrayList; import java.util.List; @@ -128,7 +128,7 @@ public class RegisterInterestOp { protected static class RegisterInterestOpImpl extends AbstractOp { protected String region; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public RegisterInterestOpImpl(String region, Object key, @@ -157,7 +157,7 @@ public class RegisterInterestOp { } /** * 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 RegisterInterestOpImpl(String region, 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/RegisterInterestTracker.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestTracker.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestTracker.java index 1ba5028..453921f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestTracker.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestTracker.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.List; @@ -24,15 +24,15 @@ import java.util.concurrent.ConcurrentMap; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.internal.cache.tier.sockets.UnregisterAllInterest; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.sockets.UnregisterAllInterest; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Used to keep track of what interest a client has registered. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java index 7e62d00..0ec5317 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.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.Collection; @@ -27,22 +27,22 @@ 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.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.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 removeAll on a server @@ -246,7 +246,7 @@ public class RemoveAllOp { private final Object callbackArg; /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public RemoveAllOpImpl(Region region, Collection<Object> keys, EventID eventId, boolean prSingleHopEnabled, 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/RollbackOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RollbackOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RollbackOp.java index bdaea85..a434257 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RollbackOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RollbackOp.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * Does a Rollback 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/ServerBlackList.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerBlackList.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerBlackList.java index 0edd260..8da1940 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerBlackList.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerBlackList.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.logging.LogService; import org.apache.logging.log4j.Logger; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerProxy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerProxy.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerProxy.java index 137f596..c7db8f9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerProxy.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerProxy.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.List; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.distributed.internal.ServerLocation; /** * Used to send operations from a client to a server. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionDataAccess.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionDataAccess.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionDataAccess.java index c2deb11..aed24ca 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionDataAccess.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionDataAccess.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.Collection; import java.util.List; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.internal.cache.EntryEventImpl; -import com.gemstone.gemfire.internal.cache.EntrySnapshot; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tx.TransactionalOperation; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.internal.cache.EntryEventImpl; +import org.apache.geode.internal.cache.EntrySnapshot; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tx.TransactionalOperation; public interface ServerRegionDataAccess { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionProxy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionProxy.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionProxy.java index 8c6c1d4..3d17f08 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionProxy.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ServerRegionProxy.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.Collection; import java.util.HashMap; @@ -25,37 +25,37 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheLoader; -import com.gemstone.gemfire.cache.CacheWriter; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.cache.client.PoolManager; -import com.gemstone.gemfire.cache.client.internal.ContainsKeyOp.MODE; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.AbstractRegion; -import com.gemstone.gemfire.internal.cache.ClientServerObserver; -import com.gemstone.gemfire.internal.cache.ClientServerObserverHolder; -import com.gemstone.gemfire.internal.cache.EntryEventImpl; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.EventIDHolder; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.TXCommitMessage; -import com.gemstone.gemfire.internal.cache.TXManagerImpl; -import com.gemstone.gemfire.internal.cache.TXStateProxy; -import com.gemstone.gemfire.internal.cache.execute.ServerRegionFunctionExecutor; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList.Iterator; -import com.gemstone.gemfire.internal.cache.tx.ClientTXStateStub; -import com.gemstone.gemfire.internal.cache.tx.TransactionalOperation.ServerRegionOperation; -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.CacheLoader; +import org.apache.geode.cache.CacheWriter; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.cache.client.PoolManager; +import org.apache.geode.cache.client.internal.ContainsKeyOp.MODE; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.AbstractRegion; +import org.apache.geode.internal.cache.ClientServerObserver; +import org.apache.geode.internal.cache.ClientServerObserverHolder; +import org.apache.geode.internal.cache.EntryEventImpl; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.EventIDHolder; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.TXCommitMessage; +import org.apache.geode.internal.cache.TXManagerImpl; +import org.apache.geode.internal.cache.TXStateProxy; +import org.apache.geode.internal.cache.execute.ServerRegionFunctionExecutor; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList.Iterator; +import org.apache.geode.internal.cache.tx.ClientTXStateStub; +import org.apache.geode.internal.cache.tx.TransactionalOperation.ServerRegionOperation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Used to send region operations from a client to a server @@ -105,7 +105,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc } } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#get(java.lang.Object, java.lang.Object) + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#get(java.lang.Object, java.lang.Object) */ public Object get(Object key, Object callbackArg, EntryEventImpl clientEvent) { recordTXOperation(ServerRegionOperation.GET, key, callbackArg); @@ -198,7 +198,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#destroy(java.lang.Object, java.lang.Object, com.gemstone.gemfire.cache.Operation, com.gemstone.gemfire.internal.cache.EventID, java.lang.Object) + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#destroy(java.lang.Object, java.lang.Object, org.apache.geode.cache.Operation, org.apache.geode.internal.cache.EventID, java.lang.Object) */ public Object destroy(Object key, Object expectedOldValue, @@ -275,7 +275,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#clear(com.gemstone.gemfire.internal.cache.EventID, java.lang.Object) + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#clear(org.apache.geode.internal.cache.EventID, java.lang.Object) */ public void clear(EventID eventId, Object callbackArg) @@ -296,7 +296,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc ClearOp.execute(con, this.pool, this.regionName, eventId, callbackArg); } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#containsKey(java.lang.Object) + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#containsKey(java.lang.Object) */ public boolean containsKey(Object key) { recordTXOperation(ServerRegionOperation.CONTAINS_KEY, key); @@ -304,7 +304,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#containsKey(java.lang.Object) + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#containsKey(java.lang.Object) */ public boolean containsValueForKey(Object key) { recordTXOperation(ServerRegionOperation.CONTAINS_VALUE_FOR_KEY, key); @@ -312,7 +312,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#containsKey(java.lang.Object) + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#containsKey(java.lang.Object) */ public boolean containsValue(Object value) { recordTXOperation(ServerRegionOperation.CONTAINS_VALUE, null, value); @@ -320,7 +320,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess#keySet() + * @see org.apache.geode.cache.client.internal.ServerRegionDataAccess#keySet() */ public Set keySet() { recordTXOperation(ServerRegionOperation.KEY_SET, null); @@ -844,7 +844,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc /** * Transaction synchronization notification to the servers - * @see com.gemstone.gemfire.internal.cache.tx.ClientTXStateStub#beforeCompletion() + * @see org.apache.geode.internal.cache.tx.ClientTXStateStub#beforeCompletion() */ public void beforeCompletion(int txId) { TXSynchronizationOp.execute(pool, 0, txId, TXSynchronizationOp.CompletionType.BEFORE_COMPLETION); @@ -854,7 +854,7 @@ public class ServerRegionProxy extends ServerProxy implements ServerRegionDataAc * Transaction synchronization notification to the servers * @param status * @return the server's TXCommitMessage - * @see com.gemstone.gemfire.internal.cache.tx.ClientTXStateStub#afterCompletion(int) + * @see org.apache.geode.internal.cache.tx.ClientTXStateStub#afterCompletion(int) */ public TXCommitMessage afterCompletion(int status, int txId) { return TXSynchronizationOp.execute(pool, status, txId, TXSynchronizationOp.CompletionType.AFTER_COMPLETION); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopClientExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopClientExecutor.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopClientExecutor.java index c13cfea..cff40ac 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopClientExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopClientExecutor.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.HashMap; import java.util.HashSet; @@ -31,25 +31,25 @@ import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicInteger; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.GemFireException; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.client.ServerConnectivityException; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.cache.client.internal.GetAllOp.GetAllOpImpl; -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.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException; -import com.gemstone.gemfire.internal.cache.execute.BucketMovedException; -import com.gemstone.gemfire.internal.cache.execute.InternalFunctionInvocationTargetException; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -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.GemFireException; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.client.ServerConnectivityException; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.cache.client.internal.GetAllOp.GetAllOpImpl; +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.internal.ServerLocation; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PutAllPartialResultException; +import org.apache.geode.internal.cache.execute.BucketMovedException; +import org.apache.geode.internal.cache.execute.InternalFunctionInvocationTargetException; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; public class SingleHopClientExecutor { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopOperationCallable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopOperationCallable.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopOperationCallable.java index a42ba8d..002d4bd 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopOperationCallable.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SingleHopOperationCallable.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; import java.util.concurrent.Callable; -import com.gemstone.gemfire.cache.client.AllConnectionsInUseException; -import com.gemstone.gemfire.cache.client.internal.ExecuteRegionFunctionOp.ExecuteRegionFunctionOpImpl; -import com.gemstone.gemfire.cache.client.internal.ExecuteRegionFunctionSingleHopOp.ExecuteRegionFunctionSingleHopOpImpl; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.cache.client.AllConnectionsInUseException; +import org.apache.geode.cache.client.internal.ExecuteRegionFunctionOp.ExecuteRegionFunctionOpImpl; +import org.apache.geode.cache.client.internal.ExecuteRegionFunctionSingleHopOp.ExecuteRegionFunctionSingleHopOpImpl; +import org.apache.geode.distributed.internal.ServerLocation; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java index 170e846..1c8e8fe 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * Does a region size on a server @@ -43,7 +43,7 @@ public class SizeOp { private static class SizeOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public SizeOpImpl(String region) { super(MessageType.SIZE, 1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXFailoverOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXFailoverOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXFailoverOp.java index 0c5628d..f5a8334 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXFailoverOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXFailoverOp.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; /** * Indicates to the server that a transaction is http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXSynchronizationOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXSynchronizationOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXSynchronizationOp.java index ee348a8..c6dea22 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXSynchronizationOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/TXSynchronizationOp.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.GemFireException; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.SynchronizationCommitConflictException; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.internal.cache.TXCommitMessage; -import com.gemstone.gemfire.internal.cache.TXManagerImpl; -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.GemFireException; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.SynchronizationCommitConflictException; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.internal.cache.TXCommitMessage; +import org.apache.geode.internal.cache.TXManagerImpl; +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; /** * TXSynchronizationOp sends JTA beforeCompletion and afterCompletion @@ -101,7 +101,7 @@ public class TXSynchronizationOp { /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.AbstractOp#processResponse(com.gemstone.gemfire.internal.cache.tier.sockets.Message) + * @see org.apache.geode.cache.client.internal.AbstractOp#processResponse(org.apache.geode.internal.cache.tier.sockets.Message) */ @Override protected Object processResponse(Message msg) throws Exception { @@ -122,7 +122,7 @@ public class TXSynchronizationOp { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.AbstractOp#isErrorResponse(int) + * @see org.apache.geode.cache.client.internal.AbstractOp#isErrorResponse(int) */ @Override protected boolean isErrorResponse(int msgType) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java index b408bf5..2d55c9d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.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; @@ -52,7 +52,7 @@ public class UnregisterInterestListOp { private static class UnregisterInterestListOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public UnregisterInterestListOpImpl(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/UnregisterInterestOp.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java index b266e60..3716587 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal; +package org.apache.geode.cache.client.internal; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.cache.tier.InterestType; /** * Does a region unregisterInterest on a server @@ -52,7 +52,7 @@ public class UnregisterInterestOp { private static class UnregisterInterestOpImpl extends AbstractOp { /** - * @throws com.gemstone.gemfire.SerializationException if serialization fails + * @throws org.apache.geode.SerializationException if serialization fails */ public UnregisterInterestOpImpl(String region, Object key, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/UserAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UserAttributes.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UserAttributes.java index cfb8d50..99939e1 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UserAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UserAttributes.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.Properties; import java.util.concurrent.ConcurrentHashMap; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.distributed.internal.ServerLocation; public class UserAttributes { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionRequest.java index dee109e..729032d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionRequest.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.Set; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.internal.DataSerializableFixedID; /** * A request from a client to the locator asking for a http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionResponse.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionResponse.java index 18d4037..d70a46a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionResponse.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientConnectionResponse.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.DataSerializableFixedID; /** * A response from a locator to a client http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientReplacementRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientReplacementRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientReplacementRequest.java index 5a2ba7f..c3898c3 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientReplacementRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ClientReplacementRequest.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.Set; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.InternalDataSerializer; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.InternalDataSerializer; /** * A request from a client to the locator asking for a http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersRequest.java index 858675d..12bda7e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersRequest.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.internal.DataSerializableFixedID; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersResponse.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersResponse.java index b50ab4a..7f9c6af 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersResponse.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/GetAllServersResponse.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; @@ -22,9 +22,9 @@ import java.io.IOException; import java.util.ArrayList; import java.util.List; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.DataSerializableFixedID; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListRequest.java index 2128047..414292f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListRequest.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal.locator; +package org.apache.geode.cache.client.internal.locator; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.internal.DataSerializableFixedID; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListResponse.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListResponse.java index bed21ee..193363b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListResponse.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorListResponse.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; @@ -22,8 +22,8 @@ import java.io.IOException; import java.util.ArrayList; import java.util.List; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.DataSerializableFixedID; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusRequest.java index 99f9191..5d93e68 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusRequest.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal.locator; +package org.apache.geode.cache.client.internal.locator; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.internal.DataSerializableFixedID; /** * The LocatorStatusRequest class... * </p> - * @see com.gemstone.gemfire.cache.client.internal.locator.ServerLocationRequest - * @see com.gemstone.gemfire.internal.DataSerializableFixedID + * @see org.apache.geode.cache.client.internal.locator.ServerLocationRequest + * @see org.apache.geode.internal.DataSerializableFixedID * @since GemFire 7.0 */ public class LocatorStatusRequest extends ServerLocationRequest { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusResponse.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusResponse.java index 07aaf33..0affa8c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusResponse.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/LocatorStatusResponse.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; @@ -26,17 +26,17 @@ import java.util.ArrayList; import java.util.Collections; import java.util.List; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.GemFireVersion; -import com.gemstone.gemfire.internal.lang.ObjectUtils; -import com.gemstone.gemfire.internal.lang.StringUtils; -import com.gemstone.gemfire.internal.process.PidUnavailableException; -import com.gemstone.gemfire.internal.process.ProcessUtils; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.GemFireVersion; +import org.apache.geode.internal.lang.ObjectUtils; +import org.apache.geode.internal.lang.StringUtils; +import org.apache.geode.internal.process.PidUnavailableException; +import org.apache.geode.internal.process.ProcessUtils; /** * The LocatorStatusResponse class... * </p> - * @see com.gemstone.gemfire.cache.client.internal.locator.ServerLocationResponse + * @see org.apache.geode.cache.client.internal.locator.ServerLocationResponse * @since GemFire 7.0 */ public class LocatorStatusResponse extends ServerLocationResponse { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionRequest.java index cbbfe91..49e039e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionRequest.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.Set; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.DataSerializer; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; /** * A request from a client to locator asking for a server http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionResponse.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionResponse.java index ed36883..356ff64 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionResponse.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/QueueConnectionResponse.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.List; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.DataSerializableFixedID; +import org.apache.geode.DataSerializer; +import org.apache.geode.internal.DataSerializableFixedID; /** * A response from locator to client indicating the servers http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/SerializationHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/SerializationHelper.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/SerializationHelper.java index fbcdcf6..cee4e4d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/SerializationHelper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/SerializationHelper.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; @@ -26,9 +26,9 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.BucketServerLocation66; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.BucketServerLocation66; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationRequest.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationRequest.java index 8c963b7..aaf5919 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationRequest.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationRequest.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.locator; +package org.apache.geode.cache.client.internal.locator; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.DataSerializer; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationResponse.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationResponse.java index 23047ce..fc04b5f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationResponse.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/ServerLocationResponse.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.locator; +package org.apache.geode.cache.client.internal.locator; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/wan/LocatorMembershipListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/wan/LocatorMembershipListener.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/wan/LocatorMembershipListener.java index 3ee08a1..aae9b3d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/wan/LocatorMembershipListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/locator/wan/LocatorMembershipListener.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.locator.wan; +package org.apache.geode.cache.client.internal.locator.wan; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.admin.remote.DistributionLocatorId; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.admin.remote.DistributionLocatorId; import java.util.Set; import java.util.concurrent.ConcurrentMap; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionDestroyedException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionDestroyedException.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionDestroyedException.java index 12e1959..643e1c8 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionDestroyedException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionDestroyedException.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.client.internal.pooling; +package org.apache.geode.cache.client.internal.pooling; -import com.gemstone.gemfire.GemFireException; +import org.apache.geode.GemFireException; /** * Indicates that the current connection has already been destroyed. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManager.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManager.java index 2f25222..dc293a3 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManager.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManager.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.pooling; +package org.apache.geode.cache.client.internal.pooling; import java.util.Set; import java.util.concurrent.ScheduledExecutorService; -import com.gemstone.gemfire.cache.client.AllConnectionsInUseException; -import com.gemstone.gemfire.cache.client.NoAvailableServersException; -import com.gemstone.gemfire.cache.client.internal.Connection; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.cache.client.AllConnectionsInUseException; +import org.apache.geode.cache.client.NoAvailableServersException; +import org.apache.geode.cache.client.internal.Connection; +import org.apache.geode.distributed.internal.ServerLocation; /** * A pool for managing client to server connections. This interface http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManagerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManagerImpl.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManagerImpl.java index e7eb3c0..4bc6dad 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/ConnectionManagerImpl.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.pooling; +package org.apache.geode.cache.client.internal.pooling; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.GatewayConfigurationException; -import com.gemstone.gemfire.cache.client.*; -import com.gemstone.gemfire.cache.client.internal.*; -import com.gemstone.gemfire.cache.client.internal.PoolImpl.PoolTask; -import com.gemstone.gemfire.distributed.PoolCancelledException; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.i18n.StringId; -import com.gemstone.gemfire.internal.cache.PoolManagerImpl; -import com.gemstone.gemfire.internal.cache.PoolStats; -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 org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.GatewayConfigurationException; +import org.apache.geode.cache.client.*; +import org.apache.geode.cache.client.internal.*; +import org.apache.geode.cache.client.internal.PoolImpl.PoolTask; +import org.apache.geode.distributed.PoolCancelledException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.i18n.StringId; +import org.apache.geode.internal.cache.PoolManagerImpl; +import org.apache.geode.internal.cache.PoolStats; +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.logging.log4j.Logger; import java.net.SocketException; @@ -141,7 +141,7 @@ public class ConnectionManagerImpl implements ConnectionManager { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManager#borrowConnection(long) + * @see org.apache.geode.cache.client.internal.pooling.ConnectionManager#borrowConnection(long) */ public Connection borrowConnection(long acquireTimeout) throws AllConnectionsInUseException, NoAvailableServersException { @@ -464,7 +464,7 @@ public class ConnectionManagerImpl implements ConnectionManager { /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManager#invalidateServer(com.gemstone.gemfire.distributed.internal.ServerLocation) + * @see org.apache.geode.cache.client.internal.pooling.ConnectionManager#invalidateServer(org.apache.geode.distributed.internal.ServerLocation) */ protected void invalidateServer(Endpoint endpoint) { Set badConnections = allConnectionsMap.removeEndpoint(endpoint); @@ -524,7 +524,7 @@ public class ConnectionManagerImpl implements ConnectionManager { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManager#returnConnection(com.gemstone.gemfire.cache.client.internal.Connection) + * @see org.apache.geode.cache.client.internal.pooling.ConnectionManager#returnConnection(org.apache.geode.cache.client.internal.Connection) */ public void returnConnection(Connection connection) { returnConnection(connection, true); @@ -611,7 +611,7 @@ public class ConnectionManagerImpl implements ConnectionManager { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.client.internal.pooling.ConnectionManager#close(boolean, long) + * @see org.apache.geode.cache.client.internal.pooling.ConnectionManager#close(boolean, long) */ public void close(boolean keepAlive) { if(logger.isDebugEnabled()) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/PooledConnection.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/PooledConnection.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/PooledConnection.java index 7dcbaad..fd469e7 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/PooledConnection.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/pooling/PooledConnection.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.pooling; +package org.apache.geode.cache.client.internal.pooling; import java.io.InputStream; import java.io.OutputStream; @@ -23,14 +23,14 @@ import java.net.SocketException; import java.nio.ByteBuffer; import java.util.concurrent.atomic.AtomicBoolean; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.cache.client.internal.Connection; -import com.gemstone.gemfire.cache.client.internal.ConnectionImpl; -import com.gemstone.gemfire.cache.client.internal.ConnectionStats; -import com.gemstone.gemfire.cache.client.internal.Endpoint; -import com.gemstone.gemfire.cache.client.internal.Op; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerQueueStatus; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.cache.client.internal.Connection; +import org.apache.geode.cache.client.internal.ConnectionImpl; +import org.apache.geode.cache.client.internal.ConnectionStats; +import org.apache.geode.cache.client.internal.Endpoint; +import org.apache.geode.cache.client.internal.Op; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.ServerQueueStatus; /** * A connection managed by the connection manager. Keeps track http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/client/package.html ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/package.html b/geode-core/src/main/java/org/apache/geode/cache/client/package.html index 9898040..598c7a4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/package.html +++ b/geode-core/src/main/java/org/apache/geode/cache/client/package.html @@ -17,27 +17,27 @@ limitations under the License. --> <HTML> <HEAD> - <TITLE>com.gemstone.gemfire.cache.client package</TITLE> + <TITLE>org.apache.geode.cache.client package</TITLE> </HEAD> <BODY> - The <code>com.gemstone.gemfire.cache.client</code> package provides APIs used + The <code>org.apache.geode.cache.client</code> package provides APIs used for client connectivity and caching. <p> Most clients will only need to create a -{@link com.gemstone.gemfire.cache.client.ClientCache} +{@link org.apache.geode.cache.client.ClientCache} using a -{@link com.gemstone.gemfire.cache.client.ClientCacheFactory}. +{@link org.apache.geode.cache.client.ClientCacheFactory}. <p> A client configures the servers it will connect to by creating one or more -{@link com.gemstone.gemfire.cache.client.Pool pools}. +{@link org.apache.geode.cache.client.Pool pools}. For most use cases one pool per client is all you need and the easiest way to get a single pool is to use -{@link com.gemstone.gemfire.cache.client.ClientCacheFactory}. +{@link org.apache.geode.cache.client.ClientCacheFactory}. If you do need more than one pool use a -{@link com.gemstone.gemfire.cache.client.PoolFactory pool factory} obtained from the -{@link com.gemstone.gemfire.cache.client.PoolManager pool manager} before you +{@link org.apache.geode.cache.client.PoolFactory pool factory} obtained from the +{@link org.apache.geode.cache.client.PoolManager pool manager} before you create the cache using -{@link com.gemstone.gemfire.cache.client.ClientCacheFactory}. +{@link org.apache.geode.cache.client.ClientCacheFactory}. <p> An alternative to these APIs is to use the <code>pool</code> XML element as described in the <code>cache6_5.dtd</code>. @@ -46,7 +46,7 @@ If you create more than one pool then for regions that will use a pool you need to configure the pool name on the regions. This can be done by setting the pool name on the region using the -{@link com.gemstone.gemfire.cache.client.ClientRegionFactory#setPoolName API} +{@link org.apache.geode.cache.client.ClientRegionFactory#setPoolName API} or using the <code>pool-name</code> attribute on the <code>region-attributes</code> as described in the <code>cache6_5.dtd</code>. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceFactory.java b/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceFactory.java index 49ff30c..c2b3842 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceFactory.java +++ b/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.control; +package org.apache.geode.cache.control; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceOperation.java b/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceOperation.java index 0051423..b3da0c9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceOperation.java +++ b/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceOperation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.control; +package org.apache.geode.cache.control; import java.util.concurrent.CancellationException; import java.util.concurrent.TimeUnit; @@ -23,7 +23,7 @@ import java.util.concurrent.TimeoutException; /** * Operation for rebalancing resources used by the {@link - * com.gemstone.gemfire.cache.Cache}. + * org.apache.geode.cache.Cache}. * * @since GemFire 6.0 */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceResults.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceResults.java b/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceResults.java index be0d3d2..b2b1f79 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceResults.java +++ b/geode-core/src/main/java/org/apache/geode/cache/control/RebalanceResults.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.control; +package org.apache.geode.cache.control; import java.util.Set; -import com.gemstone.gemfire.cache.partition.PartitionRebalanceInfo; +import org.apache.geode.cache.partition.PartitionRebalanceInfo; /** * The results of rebalancing <code>Cache</code> resources. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/control/ResourceManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/control/ResourceManager.java b/geode-core/src/main/java/org/apache/geode/cache/control/ResourceManager.java index 3226b24..1738be5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/control/ResourceManager.java +++ b/geode-core/src/main/java/org/apache/geode/cache/control/ResourceManager.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.control; +package org.apache.geode.cache.control; import java.util.Set; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.LowMemoryException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.query.QueryService; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.LowMemoryException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.query.QueryService; /** * Provides support for managing resources used by the local - * {@link com.gemstone.gemfire.cache.Cache}. + * {@link org.apache.geode.cache.Cache}. * <p> * Re-balancing the GemFire Cache resources can be accomplished using a {@link * RebalanceOperation}: @@ -95,7 +95,7 @@ public interface ResourceManager { * <li>{@link Region#create(Object, Object)} * <li>{@link Region#create(Object, Object, Object)} * <li>{@link Region#putAll(java.util.Map)} - * <li>{@linkplain QueryService#createIndex(String, com.gemstone.gemfire.cache.query.IndexType, String, String) index creation} + * <li>{@linkplain QueryService#createIndex(String, org.apache.geode.cache.query.IndexType, String, String) index creation} * <li>Execution of {@link Function}s whose {@link Function#optimizeForWrite()} returns true. * </ul> * @@ -158,7 +158,7 @@ public interface ResourceManager { * <li>{@link Region#create(Object, Object)} * <li>{@link Region#create(Object, Object, Object)} * <li>{@link Region#putAll(java.util.Map)} - * <li>{@linkplain QueryService#createIndex(String, com.gemstone.gemfire.cache.query.IndexType, String, String) index creation} + * <li>{@linkplain QueryService#createIndex(String, org.apache.geode.cache.query.IndexType, String, String) index creation} * <li>Execution of {@link Function}s whose {@link Function#optimizeForWrite()} returns true. * </ul> *
