FileDocCategorySizeDatePackage
PingSpaceMonitor.javaAPI DocAzureus 3.0.3.46461Fri Jul 06 16:35:40 BST 2007com.aelitis.azureus.core.speedmanager.impl.v2

PingSpaceMonitor

public class PingSpaceMonitor extends Object
Created on Jun 29, 2007 Created by Alan Snyder Copyright (C) 2007 Aelitis, All Rights Reserved.

This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.

AELITIS, SAS au capital de 63.529,40 euros 8 Allee Lenotre, La Grille Royale, 78600 Le Mesnil le Roi, France.

Fields Summary
PingSpaceMapper
pingMap
long
startTime
private static final long
INTERVAL
int
maxGoodPing
int
minBadPing
int
nBadPings
int
nGoodPings
int
nNeutralPings
int
upNone
int
upLow
int
upMed
int
upHigh
int
upAtLimit
int
downNone
int
downLow
int
downMed
int
downHigh
int
downAtLimit
TransferMode
transferMode
public static final int
UPLOAD
public static final int
DOWNLOAD
public static final int
NONE
boolean
hasNewLimit
int
newLimit
int
limitType
Constructors Summary
public PingSpaceMonitor(int _maxGoodPing, int _minBadPing, TransferMode mode)



         
    
        maxGoodPing=_maxGoodPing;
        minBadPing=_minBadPing;

        reset(mode);
Methods Summary
public booleanaddToPingMapData(int lastMetricValue, TransferMode mode)
Do a check and decide if the limits should be dropped.

param
lastMetricValue -
param
mode - the TransferMode
return
- true if the limits should be dropped.


        //reset if we are changing modes.
        if( transferMode==null ){
            transferMode=mode;
        }

        //reset everything if we change modes.
        if( !transferMode.equals(mode) ){
            reset(mode);
            transferMode = mode;
            return false;
        }

        transferMode = mode;

        if(lastMetricValue<maxGoodPing){
            nGoodPings++;
        }else if(lastMetricValue>minBadPing){
            nBadPings++;
        }else{
            nNeutralPings++;
        }

        pingMap.addMetricToMap(lastMetricValue);

        //If the interval is up, we need to either recommend new limits or reset.
        long curr = SystemTime.getCurrentTime();

        if( curr > startTime+INTERVAL ){

            boolean needLowerLimts = checkForLowerLimits();
            if( needLowerLimts ){

                //prepare the package for lowering the limit.
                if( transferMode.isConfTestingLimits() ){
                    reset(mode);
                    return false;
                }else if( transferMode.isDownloadMode() ){

                    //recommend a new downloading limit.
                    newLimit = pingMap.guessDownloadLimit();

                    SpeedManagerLogger.trace("PingSpaceMonitor -> guessDownloadLimit: newLimit="+newLimit);

                    //on cable modems uploads can be over-estimated by 3x. 
                    int uploadLimitGuess = pingMap.guessUploadLimit();
                    SpeedManagerLogger.trace("PingSpaceMonitor -> guessUploadLimit: guessUploadLimit="+uploadLimitGuess);

                    //download limit cannot be less the 40k
                    if(newLimit<40960){
                        newLimit=40960;
                    }

                    hasNewLimit = true;
                    limitType = DOWNLOAD;
                    reset(mode);
                    return true;
                }else{

                    //only seeding mode is left recommend a new upload limit.
                    newLimit = pingMap.guessUploadLimit();

                    //upload limit cannot be less the 20k
                    if(newLimit<20480){
                        newLimit=20480;
                    }

                    hasNewLimit = true;
                    limitType = UPLOAD;
                    reset(mode);
                    return true;
                }
            }else{
                //No need for lower limits.
                reset(mode);
            }
        }//if

        return false;
private booleancheckForLowerLimits()

        int totalPings = nGoodPings+nBadPings+nNeutralPings;

        float percentBad = (float)nBadPings/(float)totalPings;

        if(percentBad>0.15f){
            return true;
        }else{
            return false;
        }
public intgetNewLimit()

        return newLimit;
booleanhasNewLimit()
True if we have a new limit.

return
- true if there is a new limit.

        return hasNewLimit;
public intlimitType()

        return limitType;
public voidreset(TransferMode mode)


        //log results.
        StringBuffer sb = new StringBuffer("ping-monitor:");
        sb.append("good=").append(nGoodPings).append(":");
        sb.append("bad=").append(nBadPings).append(":");
        sb.append("neutral=").append(nNeutralPings);

        SpeedManagerLogger.log( sb.toString() );

        //reset all the counters.
        nBadPings=nGoodPings=nNeutralPings=0;

        //saturated mode counters
        upNone=upLow=upMed=upHigh=upAtLimit=0;
        downNone=downLow=downMed=downHigh=downAtLimit=0;

        pingMap = new PingSpaceMapper(maxGoodPing,minBadPing);
        startTime = SystemTime.getCurrentTime();

        transferMode = mode;
public voidresetNewLimit()
Call after getting new limits.

        hasNewLimit = false;
        newLimit = -2;
        limitType = NONE;
public voidsetCurrentTransferRates(int downRate, int upRate)

param
downRate -
param
upRate -

        pingMap.setCurrentTransferRates(downRate,upRate);