Package edu.jas.util

Class DHTBroadcaster<K>

  • All Implemented Interfaces:
    java.lang.Runnable
    class DHTBroadcaster<K>
extends java.lang.Thread
    Thread for broadcasting all incoming objects to the list clients.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class java.lang.Thread

        java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.List<DHTBroadcaster<K>> bcaster  
      private SocketChannel channel  
      private static boolean debug  
      (package private) boolean goon  
      private static org.apache.logging.log4j.Logger logger  
      private java.util.SortedMap<K,​DHTTransport> theList  

      • Fields inherited from class java.lang.Thread

        MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void broadcast​(DHTTransport o)
      broadcast.
      void closeChannel()
      closeChannel.
      void run()
      run.
      void sendChannel​(DHTTransport tc)
      sendChannel.
      java.lang.String toString()
      toString.

      • Methods inherited from class java.lang.Thread

        activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • logger

        private static final org.apache.logging.log4j.Logger logger

      • debug

        private static final boolean debug

      • theList

        private final java.util.SortedMap<K,​DHTTransport> theList

      • goon

        volatile boolean goon

    • Constructor Detail

      • DHTBroadcaster

        public DHTBroadcaster​(SocketChannel s,
                      java.util.List<DHTBroadcaster<K>> bc,
                      java.util.SortedMap<K,​DHTTransport> sm)
        DHTBroadcaster.
        Parameters:
        s - SocketChannel to use.
        bc - list of broadcasters.
        sm - SortedMap with key value pairs.

    • Method Detail

      • closeChannel

        public void closeChannel()
        closeChannel.

      • sendChannel

        public void sendChannel​(DHTTransport tc)
                 throws java.io.IOException
        sendChannel.
        Parameters:
        tc - DHTTransport.
        Throws:
        java.io.IOException

      • broadcast

        public void broadcast​(DHTTransport o)
        broadcast.
        Parameters:
        o - DHTTransport element to broadcast.

      • run

        public void run()
        run.
        Specified by:
        run in interface java.lang.Runnable
        Overrides:
        run in class java.lang.Thread

      • toString

        public java.lang.String toString()
        toString.
        Overrides:
        toString in class java.lang.Thread
        Returns:
        a string representation of this.