com.fr.third.jgroups.util

类 Responses

java.lang.Object

com.fr.third.jgroups.util.Responses

所有已实现的接口:

java.lang.Iterable<PingData>

public class Responses
extends java.lang.Object
implements java.lang.Iterable<PingData>

Manages responses for the discovery protocol. Moved from Discovery into this standalone class. Responses are only added but never removed.

从以下版本开始:

3.5

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
protected static class	Responses.PingDataIterator

字段概要

字段

限定符和类型	字段和说明
protected boolean	break_on_coord_rsp
protected java.util.concurrent.locks.Condition	cond
protected boolean	done
protected int	index
protected java.util.concurrent.locks.Lock	lock
protected int	num_expected_rsps
protected PingData[]	ping_rsps

构造器概要

构造器

构造器和说明
Responses(boolean break_on_coord_rsp)
Responses(int num_expected_rsps, boolean break_on_coord_rsp)
Responses(int num_expected_rsps, boolean break_on_coord_rsp, int initial_capacity)

方法概要

方法

限定符和类型	方法和说明
protected Responses	_done()
protected void	add(PingData data)
void	addResponse(PingData rsp, boolean overwrite)
Responses	clear()
boolean	containsResponseFrom(Address mbr)
Responses	done()
protected int	find(PingData data)
PingData	findResponseFrom(Address mbr)
java.util.List<PingData>	get(long timeout) 已过时。
boolean	isDone()
boolean	isEmpty()
java.util.Iterator<PingData>	iterator()
protected static int	newLength(int length)
protected int[]	numResponses()
java.lang.String	print()
protected void	resize(int new_size)
int	size()
protected java.util.List<PingData>	toList()
java.lang.String	toString()
boolean	waitFor(long timeout)

从类继承的方法 java.lang.Object

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

字段详细资料

ping_rsps

protected PingData[] ping_rsps

index

protected int index

lock

protected final java.util.concurrent.locks.Lock lock

cond

protected final java.util.concurrent.locks.Condition cond

num_expected_rsps

protected final int num_expected_rsps

break_on_coord_rsp

protected final boolean break_on_coord_rsp

done

protected boolean done

构造器详细资料

Responses

public Responses(boolean break_on_coord_rsp)

Responses

public Responses(int num_expected_rsps,
         boolean break_on_coord_rsp)

Responses

public Responses(int num_expected_rsps,
         boolean break_on_coord_rsp,
         int initial_capacity)

方法详细资料

isDone

public boolean isDone()

done

public Responses done()

clear

public Responses clear()

addResponse

public void addResponse(PingData rsp,
               boolean overwrite)

containsResponseFrom

public boolean containsResponseFrom(Address mbr)

findResponseFrom

public PingData findResponseFrom(Address mbr)

get

@Deprecated
public java.util.List<PingData> get(long timeout)
                             throws java.lang.InterruptedException

已过时。

抛出:

java.lang.InterruptedException

waitFor

public boolean waitFor(long timeout)

iterator

public java.util.Iterator<PingData> iterator()

指定者:

iterator 在接口中 java.lang.Iterable<PingData>

size

public int size()

isEmpty

public boolean isEmpty()

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object

print

public java.lang.String print()

_done

protected Responses _done()

numResponses

protected int[] numResponses()

toList

protected java.util.List<PingData> toList()

resize

protected void resize(int new_size)

add

protected void add(PingData data)

find

protected int find(PingData data)

newLength

protected static int newLength(int length)