Merge pull request #33 from GlodBlock/bugfix

fix 4096k int overflow and drops

src/main/java/com/glodblock/github/common/storage/FluidCellInventory.java

@@ -389,19 +389,19 @@ public class FluidCellInventory implements IFluidCellInventory {
 
         if( this.canHoldNewFluid() ) // room for new type, and for at least one item!
         {
-            final int remainingItemCount = (int) this.getRemainingFluidCount() - this.getBytesPerType() * 8;
+            final long remainingItemCount = this.getRemainingFluidCount() - this.getBytesPerType() * 8;
 
             if( remainingItemCount > 0 )
             {
                 if( input.getStackSize() > remainingItemCount )
                 {
                     final FluidStack toReturn = Util.cloneFluidStack(sharedFluidStack);
-                    toReturn.amount = sharedFluidStack.amount - remainingItemCount;
+                    toReturn.amount = (int) (sharedFluidStack.amount - remainingItemCount);
 
                     if( mode == Actionable.MODULATE )
                     {
                         final FluidStack toWrite = Util.cloneFluidStack( sharedFluidStack );
-                        toWrite.amount = remainingItemCount;
+                        toWrite.amount = (int) remainingItemCount;
 
                         this.cellItems.add( AEFluidStack.create( toWrite ) );
                         this.updateFluidCount( toWrite.amount );

src/main/java/com/glodblock/github/common/tile/TileFluidDiscretizer.java

@@ -1,5 +1,6 @@
 package com.glodblock.github.common.tile;
 
+import appeng.api.AEApi;
 import appeng.api.config.Actionable;
 import appeng.api.networking.GridFlags;
 import appeng.api.networking.crafting.ICraftingGrid;
@@ -19,7 +20,6 @@ import appeng.me.GridAccessException;
 import appeng.me.cache.CraftingGridCache;
 import appeng.me.storage.MEInventoryHandler;
 import appeng.tile.grid.AENetworkTile;
-import appeng.util.Platform;
 import com.glodblock.github.common.item.ItemFluidDrop;
 
 import java.util.ArrayList;
@@ -48,8 +48,6 @@ public class TileFluidDiscretizer extends AENetworkTile implements IPriorityHost
     @Override
     @SuppressWarnings("rawtypes")
     public List<IMEInventoryHandler> getCellArray(StorageChannel channel) {
-        /*conflict = !checkDiscreatizer();
-        if (conflict) return Collections.emptyList();*/
         if (getProxy().isActive()) {
             if (channel == StorageChannel.ITEMS) {
                 return Collections.singletonList(fluidDropInv.invHandler);
@@ -131,6 +129,25 @@ public class TileFluidDiscretizer extends AENetworkTile implements IPriorityHost
         updateState();
     }
 
+    @MENetworkEventSubscribe
+    public void onBootUp(MENetworkBootingStatusChange event) {
+        try {
+            IMEInventory<IAEItemStack> inventory = this.getProxy().getStorage().getItemInventory();
+            IItemList<IAEItemStack> items = inventory.getAvailableItems(AEApi.instance().storage().createItemList());
+            IItemList<IAEItemStack> drops = AEApi.instance().storage().createItemList();
+            for (IAEItemStack item : items) {
+                if (item != null && item.getItem() instanceof ItemFluidDrop) {
+                    drops.add(item);
+                }
+            }
+            for (IAEItemStack drop : drops) {
+                inventory.extractItems(drop, Actionable.MODULATE, ownActionSource);
+                inventory.injectItems(drop, Actionable.MODULATE, ownActionSource);
+            }
+        } catch (GridAccessException ignored) {
+        }
+    }
+
     private class FluidDiscretizingInventory implements IMEInventory<IAEItemStack>, IMEMonitorHandlerReceiver<IAEFluidStack> {
 
         private final MEInventoryHandler<IAEItemStack> invHandler = new MEInventoryHandler<>(this, getChannel());
@@ -142,7 +159,6 @@ public class TileFluidDiscretizer extends AENetworkTile implements IPriorityHost
 
         @Override
         public IAEItemStack injectItems(IAEItemStack request, Actionable type, BaseActionSource src) {
-            /*if (conflict) return request;*/
             IAEFluidStack fluidStack = ItemFluidDrop.getAeFluidStack(request);
             if (fluidStack == null) {
                 return request;
@@ -165,7 +181,6 @@ public class TileFluidDiscretizer extends AENetworkTile implements IPriorityHost
 
         @Override
         public IAEItemStack extractItems(IAEItemStack request, Actionable mode, BaseActionSource src) {
-            /*if (conflict) return null;*/
             IAEFluidStack fluidStack = ItemFluidDrop.getAeFluidStack(request);
             if (fluidStack == null) {
                 return null;
@@ -188,7 +203,6 @@ public class TileFluidDiscretizer extends AENetworkTile implements IPriorityHost
 
         @Override
         public IItemList<IAEItemStack> getAvailableItems(IItemList<IAEItemStack> out) {
-            /*if (conflict) return out;*/
             if (itemCache == null) {
                 itemCache = new ArrayList<>();
                 IMEMonitor<IAEFluidStack> fluidGrid = getFluidGrid();
@@ -253,7 +267,6 @@ public class TileFluidDiscretizer extends AENetworkTile implements IPriorityHost
         @Override
         @SuppressWarnings("rawtypes")
         public IAEFluidStack injectItems(IAEFluidStack input, Actionable type, BaseActionSource src) {
-            /*if (conflict) return null;*/
             ICraftingGrid craftingGrid;
             try {
                 craftingGrid = getProxy().getGrid().getCache(ICraftingGrid.class);

src/main/java/com/glodblock/github/common/tile/TileFluidInterface.java

@@ -2,18 +2,12 @@ package com.glodblock.github.common.tile;
 
 import appeng.api.config.Upgrades;
 import appeng.api.networking.IGridNode;
-import appeng.api.networking.energy.IEnergyGrid;
 import appeng.api.networking.events.MENetworkChannelsChanged;
 import appeng.api.networking.events.MENetworkEventSubscribe;
 import appeng.api.networking.events.MENetworkPowerStatusChange;
-import appeng.api.networking.security.BaseActionSource;
-import appeng.api.networking.security.MachineSource;
-import appeng.api.networking.storage.IStorageGrid;
 import appeng.api.networking.ticking.TickRateModulation;
 import appeng.api.networking.ticking.TickingRequest;
-import appeng.api.storage.IMEMonitor;
 import appeng.api.storage.data.IAEFluidStack;
-import appeng.me.GridAccessException;
 import appeng.tile.TileEvent;
 import appeng.tile.events.TileEventType;
 import appeng.tile.inventory.AppEngInternalAEInventory;