diff --git a/server/src/main/java/ServerMain.kt b/server/src/main/java/ServerMain.kt index 75813987b79..9bbe2abcb33 100644 --- a/server/src/main/java/ServerMain.kt +++ b/server/src/main/java/ServerMain.kt @@ -4,7 +4,6 @@ import net.car.Dropper import net.car.client.Client import objects.Environment - fun main(args: Array) { var roomScanner: RoomScanner? = null val carServer = net.car.server.Server.createCarServerThread() @@ -21,7 +20,6 @@ fun main(args: Array) { } } - //todo запуск потока алгоритма нужно вынести сюда, //todo а debug интерфейсутребуется исключительно возможность установки кол-ва итераций //CL user interface diff --git a/server/src/main/java/net/car/Dropper.kt b/server/src/main/java/net/car/Dropper.kt index 9f749e4e0fa..5092899a124 100644 --- a/server/src/main/java/net/car/Dropper.kt +++ b/server/src/main/java/net/car/Dropper.kt @@ -7,6 +7,8 @@ import kotlin.concurrent.thread object Dropper { + private val WAIT_TIMEOUT = 2L * 60 * 1000 + fun createCarsDestroyThread(): Thread { return thread(false, false, null, "dropCar", -1, getThreadCode()) } @@ -19,7 +21,7 @@ object Dropper { dropInactiveCar(Environment) }) try { - Thread.sleep(120000) + Thread.sleep(WAIT_TIMEOUT) } catch (e: InterruptedException) { println("thread for destroy cars stopped") stopped = true diff --git a/server/src/main/java/net/car/client/Client.kt b/server/src/main/java/net/car/client/Client.kt index 7e9cf9c0937..25de21fed28 100644 --- a/server/src/main/java/net/car/client/Client.kt +++ b/server/src/main/java/net/car/client/Client.kt @@ -8,7 +8,7 @@ import java.rmi.UnexpectedException object Client { private val client = DefaultAsyncHttpClient() - private val timeout = 5 * 60 * 60 * 1000 + private val TIMEOUT = 5 * 60 * 60 * 1000 enum class Request(val url: String) { CONNECT("connect"), @@ -27,6 +27,6 @@ object Client { } fun makeRequest(request: String, data: ByteArray): ListenableFuture = - client.preparePost(request).setBody(data).setRequestTimeout(timeout).execute() ?: throw UnexpectedException(request) + client.preparePost(request).setBody(data).setRequestTimeout(TIMEOUT).execute() ?: throw UnexpectedException(request) } diff --git a/server/src/main/java/objects/Car.kt b/server/src/main/java/objects/Car.kt index 246fb73175c..e79ae8dd999 100644 --- a/server/src/main/java/objects/Car.kt +++ b/server/src/main/java/objects/Car.kt @@ -2,16 +2,10 @@ package objects class Car constructor(val uid: Int, host: String, port: Int) { - var x = 0.0 var y = 0.0 var angle = 0.0 - - val carConnection: CarConnection - - init { - carConnection = CarConnection(host, port) - } + val carConnection = CarConnection(host, port) override fun toString(): String { return "$uid ; x:$x; y:$y; target:$angle" diff --git a/server/src/main/java/objects/CarConnection.kt b/server/src/main/java/objects/CarConnection.kt index 1f8b5a18087..d0fa2dd3810 100644 --- a/server/src/main/java/objects/CarConnection.kt +++ b/server/src/main/java/objects/CarConnection.kt @@ -6,9 +6,7 @@ import org.asynchttpclient.Response class CarConnection(val host: String, val port: Int) { - fun sendRequest(request: Client.Request, data: ByteArray): ListenableFuture { return Client.makeRequest("http://$host:$port/${request.url}", data) } - } \ No newline at end of file