Just thought id resend just in case people thought it was a question.
Dan Rossi wrote:
> Hi there ive taken the initiative because i cant seem to find any other
> solution out there to port the FMS code. Ive prob made alot of mistakes
> in terms of the HashMap and arrays. I had to also port the
> client.getStats method from FMS which returns information in methods
> returned from red5 but not easily accessible via variables, maybe there
> is a better way of accessing this until the stats API is avail ?
>
> Basically all it does is send a packet array and calculate the result
> time to work out the download rate or something like that ? Ive yet to
> manage to get the right calculation for the download rate as i was
> testing it locally, i dont think that one is right. If someone wants to
> clean it up go ahead :)
>
> //example
> public boolean appConnect(IConnection conn) {
>
> BandwidthDetection detect = new BandwidthDetection();
> detect.checkBandwidth(conn);
> }
>
> BandwidthDetection.java
>
> import org.red5.server.api.IConnection;
> import org.red5.server.api.Red5;
> import org.red5.server.api.service.IPendingServiceCall;
> import org.red5.server.api.service.IPendingServiceCallback;
> import org.red5.server.api.service.IServiceCapableConnection;
> import org.red5.server.api.stream.IStreamCapableConnection;
>
>
> import java.util.Date;
> import java.util.Map;
> import java.util.HashMap;
>
> public class BandwidthDetection implements IPendingServiceCallback {
>
> private long bytes_in = 0;
> private long msg_in;
> private long bytes_out;
> private long msg_out;
> private long msg_dropped;
> private long ping_rtt;
>
> private int latency = 0;
> private int cumLatency = 1;
> private int bwTime = 0;
> private int count = 0;
> private int sent = 0;
> private Object client;
> private long now;
> private long[] pakSent = new long[1200];
> private long[] pakRecv = new long[1200];
> private Map<String, Long> beginningValues;
> private double[] payload = new double[1200];
>
> public BandwidthDetection()
> {
> pakSent = new long[1200];
> pakRecv = new long[1200];
> payload = new double[1200];
> }
>
> public void checkBandwidth(Object client)
> {
> this.calculateClientBw(client);
> }
>
> private void calculateClientBw(Object client)
> {
>
> for (int i=0; i<1200; i++){
> payload[i] = Math.random(); //16K approx
> }
>
> this.getStats();
>
> this.client = client;
> long now = (new Date().getTime()/1);
>
> Map<String, Long> map = new HashMap<String, Long>();
> map.put("b_down", this.bytes_out);
> map.put("b_up", this.bytes_in);
> map.put("time", now);
> this.beginningValues = map;
>
> System.out.println(now);
>
> pakSent[this.sent++] = now;
>
> this.callBWCheck("");
>
> this.pakSent[this.sent++] = now;
>
> this.callBWCheck(this.payload);
>
> }
>
>
> private void callBWCheck(Object params)
> {
> IConnection conn = Red5.getConnectionLocal();
>
> if (conn instanceof IServiceCapableConnection) {
> ((IServiceCapableConnection) conn).invoke("onBWCheck", new
> Object[]{params}, this);
> //log.info("sending notification to "+conn);
> }
> }
>
> private void callBWDone(double kbitDown, long deltaDown, double
> deltaTime, int latency)
> {
> IConnection conn = Red5.getConnectionLocal();
>
> if (conn instanceof IServiceCapableConnection) {
> ((IServiceCapableConnection) conn).invoke("onBWDone", new
> Object[]{kbitDown, deltaDown, deltaTime, latency});
> //log.info("sending notification to "+conn);
> }
> }
>
> private void getStats()
> {
> IConnection conn = Red5.getConnectionLocal();
>
> if (conn instanceof IStreamCapableConnection) {
> IStreamCapableConnection streamConn =
> (IStreamCapableConnection) conn;
> bytes_in = streamConn.getReadBytes();
> msg_in = streamConn.getReadMessages();
> bytes_out = streamConn.getWrittenBytes();
> msg_out = streamConn.getWrittenMessages();
> msg_dropped = streamConn.getDroppedMessages();
> ping_rtt = streamConn.getLastPingTime();
> }
>
> }
>
>
> /**
> * Handle callback from service call.
> */
>
> public void resultReceived(IPendingServiceCall call) {
> long now = (new Date()).getTime()/1;
> this.pakRecv[this.count] = now;
> this.count++;
> int timePassed = (int)(now - this.beginningValues.get("time"));
>
> if (this.count == 1) {
>
> this.latency = Math.min(timePassed, 800);
>
> this.latency = Math.max(this.latency, 10);
>
> }
>
> //If we have a hi-speed network with low latency send more to
> determine
> // better bandwidth numbers, send no more than 6 packets
>
> if ( this.count == 2 && (timePassed<2000))
> {
>
> this.pakSent[this.sent++] = now;
> this.cumLatency++;
> this.callBWCheck(this.payload);
>
> //this.client.call("onBWCheck", res, this.client.payload);
> } else if (this.sent == this.count) {
> // See if we need to normalize latency
> if ( this.latency >= 100 )
> {
>
> // make sure we detect sattelite and modem correctly
> if (this.pakRecv[1] - this.pakRecv[0] > 1000)
> {
> this.latency = 100;
> }
>
> }
>
>
> this.payload = new double[0];
> //delete this.client.payload;
>
> // Got back responses for all the packets compute the bandwidth.
> this.getStats();
>
> long deltaDown = this.bytes_out -
> this.beginningValues.get("b_down")*8/1000;
> double deltaTime = ( (now -
> this.beginningValues.get("time")) - (this.latency*this.cumLatency))/1000;
>
> if (deltaTime <= 0) deltaTime = (now -
> this.beginningValues.get("time"))/1000;
> //System.out.println(deltaDown + " " + this.bytes_out + " "
> + this.beginningValues.get("b_down") + " " + deltaTime + " " + (now -
> this.beginningValues.get("time")) + " " + (this.latency*this.cumLatency));
>
> double kbitDown = deltaDown/deltaTime;
>
> System.out.println("onBWDone: kbitDown = " + kbitDown + ",
> deltaDown= " + deltaDown + ", deltaTime = " + deltaTime + ", latency = "
> + this.latency + "KBytes " + (this.bytes_out -
> this.beginningValues.get("b_down"))/1024);
>
> this.callBWDone(kbitDown, deltaDown, deltaTime, this.latency);
> }
>
> }
>
>
>
> }
>
> _______________________________________________
> Red5 mailing list
> [email protected]
> http://osflash.org/mailman/listinfo/red5_osflash.org
>
>
_______________________________________________
Red5 mailing list
[email protected]
http://osflash.org/mailman/listinfo/red5_osflash.org
