Constructor and Description |
---|
Discovery.Responses(int num_expected_rsps,
int num_expected_srv_rsps,
boolean break_on_coord_rsp,
Promise<JoinRsp> promise) |
Modifier and Type | Method and Description |
---|---|
void |
addResponse(PingData rsp) |
void |
addResponse(PingData rsp,
boolean overwrite) |
protected static boolean |
containsCoordinatorResponse(Collection<PingData> rsps) |
List<PingData> |
get(long timeout) |
protected static int |
getNumServerResponses(Collection<PingData> rsps) |
public void addResponse(PingData rsp)
public void addResponse(PingData rsp, boolean overwrite)
public List<PingData> get(long timeout) throws InterruptedException
InterruptedException
protected static int getNumServerResponses(Collection<PingData> rsps)
protected static boolean containsCoordinatorResponse(Collection<PingData> rsps)
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.