Fix cached item count for display going negative, fixes #343
This commit is contained in:
@@ -22,7 +22,7 @@ public class GroupedFluidStorage implements IGroupedFluidStorage {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void rebuild() {
|
public synchronized void rebuild() {
|
||||||
storages.clear();
|
storages.clear();
|
||||||
|
|
||||||
network.getNodeGraph().all().stream()
|
network.getNodeGraph().all().stream()
|
||||||
@@ -41,7 +41,7 @@ public class GroupedFluidStorage implements IGroupedFluidStorage {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void add(@Nonnull FluidStack stack, boolean rebuilding) {
|
public synchronized void add(@Nonnull FluidStack stack, boolean rebuilding) {
|
||||||
list.add(stack);
|
list.add(stack);
|
||||||
|
|
||||||
if (!rebuilding) {
|
if (!rebuilding) {
|
||||||
@@ -50,7 +50,7 @@ public class GroupedFluidStorage implements IGroupedFluidStorage {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void remove(@Nonnull FluidStack stack) {
|
public synchronized void remove(@Nonnull FluidStack stack) {
|
||||||
if (list.remove(stack, true)) {
|
if (list.remove(stack, true)) {
|
||||||
network.sendFluidStorageDeltaToClient(stack, -stack.amount);
|
network.sendFluidStorageDeltaToClient(stack, -stack.amount);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ public class GroupedItemStorage implements IGroupedItemStorage {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void rebuild() {
|
public synchronized void rebuild() {
|
||||||
storages.clear();
|
storages.clear();
|
||||||
|
|
||||||
network.getNodeGraph().all().stream()
|
network.getNodeGraph().all().stream()
|
||||||
@@ -50,7 +50,7 @@ public class GroupedItemStorage implements IGroupedItemStorage {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void add(@Nonnull ItemStack stack, boolean rebuilding) {
|
public synchronized void add(@Nonnull ItemStack stack, boolean rebuilding) {
|
||||||
list.add(stack);
|
list.add(stack);
|
||||||
|
|
||||||
if (!rebuilding) {
|
if (!rebuilding) {
|
||||||
@@ -59,7 +59,7 @@ public class GroupedItemStorage implements IGroupedItemStorage {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void remove(@Nonnull ItemStack stack) {
|
public synchronized void remove(@Nonnull ItemStack stack) {
|
||||||
if (list.remove(stack, !network.hasPattern(stack))) {
|
if (list.remove(stack, !network.hasPattern(stack))) {
|
||||||
network.sendItemStorageDeltaToClient(stack, -stack.stackSize);
|
network.sendItemStorageDeltaToClient(stack, -stack.stackSize);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user