diff --git a/build.xml b/build.xml index c9f09f6b9b..31c1fe9cfe 100644 --- a/build.xml +++ b/build.xml @@ -1304,6 +1304,43 @@ + + + + + + + + + + + + + + + + + + + + + + + + @@ -1392,24 +1427,16 @@ - - - - - - - Failed to set File Separator. This shouldn't happen. - - - - - - - + + + + + + - + @@ -1429,7 +1456,6 @@ - @@ -1453,7 +1479,6 @@ - @@ -1474,7 +1499,6 @@ - @@ -1495,7 +1519,6 @@ - @@ -1555,24 +1578,24 @@ - - + + - - + + - - + + @@ -1784,13 +1807,12 @@ - @@ -1811,8 +1833,8 @@ - - + + @@ -1831,29 +1853,29 @@ - - + + - - + + - - + + - - + + diff --git a/test/unit/org/apache/cassandra/OffsetAwareConfigurationLoader.java b/test/unit/org/apache/cassandra/OffsetAwareConfigurationLoader.java deleted file mode 100644 index fce677f1b1..0000000000 --- a/test/unit/org/apache/cassandra/OffsetAwareConfigurationLoader.java +++ /dev/null @@ -1,105 +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.cassandra; - -import org.apache.cassandra.config.Config; -import org.apache.cassandra.config.YamlConfigurationLoader; -import org.apache.cassandra.exceptions.ConfigurationException; -import org.apache.cassandra.locator.InetAddressAndPort; - -import java.io.File; -import java.net.Inet6Address; -import java.net.UnknownHostException; -import java.util.Arrays; -import java.util.stream.Collectors; - -import com.google.common.base.Joiner; - - -public class OffsetAwareConfigurationLoader extends YamlConfigurationLoader -{ - - static final String OFFSET_PROPERTY = "cassandra.test.offsetseed"; - int offset = 0; - - public OffsetAwareConfigurationLoader() - { - String offsetStr = System.getProperty(OFFSET_PROPERTY); - - if (offsetStr == null) - throw new RuntimeException("offset property is not set: "+OFFSET_PROPERTY); - - offset = Integer.valueOf(offsetStr); - - assert offset >= 0; - } - - @Override - public Config loadConfig() throws ConfigurationException - { - Config config = super.loadConfig(); - - String sep = File.pathSeparator; - - assert offset < 2000; - config.native_transport_port += offset; - if (config.native_transport_port_ssl != null) - config.native_transport_port_ssl += offset; - config.storage_port += offset; - config.ssl_storage_port += offset; - - //Rewrite the seed ports string - String[] hosts = config.seed_provider.parameters.get("seeds").split(",", -1); - String rewrittenSeeds = Joiner.on(", ").join(Arrays.stream(hosts).map(host -> { - StringBuilder sb = new StringBuilder(); - try - { - InetAddressAndPort address = InetAddressAndPort.getByName(host.trim()); - if (address.address instanceof Inet6Address) - { - sb.append('[').append(address.address.getHostAddress()).append(']'); - } - else - { - sb.append(address.address.getHostAddress()); - } - sb.append(':').append(address.port + offset); - return sb.toString(); - } - catch (UnknownHostException e) - { - throw new ConfigurationException("Error in OffsetAwareConfigurationLoader reworking seed list", e); - } - }).collect(Collectors.toList())); - config.seed_provider.parameters.put("seeds", rewrittenSeeds); - - config.commitlog_directory += sep + offset; - config.saved_caches_directory += sep + offset; - config.hints_directory += sep + offset; - - config.cdc_raw_directory += sep + offset; - - for (int i = 0; i < config.data_file_directories.length; i++) - config.data_file_directories[i] += sep + offset; - - if (config.local_system_data_file_directory != null) - config.local_system_data_file_directory += sep + offset; - - return config; - } -} diff --git a/test/unit/org/apache/cassandra/config/DatabaseDescriptorRefTest.java b/test/unit/org/apache/cassandra/config/DatabaseDescriptorRefTest.java index 521071cb84..a08375fd67 100644 --- a/test/unit/org/apache/cassandra/config/DatabaseDescriptorRefTest.java +++ b/test/unit/org/apache/cassandra/config/DatabaseDescriptorRefTest.java @@ -149,7 +149,6 @@ public class DatabaseDescriptorRefTest "org.apache.cassandra.utils.FBUtilities$1", "org.apache.cassandra.utils.CloseableIterator", "org.apache.cassandra.utils.Pair", - "org.apache.cassandra.OffsetAwareConfigurationLoader", "org.apache.cassandra.ConsoleAppender", "org.apache.cassandra.ConsoleAppender$1", "org.apache.cassandra.LogbackStatusListener",