N
- public class RadiusListener<N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,?,?>>
extends ru.bitel.common.io.DatagramChannelListener
implements ru.bitel.bgbilling.kernel.network.processor.ProcessorListener
Modifier and Type | Class and Description |
---|---|
static class |
RadiusListener.Mode |
Modifier and Type | Field and Description |
---|---|
static bitel.billing.server.util.RequestCounter |
accountingStartCounter
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
accountingStopCounter
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
accountingUpdateCounter
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
accountingUpdateIgnoreCount
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
antispamIgnoreCount
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
authenticationAcceptCounter
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
authenticationIgnoreCount
Deprecated.
|
static bitel.billing.server.util.RequestCounter |
authenticationRejectCounter
Deprecated.
|
protected ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger |
dataLogger |
protected RadiusListener.Mode |
mode |
protected RadiusProcessor<?,N,?> |
processor |
protected Setup |
setup |
protected java.lang.String |
threadCountParamName |
protected java.lang.String |
threadQueueParamName |
Constructor and Description |
---|
RadiusListener(java.lang.String host,
int port,
int byteBufferCapacity,
int socketRcvBuf,
RadiusProcessor<?,N,?> processor,
RadiusListener.Mode mode,
Setup setup,
ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger,
int threadCount,
int maxQueueSize,
java.lang.Boolean defaultAutoCommit) |
Modifier and Type | Method and Description |
---|---|
int |
getActiveThreadCount() |
int |
getCurrentThreadCount() |
int |
getMaxQueueSize() |
long |
getQueueSize() |
int |
getSlow1QueueSize() |
int |
getSlow2QueueSize() |
long |
getTaskCount() |
int |
getThreadCount() |
boolean |
isSkipAccountingRequestsOnSlow() |
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() |
void |
onPacket(java.net.SocketAddress clientAddress,
java.nio.ByteBuffer data) |
void |
setMaxQueueSize(int maxQueueSize) |
void |
setSkipAccountingRequestsOnSlow(boolean skipAccountingRequestsOnSlow) |
void |
setThreadCount(int count) |
java.lang.Thread |
startListener() |
java.lang.String |
toString() |
protected void |
toString(java.lang.StringBuilder result) |
init, run, select, send, sendResponse, setReuseAddress, shutdown
@Deprecated public static bitel.billing.server.util.RequestCounter accountingStartCounter
@Deprecated public static bitel.billing.server.util.RequestCounter accountingStopCounter
@Deprecated public static bitel.billing.server.util.RequestCounter accountingUpdateCounter
@Deprecated public static bitel.billing.server.util.RequestCounter authenticationAcceptCounter
@Deprecated public static bitel.billing.server.util.RequestCounter authenticationRejectCounter
@Deprecated public static bitel.billing.server.util.RequestCounter authenticationIgnoreCount
@Deprecated public static bitel.billing.server.util.RequestCounter accountingUpdateIgnoreCount
@Deprecated public static bitel.billing.server.util.RequestCounter antispamIgnoreCount
protected final RadiusListener.Mode mode
protected final Setup setup
protected final RadiusProcessor<?,N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,?,?>,?> processor
protected final ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger
protected java.lang.String threadCountParamName
protected java.lang.String threadQueueParamName
@ConstructorProperties(value={"host","port","recvBufferSize","soRCVBUF","processor","mode","setup","dataLogger","threadCount","maxQueueSize","defaultAutoCommit"}) public RadiusListener(java.lang.String host, int port, int byteBufferCapacity, int socketRcvBuf, RadiusProcessor<?,N,?> processor, RadiusListener.Mode mode, Setup setup, ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger, int threadCount, int maxQueueSize, java.lang.Boolean defaultAutoCommit)
host
- port
- byteBufferCapacity
- буфер на потокsocketRcvBuf
- рекомендуемый буфер сокетаprocessor
- mode
- setup
- dataLogger
- RadiusHourlyDataLogger, если нужно сохранять логиthreadCount
- количество потоков или 0, если брать из setupmaxQueueSize
- размер очереди или 0, если брать из setuppublic 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
public void onPacket(java.net.SocketAddress clientAddress, java.nio.ByteBuffer data)
onPacket
in class ru.bitel.common.io.DatagramChannelListener
public java.lang.Thread startListener()
public java.lang.String toString()
toString
in class java.lang.Object
protected void toString(java.lang.StringBuilder result)
public int getThreadCount()
public void setThreadCount(int count)
public int getMaxQueueSize()
public void setMaxQueueSize(int maxQueueSize)
public int getSlow1QueueSize()
public int getSlow2QueueSize()
public int getCurrentThreadCount()
public int getActiveThreadCount()
public long getTaskCount()
public long getQueueSize()
public boolean isSkipAccountingRequestsOnSlow()
public void setSkipAccountingRequestsOnSlow(boolean skipAccountingRequestsOnSlow)