public void receivedNodeHello(FcpConnection fcpConnection, NodeHello nodeHello) {
completionLatch.countDown();
}
public void receivedNodeHello(FcpConnection fcpConnection, NodeHello nodeHello) {
completionLatch.countDown();
}
*/
public Set<Peer> getPeers(final boolean withMetadata, final boolean withVolatile) throws IOException, FcpException {
final Set<Peer> peers = new HashSet<Peer>();
*/
public Set<Peer> getPeers(final boolean withMetadata, final boolean withVolatile) throws IOException, FcpException {
final Set<Peer> peers = new HashSet<Peer>();
public void receivedEndListPeers(FcpConnection fcpConnection, EndListPeers endListPeers) {
completionLatch.countDown();
}
public void receivedEndListPeers(FcpConnection fcpConnection, EndListPeers endListPeers) {
completionLatch.countDown();
}
public void receivedPeer(FcpConnection fcpConnection, Peer peer) {
completionLatch.countDown();
}
public void receivedPeer(FcpConnection fcpConnection, Peer peer) {
completionLatch.countDown();
}
* if an FCP error occurs
*/
public void modifyPeer(final Peer peer, final Boolean allowLocalAddresses, final Boolean disabled, final Boolean listenOnly) throws IOException, FcpException {
* if an FCP error occurs
*/
public void modifyPeer(final Peer peer, final Boolean allowLocalAddresses, final Boolean disabled, final Boolean listenOnly) throws IOException, FcpException {
public void receivedPeer(FcpConnection fcpConnection, Peer peer) {
completionLatch.countDown();
}
public void receivedPeer(FcpConnection fcpConnection, Peer peer) {
completionLatch.countDown();
}
public void receivedPeerRemoved(FcpConnection fcpConnection, PeerRemoved peerRemoved) {
completionLatch.countDown();
}
public void receivedPeerRemoved(FcpConnection fcpConnection, PeerRemoved peerRemoved) {
completionLatch.countDown();
}