134 lines
2.5 KiB
Java
134 lines
2.5 KiB
Java
package appeng.helpers;
|
|
|
|
import java.util.LinkedList;
|
|
import java.util.Queue;
|
|
import java.util.concurrent.Callable;
|
|
|
|
import net.minecraftforge.event.world.WorldEvent;
|
|
import appeng.api.networking.IGridNode;
|
|
import appeng.core.AELog;
|
|
import appeng.me.Grid;
|
|
import appeng.tile.AEBaseTile;
|
|
import appeng.util.Platform;
|
|
import cpw.mods.fml.common.eventhandler.SubscribeEvent;
|
|
import cpw.mods.fml.common.gameevent.TickEvent;
|
|
import cpw.mods.fml.common.gameevent.TickEvent.Type;
|
|
|
|
public class TickHandler
|
|
{
|
|
|
|
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();
|
|
}
|
|
|
|
@SubscribeEvent
|
|
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();
|
|
}
|
|
}
|
|
|
|
@SubscribeEvent
|
|
public void onTick(TickEvent ev)
|
|
{
|
|
if ( ev.type == Type.SERVER )
|
|
{
|
|
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)
|
|
{
|
|
AELog.error( e );
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|