N
- public class RadiusListenerWorker<N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,?,?>> extends ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<RadiusListenerWorkerContext>
Modifier and Type | Field and Description |
---|---|
protected int |
accessCode |
protected java.lang.Object |
agentDevice |
protected int |
agentDeviceId |
protected ru.bitel.bgbilling.kernel.network.ip.IpAddressSet |
ipAddressSet |
protected static org.apache.log4j.Logger |
logger |
protected static org.apache.log4j.Logger |
loggerUpdate |
protected N |
nas |
protected int |
overloadLevel |
protected RadiusProcessor<?,N,?> |
processor |
protected RadiusSession<N,?> |
radiusSession |
protected RadiusPacket |
request |
protected RadiusPacket |
response |
protected static java.lang.ThreadLocal<RadiusListenerWorker<?>> |
worker |
Constructor and Description |
---|
RadiusListenerWorker(RadiusListener<N> listener,
java.net.SocketAddress clientAddress,
long millis,
java.nio.ByteBuffer data,
int overloadLevel) |
Modifier and Type | Method and Description |
---|---|
protected void |
accessRequest(N nas,
RadiusPacket request,
RadiusPacket response,
ConnectionSet connectionSet,
java.util.Date time) |
protected void |
accessRequest0(N nas,
RadiusPacket request,
RadiusPacket response,
ConnectionSet connectionSet,
java.util.Date time) |
protected void |
accountingRequest(N nas,
RadiusPacket request,
RadiusPacket response,
ConnectionSet connectionSet,
java.util.Date time) |
int |
getAccountId() |
java.lang.Object |
getAgentDevice() |
int |
getAgentDeviceId() |
java.lang.Object |
getCircuitId() |
ru.bitel.bgbilling.kernel.container.managed.ServerContext |
getConext() |
int |
getConnectionType() |
int |
getContractId() |
ru.bitel.bgbilling.kernel.network.ip.IpAddressSet |
getIpAddressSet() |
RadiusSession<N,?> |
getRadiusSession() |
RadiusPacket |
getRequest() |
RadiusPacket |
getResponse() |
boolean |
isConnectionModified()
Было ли соединение начато/остановлено при обработке данного
request . |
boolean |
isSkip() |
void |
runImpl() |
protected java.nio.ByteBuffer |
sendReponse(N nas,
RadiusPacket response) |
void |
setAccountId(int accountId) |
void |
setAgentDevice(java.lang.Object agentDevice) |
void |
setAgentDeviceId(int agentDeviceId) |
void |
setCircuitId(java.lang.Object circuitId) |
void |
setConnectionModified(boolean connectionModified)
Было ли соединение начато/остановлено при обработке данного
request . |
void |
setContractId(int contractId) |
void |
setSkip(boolean dismiss) |
newBlockingFixedThreadPool, newFixedThreadPool, newFixedThreadPool, newScheduledThreadPool, run, runSync, runSync, setContext
protected static final org.apache.log4j.Logger logger
protected static final org.apache.log4j.Logger loggerUpdate
protected final RadiusProcessor<?,N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,?,?>,?> processor
protected final int overloadLevel
protected RadiusPacket request
protected RadiusSession<N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,?,?>,?> radiusSession
protected N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,?,?> nas
protected int agentDeviceId
protected java.lang.Object agentDevice
protected int accessCode
protected final ru.bitel.bgbilling.kernel.network.ip.IpAddressSet ipAddressSet
protected RadiusPacket response
protected static final java.lang.ThreadLocal<RadiusListenerWorker<?>> worker
public RadiusListenerWorker(RadiusListener<N> listener, java.net.SocketAddress clientAddress, long millis, java.nio.ByteBuffer data, int overloadLevel)
public int getAgentDeviceId()
public void setAgentDeviceId(int agentDeviceId)
public java.lang.Object getAgentDevice()
public void setAgentDevice(java.lang.Object agentDevice)
public boolean isConnectionModified()
request
.public void setConnectionModified(boolean connectionModified)
request
.public ru.bitel.bgbilling.kernel.network.ip.IpAddressSet getIpAddressSet()
public java.lang.Object getCircuitId()
public void setCircuitId(java.lang.Object circuitId)
public void runImpl()
runImpl
in class ru.bitel.common.worker.WorkerTask<RadiusListenerWorkerContext>
protected void accessRequest0(N nas, RadiusPacket request, RadiusPacket response, ConnectionSet connectionSet, java.util.Date time) throws ru.bitel.bgbilling.common.BGException, java.security.InvalidKeyException, java.security.NoSuchAlgorithmException, java.io.IOException
ru.bitel.bgbilling.common.BGException
java.security.InvalidKeyException
java.security.NoSuchAlgorithmException
java.io.IOException
protected void accessRequest(N nas, RadiusPacket request, RadiusPacket response, ConnectionSet connectionSet, java.util.Date time) throws ru.bitel.bgbilling.common.BGException, java.security.InvalidKeyException, java.security.NoSuchAlgorithmException, java.io.IOException
ru.bitel.bgbilling.common.BGException
java.security.InvalidKeyException
java.security.NoSuchAlgorithmException
java.io.IOException
protected void accountingRequest(N nas, RadiusPacket request, RadiusPacket response, ConnectionSet connectionSet, java.util.Date time) throws ru.bitel.bgbilling.common.BGException, java.security.InvalidKeyException, java.security.NoSuchAlgorithmException, java.io.IOException
ru.bitel.bgbilling.common.BGException
java.security.InvalidKeyException
java.security.NoSuchAlgorithmException
java.io.IOException
protected java.nio.ByteBuffer sendReponse(N nas, RadiusPacket response) throws java.security.InvalidKeyException, java.security.NoSuchAlgorithmException, java.io.IOException
java.security.InvalidKeyException
java.security.NoSuchAlgorithmException
java.io.IOException
public ru.bitel.bgbilling.kernel.container.managed.ServerContext getConext()
public RadiusSession<N,?> getRadiusSession()
public RadiusPacket getRequest()
public RadiusPacket getResponse()
public void setContractId(int contractId)
public int getContractId()
public int getAccountId()
public void setAccountId(int accountId)
public boolean isSkip()
public void setSkip(boolean dismiss)
public int getConnectionType()
InetConnection#TYPE_RADIUS, {@link InetConnection#TYPE_RADIUS_DUAL_STACK}, {@link InetConnection#TYPE_RADIUSv4},
{@link InetConnection#TYPE_RADIUSv6}.