Package org.red5.server.stream.bandwidth

Class ServerClientDetection

java.lang.Object

org.red5.server.stream.bandwidth.ServerClientDetection

All Implemented Interfaces:

IPendingServiceCallback, IBandwidthDetection

public class ServerClientDetection
extends Object
implements IPendingServiceCallback, IBandwidthDetection

Calculates the bandwidth between the client and server. The checks originate from the server.

Author:

The Red5 Project, Dan Rossi, Paul Gregoire

See Also:

• FMS 3.5 Bandwidth Doc

Field Summary

Fields

Modifier and Type	Field	Description
private IConnection	conn
private double	cumLatency
private double	deltaDown
private double	deltaTime
private double	kbitDown
private double	latency
private static final double	LATENCY_MAX
private static final double	LATENCY_MIN
private static org.slf4j.Logger	log
private AtomicInteger	packetsReceived
private AtomicInteger	packetsSent
private byte[]	payload
private byte[]	payload1
private long	startBytesWritten
private long	startTime
private long	timePassed

Constructor Summary

Constructors

Constructor	Description
ServerClientDetection()

Method Summary

Modifier and Type	Method	Description
void	calculateClientBw(IConnection conn)
private void	callBWCheck(Object payload)
private void	callBWDone()
void	checkBandwidth(IConnection conn)
void	onServerClientBWCheck()
void	resultReceived(IPendingServiceCall call)	Handle callback from service call.

Methods inherited from class java.lang.Object

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

Field Details

log

private static org.slf4j.Logger log

LATENCY_MAX

private static final double LATENCY_MAX

See Also:

• Constant Field Values

LATENCY_MIN

private static final double LATENCY_MIN

See Also:

• Constant Field Values

conn

private IConnection conn

latency

private volatile double latency

cumLatency

private volatile double cumLatency

kbitDown

private double kbitDown

deltaDown

private double deltaDown

deltaTime

private double deltaTime

startBytesWritten

private long startBytesWritten

startTime

private long startTime

timePassed

private long timePassed

packetsSent

private AtomicInteger packetsSent

packetsReceived

private AtomicInteger packetsReceived

payload

private byte[] payload

payload1

private byte[] payload1

Constructor Details

ServerClientDetection

public ServerClientDetection()

Method Details

checkBandwidth

public void checkBandwidth(IConnection conn)

Specified by:

checkBandwidth in interface IBandwidthDetection

calculateClientBw

public void calculateClientBw(IConnection conn)

Specified by:

calculateClientBw in interface IBandwidthDetection

resultReceived

public void resultReceived(IPendingServiceCall call)

Handle callback from service call.

Specified by:

resultReceived in interface IPendingServiceCallback

Parameters:

call - Call object this callback is applied to

callBWCheck

private void callBWCheck(Object payload)

callBWDone

private void callBWDone()

onServerClientBWCheck

public void onServerClientBWCheck()