reducing code duplication

This commit is contained in:
rusefi 2020-07-22 13:24:08 -04:00
parent 78fecdf191
commit 342c80d270
4 changed files with 16 additions and 10 deletions

View File

@ -69,9 +69,7 @@ public class FullServerTest {
// create virtual controller to which "rusEFI network connector" connects to // create virtual controller to which "rusEFI network connector" connects to
int controllerPort = 7002; int controllerPort = 7002;
ConfigurationImage controllerImage = prepareImage(value, createIniField(Fields.CYLINDERSCOUNT)); ConfigurationImage controllerImage = prepareImage(value, createIniField(Fields.CYLINDERSCOUNT));
CountDownLatch controllerCreated = new CountDownLatch(1); TestHelper.createVirtualController(controllerPort, controllerImage, logger);
TestHelper.createVirtualController(controllerImage, controllerPort, parameter -> controllerCreated.countDown(), logger);
assertTrue(controllerCreated.await(READ_IMAGE_TIMEOUT, TimeUnit.MILLISECONDS));
// start "rusEFI network connector" to connect controller with backend since in real life controller has only local serial port it does not have network // start "rusEFI network connector" to connect controller with backend since in real life controller has only local serial port it does not have network

View File

@ -17,6 +17,11 @@ import org.jetbrains.annotations.NotNull;
import java.io.IOException; import java.io.IOException;
import java.net.Socket; import java.net.Socket;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import static com.rusefi.Timeouts.READ_IMAGE_TIMEOUT;
import static org.junit.Assert.assertTrue;
public class TestHelper { public class TestHelper {
public static final String LOCALHOST = "localhost"; public static final String LOCALHOST = "localhost";
@ -68,4 +73,11 @@ public class TestHelper {
} }
return targetEcuSocket; return targetEcuSocket;
} }
public static BinaryProtocolServer createVirtualController(int controllerPort, ConfigurationImage controllerImage, Logger logger) throws InterruptedException {
CountDownLatch controllerCreated = new CountDownLatch(1);
BinaryProtocolServer server = createVirtualController(controllerImage, controllerPort, parameter -> controllerCreated.countDown(), logger);
assertTrue(controllerCreated.await(READ_IMAGE_TIMEOUT, TimeUnit.MILLISECONDS));
return server;
}
} }

View File

@ -51,9 +51,7 @@ public class TcpCommunicationIntegrationTest {
ConfigurationImage serverImage = TestHelper.prepareImage(value, iniField); ConfigurationImage serverImage = TestHelper.prepareImage(value, iniField);
int port = 6100; int port = 6100;
CountDownLatch serverCreated = new CountDownLatch(1); BinaryProtocolServer server = TestHelper.createVirtualController(port, serverImage, LOGGER);
BinaryProtocolServer server = TestHelper.createVirtualController(serverImage, port, parameter -> serverCreated.countDown(), LOGGER);
assertTrue(serverCreated.await(30, TimeUnit.SECONDS));
CountDownLatch connectionEstablishedCountDownLatch = new CountDownLatch(1); CountDownLatch connectionEstablishedCountDownLatch = new CountDownLatch(1);
@ -90,9 +88,7 @@ public class TcpCommunicationIntegrationTest {
int controllerPort = 6102; int controllerPort = 6102;
// create virtual controller // create virtual controller
CountDownLatch serverCreated = new CountDownLatch(1); TestHelper.createVirtualController(controllerPort, serverImage, LOGGER);
BinaryProtocolServer server = TestHelper.createVirtualController(serverImage, controllerPort, parameter -> serverCreated.countDown(), LOGGER);
assertTrue(serverCreated.await(30, TimeUnit.SECONDS));
int proxyPort = 6103; int proxyPort = 6103;

View File

@ -15,7 +15,7 @@ import java.util.concurrent.LinkedBlockingDeque;
public class UploadQueue { public class UploadQueue {
public static final String OUTBOX_FOLDER = FileUtil.RUSEFI_SETTINGS_FOLDER + File.separator + "outbox"; public static final String OUTBOX_FOLDER = FileUtil.RUSEFI_SETTINGS_FOLDER + File.separator + "outbox";
private static LinkedBlockingDeque<String> queue = new LinkedBlockingDeque<>(128); private static final LinkedBlockingDeque<String> queue = new LinkedBlockingDeque<>(128);
private static boolean isStarted; private static boolean isStarted;