public class DhcpListenerWorker<D extends Idable> extends ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<DhcpListenerWorkerContext>
Modifier and Type | Field and Description |
---|---|
int |
agentDeviceId |
protected static java.net.InetAddress |
broadcastAddress |
protected static java.net.InetSocketAddress |
broadcastAddress68 |
java.lang.String |
circuitId |
long |
connectionId |
protected D |
device |
int |
interfaceId |
int |
relayDeviceId |
protected DhcpPacket |
request |
protected DhcpPacket |
response |
Constructor and Description |
---|
DhcpListenerWorker(ru.bitel.bgbilling.kernel.network.processor.DatagramListener listener,
DhcpProcessor<D> processor,
java.net.SocketAddress clientAddress,
long millis,
java.nio.ByteBuffer data,
int overloadLevel) |
Modifier and Type | Method and Description |
---|---|
D |
getDevice() |
int |
getOverloadLevel()
0-9 текущая загруженность пула, >=10 - второй пул
|
DhcpPacket |
getRequest() |
boolean |
isConnectionModified()
Было ли соединение начато/остановлено при обработке данного
request . |
protected void |
runImpl() |
void |
setConnectionModified(boolean connectionModified)
Было ли соединение начато/остановлено при обработке данного
request . |
void |
setDevice(D device) |
void |
setResponse(DhcpPacket response) |
newBlockingFixedThreadPool, newFixedThreadPool, newFixedThreadPool, newScheduledThreadPool, run, runSync, runSync, setContext
public int interfaceId
public java.lang.String circuitId
public long connectionId
public int relayDeviceId
public int agentDeviceId
protected DhcpPacket request
protected DhcpPacket response
protected static final java.net.InetAddress broadcastAddress
protected static final java.net.InetSocketAddress broadcastAddress68
public DhcpListenerWorker(ru.bitel.bgbilling.kernel.network.processor.DatagramListener listener, DhcpProcessor<D> processor, java.net.SocketAddress clientAddress, long millis, java.nio.ByteBuffer data, int overloadLevel)
public int getOverloadLevel()
protected void runImpl()
runImpl
in class ru.bitel.common.worker.WorkerTask<DhcpListenerWorkerContext>
public void setDevice(D device)
public D getDevice()
public void setResponse(DhcpPacket response)
public boolean isConnectionModified()
request
.public void setConnectionModified(boolean connectionModified)
request
.public DhcpPacket getRequest()