AstralTransRocketries/minosoft
1
0
Fork 0
mirror of https://gitlab.bixilon.de/bixilon/minosoft.git synced 2025-09-14 01:48:04 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix infinite ticking after disconnect

Browse Source
This commit is contained in:
Bixilon 2021-06-03 22:17:15 +02:00 committed by Lukas
parent cd5d438743
commit 035a60dae2
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/de/bixilon/minosoft/protocol/network/connection/PlayConnection.kt
View File

@ -79,7 +79,7 @@ class PlayConnection(
private set
private lateinit var entityTickTask: TimeWorkerTask
private lateinit var blockEntityTickTask: TimeWorkerTask
private lateinit var worldTickTask: TimeWorkerTask
private lateinit var randomTickTask: TimeWorkerTask
val collisionDetector = CollisionDetector(this)
var retry = true
@ -124,18 +124,17 @@ class PlayConnection(
if (CLI.getCurrentConnection() == null) {
CLI.setCurrentConnection(this)
}
entityTickTask = TimeWorkerTask(ProtocolDefinition.TICK_TIME / 5) {
entityTickTask = TimeWorker.addTask(TimeWorkerTask(ProtocolDefinition.TICK_TIME / 5) {
for (entity in world.entities) {
entity.tick()
}
}
TimeWorker.addTask(entityTickTask)
})
TimeWorker.addTask(TimeWorkerTask(ProtocolDefinition.TICK_TIME, maxDelayTime = ProtocolDefinition.TICK_TIME / 2) {
worldTickTask = TimeWorker.addTask(TimeWorkerTask(ProtocolDefinition.TICK_TIME, maxDelayTime = ProtocolDefinition.TICK_TIME / 2) {
world.realTick()
})
TimeWorker.addTask(TimeWorkerTask(ProtocolDefinition.TICK_TIME, maxDelayTime = ProtocolDefinition.TICK_TIME / 2) {
randomTickTask = TimeWorker.addTask(TimeWorkerTask(ProtocolDefinition.TICK_TIME, maxDelayTime = ProtocolDefinition.TICK_TIME / 2) {
world.randomTick()
})
@ -162,8 +161,8 @@ class PlayConnection(
if (this::entityTickTask.isInitialized) {
TimeWorker.removeTask(entityTickTask)
}
if (this::blockEntityTickTask.isInitialized) {
TimeWorker.removeTask(blockEntityTickTask)
if (this::worldTickTask.isInitialized) {
TimeWorker.removeTask(worldTickTask)
}
if (this::randomTickTask.isInitialized) {
TimeWorker.removeTask(randomTickTask)

3
src/main/java/de/bixilon/minosoft/util/task/time/TimeWorker.kt
View File

@ -56,8 +56,9 @@ object TimeWorker {
TASKS += task
}
fun addTask(task: TimeWorkerTask) {
fun addTask(task: TimeWorkerTask): TimeWorkerTask {
TASKS += task
return task
}
fun removeTask(task: TimeWorkerTask) {