import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
/**
 * Attempts to extract the gas from the sub-grid.
 */
@Override
public IAEFluidStack extractItems( final IAEFluidStack request, final Actionable mode, final BaseActionSource source )
{
	// Is the fluid an essentia gas?
	if( this.isFluidEssentiaGas( request ) )
	{
		if( this.handler != null )
		{
			// Extract the gas
			IAEFluidStack extractedGas = this.handler.extractItems( request, mode, source );

			return extractedGas;
		}
	}

	return null;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
/**
 * Attempts to inject the gas into the sub-network.
 */
@Override
public IAEFluidStack injectItems( final IAEFluidStack input, final Actionable mode, final BaseActionSource source )
{
	// Is the fluid an essentia gas?
	if( this.isFluidEssentiaGas( input ) )
	{
		if( this.handler != null )
		{
			// Inject the gas
			IAEFluidStack remainingGas = this.handler.injectItems( input, mode, source );

			return remainingGas;
		}
	}
	return input;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
/**
 * The creative cell can only provide essentia based on its parition table.
 */
@Override
public IAEFluidStack extractItems( final IAEFluidStack request, final Actionable mode, final BaseActionSource src )
{
	// Ensure there is a request, and that it is an essentia gas
	if( ( request != null ) && ( request.getFluid() != null ) && ( request.getFluid() instanceof GaseousEssentia ) )
	{
		// Get the aspect of the essentia
		Aspect requestAspect = ( (GaseousEssentia)request.getFluid() ).getAspect();

		// Is the cell partitioned for this aspect?
		if( ( requestAspect != null ) && ( this.partitionAspects.contains( requestAspect ) ) )
		{
			return request.copy();
		}
	}

	return null;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
protected void notifyListenersOfChange(Iterable<StackType> diff, BaseActionSource src)
{
	hasChanged = true;// need to update the cache.
	Iterator<Entry<IMEMonitorHandlerReceiver<StackType>, Object>> i = getListeners();
	while (i.hasNext())
	{
		Entry<IMEMonitorHandlerReceiver<StackType>, Object> o = i.next();
		IMEMonitorHandlerReceiver<StackType> receiver = o.getKey();
		if ( receiver.isValid( o.getValue() ) )
			receiver.postChange( this, diff, src );
		else
			i.remove();
	}
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
private StackType monitorDifference(IAEStack original, StackType leftOvers, boolean extraction, BaseActionSource src)
{
	StackType diff = (StackType) original.copy();

	if ( extraction )
		diff.setStackSize( leftOvers == null ? 0 : -leftOvers.getStackSize() );
	else if ( leftOvers != null )
		diff.decStackSize( leftOvers.getStackSize() );

	if ( diff.getStackSize() != 0 )
		postChangesToListeners( ImmutableList.of( diff ), src );

	return leftOvers;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public StackType injectItems(StackType input, Actionable mode, BaseActionSource src)
{
	if ( mode == Actionable.SIMULATE )
		return getHandler().injectItems( input, mode, src );
	return monitorDifference(input.copy(), getHandler().injectItems(input, mode, src), false, src);
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
protected void notifyListenersOfChange(Iterable<StackType> diff, BaseActionSource src)
{
	this.hasChanged = true;// need to update the cache.
	Iterator<Entry<IMEMonitorHandlerReceiver<StackType>, Object>> i = this.getListeners();
	while (i.hasNext())
	{
		Entry<IMEMonitorHandlerReceiver<StackType>, Object> o = i.next();
		IMEMonitorHandlerReceiver<StackType> receiver = o.getKey();
		if ( receiver.isValid( o.getValue() ) )
			receiver.postChange( this, diff, src );
		else
			i.remove();
	}
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
private StackType monitorDifference(IAEStack original, StackType leftOvers, boolean extraction, BaseActionSource src)
{
	StackType diff = (StackType) original.copy();

	if ( extraction )
		diff.setStackSize( leftOvers == null ? 0 : -leftOvers.getStackSize() );
	else if ( leftOvers != null )
		diff.decStackSize( leftOvers.getStackSize() );

	if ( diff.getStackSize() != 0 )
		this.postChangesToListeners( ImmutableList.of( diff ), src );

	return leftOvers;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public StackType injectItems(StackType input, Actionable mode, BaseActionSource src)
{
	if ( mode == Actionable.SIMULATE )
		return this.getHandler().injectItems( input, mode, src );
	return this.monitorDifference(input.copy(), this.getHandler().injectItems(input, mode, src), false, src);
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public StackType extractItems(StackType request, Actionable mode, BaseActionSource src)
{
	if ( mode == Actionable.SIMULATE )
		return this.getHandler().extractItems( request, mode, src );
	return this.monitorDifference(request.copy(), this.getHandler().extractItems(request, mode, src), true, src);
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
protected void notifyListenersOfChange(Iterable<StackType> diff, BaseActionSource src) {
    hasChanged = true;// need to update the cache.
    Iterator<Entry<IMEMonitorHandlerReceiver<StackType>, Object>> i = getListeners();
    while (i.hasNext()) {
        Entry<IMEMonitorHandlerReceiver<StackType>, Object> o = i.next();
        IMEMonitorHandlerReceiver<StackType> recv = o.getKey();
        if (recv.isValid(o.getValue())) {
            recv.postChange(this, diff, src);
        } else {
            i.remove();
        }
    }
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
private StackType monitorDiffrence(IAEStack original, StackType leftOvers, boolean extraction, BaseActionSource src) {
    StackType diff = (StackType) original.copy();

    if (extraction) {
        diff.setStackSize(leftOvers == null ? 0 : -leftOvers.getStackSize());
    } else if (leftOvers != null) {
        diff.decStackSize(leftOvers.getStackSize());
    }

    if (diff.getStackSize() != 0) {
        postChangesToListeners(ImmutableList.of(diff), src);
    }

    return leftOvers;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public StackType injectItems(StackType input, Actionable mode, BaseActionSource src) {
    if (mode == Actionable.SIMULATE) {
        return getHandler().injectItems(input, mode, src);
    }
    return monitorDiffrence((StackType) input.copy(), getHandler().injectItems(input, mode, src), false, src);
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
/**
 * Returns if the player has the requested permission or not.
 *
 * @param perm
 * @param actionSource
 * @return
 */
private boolean checkSecurityPermission( final SecurityPermissions perm, final BaseActionSource actionSource )
{

	// Ensure there is an action source.
	if( actionSource == null )
	{
		return false;
	}

	// Get the source node
	IGridNode sourceNode = null;
	if( actionSource instanceof MachineSource )
	{
		sourceNode = ( (MachineSource)actionSource ).via.getActionableNode();
	}
	else if( actionSource instanceof PlayerSource )
	{
		sourceNode = ( (PlayerSource)actionSource ).via.getActionableNode();
	}

	// Ensure there is a node
	if( sourceNode == null )
	{
		return false;
	}

	// Get the security grid for the node.
	ISecurityGrid sGrid = sourceNode.getGrid().getCache( ISecurityGrid.class );

	// Return the permission.
	return sGrid.hasPermission( this.player, perm );
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
/**
 * Called when the amount of an item on the network changes.
 */
@Override
public void postChange( final IBaseMonitor<IAEItemStack> monitor, final Iterable<IAEItemStack> changes, final BaseActionSource actionSource )
{
	if( this.monitor == null )
	{
		return;
	}

	for( IAEItemStack change : changes )
	{
		// Get the total amount of the item in the network
		IAEItemStack newAmount = this.monitor.getStorageList().findPrecise( change );

		// Is there no more?
		if( newAmount == null )
		{
			// Copy the item type from the change
			newAmount = change.copy();

			// Set amount to 0
			newAmount.setStackSize( 0 );
		}

		// Send the change to the client
		Packet_C_ArcaneCraftingTerminal.stackAmountChanged( this.player, newAmount );
	}
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public long extractEssentia( final Aspect aspect, final long amount, final Actionable mode, final BaseActionSource source, final boolean powered )
{
	if( powered )
	{
		// Simulate power extraction
		double powerRequest = EssentiaMonitor.AE_PER_ESSENTIA * amount;
		double powerReceived = this.energyGrid.extractAEPower( powerRequest, Actionable.SIMULATE, PowerMultiplier.CONFIG );

		// Was enough power extracted?
		if( powerReceived < powerRequest )
		{
			// Not enough power
			return 0;
		}
	}

	// Extract
	long extractedAmount = this.internalMonitor.extractEssentia( aspect, amount, mode, source, false );

	// Extract power if modulating
	if( ( extractedAmount > 0 ) && ( powered ) && ( mode == Actionable.MODULATE ) )
	{
		this.energyGrid.extractAEPower( EssentiaMonitor.AE_PER_ESSENTIA * extractedAmount, Actionable.MODULATE, PowerMultiplier.CONFIG );
	}

	return extractedAmount;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public long injectEssentia( final Aspect aspect, final long amount, final Actionable mode, final BaseActionSource source, final boolean powered )
{
	if( powered )
	{
		// Simulate power extraction
		double powerRequest = EssentiaMonitor.AE_PER_ESSENTIA * amount;
		double powerReceived = this.energyGrid.extractAEPower( powerRequest, Actionable.SIMULATE, PowerMultiplier.CONFIG );

		// Was enough power extracted?
		if( powerReceived < powerRequest )
		{
			// Not enough power
			return 0;
		}
	}

	// Inject
	long rejectedAmount = this.internalMonitor.injectEssentia( aspect, amount, mode, source, false );
	long injectedAmount = amount - rejectedAmount;

	// Extract power if modulating
	if( ( injectedAmount > 0 ) && ( powered ) && ( mode == Actionable.MODULATE ) )
	{
		this.energyGrid.extractAEPower( EssentiaMonitor.AE_PER_ESSENTIA * injectedAmount, Actionable.MODULATE, PowerMultiplier.CONFIG );
	}

	return rejectedAmount;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
/**
 * Mirror method of the injectEssentia. Used to defer power calculations, because the simulation is not always accurate, and Essentia gas should
 * not be stored in partial amounts.
 *
 * @param aspect
 * @param amount
 * @param mode
 * @param source
 * @return Amount that was <strong>not</strong> injected
 */
private long injectEssentiaSafely(	final Aspect aspect, final long amount, final Actionable mode, final BaseActionSource source,
									final GaseousEssentia essentiaGas )
{
	// Create the fluid request
	IAEFluidStack fluidRequest = EssentiaConversionHelper.INSTANCE.createAEFluidStackInEssentiaUnits( essentiaGas, amount );

	// Inject fluid
	IAEFluidStack fluidRejected = this.fluidMonitor.injectItems( fluidRequest, mode, source );

	// Was any rejected?
	if( ( fluidRejected != null ) && ( fluidRejected.getStackSize() > 0 ) )
	{
		if( fluidRejected.getStackSize() == fluidRequest.getStackSize() )
		{
			// All essentia was rejected
			return amount;
		}

		// Calculate the adjusted amount, essentia gas can not be stored in partial units
		long rejectedAdjustedAmount = EssentiaConversionHelper.INSTANCE.convertFluidAmountToEssentiaAmount( fluidRejected.getStackSize() );
		return rejectedAdjustedAmount;
	}

	// All essentia was accepted.
	return 0;
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public void postChange( final IBaseMonitor<IAEItemStack> monitor, final Iterable<IAEItemStack> change, final BaseActionSource actionSource )
{
	for( IAEItemStack stack : change )
	{
		// Is the stack craftable, has NBT tag, and is a crafting aspect?
		if( stack.isCraftable() && stack.hasTagCompound() && ( stack.getItem() instanceof ItemCraftingAspect ) )
		{
			this.gridCache.markForUpdate();
			break;
		}
	}
}
 

import appeng.api.networking.security.BaseActionSource; //导入依赖的package包/类
@Override
public IAEFluidStack extractItems( final IAEFluidStack request, final Actionable mode, final BaseActionSource source )
{
	// Ensure we have an internal handler
	if( this.internalHandler != null )
	{
		// Pass to handler
		return this.internalHandler.extractItems( request, mode, source );
	}

	// No handler
	return null;
}