public class DummyTrafficControlChannel extends AbstractControlChannel implements java.lang.Runnable, java.util.Observer
anon.client.DummyTrafficControlChannel#DT_MAX_INTERVAL_MS}
Modifier and Type | Field and Description |
---|---|
static int |
DT_DISABLE |
static int |
DT_MAX_INTERVAL_MS |
static int |
DT_MIN_INTERVAL_MS |
private boolean |
m_bRun
Stores whether the internal thread shall work (true) or come to the end
(false).
|
private java.lang.Object |
m_internalSynchronization |
private long |
m_interval
Stores the dummy traffic interval in milliseconds.
|
private java.util.Observable |
m_observedMultiplexer |
private java.lang.Thread |
m_threadRunLoop
Stores the instance of the internal dummy traffic thread.
|
m_parentMultiplexer
Constructor and Description |
---|
DummyTrafficControlChannel(Multiplexer a_multiplexer,
IServiceContainer a_serviceContainer)
Creates a new DummyTrafficControlChannel instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
processPacketData(byte[] a_packet)
This method is called by the multiplexer, if a packet is received on the
dummy-traffic control channel.
|
void |
run()
Lets the thread sleep for the given interval.
|
void |
setDummyTrafficInterval(int a_interval)
Changes the dummy traffic interval.
|
private void |
start()
Starts the internal dummy traffic thread, if it is not already running.
|
void |
stop()
Halts the internal dummy traffic thread.
|
void |
update(java.util.Observable a_observer,
java.lang.Object a_argument)
This is the Observer implementation.
|
getServiceContainer, isSending, processReceivedPacket, sendRawMessage
createEmptyMixPacket, deleteChannel, isClosed, multiplexerClosed, sendPacket
public static final int DT_MIN_INTERVAL_MS
public static final int DT_MAX_INTERVAL_MS
public static final int DT_DISABLE
private java.util.Observable m_observedMultiplexer
private volatile boolean m_bRun
private java.lang.Thread m_threadRunLoop
private long m_interval
private java.lang.Object m_internalSynchronization
public DummyTrafficControlChannel(Multiplexer a_multiplexer, IServiceContainer a_serviceContainer)
public void run()
run
in interface java.lang.Runnable
public void stop()
public void update(java.util.Observable a_observer, java.lang.Object a_argument)
update
in interface java.util.Observer
a_observer
- The observed object (Multiplexer).a_argument
- The notification (PacketProcessedEvent).public void setDummyTrafficInterval(int a_interval)
a_interval
- The new dummy traffic interval in milliseconds or DT_DISABLE, if dummy
traffic shall be disabled.protected void processPacketData(byte[] a_packet)
processPacketData
in class AbstractControlChannel
a_packet
- The data within the received packet (should be random bytes).private void start()
Copyright © 2023. All rights reserved.