ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [3/3] incubator-ignite git commit: # Renaming
Date Fri, 05 Dec 2014 10:56:17 GMT
# Renaming


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b7a63383
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b7a63383
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b7a63383

Branch: refs/heads/master
Commit: b7a633832dfb5faa7591e2b2b620fa7729bd3dba
Parents: 650cb88
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Dec 5 13:33:49 2014 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Dec 5 13:33:49 2014 +0300

----------------------------------------------------------------------
 .../src/main/java/org/apache/ignite/Ignite.java |    8 -
 .../configuration/IgniteConfiguration.java      |   76 -
 .../grid/cache/GridCacheConfiguration.java      |   48 -
 .../main/java/org/gridgain/grid/dr/GridDr.java  |  271 ---
 .../java/org/gridgain/grid/dr/GridDrEntry.java  |   73 -
 .../org/gridgain/grid/dr/cache/package.html     |   17 -
 .../GridDrReceiverCacheConfiguration.java       |  102 --
 .../GridDrReceiverCacheConflictContext.java     |   71 -
 .../GridDrReceiverCacheConflictResolver.java    |   27 -
 ...GridDrReceiverCacheConflictResolverMode.java |   63 -
 .../receiver/GridDrReceiverCacheMetrics.java    |   46 -
 .../grid/dr/cache/receiver/package.html         |   17 -
 .../grid/dr/cache/sender/GridDrPauseReason.java |   46 -
 .../sender/GridDrSenderCacheConfiguration.java  |  277 ---
 .../sender/GridDrSenderCacheEntryFilter.java    |   25 -
 .../cache/sender/GridDrSenderCacheMetrics.java  |   76 -
 .../dr/cache/sender/GridDrSenderCacheMode.java  |   40 -
 .../sender/GridDrStateTransferDescriptor.java   |   94 -
 .../grid/dr/cache/sender/GridDrStatus.java      |   94 -
 .../gridgain/grid/dr/cache/sender/package.html  |   17 -
 .../java/org/gridgain/grid/dr/hub/package.html  |   17 -
 .../GridDrReceiverHubConfiguration.java         |  369 ----
 .../receiver/GridDrReceiverHubInMetrics.java    |   37 -
 .../GridDrReceiverHubLoadBalancingMode.java     |   26 -
 .../dr/hub/receiver/GridDrReceiverHubMBean.java |  122 --
 .../receiver/GridDrReceiverHubOutMetrics.java   |   65 -
 .../gridgain/grid/dr/hub/receiver/package.html  |   17 -
 .../sender/GridDrSenderHubConfiguration.java    |  334 ----
 .../GridDrSenderHubConnectionConfiguration.java |  194 --
 .../dr/hub/sender/GridDrSenderHubInMetrics.java |   37 -
 .../GridDrSenderHubLoadBalancingMode.java       |   41 -
 .../dr/hub/sender/GridDrSenderHubMBean.java     |  110 --
 .../hub/sender/GridDrSenderHubOutMetrics.java   |   66 -
 .../gridgain/grid/dr/hub/sender/package.html    |   17 -
 .../hub/sender/store/GridDrSenderHubStore.java  |   45 -
 .../GridDrSenderHubStoreCorruptedException.java |   29 -
 .../store/GridDrSenderHubStoreCursor.java       |   27 -
 .../sender/store/GridDrSenderHubStoreEntry.java |   25 -
 .../GridDrSenderHubStoreOverflowException.java  |   27 -
 .../store/GridDrSenderHubStoreOverflowMode.java |   36 -
 .../sender/store/fs/GridDrSenderHubFsStore.java | 1708 ------------------
 .../grid/dr/hub/sender/store/fs/package.html    |   17 -
 .../memory/GridDrSenderHubInMemoryStore.java    |  323 ----
 .../dr/hub/sender/store/memory/package.html     |   17 -
 .../grid/dr/hub/sender/store/package.html       |   17 -
 .../main/java/org/gridgain/grid/dr/package.html |   17 -
 .../org/gridgain/grid/kernal/GridKernal.java    |    7 -
 .../processors/cache/dr/GridCacheDrManager.java |    2 -
 .../java/org/gridgain/grid/GridSpringBean.java  |    8 -
 49 files changed, 5245 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/apache/ignite/Ignite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/Ignite.java b/modules/core/src/main/java/org/apache/ignite/Ignite.java
index ae706f8..a6ff544 100644
--- a/modules/core/src/main/java/org/apache/ignite/Ignite.java
+++ b/modules/core/src/main/java/org/apache/ignite/Ignite.java
@@ -15,7 +15,6 @@ import org.apache.ignite.plugin.*;
 import org.apache.ignite.product.*;
 import org.gridgain.grid.*;
 import org.gridgain.grid.cache.*;
-import org.gridgain.grid.dr.*;
 import org.gridgain.grid.hadoop.*;
 import org.gridgain.grid.security.*;
 import org.gridgain.grid.util.typedef.*;
