Package com.ericsson.otp.erlang

Class AbstractConnection

java.lang.Object

java.lang.Thread

com.ericsson.otp.erlang.AbstractConnection

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

OtpConnection, OtpCookedConnection

public abstract class AbstractConnection
extends Thread

Maintains a connection between a Java process and a remote Erlang, Java or C node. The object maintains connection state and allows data to be sent to and received from the peer.

This abstract class provides the necessary methods to maintain the actual connection and encode the messages and headers in the proper format according to the Erlang distribution protocol. Subclasses can use these methods to provide a more or less transparent communication channel as desired.

Note that no receive methods are provided. Subclasses must provide methods for message delivery, and may implement their own receive methods.

If an exception occurs in any of the methods in this class, the connection will be closed and must be reopened in order to resume communication with the peer. This will be indicated to the subclass by passing the exception to its delivery() method.

The System property OtpConnection.trace can be used to change the initial trace level setting for all connections. Normally the initial trace level is 0 and connections are not traced unless setTraceLevel() is used to change the setting for a particular connection. OtpConnection.trace can be used to turn on tracing by default for all connections.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	ChallengeAck
protected static final int	ChallengeReply
protected static final int	ChallengeStatus
protected boolean	connected
protected boolean	cookieOk
protected static int	ctrlThreshold
protected static int	defaultLevel
protected static final int	exit2Tag
protected static final int	exit2TTTag
protected static final int	exitTag
protected static final int	exitTTTag
protected static final int	groupLeaderTag
protected static int	handshakeThreshold
protected static final int	headerLen
protected static final int	linkTag
protected OtpLocalNode	localNode
protected static final byte	passThrough
protected OtpPeer	peer
protected static Random	random
protected static final int	regSendTag
protected static final int	regSendTTTag
protected boolean	sendCookie
protected static final int	sendTag
protected static int	sendThreshold
protected static final int	sendTTTag
protected OtpTransport	socket
protected int	traceLevel
protected static final int	unlinkIdAckTag
protected static final int	unlinkIdTag
protected static final int	unlinkTag
protected static final byte	version

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractConnection(OtpLocalNode self, OtpPeer other)	Intiate and open a connection to a remote node.
protected	AbstractConnection(OtpLocalNode self, OtpTransport s)	Accept an incoming connection from a remote node.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the connection to the remote node.
abstract void	deliver(OtpMsg msg)	Deliver messages to the recipient.
abstract void	deliver(Exception e)	Deliver communication exceptions to the recipient.
protected void	do_send(OtpOutputStream header)
protected void	do_send(OtpOutputStream header, OtpOutputStream payload)
protected void	doAccept()
protected void	doConnect()
protected void	doGenericConnect()
protected void	doPortConnect(int port)
protected void	finalize()
protected static int	genChallenge()
protected byte[]	genDigest(int challenge, String cookie)
int	getFlags()
int	getTraceLevel()	Get the trace level for this connection.
protected String	headerType(OtpErlangObject h)
boolean	isConnected()	Determine if the connection is still alive.
protected byte[]	read2BytePackage()
protected int	readSock(OtpTransport s, byte[] b)
protected int	recvChallenge()
protected void	recvChallengeAck(int our_challenge)
protected int	recvChallengeReply(int our_challenge)
protected void	recvComplement(int send_name_tag)
protected int	recvName(OtpPeer apeer)
protected void	recvStatus()
void	run()
protected void	sendBuf(OtpErlangPid from, OtpErlangPid dest, OtpOutputStream payload)	Send a pre-encoded message to a process on a remote node.
protected void	sendBuf(OtpErlangPid from, String dest, OtpOutputStream payload)	Send a pre-encoded message to a named process on a remote node.
protected void	sendChallenge(long her_flags, long our_flags, int challenge)
protected void	sendChallengeAck(byte[] digest)
protected void	sendChallengeReply(int challenge, byte[] digest)
protected void	sendExit(OtpErlangPid from, OtpErlangPid dest, OtpErlangObject reason)
protected void	sendExit2(OtpErlangPid from, OtpErlangPid dest, OtpErlangObject reason)	Send an exit signal to a remote process.
protected void	sendLink(OtpErlangPid from, OtpErlangPid dest)	Send link signal to remote process.
protected int	sendName(int dist, long aflags, int creation)
protected void	sendStatus(String status)
protected void	sendUnlink(OtpErlangPid from, OtpErlangPid dest, long unlink_id)	Send unlink signal to remote process.
protected void	sendUnlinkAck(OtpErlangPid from, OtpErlangPid dest, long unlink_id)	Send unlink acknowledgment signal to remote process.
void	setFlags(int flags)
int	setTraceLevel(int level)	Set the trace level for this connection.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

