zmq

Class Dist

java.lang.Object

zmq.Dist

class Dist
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private int	active
private int	eligible
private int	matching
private boolean	more
private java.util.List<Pipe>	pipes

Constructor Summary

Constructors

Constructor and Description
Dist()

Method Summary

Modifier and Type	Method and Description
void	activated(Pipe pipe)
void	attach(Pipe pipe)
boolean	checkHwm()
private void	distribute(Msg msg)
boolean	hasOut()
void	match(Pipe pipe)
boolean	sendToAll(Msg msg)
boolean	sendToMatching(Msg msg)
void	terminated(Pipe pipe)
void	unmatch()
private boolean	write(Pipe pipe, Msg msg)

Methods inherited from class java.lang.Object

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

Field Detail

pipes

private final java.util.List<Pipe> pipes

matching

private int matching

active

private int active

eligible

private int eligible

more

private boolean more

Constructor Detail

Dist

public Dist()

Method Detail

attach

public void attach(Pipe pipe)

match

public void match(Pipe pipe)

unmatch

public void unmatch()

terminated

public void terminated(Pipe pipe)

activated

public void activated(Pipe pipe)

sendToAll

public boolean sendToAll(Msg msg)

sendToMatching

public boolean sendToMatching(Msg msg)

distribute

private void distribute(Msg msg)

hasOut

public boolean hasOut()

write

private boolean write(Pipe pipe,
                      Msg msg)

checkHwm

public boolean checkHwm()