Package org.jumpmind.symmetric.service.impl

Class BandwidthService

java.lang.Object

org.jumpmind.symmetric.service.impl.BandwidthService

All Implemented Interfaces:

IBandwidthService

public class BandwidthService
extends Object
implements IBandwidthService

See Also:

• IBandwidthService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BandwidthService.BandwidthResults

Field Summary

Fields

Modifier and Type	Field	Description
static final String	Diagnostic_BandwidthFail
static final String	Diagnostic_BandwidthFailure
protected final org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
BandwidthService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
List<BandwidthService.BandwidthResults>	diagnoseDownloadBandwidth(Node localNode, Node remoteNode)
List<BandwidthService.BandwidthResults>	diagnoseUploadBandwidth(Node localNode, Node remoteNode)
double	getDownloadKbpsFor(String syncUrl, long sampleSize, long maxTestDuration)
protected BandwidthTestResults	getDownloadResultsFor(String syncUrl, long sampleSize, long maxTestDuration)
double	getUploadKbpsFor(Node remoteNode, Node localNode, long sampleSize, long maxTestDuration)
protected BandwidthTestResults	getUploadResultsFor(Node remoteNode, Node localNode, long sampleSize, long maxTestDuration)
protected boolean	isPullEnabled(Node localNode, Node remoteNode)
protected boolean	isPushEnabled(Node localNode, Node remoteNode)

Methods inherited from class java.lang.Object

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

Field Details

Diagnostic_BandwidthFail

public static final String Diagnostic_BandwidthFail

See Also:

• Constant Field Values

Diagnostic_BandwidthFailure

public static final String Diagnostic_BandwidthFailure

See Also:

• Constant Field Values

log

protected final org.slf4j.Logger log

Constructor Details

BandwidthService

public BandwidthService(ISymmetricEngine engine)

Method Details

getDownloadKbpsFor

public double getDownloadKbpsFor(String syncUrl,
 long sampleSize,
 long maxTestDuration)

Specified by:

getDownloadKbpsFor in interface IBandwidthService

getDownloadResultsFor

protected BandwidthTestResults getDownloadResultsFor(String syncUrl,
 long sampleSize,
 long maxTestDuration)
                                              throws IOException

Throws:

IOException

getUploadKbpsFor

public double getUploadKbpsFor(Node remoteNode,
 Node localNode,
 long sampleSize,
 long maxTestDuration)
                        throws IOException

Specified by:

getUploadKbpsFor in interface IBandwidthService

Throws:

IOException

getUploadResultsFor

protected BandwidthTestResults getUploadResultsFor(Node remoteNode,
 Node localNode,
 long sampleSize,
 long maxTestDuration)
                                            throws IOException

Throws:

IOException

diagnoseDownloadBandwidth

public List<BandwidthService.BandwidthResults> diagnoseDownloadBandwidth(Node localNode,
 Node remoteNode)

Specified by:

diagnoseDownloadBandwidth in interface IBandwidthService

isPullEnabled

protected boolean isPullEnabled(Node localNode,
 Node remoteNode)

diagnoseUploadBandwidth

public List<BandwidthService.BandwidthResults> diagnoseUploadBandwidth(Node localNode,
 Node remoteNode)

Specified by:

diagnoseUploadBandwidth in interface IBandwidthService

isPushEnabled

protected boolean isPushEnabled(Node localNode,
 Node remoteNode)