e94a0cfccf
Reduces the visibility of all fields to private and create setters/getters when necessary. Exceptions are fields with GuiSync as these need to be public. Reduces the visibility of internal methods to private/protected/default when possible.
293 lines
7.4 KiB
Java
293 lines
7.4 KiB
Java
/*
|
|
* This file is part of Applied Energistics 2.
|
|
* Copyright (c) 2013 - 2014, AlgorithmX2, All rights reserved.
|
|
*
|
|
* Applied Energistics 2 is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Lesser General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Applied Energistics 2 is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with Applied Energistics 2. If not, see <http://www.gnu.org/licenses/lgpl>.
|
|
*/
|
|
|
|
package appeng.me;
|
|
|
|
|
|
import java.util.Arrays;
|
|
import java.util.EnumSet;
|
|
|
|
import appeng.api.exceptions.ExistingConnectionException;
|
|
import appeng.api.exceptions.FailedConnection;
|
|
import appeng.api.exceptions.NullNodeConnectionException;
|
|
import appeng.api.exceptions.SecurityConnectionException;
|
|
import appeng.api.networking.GridFlags;
|
|
import appeng.api.networking.IGridConnection;
|
|
import appeng.api.networking.IGridNode;
|
|
import appeng.api.networking.events.MENetworkChannelsChanged;
|
|
import appeng.api.networking.pathing.IPathingGrid;
|
|
import appeng.api.util.AEPartLocation;
|
|
import appeng.api.util.DimensionalCoord;
|
|
import appeng.api.util.IReadOnlyCollection;
|
|
import appeng.core.AEConfig;
|
|
import appeng.core.AELog;
|
|
import appeng.core.features.AEFeature;
|
|
import appeng.me.pathfinding.IPathItem;
|
|
import appeng.util.Platform;
|
|
import appeng.util.ReadOnlyCollection;
|
|
|
|
|
|
public class GridConnection implements IGridConnection, IPathItem
|
|
{
|
|
|
|
private static final String EXISTING_CONNECTION_MESSAGE = "Connection between node [machine=%s, %s] and [machine=%s, %s] on [%s] already exists.";
|
|
|
|
private static final MENetworkChannelsChanged EVENT = new MENetworkChannelsChanged();
|
|
private int channelData = 0;
|
|
private Object visitorIterationNumber = null;
|
|
private GridNode sideA;
|
|
private AEPartLocation fromAtoB;
|
|
private GridNode sideB;
|
|
|
|
public GridConnection( final IGridNode aNode, final IGridNode bNode, final AEPartLocation fromAtoB ) throws FailedConnection
|
|
{
|
|
|
|
final GridNode a = (GridNode) aNode;
|
|
final GridNode b = (GridNode) bNode;
|
|
|
|
if( Platform.securityCheck( a, b ) )
|
|
{
|
|
if( AEConfig.instance.isFeatureEnabled( AEFeature.LogSecurityAudits ) )
|
|
{
|
|
final DimensionalCoord aCoordinates = a.getGridBlock().getLocation();
|
|
final DimensionalCoord bCoordinates = b.getGridBlock().getLocation();
|
|
|
|
AELog.info( "Security audit 1 failed at [%s] belonging to player [id=%d]", aCoordinates.toString(), a.getPlayerID() );
|
|
AELog.info( "Security audit 2 failed at [%s] belonging to player [id=%d]", bCoordinates.toString(), b.getPlayerID() );
|
|
}
|
|
|
|
throw new SecurityConnectionException();
|
|
}
|
|
|
|
if( a == null || b == null )
|
|
{
|
|
throw new NullNodeConnectionException();
|
|
}
|
|
|
|
if( a.hasConnection( b ) || b.hasConnection( a ) )
|
|
{
|
|
final String aMachineClass = a.getGridBlock().getMachine().getClass().getSimpleName();
|
|
final String bMachineClass = b.getGridBlock().getMachine().getClass().getSimpleName();
|
|
final String aCoordinates = a.getGridBlock().getLocation().toString();
|
|
final String bCoordinates = b.getGridBlock().getLocation().toString();
|
|
|
|
throw new ExistingConnectionException( String.format( EXISTING_CONNECTION_MESSAGE, aMachineClass, aCoordinates, bMachineClass, bCoordinates, fromAtoB ) );
|
|
}
|
|
|
|
this.sideA = a;
|
|
this.fromAtoB = fromAtoB;
|
|
this.sideB = b;
|
|
|
|
if( b.getMyGrid() == null )
|
|
{
|
|
b.setGrid( a.getInternalGrid() );
|
|
}
|
|
else
|
|
{
|
|
if( a.getMyGrid() == null )
|
|
{
|
|
final GridPropagator gp = new GridPropagator( b.getInternalGrid() );
|
|
a.beginVisit( gp );
|
|
}
|
|
else if( b.getMyGrid() == null )
|
|
{
|
|
final GridPropagator gp = new GridPropagator( a.getInternalGrid() );
|
|
b.beginVisit( gp );
|
|
}
|
|
else if( this.isNetworkABetter( a, b ) )
|
|
{
|
|
final GridPropagator gp = new GridPropagator( a.getInternalGrid() );
|
|
b.beginVisit( gp );
|
|
}
|
|
else
|
|
{
|
|
final GridPropagator gp = new GridPropagator( b.getInternalGrid() );
|
|
a.beginVisit( gp );
|
|
}
|
|
}
|
|
|
|
// a connection was destroyed RE-PATH!!
|
|
final IPathingGrid p = this.sideA.getInternalGrid().getCache( IPathingGrid.class );
|
|
p.repath();
|
|
|
|
this.sideA.addConnection( this );
|
|
this.sideB.addConnection( this );
|
|
}
|
|
|
|
private boolean isNetworkABetter( final GridNode a, final GridNode b )
|
|
{
|
|
return a.getMyGrid().getPriority() > b.getMyGrid().getPriority() || a.getMyGrid().size() > b.getMyGrid().size();
|
|
}
|
|
|
|
@Override
|
|
public IGridNode getOtherSide( final IGridNode gridNode )
|
|
{
|
|
if( gridNode == this.sideA )
|
|
{
|
|
return this.sideB;
|
|
}
|
|
if( gridNode == this.sideB )
|
|
{
|
|
return this.sideA;
|
|
}
|
|
|
|
throw new GridException( "Invalid Side of Connection" );
|
|
}
|
|
|
|
@Override
|
|
public AEPartLocation getDirection( final IGridNode side )
|
|
{
|
|
if( this.fromAtoB == AEPartLocation.INTERNAL )
|
|
{
|
|
return this.fromAtoB;
|
|
}
|
|
|
|
if( this.sideA == side )
|
|
{
|
|
return this.fromAtoB;
|
|
}
|
|
else
|
|
{
|
|
return this.fromAtoB.getOpposite();
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void destroy()
|
|
{
|
|
// a connection was destroyed RE-PATH!!
|
|
final IPathingGrid p = this.sideA.getInternalGrid().getCache( IPathingGrid.class );
|
|
p.repath();
|
|
|
|
this.sideA.removeConnection( this );
|
|
this.sideB.removeConnection( this );
|
|
|
|
this.sideA.validateGrid();
|
|
this.sideB.validateGrid();
|
|
}
|
|
|
|
@Override
|
|
public IGridNode a()
|
|
{
|
|
return this.sideA;
|
|
}
|
|
|
|
@Override
|
|
public IGridNode b()
|
|
{
|
|
return this.sideB;
|
|
}
|
|
|
|
@Override
|
|
public boolean hasDirection()
|
|
{
|
|
return this.fromAtoB != AEPartLocation.INTERNAL;
|
|
}
|
|
|
|
@Override
|
|
public int getUsedChannels()
|
|
{
|
|
return ( this.channelData >> 8 ) & 0xff;
|
|
}
|
|
|
|
@Override
|
|
public IPathItem getControllerRoute()
|
|
{
|
|
if( this.sideA.getFlags().contains( GridFlags.CANNOT_CARRY ) )
|
|
{
|
|
return null;
|
|
}
|
|
return this.sideA;
|
|
}
|
|
|
|
@Override
|
|
public void setControllerRoute( final IPathItem fast, final boolean zeroOut )
|
|
{
|
|
if( zeroOut )
|
|
{
|
|
this.channelData &= ~0xff;
|
|
}
|
|
|
|
if( this.sideB == fast )
|
|
{
|
|
final GridNode tmp = this.sideA;
|
|
this.sideA = this.sideB;
|
|
this.sideB = tmp;
|
|
this.fromAtoB = this.fromAtoB.getOpposite();
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public boolean canSupportMoreChannels()
|
|
{
|
|
return this.getLastUsedChannels() < 32; // max, PERIOD.
|
|
}
|
|
|
|
@Override
|
|
public IReadOnlyCollection<IPathItem> getPossibleOptions()
|
|
{
|
|
return new ReadOnlyCollection<IPathItem>( Arrays.asList( (IPathItem) this.a(), (IPathItem) this.b() ) );
|
|
}
|
|
|
|
@Override
|
|
public void incrementChannelCount( final int usedChannels )
|
|
{
|
|
this.channelData += usedChannels;
|
|
}
|
|
|
|
@Override
|
|
public EnumSet<GridFlags> getFlags()
|
|
{
|
|
return EnumSet.noneOf( GridFlags.class );
|
|
}
|
|
|
|
@Override
|
|
public void finalizeChannels()
|
|
{
|
|
if( this.getUsedChannels() != this.getLastUsedChannels() )
|
|
{
|
|
this.channelData &= 0xff;
|
|
this.channelData |= this.channelData << 8;
|
|
|
|
if( this.sideA.getInternalGrid() != null )
|
|
{
|
|
this.sideA.getInternalGrid().postEventTo( this.sideA, EVENT );
|
|
}
|
|
|
|
if( this.sideB.getInternalGrid() != null )
|
|
{
|
|
this.sideB.getInternalGrid().postEventTo( this.sideB, EVENT );
|
|
}
|
|
}
|
|
}
|
|
|
|
private int getLastUsedChannels()
|
|
{
|
|
return this.channelData & 0xff;
|
|
}
|
|
|
|
Object getVisitorIterationNumber()
|
|
{
|
|
return this.visitorIterationNumber;
|
|
}
|
|
|
|
void setVisitorIterationNumber( final Object visitorIterationNumber )
|
|
{
|
|
this.visitorIterationNumber = visitorIterationNumber;
|
|
}
|
|
}
|