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/12 06:49:19 UTC
[07/11] ignite git commit: ignite-2.1 Minor update of generated
classnames.
ignite-2.1 Minor update of generated classnames.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/66ccf859
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/66ccf859
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/66ccf859
Branch: refs/heads/master
Commit: 66ccf8594cc6de74c3d87620bc3c85cd86b571fa
Parents: 914fdc7
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Tue Jul 11 19:17:48 2017 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Tue Jul 11 19:17:48 2017 +0700
----------------------------------------------------------------------
.../visor/VisorCoordinatorNodeTask.java | 39 ++++++++++++++++++++
.../resources/META-INF/classnames.properties | 13 +++++--
2 files changed, 48 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/66ccf859/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorCoordinatorNodeTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorCoordinatorNodeTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorCoordinatorNodeTask.java
new file mode 100644
index 0000000..f744e9e
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorCoordinatorNodeTask.java
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.visor;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.UUID;
+import org.apache.ignite.cluster.ClusterNode;
+
+/**
+ * Base class for Visor tasks intended to execute job on coordinator node.
+ */
+public abstract class VisorCoordinatorNodeTask<A, R> extends VisorOneNodeTask<A, R> {
+ /** {@inheritDoc} */
+ @Override protected Collection<UUID> jobNodes(VisorTaskArgument<A> arg) {
+ ClusterNode crd = ignite.context().discovery().discoCache().oldestAliveServerNode();
+
+ Collection<UUID> nids = new ArrayList<>(1);
+
+ nids.add(crd == null ? ignite.localNode().id() : crd.id());
+
+ return nids;
+ }
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/66ccf859/modules/core/src/main/resources/META-INF/classnames.properties
----------------------------------------------------------------------
diff --git a/modules/core/src/main/resources/META-INF/classnames.properties b/modules/core/src/main/resources/META-INF/classnames.properties
index 8c0f400..675bd56 100644
--- a/modules/core/src/main/resources/META-INF/classnames.properties
+++ b/modules/core/src/main/resources/META-INF/classnames.properties
@@ -337,7 +337,6 @@ org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerManager$1
org.apache.ignite.internal.marshaller.optimized.OptimizedFieldType
org.apache.ignite.internal.mem.IgniteOutOfMemoryException
org.apache.ignite.internal.pagemem.impl.PageMemoryNoStoreImpl$Segment
-org.apache.ignite.internal.pagemem.snapshot.SnapshotCheckParameters
org.apache.ignite.internal.pagemem.wal.StorageException
org.apache.ignite.internal.pagemem.wal.WALIterator
org.apache.ignite.internal.pagemem.wal.record.TxRecord$TxAction
@@ -870,7 +869,11 @@ org.apache.ignite.internal.processors.cache.persistence.FullPageIdIterableCompar
org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$8
org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$CheckpointEntryType
org.apache.ignite.internal.processors.cache.persistence.GridCacheOffheapManager$RebalanceIteratorAdapter
+org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory
+org.apache.ignite.internal.processors.cache.persistence.file.RandomAccessFileIOFactory
org.apache.ignite.internal.processors.cache.persistence.pagemem.PageMemoryImpl$Segment
+org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotDiscoveryMessage
+org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotOperation
org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$Bool
org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$DestroyBag
org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$Result
@@ -1077,11 +1080,12 @@ org.apache.ignite.internal.processors.datastructures.AtomicDataStructureValue
org.apache.ignite.internal.processors.datastructures.DataStructureInfoKey
org.apache.ignite.internal.processors.datastructures.DataStructureType
org.apache.ignite.internal.processors.datastructures.DataStructuresCacheKey
-org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$11
-org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$13
-org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$15
+org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$10
+org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$12
+org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$14
org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$16
org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$17
+org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$18
org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$4
org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$5
org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor$8
@@ -1699,6 +1703,7 @@ org.apache.ignite.internal.util.typedef.T4
org.apache.ignite.internal.util.typedef.T5
org.apache.ignite.internal.util.typedef.T6
org.apache.ignite.internal.util.typedef.internal.SB
+org.apache.ignite.internal.visor.VisorCoordinatorNodeTask
org.apache.ignite.internal.visor.VisorDataTransferObject
org.apache.ignite.internal.visor.VisorEither
org.apache.ignite.internal.visor.VisorJob