Class DhcpListenerWorker<D extends Idable>

java.lang.Object
ru.bitel.bgbilling.kernel.base.server.logger.BGLogger
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>
  • Nested Class Summary

    Nested classes/interfaces inherited from class ru.bitel.common.worker.WorkerTask

    ru.bitel.common.worker.WorkerTask.BlockingExecutionHandler
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    int
     
    protected static final InetAddress
     
    protected static final InetSocketAddress
     
     
    long
     
    protected D
     
    int
     
    int
     
    protected DhcpPacket
     
    protected DhcpPacket
     

    Fields inherited from class ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest

    clientAddress, data, millis

    Fields inherited from class ru.bitel.common.worker.WorkerTask

    context
  • Constructor Summary

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

    Modifier and Type
    Method
    Description
     
    int
    0-9 текущая загруженность пула, >=10 - второй пул
     
    boolean
    Было ли соединение начато/остановлено при обработке данного request.
    protected void
     
    void
    setConnectionModified(boolean connectionModified)
    Было ли соединение начато/остановлено при обработке данного request.
    void
    setDevice(D device)
     
    void
     

    Methods inherited from class ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest

    send

    Methods inherited from class ru.bitel.common.worker.WorkerTask

    newBlockingFixedThreadPool, newFixedThreadPool, newFixedThreadPool, newScheduledThreadPool, run, runSync, runSync, setContext

    Methods inherited from class ru.bitel.bgbilling.kernel.base.server.logger.BGLogger

    error, error, error, getLogger, logError, logError

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface java.lang.Runnable

    run
  • 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()