149 lines
2.7 KiB
Java
149 lines
2.7 KiB
Java
package appeng.helpers;
|
|
|
|
import java.util.EnumSet;
|
|
import java.util.LinkedList;
|
|
import java.util.Queue;
|
|
import java.util.concurrent.Callable;
|
|
|
|
import net.minecraftforge.event.ForgeSubscribe;
|
|
import net.minecraftforge.event.world.WorldEvent;
|
|
import appeng.api.networking.IGridNode;
|
|
import appeng.me.Grid;
|
|
import appeng.tile.AEBaseTile;
|
|
import appeng.util.Platform;
|
|
import cpw.mods.fml.common.ITickHandler;
|
|
import cpw.mods.fml.common.TickType;
|
|
|
|
public class TickHandler implements ITickHandler
|
|
{
|
|
|
|
class HandlerRep
|
|
{
|
|
|
|
public Queue<AEBaseTile> tiles = new LinkedList();
|
|
|
|
public LinkedList<Grid> networks = new LinkedList();
|
|
|
|
public void clear()
|
|
{
|
|
tiles = new LinkedList();
|
|
networks = new LinkedList();
|
|
}
|
|
|
|
};
|
|
|
|
final public static TickHandler instance = new TickHandler();
|
|
|
|
final private Queue<Callable> callQueue = new LinkedList();
|
|
|
|
final private HandlerRep server = new HandlerRep();
|
|
final private HandlerRep client = new HandlerRep();
|
|
|
|
HandlerRep getRepo()
|
|
{
|
|
if ( Platform.isServer() )
|
|
return server;
|
|
return client;
|
|
}
|
|
|
|
public void addCallable(Callable c)
|
|
{
|
|
callQueue.add( c );
|
|
}
|
|
|
|
public void addInit(AEBaseTile tile)
|
|
{
|
|
getRepo().tiles.add( tile );
|
|
}
|
|
|
|
public void addNetwork(Grid grid)
|
|
{
|
|
if ( Platform.isServer() )
|
|
getRepo().networks.add( grid );
|
|
}
|
|
|
|
public void removeNetwork(Grid grid)
|
|
{
|
|
if ( Platform.isServer() )
|
|
getRepo().networks.remove( grid );
|
|
}
|
|
|
|
public Iterable<Grid> getGridList()
|
|
{
|
|
return getRepo().networks;
|
|
}
|
|
|
|
public void shutdown()
|
|
{
|
|
getRepo().clear();
|
|
}
|
|
|
|
@ForgeSubscribe
|
|
public void unloadWorld(WorldEvent.Unload ev)
|
|
{
|
|
if ( Platform.isServer() )
|
|
{
|
|
LinkedList<IGridNode> toDestroy = new LinkedList();
|
|
|
|
for (Grid g : getRepo().networks)
|
|
{
|
|
for (IGridNode n : g.getNodes())
|
|
{
|
|
if ( n.getWorld() == ev.world )
|
|
toDestroy.add( n );
|
|
}
|
|
}
|
|
|
|
for (IGridNode n : toDestroy)
|
|
n.destroy();
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void tickStart(EnumSet<TickType> type, Object... tickData)
|
|
{
|
|
|
|
}
|
|
|
|
@Override
|
|
public void tickEnd(EnumSet<TickType> type, Object... tickData)
|
|
{
|
|
HandlerRep repo = getRepo();
|
|
while (!repo.tiles.isEmpty())
|
|
{
|
|
AEBaseTile bt = repo.tiles.poll();
|
|
bt.onReady();
|
|
}
|
|
|
|
for (Grid g : getRepo().networks)
|
|
{
|
|
g.update();
|
|
}
|
|
|
|
Callable c = null;
|
|
while ((c = callQueue.poll()) != null)
|
|
{
|
|
try
|
|
{
|
|
c.call();
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public EnumSet<TickType> ticks()
|
|
{
|
|
return EnumSet.of( TickType.SERVER );
|
|
}
|
|
|
|
@Override
|
|
public String getLabel()
|
|
{
|
|
return "AE-TickHandler";
|
|
}
|
|
}
|