org.jumpmind.symmetric.service.impl

Class BandwidthService

java.lang.Object

org.jumpmind.symmetric.service.impl.BandwidthService

All Implemented Interfaces:

IBandwidthService

public class BandwidthService
extends java.lang.Object
implements IBandwidthService

See Also:

IBandwidthService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BandwidthService.BandwidthResults

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
BandwidthService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
java.util.List<BandwidthService.BandwidthResults>	diagnoseDownloadBandwidth(Node localNode, Node remoteNode)
java.util.List<BandwidthService.BandwidthResults>	diagnoseUploadBandwidth(Node localNode, Node remoteNode)
double	getDownloadKbpsFor(java.lang.String syncUrl, long sampleSize, long maxTestDuration)
protected BandwidthTestResults	getDownloadResultsFor(java.lang.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 Detail

Diagnostic_BandwidthFail

public static final java.lang.String Diagnostic_BandwidthFail

See Also:

Constant Field Values

Diagnostic_BandwidthFailure

public static final java.lang.String Diagnostic_BandwidthFailure

See Also:

Constant Field Values

log

protected final org.slf4j.Logger log

Constructor Detail

BandwidthService

public BandwidthService(ISymmetricEngine engine)

Method Detail

getDownloadKbpsFor

public double getDownloadKbpsFor(java.lang.String syncUrl,
                                 long sampleSize,
                                 long maxTestDuration)

Specified by:

getDownloadKbpsFor in interface IBandwidthService

getDownloadResultsFor

protected BandwidthTestResults getDownloadResultsFor(java.lang.String syncUrl,
                                                     long sampleSize,
                                                     long maxTestDuration)
                                              throws java.io.IOException

Throws:

java.io.IOException

getUploadKbpsFor

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

Specified by:

getUploadKbpsFor in interface IBandwidthService

Throws:

java.io.IOException

getUploadResultsFor

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

Throws:

java.io.IOException

diagnoseDownloadBandwidth

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

Specified by:

diagnoseDownloadBandwidth in interface IBandwidthService

isPullEnabled

protected boolean isPullEnabled(Node localNode,
                                Node remoteNode)

diagnoseUploadBandwidth

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

Specified by:

diagnoseUploadBandwidth in interface IBandwidthService

isPushEnabled

protected boolean isPushEnabled(Node localNode,
                                Node remoteNode)