AstralTransRocketries/OpenComputers
1
0
Fork 0
mirror of https://github.com/MightyPirates/OpenComputers.git synced 2025-09-16 02:39:48 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master-MC1.11' into master-MC1.12

Browse Source
This commit is contained in:
payonel 2018-10-28 00:23:48 -07:00
commit 7ffc9525a4
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/scala/li/cil/oc/server/component/UpgradeChunkloader.scala
View File

@ -66,20 +66,20 @@ class UpgradeChunkloader(val host: EnvironmentHost) extends AbstractManagedEnvir
super.onConnect(node)
if (node == this.node) {
val restoredTicket = ChunkloaderUpgradeHandler.restoredTickets.remove(node.address)
ticket = if (restoredTicket.isDefined) {
if (restoredTicket.isDefined) {
if (!isDimensionAllowed) {
try ForgeChunkManager.releaseTicket(restoredTicket.get) catch {
case _: Throwable => // Ignored.
}
OpenComputers.log.info(s"Releasing chunk loader ticket at (${host.xPosition()}, ${host.yPosition()}, ${host.zPosition()}) in blacklisted dimension ${host.world().provider.getDimension}.")
None
} else {
OpenComputers.log.info(s"Reclaiming chunk loader ticket at (${host.xPosition()}, ${host.yPosition()}, ${host.zPosition()}) in dimension ${host.world().provider.getDimension}.")
restoredTicket
ticket = restoredTicket
ChunkloaderUpgradeHandler.updateLoadedChunk(this)
}
} else host match {
case context: Context if context.isRunning => requestTicket()
case _ => None
case _ =>
}
}
}
@ -106,7 +106,7 @@ class UpgradeChunkloader(val host: EnvironmentHost) extends AbstractManagedEnvir
private def setActive(enabled: Boolean, throwIfBlocked: Boolean = false) = {
if (enabled && ticket.isEmpty) {
ticket = requestTicket(throwIfBlocked)
requestTicket(throwIfBlocked)
ticket.isDefined
}
else if (!enabled && ticket.isDefined) {
@ -136,16 +136,14 @@ class UpgradeChunkloader(val host: EnvironmentHost) extends AbstractManagedEnvir
true
}
private def requestTicket(throwIfBlocked: Boolean = false): Option[Ticket] = {
private def requestTicket(throwIfBlocked: Boolean = false): Unit = {
if (!isDimensionAllowed) {
if (throwIfBlocked) {
throw new Exception("this dimension is blacklisted")
}
None
} else {
val result = Option(ForgeChunkManager.requestTicket(OpenComputers, host.world, ForgeChunkManager.Type.NORMAL))
ticket = Option(ForgeChunkManager.requestTicket(OpenComputers, host.world, ForgeChunkManager.Type.NORMAL))
ChunkloaderUpgradeHandler.updateLoadedChunk(this)
result
}
}
}