headerLen

protected static final int headerLen

See Also:

• Constant Field Values

passThrough

protected static final byte passThrough

See Also:

• Constant Field Values

version

protected static final byte version

See Also:

• Constant Field Values

linkTag

protected static final int linkTag

See Also:

• Constant Field Values

sendTag

protected static final int sendTag

See Also:

• Constant Field Values

exitTag

protected static final int exitTag

See Also:

• Constant Field Values

unlinkTag

protected static final int unlinkTag

See Also:

• Constant Field Values

regSendTag

protected static final int regSendTag

See Also:

• Constant Field Values

groupLeaderTag

protected static final int groupLeaderTag

See Also:

• Constant Field Values

exit2Tag

protected static final int exit2Tag

See Also:

• Constant Field Values

sendTTTag

protected static final int sendTTTag

See Also:

• Constant Field Values

exitTTTag

protected static final int exitTTTag

See Also:

• Constant Field Values

regSendTTTag

protected static final int regSendTTTag

See Also:

• Constant Field Values

exit2TTTag

protected static final int exit2TTTag

See Also:

• Constant Field Values

unlinkIdTag

protected static final int unlinkIdTag

See Also:

• Constant Field Values

unlinkIdAckTag

protected static final int unlinkIdAckTag

See Also:

• Constant Field Values

ChallengeReply

protected static final int ChallengeReply

See Also:

• Constant Field Values

ChallengeAck

protected static final int ChallengeAck

See Also:

• Constant Field Values

ChallengeStatus

protected static final int ChallengeStatus

See Also:

• Constant Field Values

connected

protected boolean connected

socket

protected OtpTransport socket

peer

protected OtpPeer peer

localNode

protected OtpLocalNode localNode

cookieOk

protected boolean cookieOk

sendCookie

protected boolean sendCookie

traceLevel

protected int traceLevel

defaultLevel

protected static int defaultLevel

sendThreshold

protected static int sendThreshold

ctrlThreshold

protected static int ctrlThreshold

handshakeThreshold

protected static int handshakeThreshold

random

protected static Random random

Constructor Details

AbstractConnection

protected AbstractConnection(OtpLocalNode self,
 OtpTransport s)
                      throws IOException,
OtpAuthException

Accept an incoming connection from a remote node. Used by OtpSelf.accept() to create a connection based on data received when handshaking with the peer node, when the remote node is the connection initiator.

Throws:

IOException - if it was not possible to connect to the peer.

OtpAuthException - if handshake resulted in an authentication error

AbstractConnection

protected AbstractConnection(OtpLocalNode self,
 OtpPeer other)
                      throws IOException,
OtpAuthException

Intiate and open a connection to a remote node.

Throws:

IOException - if it was not possible to connect to the peer.

OtpAuthException - if handshake resulted in an authentication error.

Method Details

deliver

public abstract void deliver(Exception e)

Deliver communication exceptions to the recipient.

deliver

public abstract void deliver(OtpMsg msg)

Deliver messages to the recipient.

sendBuf

protected void sendBuf(OtpErlangPid from,
 String dest,
 OtpOutputStream payload)
                throws IOException

Send a pre-encoded message to a named process on a remote node.

Parameters:

dest - the name of the remote process.

payload - the encoded message to send.

Throws:

IOException - if the connection is not active or a communication error occurs.

sendBuf

protected void sendBuf(OtpErlangPid from,
 OtpErlangPid dest,
 OtpOutputStream payload)
                throws IOException

Send a pre-encoded message to a process on a remote node.

Parameters:

dest - the Erlang PID of the remote process.

payload - the encoded message to send.

Throws:

IOException - if the connection is not active or a communication error occurs.

sendLink

protected void sendLink(OtpErlangPid from,
 OtpErlangPid dest)
                 throws IOException

Send link signal to remote process.

Parameters:

dest - the Erlang PID of the remote process.

Throws:

IOException - if the connection is not active or a communication error occurs.

sendUnlink

protected void sendUnlink(OtpErlangPid from,
 OtpErlangPid dest,
 long unlink_id)
                   throws IOException

Send unlink signal to remote process.

