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

Field Summary

Fields

Modifier and Type	Field	Description
private int	count
private int	liveNodes
private int	min
private Mtrie[]	next
private java.util.Set<Pipe>	pipes

Constructor Summary

Constructors

Constructor	Description
Mtrie()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pipes

private java.util.Set<Pipe> pipes

min

private int min

count

private int count

liveNodes

private int liveNodes

next

private Mtrie[] next

Constructor Detail

Mtrie

public Mtrie()

Method Detail

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(java.nio.ByteBuffer data,
                  int size,
                  Mtrie.IMtrieHandler func,
                  XPub pub)

isRedundant

private boolean isRedundant()