@@ -198,13 +197,6 @@ public interface Ignite extends AutoCloseable {
     public IgnitePortables portables();
 
     /**
-     * Gets an instance of Data Center Replication.
-     *
-     * @return Instance of Data Center Replication.
-     */
-    public GridDr dr();
-
-    /**
      * Gets the cache instance for the given name, if one does not
      * exist {@link IllegalArgumentException} will be thrown.
      * Note that in case named cache instance is used as GGFS data or meta cache, {@link IllegalStateException}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
index 13b135c..6918512 100644
--- a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
@@ -23,8 +23,6 @@ import org.gridgain.client.ssl.*;
 import org.gridgain.grid.*;
 import org.gridgain.grid.cache.*;
 import org.gridgain.grid.dotnet.*;
-import org.gridgain.grid.dr.hub.receiver.*;
-import org.gridgain.grid.dr.hub.sender.*;
 import org.gridgain.grid.hadoop.*;
 import org.gridgain.grid.kernal.managers.eventstorage.*;
 import org.gridgain.grid.security.*;
@@ -513,15 +511,6 @@ public class IgniteConfiguration {
     /** Streamer configuration. */
     private StreamerConfiguration[] streamerCfg;
 
-    /** Data center receiver hub configuration. */
-    private GridDrReceiverHubConfiguration drRcvHubCfg;
-
-    /** Data center sender hub configuration. */
-    private GridDrSenderHubConfiguration drSndHubCfg;
-
-    /** Data center ID. */
-    private byte dataCenterId;
-
     /** Security credentials. */
     private GridSecurityCredentialsProvider securityCred;
 
@@ -584,13 +573,8 @@ public class IgniteConfiguration {
         clientMsgInterceptor = cfg.getClientMessageInterceptor();
         clockSyncFreq = cfg.getClockSyncFrequency();
         clockSyncSamples = cfg.getClockSyncSamples();
-        dataCenterId = cfg.getDataCenterId();
         deployMode = cfg.getDeploymentMode();
         discoStartupDelay = cfg.getDiscoveryStartupDelay();
-        drRcvHubCfg = cfg.getDrReceiverHubConfiguration() != null ?
-            new GridDrReceiverHubConfiguration(cfg.getDrReceiverHubConfiguration()) : null;
-        drSndHubCfg = cfg.getDrSenderHubConfiguration() != null ?
-            new GridDrSenderHubConfiguration(cfg.getDrSenderHubConfiguration()) : null;
         execSvc = cfg.getExecutorService();
         execSvcShutdown = cfg.getExecutorServiceShutdown();
         ggHome = cfg.getGridGainHome();
@@ -3015,66 +2999,6 @@ public class IgniteConfiguration {
     }
 
     /**
-     * Set data center receiver hub configuration.
-     *
-     * @return Data center receiver hub configuration.
-     */
-    public GridDrReceiverHubConfiguration getDrReceiverHubConfiguration() {
-        return drRcvHubCfg;
-    }
-
-    /**
-     * Set data center sender hub configuration.
-     *
-     * @param drRcvHubCfg Data center sender hub configuration.
-     */
-    public void setDrReceiverHubConfiguration(GridDrReceiverHubConfiguration drRcvHubCfg) {
-        this.drRcvHubCfg = drRcvHubCfg;
-    }
-
-    /**
-     * Get data center sender hub configuration.
-     *
-     * @return Data center sender hub configuration.
-     */
-    public GridDrSenderHubConfiguration getDrSenderHubConfiguration() {
-        return drSndHubCfg;
-    }
-
-    /**
-     * Set data center receiver hub configuration.
-     *
-     * @param drSndHubCfg Data center receiver hub configuration.
-     */
-    public void setDrSenderHubConfiguration(GridDrSenderHubConfiguration drSndHubCfg) {
-        this.drSndHubCfg = drSndHubCfg;
-    }
-
-    /**
-     * Gets data center ID of the grid.
-     * <p>
-     * It is expected that data center ID will be unique among all the topologies participating in data center
-     * replication and the same for all the nodes that belong the given topology.
-     *
-     * @return Data center ID or {@code 0} if it is not set.
-     */
-    public byte getDataCenterId() {
-        return dataCenterId;
-    }
-
-    /**
-     * Sets data center ID of the grid.
-     * <p>
-     * It is expected that data center ID will be unique among all the topologies participating in data center
-     * replication and the same for all the nodes that belong the given topology.
-     *
-     * @param dataCenterId Data center ID.
-     */
-    public void setDataCenterId(byte dataCenterId) {
-        this.dataCenterId = dataCenterId;
-    }
-
-    /**
      * Gets hadoop configuration.
      *
      * @return Hadoop configuration.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/cache/GridCacheConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/cache/GridCacheConfiguration.java b/modules/core/src/main/java/org/gridgain/grid/cache/GridCacheConfiguration.java
index 2875721..054a234 100644
--- a/modules/core/src/main/java/org/gridgain/grid/cache/GridCacheConfiguration.java
+++ b/modules/core/src/main/java/org/gridgain/grid/cache/GridCacheConfiguration.java
@@ -16,8 +16,6 @@ import org.gridgain.grid.cache.datastructures.*;
 import org.gridgain.grid.cache.eviction.*;
 import org.gridgain.grid.cache.query.*;
 import org.gridgain.grid.cache.store.*;
-import org.gridgain.grid.dr.cache.receiver.*;
-import org.gridgain.grid.dr.cache.sender.*;
 import org.gridgain.grid.spi.indexing.*;
 import org.gridgain.grid.util.typedef.internal.*;
 import org.jetbrains.annotations.*;
@@ -334,12 +332,6 @@ public class GridCacheConfiguration {
     private long preloadThrottle = DFLT_PRELOAD_THROTTLE;
 
     /** */
-    private GridDrReceiverCacheConfiguration drRcvCacheCfg;
-
-    /** */
-    private GridDrSenderCacheConfiguration drSndCacheCfg;
-
-    /** */
     private GridCacheInterceptor<?, ?> interceptor;
 
     /** */
@@ -376,10 +368,6 @@ public class GridCacheConfiguration {
         dgcRmvLocks = cc.isDgcRemoveLocks();
         dgcSuspectLockTimeout = cc.getDgcSuspectLockTimeout();
         distro = cc.getDistributionMode();
-        drSndCacheCfg = cc.getDrSenderConfiguration() != null ?
-            new GridDrSenderCacheConfiguration(cc.getDrSenderConfiguration()) : null;
-        drRcvCacheCfg = cc.getDrReceiverConfiguration() != null ?
-            new GridDrReceiverCacheConfiguration(cc.getDrReceiverConfiguration()) : null;
         eagerTtl = cc.isEagerTtl();
         evictFilter = cc.getEvictionFilter();
         evictKeyBufSize = cc.getEvictSynchronizedKeyBufferSize();
@@ -1732,42 +1720,6 @@ public class GridCacheConfiguration {
     }
 
     /**
-     * Gets data center replication send configuration.
-     *
-     * @return Data center replication send configuration.
-     */
-    @Nullable public GridDrSenderCacheConfiguration getDrSenderConfiguration() {
-        return drSndCacheCfg;
-    }
-
-    /**
-     * Sets data center replication send configuration. See {@link #getDrSenderConfiguration} for more information.
-     *
-     * @param drSndCacheCfg Data center replication send configuration.
-     */
-    public void setDrSenderConfiguration(GridDrSenderCacheConfiguration drSndCacheCfg) {
-        this.drSndCacheCfg = drSndCacheCfg;
-    }
-
-    /**
-     * Gets data center replication receive configuration.
-     *
-     * @return Data center replication receive configuration.
-     */
-    @Nullable public GridDrReceiverCacheConfiguration getDrReceiverConfiguration() {
-        return drRcvCacheCfg;
-    }
-
-    /**
-     * Sets data center replication receive configuration. See {@link #getDrReceiverConfiguration} for more information.
-     *
-     * @param drRcvCacheCfg Data center replication receive configuration.
-     */
-    public void setDrReceiverConfiguration(GridDrReceiverCacheConfiguration drRcvCacheCfg) {
-        this.drRcvCacheCfg = drRcvCacheCfg;
-    }
-
-    /**
      * Gets cache interceptor.
      *
      * @return Cache interceptor.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/GridDr.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/GridDr.java b/modules/core/src/main/java/org/gridgain/grid/dr/GridDr.java
deleted file mode 100644
index 9890f9d..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/GridDr.java
+++ /dev/null
@@ -1,271 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr;
-
-import org.apache.ignite.lang.*;
-import org.gridgain.grid.cache.*;
-import org.gridgain.grid.dr.cache.receiver.*;
-import org.gridgain.grid.dr.cache.sender.*;
-import org.gridgain.grid.dr.hub.receiver.*;
-import org.gridgain.grid.dr.hub.sender.*;
-import org.jetbrains.annotations.*;
-
-import java.util.*;
-
-/**
- * Data center replication (DR) interface.
- * <p>
- * DR is a process of transferring updates from a cache located in one topology to a cache located in another topology.
- * Usual use case for DR is synchronizing cache state between several geographically remote topologies through WAN.
- * <p>
- * DR operates on the following terms:
- * <ul>
- *     <li><b>Data center</b> - particular GridGain topology with unique ID;</li>
- *     <li><b>Sender cache</b> - cache from which data is being replicated;</li>
- *     <li><b>Receiver cache</b> - cache which applies updates from remote data center;</li>
- *     <li><b>Sender hub</b> - node which accumulates updates from sender data nodes and sends that to receiver hub in
- *     remote data center;</li>
- *     <li><b>receiver hub</b> - node which receives updates from remote data center sender hub and applies them to
- *     receiver data nodes.</li>
- * </ul>
- *
- * Cache is considered as sender in case it has {@link GridCacheConfiguration#getDrSenderConfiguration()}, and it is
- * considered as receiver cache in case it has {@link GridCacheConfiguration#getDrReceiverConfiguration()}.
- * <p>
- * Node is considered as sender hub in case it has {@link org.apache.ignite.configuration.IgniteConfiguration#getDrSenderHubConfiguration()},
- * and it is considered as receiver hub in case it has
- * {@link org.apache.ignite.configuration.IgniteConfiguration#getDrReceiverHubConfiguration()}.
- * <p>
- * Particular cache can be both sender and receiver at the same time. Particular node can be both sender and receiver
- * hub and host sender/receiver caches at the same time.
- * <p>
- * This API provides ability to manage DR process on sender cache node as well as get metrics for sender cache,
- * receiver cache, sender hub and receiver hub.
- */
-public interface GridDr {
-    /**
-     * Starts full state transfer for the given sender cache.
-     * <p>
-     * In case node doesn't have cache with the given name or this cache is not sender cache, an exception will be
-     * thrown.
-     * <p>
-     * Only one state transfer for particular cache and data center is allowed at a time. In case another state
-     * transfer for the given cache and data center had been already in progress when this method was called,
-     * then no new state transfer for this (cache name, data center) pair will be initiated and returned future
-     * will "join" existing state transfer.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not sender cache or grid is stopping then {@link IllegalStateException}
-     * will be thrown.
-     *
-     * @param cacheName Sender cache name.
-     * @param dataCenterId Remote data center IDs for which full state transfer was requested.
-     * @return Future that will be completed when all required data is transferred from sender caches to sender hubs.
-     */
-    public IgniteFuture<?> senderCacheDrStateTransfer(String cacheName, byte... dataCenterId);
-
-    /**
-     * List all currently active state transfer for the given sender cache.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not sender cache or grid is stopping then {@link IllegalStateException}
-     * will be thrown.
-     *
-     * @param cacheName Cache name.
-     * @return All currently active state transfers.
-     */
-    public Collection<GridDrStateTransferDescriptor> senderCacheDrListStateTransfers(String cacheName);
-
-    /**
-     * Pauses data center replication for particular sender cache.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not sender cache or grid is stopping then {@link IllegalStateException}
-     * will be thrown.
-     *
-     * @param cacheName Sender cache name.
-     */
-    public void senderCacheDrPause(String cacheName);
-
-    /**
-     * Resumes data center replication for particular sender cache.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not sender cache or grid is stopping then {@link IllegalStateException}
-     * will be thrown.
-     *
-     * @param cacheName Cache name.
-     */
-    public void senderCacheDrResume(String cacheName);
-
-    /**
-     * Gets data center replication status for particular sender cache.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not sender cache or grid is stopping then {@link IllegalStateException}
-     * will be thrown.
-     *
-     * @param cacheName Cache name.
-     * @return Data center replication status.
-     */
-    public GridDrStatus senderCacheDrStatus(String cacheName);
-
-    /**
-     * Gets sender cache metrics.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not sender cache then {@link IllegalStateException} will be thrown.
-     *
-     * @param cacheName Sender cache name.
-     * @return Sender cache metrics.
-     */
-    public GridDrSenderCacheMetrics senderCacheMetrics(String cacheName);
-
-    /**
-     * Gets receiver cache metrics.
-     * <p>
-     * In case node doesn't have cache with the given name then {@link IllegalArgumentException}
-     * will be thrown, and if this cache is not receiver cache {@link IllegalStateException} will be thrown.
-     *
-     * @param cacheName Receiver cache name.
-     * @return Receiver cache metrics..
-     */
-    public GridDrReceiverCacheMetrics receiverCacheMetrics(String cacheName);
-
-    /**
-     * Gets sender hub incoming data metrics for specified sender cache.
-     * <p>
-     * In case node is not sender hub then {@link IllegalStateException} will be thrown.
-     * If this sender hub does not work with the given cache {@link IllegalArgumentException} will be thrown.
-     *
-     * @param cacheName Sender cache name.
-     * @return Sender hub incoming data metrics.
-     */
-    public GridDrSenderHubInMetrics senderHubInMetrics(@Nullable String cacheName);
-
-    /**
-     * Gets sender hub incoming data metrics aggregated across all caches.
-     * <p>
-     * In case node is not sender hub then {@link IllegalStateException} will be thrown.
-     *
-     * @return Sender hub incoming data metrics.
-     */
-    public GridDrSenderHubInMetrics senderHubAggregatedInMetrics();
-
-    /**
-     * Gets sender hub outgoing data metrics for the given remote data center ID and cache name.
-     * <p>
-     * In case node is not sender hub then {@link IllegalStateException} will be thrown. If this sender hub does not
-     * work with the given data center or cache {@link IllegalArgumentException} will be thrown.
-     *
-     * @param destDataCenterId Remote data center ID.
-     * @param cacheName Cache name.
-     * @return Sender hub outgoing data metrics.
-     */
-    public GridDrSenderHubOutMetrics senderHubOutMetrics(byte destDataCenterId, @Nullable String cacheName);
-
-    /**
-     * Gets sender hub outgoing data metrics aggregated across all cache names for the given remote data center ID.
-     * <p>
-     * In case node is not sender hub then {@link IllegalStateException} will be thrown. If this sender hub does not
-     * work with the given data center {@link IllegalArgumentException} will be thrown.
-     *
-     * @param destDataCenterId Remote data center ID.
-     * @return Sender hub outgoing data metrics.
-     */
-    public GridDrSenderHubOutMetrics senderHubAggregatedOutMetrics(byte destDataCenterId);
-
-    /**
-     * Gets sender hub outgoing data metrics aggregated across all remote data centers for the given cache name.
-     * <p>
-     * In case node is not sender hub then {@link IllegalStateException} will be thrown. If this sender hub does not
-     * work with the given cache {@link IllegalArgumentException} will be thrown.
-     *
-     * @param cacheName Cache name.
-     * @return Sender hub outgoing data metrics.
-     */
-    public GridDrSenderHubOutMetrics senderHubAggregatedOutMetrics(@Nullable String cacheName);
-
-    /**
-     * Gets sender hub outgoing data metrics aggregated across all remote data centers and cache names.
-     * <p>
-     * In case node is not sender hub then {@link IllegalStateException} will be thrown.
-     *
-     * @return Sender hub outgoing data metrics.
-     */
-    public GridDrSenderHubOutMetrics senderHubAggregatedOutMetrics();
-
-    /**
-     * Gets receiver hub incoming data metrics for the given remote data center and cache name.
-     * <p>
-     * In case node is not receiver hub then {@link IllegalStateException} will be thrown.
-     *
-     * @param srcDataCenterId Remote data center ID.
-     * @param cacheName Cache name.
-     * @return Receiver hub incoming data metrics.
-     */
-    public GridDrReceiverHubInMetrics receiverHubInMetrics(byte srcDataCenterId, @Nullable String cacheName);
-
-    /**
-     * Gets receiver hub incoming data metrics aggregated across all cache names for the given remote data center.
-     * <p>
-     * In case node is not receiver hub then {@link IllegalStateException} will be thrown.
-     *
-     * @param srcDataCenterId Remote data center ID.
-     * @return Receiver hub incoming data metrics.
-     */
-    public GridDrReceiverHubInMetrics receiverHubAggregatedInMetrics(byte srcDataCenterId);
-
-    /**
-     * Gets receiver hub incoming data metrics aggregated across all remote data centers for the given cache name.
-     * <p>
-     * In case node is not receiver hub then {@link IllegalStateException} will be thrown.
-     *
-     * @param cacheName Cache name.
-     * @return Receiver hub incoming data metrics.
-     */
-    public GridDrReceiverHubInMetrics receiverHubAggregatedInMetrics(@Nullable String cacheName);
-
-    /**
-     * Gets receiver hub incoming data metrics aggregated across all remote data centers and cache names.
-     * <p>
-     * In case node is not receiver hub then {@link IllegalStateException} will be thrown.
-     *
-     * @return Receiver hub incoming data metrics.
-     */
-    public GridDrReceiverHubInMetrics receiverHubAggregatedInMetrics();
-
-    /**
-     * Gets receiver hub outgoing data metrics for the given cache name.
-     * <p>
-     * In case node is not receiver hub then {@link IllegalStateException} will be thrown.
-     *
-     * @param cacheName Cache name.
-     * @return Receiver hub outgoing data metrics.
-     */
-    public GridDrReceiverHubOutMetrics receiverHubOutMetrics(@Nullable String cacheName);
-
-    /**
-     * Gets receiver hub outgoing data metrics aggregated across all receiver caches.
-     * <p>
-     * In case node is not receiver hub then {@link IllegalStateException} will be thrown.
-     *
-     * @return Receiver hub outgoing data metrics.
-     */
-    public GridDrReceiverHubOutMetrics receiverHubAggregatedOutMetrics();
-
-    /**
-     * Reset all sender hub and receiver hub metrics on this node. In case this node is neither sender hub, nor
-     * receiver hub, the method is no-op.
-     * <p>
-     * Sender and receiver cache metrics must be reset through {@link GridCache#resetMetrics()}.
-     */
-    public void resetMetrics();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/GridDrEntry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/GridDrEntry.java b/modules/core/src/main/java/org/gridgain/grid/dr/GridDrEntry.java
deleted file mode 100644
index 114855d..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/GridDrEntry.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr;
-
-import org.jetbrains.annotations.*;
-
-/**
- * Data center replication entry.
- */
-public interface GridDrEntry<K, V> {
-    /**
-     * Gets entry's key.
-     *
-     * @return Entry's key.
-     */
-    public K key();
-
-    /**
-     * Gets entry's value.
-     *
-     * @return Entry's value.
-     */
-    @Nullable public V value();
-
-    /**
-     * Gets entry's TTL.
-     *
-     * @return Entry's TTL.
-     */
-    public long ttl();
-
-    /**
-     * Gets entry's expire time.
-     *
-     * @return Entry's expire time.
-     */
-    public long expireTime();
-
-    /**
-     * Gets ID of initiator data center.
-     *
-     * @return ID of initiator data center.
-     */
-    public byte dataCenterId();
-
-    /**
-     * Gets entry's topology version in initiator data center.
-     *
-     * @return Entry's topology version in initiator data center.
-     */
-    public int topologyVersion();
-
-    /**
-     * Gets entry's order in initiator data center.
-     *
-     * @return Entry's order in initiator data center
-     */
-    public long order();
-
-    /**
-     * Gets entry's global time in initiator data center.
-     *
-     * @return Entry's global time in initiator data center
-     */
-    public long globalTime();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/package.html b/modules/core/src/main/java/org/gridgain/grid/dr/cache/package.html
deleted file mode 100644
index e56975e..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/package.html
+++ /dev/null
@@ -1,17 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
-    @html.file.header
-    _________        _____ __________________        _____
-    __  ____/___________(_)______  /__  ____/______ ____(_)_______
-    _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
-    / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
-    \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
--->
-<html>
-<body>
-    <img alt="icon" class="javadocimg" src="{@docRoot}/img/cube.gif"/>
-    Data center replication-related interfaces and classes for sender and receiver caches.
-    <p>
-    @html.java.package
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConfiguration.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConfiguration.java
deleted file mode 100644
index 40f1369..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConfiguration.java
+++ /dev/null
@@ -1,102 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.receiver;
-
-import org.gridgain.grid.util.typedef.internal.*;
-import org.jetbrains.annotations.*;
-
-import static org.gridgain.grid.dr.cache.receiver.GridDrReceiverCacheConflictResolverMode.*;
-
-/**
- * Data center replication receiver cache configuration.
- */
-public class GridDrReceiverCacheConfiguration {
-    /** Default data center replication receiver cache conflict resolver mode. */
-    public static final GridDrReceiverCacheConflictResolverMode DFLT_CONFLICT_RSLVR_MODE = DR_AUTO;
-
-    /** Receiver cache conflict resolver mode. */
-    private GridDrReceiverCacheConflictResolverMode conflictRslvrMode = DFLT_CONFLICT_RSLVR_MODE;
-
-    /** Receiver cache conflict resolver. */
-    private GridDrReceiverCacheConflictResolver conflictRslvr;
-
-    /**
-     * Default constructor.
-     */
-    public GridDrReceiverCacheConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copying constructor.
-     *
-     * @param cfg Configuration to copy.
-     */
-    public GridDrReceiverCacheConfiguration(GridDrReceiverCacheConfiguration cfg) {
-        assert cfg != null;
-
-        conflictRslvr = cfg.getConflictResolver();
-        conflictRslvrMode = cfg.getConflictResolverMode();
-    }
-
-    /**
-     * Gets conflict resolver mode. See {@link GridDrReceiverCacheConflictResolverMode} for more information.
-     * <p>
-     * Defaults to {@link #DFLT_CONFLICT_RSLVR_MODE}.
-     *
-     * @return Conflict resolution mode.
-     */
-    public GridDrReceiverCacheConflictResolverMode getConflictResolverMode() {
-        return conflictRslvrMode;
-    }
-
-    /**
-     * Sets conflict resolver mode. See {@link #getConflictResolverMode()} for
-     * more information.
-     *
-     * @param conflictRslvrMode Conflict resolver mode.
-     */
-    public void setConflictResolverMode(GridDrReceiverCacheConflictResolverMode conflictRslvrMode) {
-        this.conflictRslvrMode = conflictRslvrMode;
-    }
-
-    /**
-     * Gets conflict resolver.
-     * <p>
-     * For {@link GridDrReceiverCacheConflictResolverMode#DR_AUTO} mode this parameter can be {@code null} and in
-     * this case new entry will always overwrite the old one.
-     * <p>
-     * For {@link GridDrReceiverCacheConflictResolverMode#DR_ALWAYS} mode this parameter is mandatory.
-     * <p>
-     * Default value is {@code null}.
-     *
-     * @return Conflict resolver.
-     */
-    @Nullable public GridDrReceiverCacheConflictResolver getConflictResolver() {
-        return conflictRslvr;
-    }
-
-    /**
-     * Sets conflict resolver. See {@link #getConflictResolver()} for more
-     * information.
-     * <p>
-     * Defaults to {@code null}.
-     *
-     * @param conflictRslvr Conflict resolver.
-     */
-    public void setConflictResolver(GridDrReceiverCacheConflictResolver conflictRslvr) {
-        this.conflictRslvr = conflictRslvr;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrReceiverCacheConfiguration.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictContext.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictContext.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictContext.java
deleted file mode 100644
index 275ce23..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictContext.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.receiver;
-
-import org.gridgain.grid.cache.*;
-
-import org.gridgain.grid.dr.*;
-import org.jetbrains.annotations.*;
-
-/**
- * Data center replication receiver cache conflict context. Whenever conflict which cannot be resolved automatically
- * occurs this entity is passed to {@link GridDrReceiverCacheConflictResolver} to perform explicit conflict resolution.
- * <p>
- * Contains all data necessary for conflict resolution.
- */
-public interface GridDrReceiverCacheConflictContext<K, V> {
-    /**
-     * Gets old (existing) cache entry.
-     *
-     * @return Old (existing) cache entry.
-     */
-    public GridDrEntry<K, V> oldEntry();
-
-    /**
-     * Gets new cache entry.
-     *
-     * @return New cache entry.
-     */
-    public GridDrEntry<K, V> newEntry();
-
-    /**
-     * Force data center replication receiver cache to ignore new entry and leave old (existing) entry unchanged.
-     */
-    public void useOld();
-
-    /**
-     * Force data center replication receiver cache to apply new entry thus overwriting old (existing) entry.
-     * <p>
-     * Note that updates from remote data centers always have explicit TTL , while local data center
-     * updates will only have explicit TTL in case {@link GridCacheEntry#timeToLive(long)} was called
-     * before update. In the latter case new entry will pick TTL of the old (existing) entry, even
-     * if it was set through update from remote data center. it means that depending on concurrent
-     * update timings new update might pick unexpected TTL. For example, consider that three updates
-     * of the same key are performed: local update with explicit TTL (1) followed by another local
-     * update without explicit TTL (2) and one remote update (3). In this case you might expect that
-     * update (2) will pick TTL set during update (1). However, in case update (3) occurrs between (1)
-     * and (2) and it overwrites (1) during conflict resolution, then update (2) will pick TTL of
-     * update (3). To have predictable TTL in such cases you should either always set it explicitly
-     * through {@code GridCacheEntry.timeToLive(long)} or use {@link #merge(Object, long)}.
-     */
-    public void useNew();
-
-    /**
-     * Force data center replication engine to use neither old, nor new, but some other value passed
-     * as argument. In this case old value will be replaced with merge value and update will be
-     * considered as local (i.e. {@link org.apache.ignite.configuration.IgniteConfiguration#getDataCenterId()} will be used).
-     * <p>
-     * Also in case of merge you have to specify new TTL explicitly. For unlimited TTL use {@code 0}.
-     *
-     * @param mergeVal Merge value or {@code null} to force remove.
-     * @param ttl Time to live in milliseconds.
-     */
-    public void merge(@Nullable V mergeVal, long ttl);
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolver.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolver.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolver.java
deleted file mode 100644
index 5356ce2..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolver.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.receiver;
-
-/**
- * Data center replication receiver cache conflict resolver. In case particular cache can be updated from multiple
- * topologies (e.g. from local topology and remote data center, or from several remote data centers, etc.), then
- * conflict resolver will be used to determine which value to pick in case conflicting topologies update the same key
- * and this conflict cannot be resolved automatically for some reason.
- * <p>
- * You can inject any resources in implementation of this interface.
- */
-public interface GridDrReceiverCacheConflictResolver<K, V> {
-    /**
-     * Resolve conflicting key update.
-     *
-     * @param ctx Conflict resolution context.
-     */
-    public void resolve(GridDrReceiverCacheConflictContext<K, V> ctx);
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolverMode.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolverMode.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolverMode.java
deleted file mode 100644
index 1e5d385..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheConflictResolverMode.java
+++ /dev/null
@@ -1,63 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.receiver;
-
-import org.jetbrains.annotations.*;
-
-/**
- * Data center replication receiver cache conflict resolver mode.
- * <p>
- * Each cache entry has data center ID. In case cache update is performed and either old or new cache entry has data
- * center ID which differs from local data center ID defined by {@link org.apache.ignite.configuration.IgniteConfiguration#getDataCenterId()}, then
- * we consider such situation as conflict.
- * <p>
- * If both entries participating in conflict have the same data cneter ID (i.e. they both were replicated from the same
- * remote data center), then GridGain can potentially resolve this conflict automatically based on entry metadata.
- * <p>
- * But in case old and new entries have different data center IDs (i.e. in active-active scenario when cache is updated
- * in both data centers participating in data center replication, or when cache is updated from multiple remote data
- * centers), then explicit conflict resolution is required.
- * <p>
- * This enumeration provides several different strategies for conflict resolution.
- */
-public enum GridDrReceiverCacheConflictResolverMode {
-    /**
-     * GridGain will automatically resolve conflicts when possible (i.e. when both old and new entries have the same
-     * data center ID). In all other situations, conflict resolution will be delegated to
-     * {@link GridDrReceiverCacheConflictResolver} configured through
-     * {@link GridDrReceiverCacheConfiguration#getConflictResolver()}. In case conflict resolver is not configured,
-     * GridGain will overwrite old entry with a new one.
-     * <p>
-     * This mode is default.
-     */
-    DR_AUTO,
-
-    /**
-     * GridGain will always delegate to conflict resolver. This applies to all possible cases, even if both old and new
-     * entries have local data center ID and therefore are not considered conflicting when cache is not data center
-     * replication receiver.
-     * <p>
-     * In this mode {@link GridDrReceiverCacheConfiguration#getConflictResolver()} is mandatory.
-     */
-    DR_ALWAYS;
-
-    /** Enumerated values. */
-    private static final GridDrReceiverCacheConflictResolverMode[] VALS = values();
-
-    /**
-     * Efficiently gets enumerated value from its ordinal.
-     *
-     * @param ord Ordinal value.
-     * @return Enumerated value or {@code null} if ordinal out of range.
-     */
-    @Nullable public static GridDrReceiverCacheConflictResolverMode fromOrdinal(int ord) {
-        return ord >= 0 && ord < VALS.length ? VALS[ord] : null;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheMetrics.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheMetrics.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheMetrics.java
deleted file mode 100644
index ee14c35..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/GridDrReceiverCacheMetrics.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.receiver;
-
-/**
- * Metrics for data center replication receiver cache.
- */
-public interface GridDrReceiverCacheMetrics {
-    /**
-     * Gets total amount of cache entries received from receiver hub.
-     *
-     * @return Total amount of cache entries received from receiver hub.
-     */
-    public long entriesReceived();
-
-    /**
-     * Gets total amount of conflicts resolved by using new value. See
-     * {@link GridDrReceiverCacheConflictContext#useNew()} for more info.
-     *
-     * @return Total amount of conflicts resolved by using new value.
-     */
-    public long conflictNew();
-
-    /**
-     * Gets total amount of conflicts resolved by using old value. See
-     * {@link GridDrReceiverCacheConflictContext#useOld()} for more info.
-     *
-     * @return Total amount of conflicts resolved by using old value.
-     */
-    public long conflictOld();
-
-    /**
-     * Gets total amount of conflicts resolved by merge. See
-     * {@link GridDrReceiverCacheConflictContext#merge(Object, long)} for more info.
-     *
-     * @return Total amount of conflicts resolved by merge.
-     */
-    public long conflictMerge();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/package.html b/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/package.html
deleted file mode 100644
index 90e9c89..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/receiver/package.html
+++ /dev/null
@@ -1,17 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
-    @html.file.header
-    _________        _____ __________________        _____
-    __  ____/___________(_)______  /__  ____/______ ____(_)_______
-    _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
-    / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
-    \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
--->
-<html>
-<body>
-    <img alt="icon" class="javadocimg" src="{@docRoot}/img/cube.gif"/>
-    Data center replication-related interfaces and classes for receiver caches.
-    <p>
-    @html.java.package
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrPauseReason.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrPauseReason.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrPauseReason.java
deleted file mode 100644
index f7703ac..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrPauseReason.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.gridgain.grid.kernal.processors.cache.*;
-import org.jetbrains.annotations.*;
-
-/**
- * Reason of data center replication pause.
- */
-public enum GridDrPauseReason {
-    /**
-     * Method {@link GridCacheProjectionEx#drPause()} was called.
-     */
-    USER_REQUEST,
-
-    /**
-     * All sender hubs failed to process batch.
-     */
-    BATCH_FAILED,
-
-    /**
-     * All sender hubs left.
-     */
-    NO_SND_HUBS;
-
-    /** Enumerated values. */
-    private static final GridDrPauseReason[] VALS = values();
-
-    /**
-     * Efficiently gets enumerated value from its ordinal.
-     *
-     * @param ord Ordinal value.
-     * @return Enumerated value or {@code null} if ordinal out of range.
-     */
-    @Nullable public static GridDrPauseReason fromOrdinal(int ord) {
-        return ord >= 0 && ord < VALS.length ? VALS[ord] : null;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheConfiguration.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheConfiguration.java
deleted file mode 100644
index 27de436..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheConfiguration.java
+++ /dev/null
@@ -1,277 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.gridgain.grid.dr.hub.sender.*;
-import org.gridgain.grid.util.typedef.internal.*;
-import org.jetbrains.annotations.*;
-
-import static org.gridgain.grid.dr.cache.sender.GridDrSenderCacheMode.*;
-
-/**
- * Data center replication sender cache configuration.
- */
-public class GridDrSenderCacheConfiguration {
-    /** Default data center replication sender cache mode. */
-    public static final GridDrSenderCacheMode DFLT_MODE = DR_ASYNC;
-
-    /** Default data center replication sender cache batch send frequency. */
-    public static final long DFLT_BATCH_SND_FREQUENCY = 2000L;
-
-    /** Default data center replication sender cache batch send size. */
-    public static final int DFLT_BATCH_SND_SIZE = 2048;
-
-    /** Default data center replication sender cache maximum amount of pending batches. */
-    public static final int DFLT_MAX_BATCHES = 32;
-
-    /** Default data center replication sender cache sender hub load balancing mode. */
-    public static final GridDrSenderHubLoadBalancingMode DFLT_SND_HUB_LOAD_BALANCING_MODE = GridDrSenderHubLoadBalancingMode.DR_RANDOM;
-
-    /** Default data center replication sender cache amount of worker threads responsible for full state transfer. */
-    public static final int DFLT_STATE_TRANSFER_THREADS_CNT = 2;
-
-    /** Default data center replication sender cache state transfer throttle. */
-    public static final long DFLT_STATE_TRANSFER_THROTTLE = 0;
-
-    /** Mode. */
-    private GridDrSenderCacheMode mode = DFLT_MODE;
-
-    /** Batch send size. */
-    private int batchSndSize = DFLT_BATCH_SND_SIZE;
-
-    /** Batch send frequency. */
-    private long batchSndFreq = DFLT_BATCH_SND_FREQUENCY;
-
-    /** Maximum amount of pending entries awaiting for replication to happen. */
-    private int maxBatches = DFLT_MAX_BATCHES;
-
-    /** Entry filter. */
-    private GridDrSenderCacheEntryFilter entryFilter;
-
-    /** Sender hub load balancing mode. */
-    private GridDrSenderHubLoadBalancingMode sndHubLoadBalancingMode = DFLT_SND_HUB_LOAD_BALANCING_MODE;
-
-    /** Time in milliseconds to wait between full state transfer batches creation. */
-    @SuppressWarnings("RedundantFieldInitialization")
-    private long stateTransferThrottle = DFLT_STATE_TRANSFER_THROTTLE;
-
-    /** Amount of worker threads responsible for full state transfer. */
-    private int stateTransferThreadsCnt = DFLT_STATE_TRANSFER_THREADS_CNT;
-
-    /**
-     * Default constructor.
-     */
-    public GridDrSenderCacheConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copying constructor.
-     *
-     * @param cfg Configuration to copy.
-     */
-    public GridDrSenderCacheConfiguration(GridDrSenderCacheConfiguration cfg) {
-        assert cfg != null;
-
-        batchSndFreq = cfg.getBatchSendFrequency();
-        batchSndSize = cfg.getBatchSendSize();
-        entryFilter = cfg.getEntryFilter();
-        maxBatches = cfg.getMaxBatches();
-        mode = cfg.getMode();
-        sndHubLoadBalancingMode = cfg.getSenderHubLoadBalancingMode();
-        stateTransferThreadsCnt = cfg.getStateTransferThreadsCount();
-        stateTransferThrottle = cfg.getStateTransferThrottle();
-    }
-
-    /**
-     * Gets mode. See {@link GridDrSenderCacheMode} for more info.
-     * <p>
-     * Defaults to {@link #DFLT_MODE}.
-     *
-     * @return Mode.
-     */
-    @Nullable public GridDrSenderCacheMode getMode() {
-        return mode;
-    }
-
-    /**
-     * Sets mode. See {@link #getMode()} for more information.
-     *
-     * @param mode Mode.
-     */
-    public void setMode(GridDrSenderCacheMode mode) {
-        this.mode = mode;
-    }
-
-    /**
-     * Gets batch send size. When size of a batch is greater than the given value or it's lifetime is greater than
-     * {@link #getBatchSendFrequency()} batch will be sent to a sender hub.
-     * <p>
-     * When set to non-positive value, batch will be sent only in case it's lifetime is greater than
-     * {@code getBatchSendFrequency()}.
-     * <p>
-     * Defaults to {@link #DFLT_BATCH_SND_SIZE}.
-     *
-     * @return Batch send size.
-     */
-    public int getBatchSendSize() {
-        return batchSndSize;
-    }
-
-    /**
-     * Sets batch send size. See {@link #getBatchSendSize()} for more information.
-     *
-     * @param batchSndSize Batch send size.
-     */
-    public void setBatchSendSize(int batchSndSize) {
-        this.batchSndSize = batchSndSize;
-    }
-
-    /**
-     * Gets batch send frequency. When size of a batch is greater than {@link #getBatchSendSize()} or it's lifetime
-     * is greater than the given value batch will be sent to a sender hub.
-     * <p>
-     * When set to non-positive value, batch will be sent only in case it's size is greater than
-     * {@code #getBatchSendSize()}.
-     * <p>
-     * Defaults to {@link #DFLT_BATCH_SND_FREQUENCY}.
-     *
-     * @return Batch send frequency.
-     */
-    public long getBatchSendFrequency() {
-        return batchSndFreq;
-    }
-
-    /**
-     * Sets batch send frequency. See {@link #getBatchSendFrequency()} for more
-     * information.
-     *
-     * @param batchSndFreq Batch send frequency.
-     */
-    public void setBatchSendFrequency(long batchSndFreq) {
-        this.batchSndFreq = batchSndFreq;
-    }
-
-    /**
-     * Gets maximum amount of batches awaiting for sender hub acknowledge. When amount of batches awaiting
-     * sender hub delivery acknowledge reaches this value, all further cache updates will be suspended until
-     * it is below the limit again.
-     * <p>
-     * When set to non-positive value, maximum amount of batches is unlimited.
-     * <p>
-     * Defaults to {@link #DFLT_MAX_BATCHES}.
-     *
-     * @return Maximum amount of batches awaiting for sender hub acknowledge.
-     */
-    public int getMaxBatches() {
-        return maxBatches;
-    }
-
-    /**
-     * Sets maximum amount of batches awaiting for sender hub acknowledge. See {@link #getMaxBatches()} for more
-     * information.
-     *
-     * @param maxBatches Maximum amount of batches awaiting for sender hub acknowledge.
-     */
-    public void setMaxBatches(int maxBatches) {
-        this.maxBatches = maxBatches;
-    }
-
-    /**
-     * Gets entry filter. When set it will be applied to all entries which are candidates for data center replication.
-     * If the filter is not passed, data center replication will not be performed on that entry.*
-     * <p>
-     * Defaults to {@code null}.
-     *
-     * @return Entry filter.
-     */
-    public GridDrSenderCacheEntryFilter getEntryFilter() {
-        return entryFilter;
-    }
-
-    /**
-     * Set entry filter. See {@link #getEntryFilter()} for more information.
-     *
-     * @param entryFilter Entry filter.
-     */
-    public void setEntryFilter(@Nullable GridDrSenderCacheEntryFilter entryFilter) {
-        this.entryFilter = entryFilter;
-    }
-
-    /**
-     * Gets sender hub load balancing mode. When batch is ready to be sent, this parameter defines how to select the
-     * next sender hub this batch will be sent to.
-     * <p>
-     * Defaults to {@link #DFLT_SND_HUB_LOAD_BALANCING_MODE}.
-     *
-     * @return Sender hub load balancing mode.
-     */
-    public GridDrSenderHubLoadBalancingMode getSenderHubLoadBalancingMode() {
-        return sndHubLoadBalancingMode;
-    }
-
-    /**
-     * Sets sender hub load balancing mode. See {@link #getSenderHubLoadBalancingMode()} for more information.
-     *
-     * @param sndHubLoadBalancingMode Sender hub load balancing mode.
-     */
-    public void setSenderHubLoadBalancingMode(GridDrSenderHubLoadBalancingMode sndHubLoadBalancingMode) {
-        this.sndHubLoadBalancingMode = sndHubLoadBalancingMode;
-    }
-
-    /**
-     * Gets state transfer throttle. Defines delay in milliseconds to wait between full state transfer batches
-     * creation to avoid CPU or network overload.
-     * <p>
-     * When set to {@code 0} throttling is disabled.
-     * <p>
-     * Defaults to {@link #DFLT_STATE_TRANSFER_THROTTLE}.
-     *
-     * @return State transfer throttle.
-     */
-    public long getStateTransferThrottle() {
-        return stateTransferThrottle;
-    }
-
-    /**
-     * Sets state transfer throttle. See {@link #getStateTransferThrottle()} for more information.
-     *
-     * @param stateTransferThrottle State transfer throttle.
-     */
-    public void setStateTransferThrottle(long stateTransferThrottle) {
-        this.stateTransferThrottle = stateTransferThrottle;
-    }
-
-    /**
-     * Gets state transfer threads count. Defines amount of threads which will iterate over cache and force
-     * entries data center replication.
-     * <p>
-     * Defaults to {@link #DFLT_STATE_TRANSFER_THREADS_CNT}.
-     *
-     * @return State transfer threads count
-     */
-    public int getStateTransferThreadsCount() {
-        return stateTransferThreadsCnt;
-    }
-
-    /**
-     * Sets state transfer threads count. See {@link #getStateTransferThreadsCount()} for more information.
-     *
-     * @param stateTransferThreadsCnt State transfer threads count
-     */
-    public void setStateTransferThreadsCount(int stateTransferThreadsCnt) {
-        this.stateTransferThreadsCnt = stateTransferThreadsCnt;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrSenderCacheConfiguration.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheEntryFilter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheEntryFilter.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheEntryFilter.java
deleted file mode 100644
index 0a23bf8..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheEntryFilter.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.gridgain.grid.dr.*;
-
-/**
- * Data center replication sender cache filter. Prevents data center replication of cache entries which do not pass it.
- */
-public interface GridDrSenderCacheEntryFilter<K, V> {
-    /**
-     * Whether to perform data center replication for particular cache entry or not.
-     *
-     * @param entry DR entry.
-     * @return {@code True} in case data center replication should be performed for the entry..
-     */
-    public boolean accept(GridDrEntry<K, V> entry);
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMetrics.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMetrics.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMetrics.java
deleted file mode 100644
index 1401a06..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMetrics.java
+++ /dev/null
@@ -1,76 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.jetbrains.annotations.*;
-
-/**
- * Metrics for data center replication sender cache.
- */
-public interface GridDrSenderCacheMetrics {
-    /**
-     * Gets total amount of batches sent to sender hubs.
-     *
-     * @return Total amount of batches sent to sender hubs.
-     */
-    public int batchesSent();
-
-    /**
-     * Gets total amount of entries sent to sender hubs.
-     *
-     * @return Total amount of entries sent to sender hubs.
-     */
-    public long entriesSent();
-
-    /**
-     * Gets total amount of sent batches acknowledged by sender hub.
-     *
-     * @return Total amount of sent batches acknowledged by sender hub.
-     */
-    public int batchesAcked();
-
-    /**
-     * Gets total amount of sent entries acknowledged by sender hub.
-     *
-     * @return Total amount of sent entries acknowledged by sender hub.
-     */
-    public long entriesAcked();
-
-    /**
-     * Gets total amount of failed batches. Failure may occur because there was no available sender hubs during
-     * batch send or sender hub replied with an error.
-     *
-     * @return Total amount of failed batches.
-     */
-    public int batchesFailed();
-
-    /**
-     * Gets total amount of filtered cache entries. Data center replication provides ability to filter entries
-     * before being replicated to another data center (see {@link GridDrSenderCacheConfiguration#getEntryFilter()}).
-     * This metric returns the number of entries that didn't pass that filter.
-     *
-     * @return Total amount of filtered cache entries.
-     */
-    public long entriesFiltered();
-
-    /**
-     * Gets current amount of cache entries in backup queue.
-     *
-     * @return Current amount of cache entries in backup queue.
-     */
-    public long backupQueueSize();
-
-    /**
-     * Gets data center replication status.
-     *
-     * @return Data center replication status.
-     */
-    public GridDrStatus status();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMode.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMode.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMode.java
deleted file mode 100644
index 10e93cb..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrSenderCacheMode.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.jetbrains.annotations.*;
-
-/**
- * Cache data center replication sender cache mode.
- */
-public enum GridDrSenderCacheMode {
-    /**
-     * Asynchronous mode. Transactions do not wait for acknowledge from sender hub before commit. Instead updat4d
-     * data are put into shared batch. Once batch is too big or too old, it will be sent to the sender hub.
-     * <p>
-     * When there are too many cache entries enqueued for data center replication, ongoing transaction may block in
-     * case total amount of batches awaiting acknowledge is greater than
-     * {@link GridDrSenderCacheConfiguration#getMaxBatches()}.
-     */
-    DR_ASYNC;
-
-    /** Enumerated values. */
-    private static final GridDrSenderCacheMode[] VALS = values();
-
-    /**
-     * Efficiently gets enumerated value from its ordinal.
-     *
-     * @param ord Ordinal value.
-     * @return Enumerated value or {@code null} if ordinal out of range.
-     */
-    @Nullable public static GridDrSenderCacheMode fromOrdinal(int ord) {
-        return ord >= 0 && ord < VALS.length ? VALS[ord] : null;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStateTransferDescriptor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStateTransferDescriptor.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStateTransferDescriptor.java
deleted file mode 100644
index ff223bb..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStateTransferDescriptor.java
+++ /dev/null
@@ -1,94 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.apache.ignite.lang.*;
-import org.gridgain.grid.util.typedef.*;
-import org.gridgain.grid.util.typedef.internal.*;
-
-import java.io.*;
-import java.util.*;
-
-/**
- * Data center replication state transfer descriptor.
- */
-public class GridDrStateTransferDescriptor implements Externalizable {
-    /** */
-    private static final long serialVersionUID = 0L;
-
-    /** Unique state transfer ID. */
-    private IgniteUuid id;
-
-    /** Target data center IDs. */
-    private Collection<Byte> dataCenterIds;
-
-    /**
-     * {@link Externalizable} support.
-     */
-    public GridDrStateTransferDescriptor() {
-        // No-op.
-    }
-
-    /**
-     * Constructor.
-     *
-     * @param id Unique state transfer ID.
-     * @param dataCenterIds Target data center IDs.
-     */
-    public GridDrStateTransferDescriptor(IgniteUuid id, Collection<Byte> dataCenterIds) {
-        this.id = id;
-        this.dataCenterIds = dataCenterIds;
-    }
-
-    /**
-     * Gets unique state transfer ID.
-     *
-     * @return Unique state transfer ID.
-     */
-    public IgniteUuid id() {
-        return id;
-    }
-
-    /**
-     * Gets target data center IDs.
-     *
-     * @return Target data center IDs.
-     */
-    public Collection<Byte> dataCenterIds() {
-        return dataCenterIds;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean equals(Object obj) {
-        return obj != null && obj instanceof GridDrStateTransferDescriptor && F.eq(id, (((GridDrStateTransferDescriptor) obj).id));
-    }
-
-    /** {@inheritDoc} */
-    @Override public int hashCode() {
-        return id.hashCode();
-    }
-
-    /** {@inheritDoc} */
-    @Override public void writeExternal(ObjectOutput out) throws IOException {
-        U.writeGridUuid(out, id);
-        U.writeCollection(out, dataCenterIds);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
-        id = U.readGridUuid(in);
-        dataCenterIds = U.readCollection(in);
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrStateTransferDescriptor.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStatus.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStatus.java b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStatus.java
deleted file mode 100644
index bf22c56..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/GridDrStatus.java
+++ /dev/null
@@ -1,94 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.cache.sender;
-
-import org.gridgain.grid.util.typedef.internal.*;
-import org.jetbrains.annotations.*;
-
-import java.io.*;
-
-/**
- * Data center replication status.
- */
-public class GridDrStatus implements Externalizable {
-    /** */
-    private static final long serialVersionUID = 0L;
-
-    /** Status: not paused. */
-    public static final GridDrStatus NOT_PAUSED = new GridDrStatus(null, null);
-
-    /** Pause reason or {@code null} if not paused. */
-    private GridDrPauseReason reason;
-
-    /** Error description. */
-    private String errMsg;
-
-    /**
-     * Required by {@link Externalizable}.
-     */
-    public GridDrStatus() {
-        // No-op.
-    }
-
-    /**
-     * Constructor.
-     *
-     * @param reason Pause reason.
-     * @param errMsg Error description.
-     */
-    public GridDrStatus(@Nullable GridDrPauseReason reason, @Nullable String errMsg) {
-        this.reason = reason;
-        this.errMsg = errMsg;
-    }
-
-    /**
-     * Gets pause flag.
-     *
-     * @return {@code True} if paused.
-     */
-    public boolean paused() {
-        return reason != null;
-    }
-
-    /**
-     * Gets pause reason.
-     *
-     * @return Pause reason or {@code null} if not paused.
-     */
-    @Nullable public GridDrPauseReason reason() {
-        return reason;
-    }
-
-    /**
-     * Gets error description.
-     *
-     * @return Error description.
-     */
-    @Nullable public String error() {
-        return errMsg;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void writeExternal(ObjectOutput out) throws IOException {
-        U.writeEnum(out, reason);
-        U.writeString(out, errMsg);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
-        reason = GridDrPauseReason.fromOrdinal(in.readByte());
-        errMsg = U.readString(in);
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrStatus.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/package.html b/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/package.html
deleted file mode 100644
index bea1933..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/cache/sender/package.html
+++ /dev/null
@@ -1,17 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
-    @html.file.header
-    _________        _____ __________________        _____
-    __  ____/___________(_)______  /__  ____/______ ____(_)_______
-    _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
-    / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
-    \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
--->
-<html>
-<body>
-    <img alt="icon" class="javadocimg" src="{@docRoot}/img/cube.gif"/>
-    Data center replication-related interfaces and classes for sender caches.
-    <p>
-    @html.java.package
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/package.html b/modules/core/src/main/java/org/gridgain/grid/dr/hub/package.html
deleted file mode 100644
index 328f49a..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/package.html
+++ /dev/null
@@ -1,17 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
-    @html.file.header
-    _________        _____ __________________        _____
-    __  ____/___________(_)______  /__  ____/______ ____(_)_______
-    _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
-    / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
-    \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
--->
-<html>
-<body>
-    <img alt="icon" class="javadocimg" src="{@docRoot}/img/cube.gif"/>
-    Data center replication-related interfaces and classes for sender and receiver hubs.
-    <p>
-    @html.java.package
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubConfiguration.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubConfiguration.java
deleted file mode 100644
index 57b0f5e..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubConfiguration.java
+++ /dev/null
@@ -1,369 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.receiver;
-
-import org.gridgain.grid.util.nio.*;
-import org.gridgain.grid.util.typedef.internal.*;
-
-/**
- * Data center replication receiver hub configuration.
- */
-public class GridDrReceiverHubConfiguration {
-    /** Default server port. */
-    public static final int DFLT_LOCAL_PORT = 49000;
-
-    /** Default quantity of NIO threads responsible for sender hub connections processing.  */
-    public static final int DFLT_SELECTOR_CNT = Math.min(4, Runtime.getRuntime().availableProcessors());
-
-    /** Default number of threads responsible for sender hub requests processing.  */
-    public static final int DFLT_WORKER_THREAD_CNT = Runtime.getRuntime().availableProcessors() * 4;
-
-    /** Default message queue limit per connection (for incoming and outgoing . */
-    public static final int DFLT_MSG_QUEUE_LIMIT = GridNioServer.DFLT_SEND_QUEUE_LIMIT;
-
-    /** Default TCP_NODELAY flag value for server sockets. */
-    public static final boolean DFLT_TCP_NODELAY = true;
-
-    /** Default value of direct buffer allocation. */
-    public static final boolean DFLT_DIRECT_BUF = true;
-
-    /** Default server socket idle timeout. */
-    public static final long DFLT_IDLE_TIMEOUT = 60 * 1000L;
-
-    /** Default server socket write timeout. */
-    public static final long DFLT_WRITE_TIMEOUT = 60 * 1000L;
-
-    /** Default flush frequency DR data loader. */
-    public static final long DFLT_FLUSH_FREQ = 2000L;
-
-    /** Default per node buffer buffer size for DR data loader. */
-    public static final int DFLT_PER_NODE_BUF_SIZE = 1024;
-
-    /** Default per node parallel operations for DR data loader. */
-    public static final int DFLT_PARALLEL_LOAD_OPS = 16;
-
-    /** Replication server host. */
-    private String locInboundHost;
-
-    /** Replication server port. */
-    private int locInboundPort = DFLT_LOCAL_PORT;
-
-    /** Quantity of NIO threads responsible for sender hub connections processing. */
-    private int selectorCnt = DFLT_SELECTOR_CNT;
-
-    /**  Number of threads responsible for sender hub requests processing. */
-    private int workerCnt = DFLT_WORKER_THREAD_CNT;
-
-    /** Message queue limit. */
-    private int msgQueueLimit = DFLT_MSG_QUEUE_LIMIT;
-
-    /** TCP_NODELAY flag value for server sockets. */
-    private boolean tcpNodelay = DFLT_TCP_NODELAY;
-
-    /** Direct buffer allocation flag. */
-    private boolean directBuf = DFLT_DIRECT_BUF;
-
-    /** Server socket idle timeout. */
-    private long idleTimeout = DFLT_IDLE_TIMEOUT;
-
-    /** Server socket write timeout. */
-    private long writeTimeout = DFLT_WRITE_TIMEOUT;
-
-    /** Data loader flush frequency. */
-    private long flushFreq = DFLT_FLUSH_FREQ;
-
-    /** Data loader per node buffer size. */
-    private int perNodeBufSize = DFLT_PER_NODE_BUF_SIZE;
-
-    /** Data loader per node parallel load operations. */
-    private int perNodeParallelLoadOps = DFLT_PARALLEL_LOAD_OPS;
-
-    /**
-     * Default constructor.
-     */
-    public GridDrReceiverHubConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copying constructor.
-     *
-     * @param cfg Configuration to copy.
-     */
-    public GridDrReceiverHubConfiguration(GridDrReceiverHubConfiguration cfg) {
-        directBuf = cfg.isDirectBuffer();
-        flushFreq = cfg.getFlushFrequency();
-        idleTimeout = cfg.getIdleTimeout();
-        locInboundHost = cfg.getLocalInboundHost();
-        locInboundPort = cfg.getLocalInboundPort();
-        msgQueueLimit = cfg.getMessageQueueLimit();
-        perNodeBufSize = cfg.getPerNodeBufferSize();
-        perNodeParallelLoadOps = cfg.getPerNodeParallelLoadOperations();
-        selectorCnt = cfg.getSelectorCount();
-        tcpNodelay = cfg.isTcpNodelay();
-        workerCnt = cfg.getWorkerThreads();
-        writeTimeout = cfg.getWriteTimeout();
-    }
-
-    /**
-     * Gets local host name receiver hub TCP server is bound to.
-     * <p>
-     * If not set, {@link org.apache.ignite.configuration.IgniteConfiguration#getLocalHost()} will be used.
-     * <p>
-     * Defaults to {@code null}.
-     *
-     * @return Local host name receiver hub TCP server is bound to.
-     */
-    public String getLocalInboundHost() {
-        return locInboundHost;
-    }
-
-    /**
-     * Sets local host name receiver hub TCP server is bound to. See {@link #getLocalInboundHost()} for more
-     * information.
-     *
-     * @param locInboundHost Local host name receiver hub TCP server is bound to.
-     */
-    public void setLocalInboundHost(String locInboundHost) {
-        this.locInboundHost = locInboundHost;
-    }
-
-    /**
-     * Gets local port receiver hub TCP server is bound to.
-     * <p>
-     * Defaults to {@link #DFLT_LOCAL_PORT}.
-     *
-     * @return Local port receiver hub TCP server is bound to.
-     */
-    public int getLocalInboundPort() {
-        return locInboundPort;
-    }
-
-    /**
-     * Sets local port receiver hub TCP server is bound to. See {@link #getLocalInboundPort()} for more information.
-     *
-     * @param locInboundPort Local port receiver hub TCP server is bound to.
-     */
-    public void setLocalInboundPort(int locInboundPort) {
-        this.locInboundPort = locInboundPort;
-    }
-
-    /**
-     * Gets amount of selector threads in receiver hub's TCP server.
-     * <p>
-     * Defaults to {@link #DFLT_SELECTOR_CNT}.
-     *
-     * @return Amount of selector threads in receiver hub's TCP server.
-     */
-    public int getSelectorCount() {
-        return selectorCnt;
-    }
-
-    /**
-     * Sets amount of selector threads in receiver hub's TCP server. See {@link #getSelectorCount()} for more
-     * information.
-     *
-     * @param selectorCnt Amount of selector threads in receiver hub's TCP server.
-     */
-    public void setSelectorCount(int selectorCnt) {
-        this.selectorCnt = selectorCnt;
-    }
-
-    /**
-     * Gets amount of threads responsible for sender hub batches processing.
-     * <p>
-     * Defaults to {@link #DFLT_WORKER_THREAD_CNT}.
-     *
-     * @return Amount of threads responsible for sender hub batches processing.
-     */
-    public int getWorkerThreads() {
-        return workerCnt;
-    }
-
-    /**
-     * Sets amount of threads responsible for sender hub batches processing. See {@link #getWorkerThreads()} for
-     * more information.
-     *
-     * @param workerCnt Amount of threads responsible for sender hub batches processing.
-     */
-    public void setWorkerThreads(int workerCnt) {
-        this.workerCnt = workerCnt;
-    }
-
-    /**
-     * Gets message queue limit for incoming and outgoing messages in receiver hub's TCP server.
-     * <p>
-     * Defaults to {@link #DFLT_MSG_QUEUE_LIMIT}.
-     *
-     * @return Message queue limit for incoming and outgoing messages in receiver hub's TCP server.
-     */
-    public int getMessageQueueLimit() {
-        return msgQueueLimit;
-    }
-
-    /**
-     * Sets message queue limit for incoming and outgoing messages in receiver hub's TCP server. See
-     * {@link #getMessageQueueLimit()} for more information.
-     *
-     * @param msgQueueLimit Message queue limit for incoming and outgoing messages in receiver hub's TCP server.
-     */
-    public void setMessageQueueLimit(int msgQueueLimit) {
-        this.msgQueueLimit = msgQueueLimit;
-    }
-
-    /**
-     * Gets TCP_NODELAY flag in receiver hub's TCP server.
-     * <p>
-     * Defaults to {@link #DFLT_TCP_NODELAY}.
-     *
-     * @return TCP_NODELAY flag in receiver hub's TCP server.
-     */
-    public boolean isTcpNodelay() {
-        return tcpNodelay;
-    }
-
-    /**
-     * Sets TCP_NODELAY flag in receiver hub's TCP server. See {@link #isTcpNodelay()} for more information.
-     *
-     * @param tcpNodelay TCP_NODELAY flag in receiver hub's TCP server.
-     */
-    public void setTcpNodelay(boolean tcpNodelay) {
-        this.tcpNodelay = tcpNodelay;
-    }
-
-    /**
-     * Gets direct buffer flag in receiver hub's TCP server.
-     * <p>
-     * Defaults to {@link #DFLT_DIRECT_BUF}.
-     *
-     * @return Direct buffer flag in receiver hub's TCP server.
-     */
-    public boolean isDirectBuffer() {
-        return directBuf;
-    }
-
-    /**
-     * Sets direct buffer flag in receiver hub's TCP server. See {@link #isDirectBuffer()} for more information.
-     *
-     * @param directBuf Direct buffer flag in receiver hub's TCP server.
-     */
-    public void setDirectBuffer(boolean directBuf) {
-        this.directBuf = directBuf;
-    }
-
-    /**
-     * Gets idle timeout for receiver hub's TCP server connection.
-     * <p>
-     * Defaults to {@link #DFLT_IDLE_TIMEOUT}.
-     *
-     * @return Idle timeout for receiver hub's TCP server connection.
-     */
-    public long getIdleTimeout() {
-        return idleTimeout;
-    }
-
-    /**
-     * Sets idle timeout for receiver hub's TCP server connection. See {@link #getWriteTimeout()} for more information.
-     *
-     * @param idleTimeout Idle timeout for receiver hub's TCP server connection.
-     */
-    public void setIdleTimeout(long idleTimeout) {
-        this.idleTimeout = idleTimeout;
-    }
-
-    /**
-     * Gets write timeout for receiver hub's TCP server connection.
-     * <p>
-     * Defaults to {@link #DFLT_WRITE_TIMEOUT}.
-     *
-     * @return Write timeout for receiver hub's TCP server connection.
-     */
-    public long getWriteTimeout() {
-        return writeTimeout;
-    }
-
-    /**
-     * Sets write timeout for receiver hub's TCP server connection. See {@link #getWriteTimeout()} for more
-     * information.
-     *
-     * @param writeTimeout Write timeout for receiver hub's TCP server connection.
-     */
-    public void setWriteTimeout(long writeTimeout) {
-        this.writeTimeout = writeTimeout;
-    }
-
-    /**
-     * Gets data flush frequency. Defines how often receiver hub flushes batches received from sender hubs to receiver
-     * caches.
-     * <p>
-     * Defaults to {@link #DFLT_FLUSH_FREQ}.
-     *
-     * @return Data flush frequency.
-     */
-    public long getFlushFrequency() {
-        return flushFreq;
-    }
-
-    /**
-     * Sets data flush frequency. See {@link #getFlushFrequency()} for more information.
-     *
-     * @param flushFreq Data flush frequency.
-     */
-    public void setFlushFrequency(long flushFreq) {
-        this.flushFreq = flushFreq;
-    }
-
-    /**
-     * Gets per-node data buffer size. When amount of cache entries enqueued for particular receiver cache data node
-     * exceeds this limit, pending data will be flushed to that data node.
-     * <p>
-     * Defaults to {@link #DFLT_PER_NODE_BUF_SIZE}.
-     *
-     * @return Per-node data buffer size.
-     */
-    public int getPerNodeBufferSize() {
-        return perNodeBufSize;
-    }
-
-    /**
-     * Sets per-node data buffer size. See {@link #getPerNodeBufferSize()} for more information.
-     *
-     * @param perNodeBufSize Per-node data buffer size.
-     */
-    public void setPerNodeBufferSize(int perNodeBufSize) {
-        this.perNodeBufSize = perNodeBufSize;
-    }
-
-    /**
-     * Gets per-node parallel load operations. Defines how many data flush operations can be performed on a single
-     * receiver cache data node simultaneously.
-     * <p>
-     * Defaults {@link #DFLT_PARALLEL_LOAD_OPS}.
-     *
-     * @return Per-node parallel load operations
-     */
-    public int getPerNodeParallelLoadOperations() {
-        return perNodeParallelLoadOps;
-    }
-
-    /**
-     * Sets per-node parallel load operations. See {@link #getPerNodeParallelLoadOperations()} for more information.
-     *
-     * @param perNodeParallelLoadOps Per-node parallel load operations
-     */
-    public void setPerNodeParallelLoadOperations(int perNodeParallelLoadOps) {
-        this.perNodeParallelLoadOps = perNodeParallelLoadOps;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrReceiverHubConfiguration.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubInMetrics.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubInMetrics.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubInMetrics.java
deleted file mode 100644
index 6ef0813..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubInMetrics.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.receiver;
-
-/**
- * Data center replication receiver hub metrics for incoming data, i.e. data transferred from remote sender hubs to
- * receiver hub.
- */
-public interface GridDrReceiverHubInMetrics {
-    /**
-     * Gets amount of batches received from remote sender hubs.
-     *
-     * @return Amount of batches received from remote sender hubs.
-     */
-    public int batchesReceived();
-
-    /**
-     * Gets amount of cache entries received from remote sender hubs.
-     *
-     * @return Amount of cache entries received from remote sender hubs.
-     */
-    public long entriesReceived();
-
-    /**
-     * Gets total amount of bytes received from remote sender hubs.
-     *
-     * @return Total amount of bytes received from remote sender hubs.
-     */
-    public long bytesReceived();
-}


Mime
View raw message