Class Trie

java.lang.Object
zmq.socket.pubsub.Trie

class Trie extends Object
  • Field Details

    • refcnt

      private int refcnt
    • min

      private byte min
    • count

      private int count
    • liveNodes

      private int liveNodes
    • next

      Trie[] next
  • Constructor Details

    • Trie

      public Trie()
  • Method Details

    • add

      public boolean add(Msg msg, int start, int size)
    • realloc

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

      public boolean rm(Msg msg, int start, int size)
    • check

      public boolean check(ByteBuffer data)
    • apply

      public void apply(Trie.ITrieHandler func, Pipe arg)
    • applyHelper

      private void applyHelper(byte[] buff, int buffsize, int maxBuffsize, Trie.ITrieHandler func, Pipe pipe)
    • isRedundant

      private boolean isRedundant()