Parameters:

dest - the Erlang PID of the remote process.

Throws:

IOException - if the connection is not active or a communication error occurs.

sendUnlinkAck

protected void sendUnlinkAck(OtpErlangPid from,
 OtpErlangPid dest,
 long unlink_id)
                      throws IOException

Send unlink acknowledgment signal to remote process.

Parameters:

dest - the Erlang PID of the remote process.

Throws:

IOException - if the connection is not active or a communication error occurs.

sendExit

protected void sendExit(OtpErlangPid from,
 OtpErlangPid dest,
 OtpErlangObject reason)
                 throws IOException

Throws:

IOException

sendExit2

protected void sendExit2(OtpErlangPid from,
 OtpErlangPid dest,
 OtpErlangObject reason)
                  throws IOException

Send an exit signal to a remote process.

Parameters:

dest - the Erlang PID of the remote process.

reason - an Erlang term describing the exit reason.

Throws:

IOException - if the connection is not active or a communication error occurs.

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

setTraceLevel

public int setTraceLevel(int level)

Set the trace level for this connection. Normally tracing is off by default unless System property OtpConnection.trace was set.

The following levels are valid: 0 turns off tracing completely, 1 shows ordinary send and receive messages, 2 shows control messages such as link and unlink, 3 shows handshaking at connection setup, and 4 shows communication with Epmd. Each level includes the information shown by the lower ones.

Parameters:

level - the level to set.

Returns:

the previous trace level.

getTraceLevel

public int getTraceLevel()

Get the trace level for this connection.

Returns:

the current trace level.

close

public void close()

Close the connection to the remote node.

finalize

protected void finalize()

Overrides:

finalize in class Object

isConnected

public boolean isConnected()

Determine if the connection is still alive. Note that this method only reports the status of the connection, and that it is possible that there are unread messages waiting in the receive queue.

Returns:

true if the connection is alive.

do_send

protected void do_send(OtpOutputStream header,
 OtpOutputStream payload)
                throws IOException

Throws:

IOException

do_send

protected void do_send(OtpOutputStream header)
                throws IOException

Throws:

IOException

headerType

protected String headerType(OtpErlangObject h)

readSock

protected int readSock(OtpTransport s,
 byte[] b)
                throws IOException

Throws:

IOException

doAccept

protected void doAccept()
                 throws IOException,
OtpAuthException

Throws:

IOException

OtpAuthException

doPortConnect

protected void doPortConnect(int port)
                      throws IOException,
OtpAuthException

Throws:

IOException

OtpAuthException

doConnect

protected void doConnect()
                  throws IOException,
OtpAuthException

Throws:

IOException

OtpAuthException

doGenericConnect

protected void doGenericConnect()
                         throws IOException,
OtpAuthException

Throws:

IOException

OtpAuthException

genChallenge

protected static int genChallenge()

genDigest

protected byte[] genDigest(int challenge,
 String cookie)

sendName

protected int sendName(int dist,
 long aflags,
 int creation)
                throws IOException

Throws:

IOException

sendChallenge

protected void sendChallenge(long her_flags,
 long our_flags,
 int challenge)
                      throws IOException

Throws:

IOException

read2BytePackage

protected byte[] read2BytePackage()
                           throws IOException,
OtpErlangDecodeException

Throws:

IOException

OtpErlangDecodeException

recvName

protected int recvName(OtpPeer apeer)
                throws IOException

Throws:

IOException

recvChallenge

protected int recvChallenge()
                     throws IOException

Throws:

IOException

recvComplement

protected void recvComplement(int send_name_tag)
                       throws IOException

Throws:

IOException

sendChallengeReply

protected void sendChallengeReply(int challenge,
 byte[] digest)
                           throws IOException

Throws:

IOException

recvChallengeReply

protected int recvChallengeReply(int our_challenge)
                          throws IOException,
OtpAuthException

Throws:

IOException

OtpAuthException

sendChallengeAck

protected void sendChallengeAck(byte[] digest)
                         throws IOException

Throws:

IOException

recvChallengeAck

protected void recvChallengeAck(int our_challenge)
                         throws IOException,
OtpAuthException

Throws:

IOException

OtpAuthException

sendStatus

protected void sendStatus(String status)
                   throws IOException

Throws:

IOException

recvStatus

protected void recvStatus()
                   throws IOException

Throws:

IOException

setFlags

public void setFlags(int flags)

getFlags

public int getFlags()