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 byte[] |
ipAddress |
protected int |
ipResourceId |
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) |
java.lang.Object |
getAgentDevice() |
int |
getAgentDeviceId() |
java.lang.Object |
getCircuitId() |
ru.bitel.bgbilling.kernel.container.managed.ServerContext |
getConext() |
int |
getContractId() |
byte[] |
getIpAddress() |
int |
getIpResourceId() |
RadiusSession<N,?> |
getRadiusSession() |
RadiusPacket |
getRequest() |
RadiusPacket |
getResponse() |
boolean |
isConnectionModified()
Было ли соединение начато/остановлено при обработке данного
request . |
boolean |
isSkip() |
void |
runImpl() |
protected java.nio.ByteBuffer |
sendReponse(N nas,
RadiusPacket response) |
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 |
setIpAddress(byte[] ipAddress) |
void |
setIpResourceId(int ipResourceId) |
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 byte[] ipAddress
protected int ipResourceId
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 byte[] getIpAddress()
public void setIpAddress(byte[] ipAddress)
public int getIpResourceId()
public void setIpResourceId(int ipResourceId)
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 boolean isSkip()
public void setSkip(boolean dismiss)