You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2017/07/07 09:37:27 UTC
[26/50] [abbrv] ignite git commit: Code style
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/master
Commit: d82b2b81a487e244584a7101c6d0e3bc0ad38151
Parents: f4ad01b
Author: Ivan Rakov <iv...@gmail.com>
Authored: Wed Jul 5 20:05:52 2017 +0300
Committer: Ivan Rakov <iv...@gmail.com>
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;
}