public class SimulatedLimitedDataChannel extends AbstractDataChannel implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private boolean |
m_channelClosed |
private boolean |
m_channelOpened |
private long |
m_channelTimeout |
private int |
m_downstreamPackets |
private java.lang.Object |
m_internalSynchronization |
private int |
m_receivedPackets |
(package private) java.lang.Thread |
m_timeoutSupervisionThread |
(package private) java.lang.Object |
m_timeoutSynchronization |
m_channelMessageQueue, m_mixCipherChain
m_parentMultiplexer
Constructor and Description |
---|
SimulatedLimitedDataChannel(int a_channelId,
Multiplexer a_parentMultiplexer,
AbstractDataChain a_parentDataChain,
MixCipherChain a_mixCipherChain,
int a_downstreamPackets,
long a_channelTimeout) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleReceivedPacket(MixPacket a_mixPacket) |
void |
multiplexerClosed()
This method is called on every channel in the channel-table after the
multiplexer is closed.
|
void |
organizeChannelClose() |
boolean |
processSendOrder(DataChainSendOrderStructure a_order) |
void |
run() |
createAndSendMixPacket, getChannelMessageQueue, getDataChain, getMixCipherChain, getNextPacketRecommandedOutputBlocksize, processReceivedPacket
createEmptyMixPacket, deleteChannel, isClosed, sendPacket
private java.lang.Object m_internalSynchronization
private boolean m_channelOpened
private int m_downstreamPackets
private long m_channelTimeout
private int m_receivedPackets
java.lang.Thread m_timeoutSupervisionThread
java.lang.Object m_timeoutSynchronization
private volatile boolean m_channelClosed
public SimulatedLimitedDataChannel(int a_channelId, Multiplexer a_parentMultiplexer, AbstractDataChain a_parentDataChain, MixCipherChain a_mixCipherChain, int a_downstreamPackets, long a_channelTimeout)
public void organizeChannelClose()
organizeChannelClose
in class AbstractDataChannel
public boolean processSendOrder(DataChainSendOrderStructure a_order)
processSendOrder
in class AbstractDataChannel
public void multiplexerClosed()
AbstractChannel
multiplexerClosed
in class AbstractChannel
protected void handleReceivedPacket(MixPacket a_mixPacket)
handleReceivedPacket
in class AbstractDataChannel
public void run()
run
in interface java.lang.Runnable
Copyright © 2023. All rights reserved.