package appeng.me.cache; import java.util.Iterator; import java.util.LinkedList; import java.util.Map.Entry; import java.util.Set; import appeng.api.networking.events.MENetworkStorageEvent; import appeng.api.networking.security.BaseActionSource; import appeng.api.storage.IMEInventoryHandler; import appeng.api.storage.IMEMonitorHandlerReceiver; import appeng.api.storage.MEMonitorHandler; import appeng.api.storage.StorageChannel; import appeng.api.storage.data.IAEStack; import appeng.api.storage.data.IItemList; import appeng.me.storage.ItemWatcher; public class NetworkMonitor> extends MEMonitorHandler { final private GridStorageCache myGridCache; final private StorageChannel myChannel; boolean sendEvent = false; public void forceUpdate() { hasChanged = true; Iterator, Object>> i = getListeners(); while (i.hasNext()) { Entry, Object> o = i.next(); IMEMonitorHandlerReceiver recv = o.getKey(); if ( recv.isValid( o.getValue() ) ) recv.onListUpdate(); else i.remove(); } } public NetworkMonitor(GridStorageCache cache, StorageChannel chan) { super( null, chan ); myGridCache = cache; myChannel = chan; } final static public LinkedList depth = new LinkedList(); @Override protected void postChange(T diff, BaseActionSource src) { if ( depth.contains( this ) ) return; depth.push( this ); sendEvent = true; super.postChange( diff, src ); if ( myGridCache.interestManager.containsKey( diff ) ) { Set list = myGridCache.interestManager.get( diff ); if ( !list.isEmpty() ) { IItemList myStorageList = getStorageList(); IAEStack fullStack = myStorageList.findPrecise( diff ); if ( fullStack == null ) { fullStack = diff.copy(); fullStack.setStackSize( 0 ); } myGridCache.interestManager.enableTransactions(); for (ItemWatcher iw : list) iw.getHost().onStackChange( myStorageList, fullStack, diff, src, getChannel() ); myGridCache.interestManager.disableTransactions(); } } Object last = depth.pop(); if ( last != this ) throw new RuntimeException( "Invalid Access to Networked Storage API detected." ); } public void onTick() { if ( sendEvent ) { sendEvent = false; myGridCache.myGrid.postEvent( new MENetworkStorageEvent( this, myChannel ) ); } } @Override protected IMEInventoryHandler getHandler() { switch (myChannel) { case ITEMS: return myGridCache.getItemInventoryHandler(); case FLUIDS: return myGridCache.getFluidInventoryHandler(); default: } return null; } }