aboutsummaryrefslogtreecommitdiffstats
path: root/server/sonar-search
diff options
context:
space:
mode:
authorSimon Brandhof <simon.brandhof@sonarsource.com>2014-09-12 17:46:05 +0200
committerSimon Brandhof <simon.brandhof@sonarsource.com>2014-09-12 17:46:05 +0200
commit6309b7510b59176c836102e2d19e736d260114da (patch)
tree0f267400a23367ddc77b951ff0abe464d8eca638 /server/sonar-search
parent3166381a9020db85e45bfef8ebea9f841736af69 (diff)
downloadsonarqube-6309b7510b59176c836102e2d19e736d260114da.tar.gz
sonarqube-6309b7510b59176c836102e2d19e736d260114da.zip
SONAR-4898 fix quality flaws
Diffstat (limited to 'server/sonar-search')
-rw-r--r--server/sonar-search/src/test/java/org/sonar/search/SearchServerTest.java155
1 files changed, 0 insertions, 155 deletions
diff --git a/server/sonar-search/src/test/java/org/sonar/search/SearchServerTest.java b/server/sonar-search/src/test/java/org/sonar/search/SearchServerTest.java
deleted file mode 100644
index 54fb02435e9..00000000000
--- a/server/sonar-search/src/test/java/org/sonar/search/SearchServerTest.java
+++ /dev/null
@@ -1,155 +0,0 @@
-/*
- * SonarQube, open source software quality management tool.
- * Copyright (C) 2008-2014 SonarSource
- * mailto:contact AT sonarsource DOT com
- *
- * SonarQube is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 3 of the License, or (at your option) any later version.
- *
- * SonarQube is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this program; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
- */
-package org.sonar.search;
-
-import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus;
-import org.elasticsearch.client.transport.TransportClient;
-import org.elasticsearch.common.settings.ImmutableSettings;
-import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.common.transport.InetSocketTransportAddress;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Ignore;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.TemporaryFolder;
-import org.sonar.process.JmxUtils;
-import org.sonar.process.Props;
-
-import javax.management.InstanceNotFoundException;
-import javax.management.MBeanRegistrationException;
-import javax.management.MBeanServer;
-
-import java.io.IOException;
-import java.lang.management.ManagementFactory;
-import java.net.ServerSocket;
-import java.util.Properties;
-
-import static org.fest.assertions.Assertions.assertThat;
-import static org.junit.Assert.fail;
-
-@Ignore
-public class SearchServerTest {
-
- @Rule
- public TemporaryFolder temp = new TemporaryFolder();
-
- SearchServer searchServer;
- int freePort;
- int freeESPort;
-
- @Before
- public void setup() throws IOException {
- ServerSocket socket = new ServerSocket(0);
- freePort = socket.getLocalPort();
- socket.close();
-
- socket = new ServerSocket(0);
- freeESPort = socket.getLocalPort();
- socket.close();
- }
-
- @After
- public void tearDown() throws MBeanRegistrationException, InstanceNotFoundException {
- resetMBeanServer();
- }
-
- private void resetMBeanServer() throws MBeanRegistrationException, InstanceNotFoundException {
- try {
- MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
- mbeanServer.unregisterMBean(JmxUtils.objectName("ES"));
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- @Test
- public void server_fail_to_start() throws Exception {
- Properties properties = new Properties();
-
- searchServer = new SearchServer(new Props(properties));
- new Thread(new Runnable() {
- @Override
- public void run() {
- searchServer.start();
- }
- }).start();
- assertThat(searchServer.isReady()).isFalse();
-
- int count = 0;
- while (!searchServer.isReady() && count < 5) {
- try {
- Thread.sleep(100);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- count++;
- }
- assertThat(count).isEqualTo(5);
- }
-
- @Test
- public void can_connect() throws Exception {
- Properties properties = new Properties();
- properties.setProperty(SearchServer.SONAR_PATH_DATA, temp.newFolder().getAbsolutePath());
- properties.setProperty(SearchServer.SONAR_PATH_TEMP, temp.newFolder().getAbsolutePath());
- properties.setProperty(SearchServer.SONAR_PATH_LOG, temp.newFolder().getAbsolutePath());
- properties.setProperty(SearchServer.ES_PORT_PROPERTY, Integer.toString(freeESPort));
- properties.setProperty(SearchServer.ES_CLUSTER_PROPERTY, "sonarqube");
-
- searchServer = new SearchServer(new Props(properties));
- new Thread(new Runnable() {
- @Override
- public void run() {
- searchServer.start();
- }
- }).start();
- assertThat(searchServer.isReady()).isFalse();
-
- int count = 0;
- while (!searchServer.isReady() && count < 100) {
- try {
- Thread.sleep(500);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- count++;
- }
- assertThat(count).isLessThan(100);
-
- Settings settings = ImmutableSettings.settingsBuilder()
- .put("cluster.name", "sonarqube")
- .build();
- TransportClient client = new TransportClient(settings)
- .addTransportAddress(new InetSocketTransportAddress("localhost", freeESPort));
-
- // 0 assert that we have a OK cluster available
- assertThat(client.admin().cluster().prepareClusterStats().get().getStatus()).isEqualTo(ClusterHealthStatus.GREEN);
-
- // 2 assert that we can shut down ES
- searchServer.terminate();
- try {
- client.admin().cluster().prepareClusterStats().get().getStatus();
- fail();
- } catch (Exception e) {
- assertThat(e.getMessage()).isEqualTo("No node available");
- }
- }
-}