public class DhcpListener
extends ru.bitel.bgbilling.kernel.network.processor.DatagramListener
implements ru.bitel.bgbilling.kernel.network.processor.ProcessorListener
Modifier and Type | Field and Description |
---|---|
protected ru.bitel.bgbilling.kernel.network.dhcp.datalog.hourly.DhcpHourlyDataLogger |
dataLogger |
protected DhcpProcessor<Idable> |
processor |
Constructor and Description |
---|
DhcpListener(java.lang.String host,
int port,
int byteBufferCapacity,
DhcpProcessor<Idable> processor,
ru.bitel.bgbilling.kernel.network.dhcp.datalog.hourly.DhcpHourlyDataLogger dataLogger,
int threadCount,
int maxQueueSize) |
Modifier and Type | Method and Description |
---|---|
ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<?> |
newRequest(java.net.SocketAddress clientAddress,
long millis,
java.nio.ByteBuffer data,
int overloadLevel) |
ru.bitel.common.worker.ThreadContext |
newThreadContext() |
destroy, getActiveThreadCount, getCurrentThreadCount, getMaxQueueSize, getQueueSize, getSlow1QueueSize, getSlow2QueueSize, getTaskCount, getThreadCount, init, onPacket, setMaxQueueSize, setThreadCount, start, stop
run, select, send, sendResponse, shutdown
protected final DhcpProcessor<Idable> processor
protected final ru.bitel.bgbilling.kernel.network.dhcp.datalog.hourly.DhcpHourlyDataLogger dataLogger
@ConstructorProperties(value={"host","port","recvBufferSize","processor","dataLogger","threadCount","maxQueueSize"}) public DhcpListener(java.lang.String host, int port, int byteBufferCapacity, DhcpProcessor<Idable> processor, ru.bitel.bgbilling.kernel.network.dhcp.datalog.hourly.DhcpHourlyDataLogger dataLogger, int threadCount, int maxQueueSize)
public ru.bitel.common.worker.ThreadContext newThreadContext()
newThreadContext
in interface ru.bitel.common.worker.ThreadContextFactory<ru.bitel.common.worker.ThreadContext>
public ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<?> newRequest(java.net.SocketAddress clientAddress, long millis, java.nio.ByteBuffer data, int overloadLevel)
newRequest
in interface ru.bitel.bgbilling.kernel.network.processor.ProcessorListener
newRequest
in class ru.bitel.bgbilling.kernel.network.processor.DatagramListener