org.vishia.inspectorTarget

Class Comm

java.lang.Object

org.vishia.inspectorTarget.Comm

All Implemented Interfaces:

java.lang.Runnable

public class Comm
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	bEnablePrintfOnComm
private CmdExecuter	cmdExecuter
private int	ctErrorTelg
private byte[]	data_rxBuffer Use a static receive buffer.
private InterProcessComm	ipc
private Address_InterProcessComm	myAnswerAddress
private int[]	nrofBytesReceived
private byte[]	rxBuffer For C: store the reference and length of the SimpleArray in the next structure.
private char	state State of function.
private java.lang.Thread	thread
static int	version Version and history 2011-11-17 Hartmut new shutdown() to end communication thread.

Constructor Summary

Constructors

Constructor and Description
Comm(java.lang.String ownAddrIpc, CmdExecuter cmdExecuter) Creates the communication for the inspector.

Method Summary

Modifier and Type	Method and Description
boolean	openComm(boolean blocking)
private void	receiveAndExecute()
void	run()
int	sendAnswer(byte[] bufferAnswerData, int nrofBytesAnswer) Sends the answer telg to the sender of the received telegram.
void	shutdown() Shutdown the communication, close the thread.
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

version

public static final int version

Version and history

• 2011-11-17 Hartmut new shutdown() to end communication thread.
• 2011-01-00 Hartmut Created from C-Sources, then re-translated to C and testet with Java2C

See Also:

Constant Field Values

cmdExecuter

private final CmdExecuter cmdExecuter

state

private char state

State of function.

• o: opened
• e: error (open error)
• x: exit
• z: is exited.

bEnablePrintfOnComm

private boolean bEnablePrintfOnComm

ipc

private final InterProcessComm ipc

ctErrorTelg

private int ctErrorTelg

thread

private final java.lang.Thread thread

nrofBytesReceived

private final int[] nrofBytesReceived

data_rxBuffer

private final byte[] data_rxBuffer

Use a static receive buffer. It is important for C-applications.

rxBuffer

private final byte[] rxBuffer

For C: store the reference and length of the SimpleArray in the next structure.

myAnswerAddress

private final Address_InterProcessComm myAnswerAddress

Constructor Detail

Comm

public Comm(java.lang.String ownAddrIpc,
            CmdExecuter cmdExecuter)

Creates the communication for the inspector. The InterProcessComm interface implementation is got depending on

• the ownAddrIpc-string
• the existing InterProcessComm-Implementation, which analyzes the address-string.
  It means, the communication is not determined from this implementation, it depends on the parameter of the ownAddrIpc and the possibilities.

Parameters:

ownAddrIpc - The address String

cmdExecuter - aggregation of executer of all commands.

Method Detail

openComm

public final boolean openComm(boolean blocking)

start

public final void start()

run

public void run()

Specified by:

run in interface java.lang.Runnable

receiveAndExecute

private final void receiveAndExecute()

sendAnswer

public final int sendAnswer(byte[] bufferAnswerData,
                            int nrofBytesAnswer)

Sends the answer telg to the sender of the received telegram. If the receiving process fails, the answer isn't send. This situation can occur only if the preparation of the answer runs in another thread.

Parameters:

bufferAnswerData - The bytes to send.

nrofBytesAnswer - number of bytes to send.

Returns:

number of bytes sent or a negative value on error.

shutdown

public void shutdown()

Shutdown the communication, close the thread. This routine should be called either on shutdown of the whole system or on closing the inspector functionality. The inspector functionality can be restarted calling #start(Object).