org.vishia.inspcPC.accTarget

Class InspcCommPort

java.lang.Object

org.vishia.inspcPC.accTarget.InspcCommPort

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class InspcCommPort
extends java.lang.Object
implements java.io.Closeable

This class is one communication port for a target communication.

• A communication port is associated with one instance of InterProcessComm.
• A communication port can handle more as one devices. It associates a Map of targetAccessors.
• A communication port contains the receiveThread and the receiveRun routine.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	bFinish
(package private) boolean	bRun
(package private) boolean	bWaitFinish
private InterProcessComm	ipc
(package private) java.lang.Runnable	receiveRun
(package private) java.lang.Thread	receiveThread A receive thread should be used anyway if a socket receiving or other receiving is given.
(package private) java.lang.String	sOwnIpAddr
(package private) java.util.Map<java.lang.String,InspcTargetAccessor>	targetAccessors All access instances which uses this port.
(package private) Address_InterProcessComm	targetSenderAddr
static java.lang.String	version Version, history and license.

Constructor Summary

Constructors

Constructor and Description
InspcCommPort()

Method Summary

Modifier and Type	Method and Description
void	close() Closes the thread for receive
Address_InterProcessComm	createTargetAddr(java.lang.String sAddr)
boolean	open(java.lang.String sOwnIpAddrP)
(package private) void	receiveFromTarget()
(package private) void	registerTargetAccessor(InspcTargetAccessor accessor) Register an target access instance which uses this port.
(package private) int	send(InspcTargetAccessor targerAccessor, byte[] txBuffer, int lengthDatagram)

Methods inherited from class java.lang.Object

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

Field Detail

version

public static final java.lang.String version

Version, history and license.

• 2014-11-05 Hartmut: catch exception in thread loop
• 2011-05-01 Hartmut: Created

Copyright/Copyleft: For this source the LGPL Lesser General Public License, published by the Free Software Foundation is valid. It means:

1. You can use this source without any restriction for any desired purpose.
2. You can redistribute copies of this source to everybody.
3. Every user of this source, also the user of redistribute copies with or without payment, must accept this license for further using.
4. But the LPGL ist not appropriate for a whole software product, if this source is only a part of them. It means, the user must publish this part of source, but don't need to publish the whole source of the own product.
5. You can study and modify (improve) this source for own using or for redistribution, but you have to license the modified sources likewise under this LGPL Lesser General Public License. You mustn't delete this Copyright/Copyleft inscription in this source file.

If you are intent to use this sources without publishing its usage, you can get a second license subscribing a special contract with the author.

See Also:

Constant Field Values

ipc

private InterProcessComm ipc

sOwnIpAddr

java.lang.String sOwnIpAddr

targetAccessors

java.util.Map<java.lang.String,InspcTargetAccessor> targetAccessors

All access instances which uses this port. The key is the targetAddr.toString().

receiveRun

java.lang.Runnable receiveRun

receiveThread

java.lang.Thread receiveThread

A receive thread should be used anyway if a socket receiving or other receiving is given. Because: Anytime any telegram can be received, the receiver buffer should be cleared, also if the telegram is unexpected.

bRun

boolean bRun

bFinish

boolean bFinish

bWaitFinish

boolean bWaitFinish

targetSenderAddr

Address_InterProcessComm targetSenderAddr

Constructor Detail

InspcCommPort

public InspcCommPort()

Method Detail

registerTargetAccessor

void registerTargetAccessor(InspcTargetAccessor accessor)

Register an target access instance which uses this port. An instance can be registered more as one time, especially for any usage. This routine checks whether it is registered already, it registers one time. The registration is necessary for association of an answer telegram for this port.

Parameters:

accessor -

createTargetAddr

public Address_InterProcessComm createTargetAddr(java.lang.String sAddr)

open

public boolean open(java.lang.String sOwnIpAddrP)

close

public void close()
           throws java.io.IOException

Closes the thread for receive

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

See Also:

Closeable.close()

send

int send(InspcTargetAccessor targerAccessor,
         byte[] txBuffer,
         int lengthDatagram)

receiveFromTarget

void receiveFromTarget()