Package zmq.socket.pubsub
Class Trie
- java.lang.Object
-
- zmq.socket.pubsub.Trie
-
class Trie extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
Trie.ITrieHandler
-
Constructor Summary
Constructors Constructor Description Trie()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
add(Msg msg, int start, int size)
void
apply(Trie.ITrieHandler func, Pipe arg)
private void
applyHelper(byte[] buff, int buffsize, int maxBuffsize, Trie.ITrieHandler func, Pipe pipe)
boolean
check(java.nio.ByteBuffer data)
private boolean
isRedundant()
private Trie[]
realloc(Trie[] table, int size, boolean ended)
boolean
rm(Msg msg, int start, int size)
-
-
-
Field Detail
-
refcnt
private int refcnt
-
min
private byte min
-
count
private int count
-
liveNodes
private int liveNodes
-
next
Trie[] next
-
-
Method Detail
-
add
public boolean add(Msg msg, int start, int size)
-
rm
public boolean rm(Msg msg, int start, int size)
-
check
public boolean check(java.nio.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()
-
-