eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-15 10:18:45 +00:00
Code Activity

bug5813: remove now obsolete test code after removing concurrent query aborts

Browse Source
This commit is contained in:
Axel Uhl
2023-02-15 21:46:28 +01:00
parent acb5df8431
commit 85bd0900c4
1 changed files with 1 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sse.datamining.test/src/com/sap/sse/datamining/impl/components/management/TestServerQueryManagement.java
+1 -80
View File
@@ -1,8 +1,8 @@
package com.sap.sse.datamining.impl.components.management;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;
import static org.hamcrest.Matchers.not;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.junit.Assert.fail;
import java.lang.reflect.Method;
@@ -44,16 +44,6 @@ public class TestServerQueryManagement {
server = TestsUtil.createNewServer();
}
@Test
public void testStatisticQueryManagementWithConflict() {
DataMiningSession session = new UUIDDataMiningSession(UUID.randomUUID());
AdditionalQueryData additionalData = new AdditionalStatisticQueryData();
final ControllablePseudoQuery<Double> firstQuery = new ControllablePseudoQuery<Double>(Double.class, additionalData);
final ControllablePseudoQuery<Double> secondQuery = new ControllablePseudoQuery<Double>(Double.class, additionalData);
runQueriesAndVerifyConflict(session, firstQuery, session, secondQuery);
}
@Test
public void testStatisticQueryManagementWithoutConflict() {
DataMiningSession firstQuerySession = new UUIDDataMiningSession(UUID.randomUUID());
@@ -65,19 +55,6 @@ public class TestServerQueryManagement {
runQueriesAndVerifyNoConflict(firstQuerySession, firstQuery, secondQuerySession, secondQuery);
}
@Test
public void testDimensionValuesQueryManagementWithConflict() {
DataMiningSession session = new UUIDDataMiningSession(UUID.randomUUID());
Collection<Function<?>> dimensions = new ArrayList<>();
Method getYear = FunctionTestsUtil.getMethodFromClass(Test_HasRaceContext.class, "getYear");
dimensions.add(functionFactory.createMethodWrappingFunction(getYear));
AdditionalQueryData additionalData = new AdditionalDimensionValuesQueryData(dimensions);
final ControllablePseudoQuery<Double> firstQuery = new ControllablePseudoQuery<Double>(Double.class, additionalData);
final ControllablePseudoQuery<Double> secondQuery = new ControllablePseudoQuery<Double>(Double.class, additionalData);
runQueriesAndVerifyConflict(session, firstQuery, session, secondQuery);
}
@Test
public void testDimensionValuesQueryManagementWithoutConflictsDueToDifferentDimensions() {
DataMiningSession session = new UUIDDataMiningSession(UUID.randomUUID());
@@ -123,25 +100,6 @@ public class TestServerQueryManagement {
runQueriesAndVerifyNoConflict(session, firstQuery, session, secondQuery);
}
private void runQueriesAndVerifyConflict(DataMiningSession firstQuerySession, ControllablePseudoQuery<?> firstQuery, DataMiningSession secondQuerySession, ControllablePseudoQuery<?> secondQuery) {
Thread firstQueryWorker = new Thread(new ServerQueryWorker(firstQuerySession, firstQuery));
Thread secondQueryWorker = new Thread(new ServerQueryWorker(secondQuerySession, secondQuery));
firstQueryWorker.start();
ConcurrencyTestsUtil.sleepFor(75);
assertThat(server.getNumberOfRunningQueries(), is(1));
assertThat(firstQuery.getState(), not(QueryState.ABORTED));
secondQueryWorker.start();
ConcurrencyTestsUtil.sleepFor(75);
assertThat(server.getNumberOfRunningQueries(), is(1));
assertThat(firstQuery.getState(), is(QueryState.ABORTED));
secondQuery.enableProcess();
ConcurrencyTestsUtil.sleepFor(110);
assertThat(server.getNumberOfRunningQueries(), is(0));
assertThat(secondQuery.getState(), is(QueryState.NORMAL));
}
private void runQueriesAndVerifyNoConflict(DataMiningSession firstQuerySession, ControllablePseudoQuery<?> firstQuery, DataMiningSession secondQuerySession, ControllablePseudoQuery<?> secondQuery) {
Thread firstQueryWorker = new Thread(new ServerQueryWorker(firstQuerySession, firstQuery));
Thread secondQueryWorker = new Thread(new ServerQueryWorker(secondQuerySession, secondQuery));
@@ -395,42 +353,5 @@ public class TestServerQueryManagement {
fail("Expected a NullPointerException");
} catch (NullPointerException e) {
}
try {
Query<Object> query = new NullQuery();
server.runNewQueryAndAbortPreviousQueries(null, query);
fail("Expected a NullPointerException");
} catch (NullPointerException e) {
}
}
private static class NullQuery implements Query<Object> {
@Override
public QueryState getState() {
return QueryState.NOT_STARTED;
}
@Override
public Class<Object> getResultType() {
return Object.class;
}
@Override
public AdditionalQueryData getAdditionalData() {
return new AdditionalStatisticQueryData();
}
@Override
public <T extends AdditionalQueryData> T getAdditionalData(Class<T> additionalDataType) {
return null;
}
@Override
public QueryResult<Object> run() {
return null;
}
@Override
public QueryResult<Object> run(long timeout, TimeUnit unit) throws TimeoutException {
return null;
}
@Override
public void abort() { }
}
}