Class Mtrie

java.lang.Object
zmq.socket.pubsub.Mtrie

class Mtrie extends Object
  • Field Details

    • pipes

      private Set<Pipe> pipes
    • min

      private int min
    • count

      private int count
    • liveNodes

      private int liveNodes
    • next

      private Mtrie[] next
  • Constructor Details

    • Mtrie

      public Mtrie()
  • Method Details

    • addOnTop

      final boolean addOnTop(Pipe pipe)
    • add

      public boolean add(Msg msg, Pipe pipe)
    • addHelper

      private boolean addHelper(Msg msg, int start, int size, Pipe pipe)
    • realloc

      private Mtrie[] realloc(Mtrie[] table, int size, boolean ended)
    • rm

      public boolean rm(Pipe pipe, Mtrie.IMtrieHandler func, XPub pub)
    • rmHelper

      private boolean rmHelper(Pipe pipe, byte[] buff, int buffsize, int maxBuffSize, Mtrie.IMtrieHandler func, XPub pub)
    • rm

      public boolean rm(Msg msg, Pipe pipe)
    • rmHelper

      private boolean rmHelper(Msg msg, int start, int size, Pipe pipe)
    • match

      public void match(ByteBuffer data, int size, Mtrie.IMtrieHandler func, XPub pub)
    • isRedundant

      private boolean isRedundant()