private class Wiretapper.Link extends AbstractDataLinkLayer.Link implements DataLinkLayer.Link, PropertyQueryInterface
| Modifier and Type | Field and Description |
|---|---|
private boolean |
_fcb |
private long |
_lastGoodReply |
private Properties |
_properties |
private PropertyConsultant |
_propertyConsultant |
private boolean |
_tolerateRetry |
_linkLock, _linkPropertyLock, _linkState, _remoteAddress| Modifier | Constructor and Description |
|---|---|
private |
Wiretapper.Link(int remoteAddress) |
| Modifier and Type | Method and Description |
|---|---|
void |
abort()
Abbruch der Kommunikation auf dieser logischen Verbindung.
|
void |
connect()
Aktiviert die Kommunikation auf dieser logischen Verbindung.
|
DataLinkLayer |
getDataLinkLayer()
Bestimmt das Kommunikationsprotokoll zu dem diese Verbindung gehört.
|
String |
getProperty(String name)
Bestimmt den Wert eines bestimmten Verbindungsparameters.
|
void |
handleErrorSituation(String message) |
void |
handleQuery(PrimaryFrame primaryFrame,
SecondaryFrame secondaryFrame) |
void |
send(byte[] bytes,
int priority)
Übernimmt die übergebenen Nutzdaten in den Sendepuffer.
|
void |
setProperties(Properties properties)
Setzt einen neuen verbindungsspezifischen Satz von Verbindungsparametern.
|
void |
shutdown()
Beendet die Kommunikation auf dieser logischen Verbindung.
|
private boolean |
synchronizedPollAction()
Führt Pollaktionen durch, die notwendig sind, bevor der synchronisierte Bereich zum Zugriff auf die Liste mit den zu bearbeitenden Verbindungen (_links)
verlassen wird.
|
String |
toString() |
private void |
unsynchronizedPollAction() |
getRemoteAddress, getState, notifyEventclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetRemoteAddress, getStateprivate Properties _properties
private boolean _fcb
private long _lastGoodReply
private final PropertyConsultant _propertyConsultant
private boolean _tolerateRetry
public String toString()
toString in class AbstractDataLinkLayer.Linkpublic DataLinkLayer getDataLinkLayer()
DataLinkLayer.LinkgetDataLinkLayer in interface DataLinkLayer.Linkpublic String getProperty(String name)
DataLinkLayer.LinkDataLinkLayer.getProperty(java.lang.String) Methode des Sicherungsprotokolls ein Defaultwert bestimmt.getProperty in interface DataLinkLayer.LinkgetProperty in interface PropertyQueryInterfacename - Name des Verbindungsparameters.DataLinkLayer.Link.setProperties(java.util.Properties),
DataLinkLayer.getProperty(java.lang.String)public void setProperties(Properties properties)
DataLinkLayer.LinksetProperties in interface DataLinkLayer.Linkproperties - Neue Verbindungsparameter.public void connect()
DataLinkLayer.Linkconnect in interface DataLinkLayer.Linkpublic void shutdown()
throws InterruptedException
DataLinkLayer.LinkDataLinkLayer.Link.send(byte[], int) übergeben wurden, auch übertragen werden.shutdown in interface DataLinkLayer.LinkInterruptedExceptionpublic void abort()
throws InterruptedException
DataLinkLayer.LinkDataLinkLayer.Link.send(byte[], int) übergeben wurden und noch nicht übertragen wurden, werden nicht mehr übertragen.abort in interface DataLinkLayer.LinkInterruptedExceptionpublic void send(byte[] bytes,
int priority)
throws InterruptedException
DataLinkLayer.Linksend in interface DataLinkLayer.Linkbytes - Zu übertragende Nutzdatenbytes.priority - Priorität der zu übertragenden DatenInterruptedExceptionprivate boolean synchronizedPollAction()
true, wenn eine Aktion durchgeführt wurde und das Polling mit der nächsten Verbindung fortgesetzt werden soll, sonst
false.private void unsynchronizedPollAction()
public void handleQuery(PrimaryFrame primaryFrame, SecondaryFrame secondaryFrame)
public void handleErrorSituation(String message)