Removed duplicated benchmark.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/864a95e1 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/864a95e1 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/864a95e1 Branch: refs/heads/ignite-3477 Commit: 864a95e13f1262f14351df0883d0a1abd1bf70c7 Parents: 8372e69 Author: sboikov <sboi...@gridgain.com> Authored: Thu Dec 29 14:45:08 2016 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Dec 29 14:45:08 2016 +0300 ---------------------------------------------------------------------- .../yardstick/cache/IgniteIoTestBenchmark.java | 73 -------------------- 1 file changed, 73 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/864a95e1/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteIoTestBenchmark.java ---------------------------------------------------------------------- diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteIoTestBenchmark.java b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteIoTestBenchmark.java deleted file mode 100644 index bee45e0..0000000 --- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteIoTestBenchmark.java +++ /dev/null @@ -1,73 +0,0 @@ -/* - * 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.yardstick.cache; - -import org.apache.ignite.IgniteException; -import org.apache.ignite.cluster.ClusterNode; -import org.apache.ignite.internal.IgniteKernal; -import org.apache.ignite.yardstick.IgniteAbstractBenchmark; -import org.yardstickframework.BenchmarkConfiguration; -import org.yardstickframework.BenchmarkUtils; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.List; -import java.util.Map; - -/** - * - */ -public class IgniteIoTestBenchmark extends IgniteAbstractBenchmark { - /** */ - private List<ClusterNode> targetNodes; - - /** */ - private IgniteKernal ignite; - - /** {@inheritDoc} */ - @Override public void setUp(BenchmarkConfiguration cfg) throws Exception { - super.setUp(cfg); - - ignite = (IgniteKernal)ignite(); - - targetNodes = new ArrayList<>(); - - ClusterNode loc = ignite().cluster().localNode(); - - Collection<ClusterNode> nodes = ignite().cluster().forServers().nodes(); - - for (ClusterNode node : nodes) { - if (!loc.equals(node)) - targetNodes.add(node); - } - - if (targetNodes.isEmpty()) - throw new IgniteException("Failed to find remote server nodes [nodes=" + nodes + ']'); - - BenchmarkUtils.println(cfg, "Initialized target nodes: " + targetNodes + ']'); - } - - /** {@inheritDoc} */ - @Override public boolean test(Map<Object, Object> ctx) throws Exception { - ClusterNode node = targetNodes.get(nextRandom(targetNodes.size())); - - ignite.sendIoTest(node, null, false).get(); - - return true; - } -}
