Package zmq.socket.pubsub
Class Mtrie
java.lang.Object
zmq.socket.pubsub.Mtrie
-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
private boolean
(package private) final boolean
private boolean
void
match
(ByteBuffer data, int size, Mtrie.IMtrieHandler func, XPub pub) private Mtrie[]
boolean
boolean
rm
(Pipe pipe, Mtrie.IMtrieHandler func, XPub pub) private boolean
private boolean
rmHelper
(Pipe pipe, byte[] buff, int buffsize, int maxBuffSize, Mtrie.IMtrieHandler func, XPub pub)
-
Field Details
-
pipes
-
min
private int min -
count
private int count -
liveNodes
private int liveNodes -
next
-
-
Constructor Details
-
Mtrie
public Mtrie()
-
-
Method Details
-
addOnTop
-
add
-
addHelper
-
realloc
-
rm
-
rmHelper
private boolean rmHelper(Pipe pipe, byte[] buff, int buffsize, int maxBuffSize, Mtrie.IMtrieHandler func, XPub pub) -
rm
-
rmHelper
-
match
-
isRedundant
private boolean isRedundant()
-