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

Field Summary

Fields

Modifier and Type	Field	Description
private int	count
private int	liveNodes
private byte	min
(package private) Trie[]	next
private int	refcnt

Constructor Summary

Constructors

Constructor	Description
Trie()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

refcnt

private int refcnt

min

private byte min

count

private int count

liveNodes

private int liveNodes

next

Trie[] next

Constructor Detail

Trie

public Trie()

Method Detail

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(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()