Code style
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d82b2b81 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d82b2b81 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d82b2b81 Branch: refs/heads/ignite-2.1 Commit: d82b2b81a487e244584a7101c6d0e3bc0ad38151 Parents: f4ad01b Author: Ivan Rakov <[email protected]> Authored: Wed Jul 5 20:05:52 2017 +0300 Committer: Ivan Rakov <[email protected]> Committed: Wed Jul 5 20:05:52 2017 +0300 ---------------------------------------------------------------------- .../FinishSnapshotOperationAckDiscoveryMessage.java | 8 +++----- .../cache/persistence/DbCheckpointListener.java | 14 +++++++++++++- 2 files changed, 16 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d82b2b81/modules/core/src/main/java/org/apache/ignite/internal/pagemem/snapshot/FinishSnapshotOperationAckDiscoveryMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/snapshot/FinishSnapshotOperationAckDiscoveryMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/snapshot/FinishSnapshotOperationAckDiscoveryMessage.java index 83c512a..f6758e0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/snapshot/FinishSnapshotOperationAckDiscoveryMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/snapshot/FinishSnapshotOperationAckDiscoveryMessage.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.pagemem.snapshot; import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage; +import org.apache.ignite.internal.util.typedef.internal.S; import org.apache.ignite.lang.IgniteUuid; import org.jetbrains.annotations.Nullable; @@ -77,10 +78,7 @@ public class FinishSnapshotOperationAckDiscoveryMessage implements DiscoveryCust /** {@inheritDoc} */ @Override public String toString() { - return "FinishSnapshotOperationAckDiscoveryMessage{" + - "id=" + id + - ", opId=" + opId + - ", success=" + success + - '}'; + return S.toString(FinishSnapshotOperationAckDiscoveryMessage.class, this, + "id", id, "opId", opId, "success", success); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/d82b2b81/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/DbCheckpointListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/DbCheckpointListener.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/DbCheckpointListener.java index daaccff..0b28b6a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/DbCheckpointListener.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/DbCheckpointListener.java @@ -25,16 +25,28 @@ import org.apache.ignite.internal.util.typedef.T2; * */ public interface DbCheckpointListener { + /** + * Context with information about current snapshots. + */ public interface Context { + /** + * + */ public boolean nextSnapshot(); + /** + * + */ public Map<T2<Integer, Integer>, T2<Integer, Integer>> partitionStatMap(); + /** + * @param cacheOrGrpName Cache or group name. + */ public boolean needToSnapshot(String cacheOrGrpName); } /** * @throws IgniteCheckedException If failed. */ - public void onCheckpointBegin(Context context) throws IgniteCheckedException; + public void onCheckpointBegin(Context ctx) throws IgniteCheckedException; }
