Package zmq.socket.pubsub
Class Mtrie
- java.lang.Object
-
- zmq.socket.pubsub.Mtrie
-
class Mtrie extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
Mtrie.IMtrieHandler
-
Constructor Summary
Constructors Constructor Description Mtrie()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
add(Msg msg, Pipe pipe)
private boolean
addHelper(Msg msg, int start, int size, Pipe pipe)
(package private) boolean
addOnTop(Pipe pipe)
private boolean
isRedundant()
void
match(java.nio.ByteBuffer data, int size, Mtrie.IMtrieHandler func, XPub pub)
private Mtrie[]
realloc(Mtrie[] table, int size, boolean ended)
boolean
rm(Msg msg, Pipe pipe)
boolean
rm(Pipe pipe, Mtrie.IMtrieHandler func, XPub pub)
private boolean
rmHelper(Msg msg, int start, int size, Pipe pipe)
private boolean
rmHelper(Pipe pipe, byte[] buff, int buffsize, int maxBuffSize, Mtrie.IMtrieHandler func, XPub pub)
-
-
-
Method Detail
-
addOnTop
final boolean addOnTop(Pipe pipe)
-
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)
-
match
public void match(java.nio.ByteBuffer data, int size, Mtrie.IMtrieHandler func, XPub pub)
-
isRedundant
private boolean isRedundant()
-
-