com.allanbank.mongodb.client.state

Class ClusterPinger.Pinger

java.lang.Object

com.allanbank.mongodb.client.state.ClusterPinger.Pinger

Enclosing class:

ClusterPinger

protected static final class ClusterPinger.Pinger
extends Object

Pinger provides logic to ping servers.

Copyright ©:

2012-2013, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClusterPinger.Pinger()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	ping(Server server, Connection conn) Pings the server and suppresses all exceptions.
Future<Reply>	pingAsync(ClusterType type, Server server, Connection conn) Pings the server and suppresses all exceptions.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterPinger.Pinger

protected ClusterPinger.Pinger()

Method Detail

ping

public boolean ping(Server server,
           Connection conn)

Pings the server and suppresses all exceptions. Updates the server state with a latency and the tags found in the response, if any.

Parameters:

server - The server to update with the results of the ping. If false is returned then the state will not have been updated. Passing null for the state is allowed.

conn - The connection to ping.

Returns:

True if the ping worked, false otherwise.

pingAsync

public Future<Reply> pingAsync(ClusterType type,
                      Server server,
                      Connection conn)

Pings the server and suppresses all exceptions. Returns a future that can be used to determine if a response has been received. The future will update the Server latency and tags if found.

Parameters:

type - The type of cluster to ping.

server - The server to update with the results of the ping. If false is returned then the state will not have been updated. Passing null for the state is allowed.

conn - The connection to ping.

Returns:

A Future that will be updated once the reply is received.