public class DhcpListener
extends ru.bitel.bgbilling.kernel.network.processor.DatagramListener
implements ru.bitel.bgbilling.kernel.network.processor.ProcessorListener, ru.bitel.bgbilling.kernel.application.server.CommandListener
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,
java.lang.Boolean fallbackPool) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
executeCommand(java.lang.String cmd,
java.lang.String param) |
boolean |
fallback(java.net.SocketAddress clientAddress,
long millis,
java.nio.ByteBuffer data,
int overloadLevel) |
java.lang.String |
getCommandsHelp() |
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, getLastHourAverage, getLastMinuteCount, getLastTenMinutesAverage, getMaxQueueSize, getOverloadLevel, getQueueSize, getSlow1QueueSize, getSlow2QueueSize, getTaskCount, getThreadCount, init, onPacket, setMaxQueueSize, setThreadCount, start, stop
run, select, send, sendResponse, setReuseAddress, 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","fallbackPool"}) 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, java.lang.Boolean fallbackPool)
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
public java.lang.String getCommandsHelp()
getCommandsHelp
in interface ru.bitel.bgbilling.kernel.application.server.CommandListener
public java.lang.String executeCommand(java.lang.String cmd, java.lang.String param)
executeCommand
in interface ru.bitel.bgbilling.kernel.application.server.CommandListener
public boolean fallback(java.net.SocketAddress clientAddress, long millis, java.nio.ByteBuffer data, int overloadLevel)
fallback
in class ru.bitel.bgbilling.kernel.network.processor.DatagramListener