Package org.openmuc.jeebus.ship.shipconnection

Class ShipConnectionImpl

java.lang.Object

org.openmuc.jeebus.ship.shipconnection.ShipConnectionImpl

All Implemented Interfaces:

ShipConnectionInterface, ShipConnection

public class ShipConnectionImpl
extends java.lang.Object
implements ShipConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ShipConnectionImpl.Role

Constructor Summary

Constructors

Constructor	Description
ShipConnectionImpl(boolean server, int trustLevel, ShipNodeContext nodeContext, AuthenticatedConnection connection)

Method Summary

Modifier and Type	Method	Description
void	close()	closes the connection
void	closeImmediately()
void	disableForcedTrustLevel()	Stop forcing a trust level, relying instead on the trust level recorded for the peer's SKI in the KeyManagement.
void	distrustCommPartner()	Set the communication partner to untrusted.
void	enableConnectionDataExchange()
ShipConnectionInterface	getApiShipConn()
ConnectionDataExchange	getCde()
Configuration	getConfig()
AuthenticatedConnection	getConnection()
java.lang.String	getLogPrefix()
java.lang.String	getRemoteAddress()
java.lang.String	getRemoteSki()
java.lang.String	getSelectedFormat()
int	getSelectedMajor()
int	getSelectedMinor()
State	getState()
int	getTrustLevel()
void	initiateConnectionClose(java.lang.Integer maxTime, ConnectionCloseReasonType reason)
void	initState()	Start up the SHIP state machine.
boolean	isConnectionCloseState()
boolean	isServer()
void	onMessage(byte[] message)
void	prepareCDEShutdown()
void	requestAccessMethods()	requests access methods from client, only works as server, an exception is thrown otherwise
void	sendCdeMsg(byte[] msg)
void	sendMsg(byte[] msg)	sends a message to the communication partner
void	sendRawMessage(byte[] message)
void	setApiShipConn(ShipConnectionInterface shipConnInterface)
void	setConnection(AuthenticatedConnection basicCB)
void	setSelectedFormat(java.lang.String selectedFormat)
void	setSelectedMajor(int selectedMajor)
void	setSelectedMinor(int selectedMinor)
void	setSelectedVersion(int major, int minor)
void	setTrustLevel(int trustLevel)	Set the trust level for this connection, overriding any trust level configured for the peer's SKI.
void	setUserInterface(UserInterface userInterface)
void	stopStateTimeouts()
void	trustCommPartner()	Set the communication partner to be trusted, allowing communication to proceed.
boolean	trustsCommPartner()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ShipConnectionImpl

public ShipConnectionImpl(boolean server,
                          int trustLevel,
                          ShipNodeContext nodeContext,
                          AuthenticatedConnection connection)

Method Detail

initState

public void initState()

Description copied from interface: ShipConnection

Start up the SHIP state machine. Callable only once.

Specified by:

initState in interface ShipConnection

onMessage

public void onMessage(byte[] message)

isServer

public boolean isServer()

Specified by:

isServer in interface ShipConnection

getState

public State getState()

stopStateTimeouts

public void stopStateTimeouts()

initiateConnectionClose

public void initiateConnectionClose(java.lang.Integer maxTime,
                                    ConnectionCloseReasonType reason)

getTrustLevel

public int getTrustLevel()

Specified by:

getTrustLevel in interface ShipConnection

setTrustLevel

public void setTrustLevel(int trustLevel)

Set the trust level for this connection, overriding any trust level configured for the peer's SKI.

Parameters:

trustLevel - the trust level to set.

See Also:

disableForcedTrustLevel()

disableForcedTrustLevel

public void disableForcedTrustLevel()

Stop forcing a trust level, relying instead on the trust level recorded for the peer's SKI in the KeyManagement.

See Also:

setTrustLevel(int)

trustsCommPartner

public boolean trustsCommPartner()

trustCommPartner

public void trustCommPartner()

Set the communication partner to be trusted, allowing communication to proceed.

This is only allowed if the trust level for this connection is ≥8.

distrustCommPartner

public void distrustCommPartner()

Set the communication partner to untrusted. This does not affect the trust level configured for this connection or for the partner's SKI.

getConnection

public AuthenticatedConnection getConnection()

setConnection

public void setConnection(AuthenticatedConnection basicCB)

getSelectedMajor

public int getSelectedMajor()

setSelectedMajor

public void setSelectedMajor(int selectedMajor)

getSelectedMinor

public int getSelectedMinor()

setSelectedMinor

public void setSelectedMinor(int selectedMinor)

setSelectedVersion

public void setSelectedVersion(int major,
                               int minor)

getSelectedFormat

public java.lang.String getSelectedFormat()

setSelectedFormat

public void setSelectedFormat(java.lang.String selectedFormat)

getApiShipConn

public ShipConnectionInterface getApiShipConn()

setApiShipConn

public void setApiShipConn(ShipConnectionInterface shipConnInterface)

isConnectionCloseState

public boolean isConnectionCloseState()

getConfig

public Configuration getConfig()

getLogPrefix

public java.lang.String getLogPrefix()

getCde

public ConnectionDataExchange getCde()

requestAccessMethods

public void requestAccessMethods()

Description copied from interface: ShipConnectionInterface

requests access methods from client, only works as server, an exception is thrown otherwise

Specified by:

requestAccessMethods in interface ShipConnectionInterface

enableConnectionDataExchange

public void enableConnectionDataExchange()

Specified by:

enableConnectionDataExchange in interface ShipConnection

sendCdeMsg

public void sendCdeMsg(byte[] msg)

setUserInterface

public void setUserInterface(UserInterface userInterface)

Specified by:

setUserInterface in interface ShipConnection

getRemoteSki

public java.lang.String getRemoteSki()

Specified by:

getRemoteSki in interface ShipConnectionInterface

Returns:

the current SKI of the communication partner

getRemoteAddress

public java.lang.String getRemoteAddress()

Specified by:

getRemoteAddress in interface ShipConnectionInterface

Returns:

the IP address of the communication partner

sendMsg

public void sendMsg(byte[] msg)

Description copied from interface: ShipConnectionInterface

sends a message to the communication partner

Specified by:

sendMsg in interface ShipConnectionInterface

Parameters:

msg - the message to send

sendRawMessage

public void sendRawMessage(byte[] message)

Specified by:

sendRawMessage in interface ShipConnection

prepareCDEShutdown

public void prepareCDEShutdown()

closeImmediately

public void closeImmediately()

Specified by:

closeImmediately in interface ShipConnection

close

public void close()

Description copied from interface: ShipConnectionInterface

closes the connection

Specified by:

close in interface ShipConnectionInterface