Class DhcpListenerWorker<D extends Idable>

java.lang.Object
ru.bitel.common.worker.WorkerTask<C>
ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<DhcpListenerWorkerContext>
ru.bitel.bgbilling.kernel.network.dhcp.DhcpListenerWorker<D>
All Implemented Interfaces:
Runnable

public class DhcpListenerWorker<D extends Idable> extends ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<DhcpListenerWorkerContext>
  • Field Details

    • interfaceId

      public int interfaceId
    • circuitId

      public String circuitId
    • connectionId

      public long connectionId
    • relayDeviceId

      public int relayDeviceId
    • agentDeviceId

      public int agentDeviceId
    • device

      protected D extends Idable device
    • request

      protected DhcpPacket request
    • response

      protected DhcpPacket response
    • broadcastAddress

      protected static final InetAddress broadcastAddress
    • broadcastAddress68

      protected static final InetSocketAddress broadcastAddress68
  • Constructor Details

    • DhcpListenerWorker

      public DhcpListenerWorker(ru.bitel.bgbilling.kernel.network.processor.DatagramListener listener, DhcpProcessor<D> processor, SocketAddress clientAddress, long millis, ByteBuffer data, int overloadLevel)
  • Method Details

    • getOverloadLevel

      public int getOverloadLevel()
      0-9 текущая загруженность пула, >=10 - второй пул
      Returns:
    • runImpl

      protected void runImpl()
      Specified by:
      runImpl in class ru.bitel.common.worker.WorkerTask<DhcpListenerWorkerContext>
    • setDevice

      public void setDevice(D device)
    • getDevice

      public D getDevice()
    • setResponse

      public void setResponse(DhcpPacket response)
    • isConnectionModified

      public boolean isConnectionModified()
      Было ли соединение начато/остановлено при обработке данного request.
    • setConnectionModified

      public void setConnectionModified(boolean connectionModified)
      Было ли соединение начато/остановлено при обработке данного request.
    • getRequest

      public DhcpPacket getRequest()