io.github.opencubicchunks.cubicchunks.core.server.chunkio

Class AsyncBatchingCubeIO

java.lang.Object

io.github.opencubicchunks.cubicchunks.core.server.chunkio.AsyncBatchingCubeIO

All Implemented Interfaces:

ICubeIO, java.io.Flushable, java.lang.AutoCloseable, net.minecraft.world.storage.IThreadedFileIO

public class AsyncBatchingCubeIO
extends java.lang.Object
implements ICubeIO

Implementation of ICubeIO which internally batches cubes/columns together, and forwards them along to a ICubicStorage on the I/O thread.

Nested Class Summary

Nested classes/interfaces inherited from interface io.github.opencubicchunks.cubicchunks.core.server.chunkio.ICubeIO

ICubeIO.PartialData<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.ReadWriteLock	lock
protected boolean	open
protected java.util.Map<net.minecraft.util.math.ChunkPos,net.minecraft.nbt.NBTTagCompound>	pendingColumns
protected java.util.Map<CubePos,net.minecraft.nbt.NBTTagCompound>	pendingCubes
protected ICubicStorage	storage
protected net.minecraft.world.World	world

Constructor Summary

Constructors

Constructor and Description
AsyncBatchingCubeIO(net.minecraft.world.World world, ICubicStorage storage)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	columnExists(int columnX, int columnZ)
boolean	cubeExists(int cubeX, int cubeY, int cubeZ)
protected void	drainQueueBlocking() Blocks the calling thread until the write queues have been completely drained.
protected void	ensureOpen()
void	flush()
int	getPendingColumnCount()
int	getPendingCubeCount()
ICubicStorage	getStorage()
void	loadColumnAsyncPart(ICubeIO.PartialData<net.minecraft.world.chunk.Chunk> info, int chunkX, int chunkZ)
ICubeIO.PartialData<net.minecraft.world.chunk.Chunk>	loadColumnNbt(int chunkX, int chunkZ)
void	loadColumnSyncPart(ICubeIO.PartialData<net.minecraft.world.chunk.Chunk> info)
void	loadCubeAsyncPart(ICubeIO.PartialData<ICube> info, net.minecraft.world.chunk.Chunk column, int cubeY)
ICubeIO.PartialData<ICube>	loadCubeNbt(net.minecraft.world.chunk.Chunk column, int cubeY)
void	loadCubeSyncPart(ICubeIO.PartialData<ICube> info)
void	saveColumn(net.minecraft.world.chunk.Chunk column)
void	saveCube(Cube cube)
boolean	writeNextIO()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.github.opencubicchunks.cubicchunks.core.server.chunkio.ICubeIO

loadColumnAsyncPart, loadCubeAsyncPart

Field Detail

lock

protected final java.util.concurrent.locks.ReadWriteLock lock

world

protected final net.minecraft.world.World world

storage

protected final ICubicStorage storage

pendingColumns

protected final java.util.Map<net.minecraft.util.math.ChunkPos,net.minecraft.nbt.NBTTagCompound> pendingColumns

pendingCubes

protected final java.util.Map<CubePos,net.minecraft.nbt.NBTTagCompound> pendingCubes

open

protected volatile boolean open

Constructor Detail

AsyncBatchingCubeIO

public AsyncBatchingCubeIO(net.minecraft.world.World world,
                           ICubicStorage storage)
                    throws java.io.IOException

Throws:

java.io.IOException

Method Detail

ensureOpen

protected void ensureOpen()

getStorage

public ICubicStorage getStorage()

columnExists

public boolean columnExists(int columnX,
                            int columnZ)

Specified by:

columnExists in interface ICubeIO

cubeExists

public boolean cubeExists(int cubeX,
                          int cubeY,
                          int cubeZ)

Specified by:

cubeExists in interface ICubeIO

loadColumnNbt

public ICubeIO.PartialData<net.minecraft.world.chunk.Chunk> loadColumnNbt(int chunkX,
                                                                          int chunkZ)
                                                                   throws java.io.IOException

Specified by:

loadColumnNbt in interface ICubeIO

Throws:

java.io.IOException

loadCubeNbt

public ICubeIO.PartialData<ICube> loadCubeNbt(net.minecraft.world.chunk.Chunk column,
                                              int cubeY)
                                       throws java.io.IOException

Specified by:

loadCubeNbt in interface ICubeIO

Throws:

java.io.IOException

saveColumn

public void saveColumn(net.minecraft.world.chunk.Chunk column)

Specified by:

saveColumn in interface ICubeIO

saveCube

public void saveCube(Cube cube)

Specified by:

saveCube in interface ICubeIO

getPendingColumnCount

public int getPendingColumnCount()

Specified by:

getPendingColumnCount in interface ICubeIO

getPendingCubeCount

public int getPendingCubeCount()

Specified by:

getPendingCubeCount in interface ICubeIO

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface ICubeIO

Specified by:

flush in interface java.io.Flushable

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface ICubeIO

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

drainQueueBlocking

protected void drainQueueBlocking()
                           throws java.lang.InterruptedException

Blocks the calling thread until the write queues have been completely drained.

Throws:

java.lang.InterruptedException - if the thread has been interrupted

writeNextIO

public boolean writeNextIO()

Specified by:

writeNextIO in interface net.minecraft.world.storage.IThreadedFileIO

loadColumnAsyncPart

public void loadColumnAsyncPart(ICubeIO.PartialData<net.minecraft.world.chunk.Chunk> info,
                                int chunkX,
                                int chunkZ)

Specified by:

loadColumnAsyncPart in interface ICubeIO

loadColumnSyncPart

public void loadColumnSyncPart(ICubeIO.PartialData<net.minecraft.world.chunk.Chunk> info)

Specified by:

loadColumnSyncPart in interface ICubeIO

loadCubeAsyncPart

public void loadCubeAsyncPart(ICubeIO.PartialData<ICube> info,
                              net.minecraft.world.chunk.Chunk column,
                              int cubeY)

Specified by:

loadCubeAsyncPart in interface ICubeIO

loadCubeSyncPart

public void loadCubeSyncPart(ICubeIO.PartialData<ICube> info)

Specified by:

loadCubeSyncPart in interface ICubeIO