Package de.uni_kl.cs.discodnc.curves.mpa_rtc_pwaffine

Class Curve_MPARTC_PwAffine

java.lang.Object

de.uni_kl.cs.discodnc.curves.mpa_rtc_pwaffine.Curve_MPARTC_PwAffine

All Implemented Interfaces:

Curve, CurvePwAffine

Direct Known Subclasses:

ArrivalCurve_MPARTC_PwAffine, MaxServiceCurve_MPARTC_PwAffine, ServiceCurve_MPARTC_PwAffine

public class Curve_MPARTC_PwAffine
extends java.lang.Object
implements CurvePwAffine

Nested Class Summary

Nested classes/interfaces inherited from interface de.uni_kl.cs.discodnc.curves.CurvePwAffine

CurvePwAffine.CurveOperation

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	has_rate_latency_meta_info
protected boolean	has_token_bucket_meta_info
private static Curve_MPARTC_PwAffine	instance
protected boolean	is_delayed_infinite_burst
protected boolean	is_rate_latency
protected boolean	is_token_bucket
protected java.util.List<Curve_MPARTC_PwAffine>	rate_latencies
protected ch.ethz.rtc.kernel.Curve	rtc_curve
protected java.util.List<Curve_MPARTC_PwAffine>	token_buckets

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Curve_MPARTC_PwAffine()	Creates a Curve instance with a single segment on the x-axis.
protected	Curve_MPARTC_PwAffine(int segment_count)	Creates a Curve instance with segment_count empty LinearSegment instances.
protected	Curve_MPARTC_PwAffine(CurvePwAffine curve)

Method Summary

Modifier and Type	Method	Description
void	addSegment(int pos, LinearSegment s)	Starting at 0 as the RTC SegmentList extends ArrayList.
void	addSegment(LinearSegment s)
void	beautify()
private void	clearMetaInfo()
Curve_MPARTC_PwAffine	copy()	Returns a copy of this instance.
void	copy(Curve curve)
ArrivalCurve_MPARTC_PwAffine	createArrivalCurve()
ArrivalCurve_MPARTC_PwAffine	createArrivalCurve(int segment_count)
ArrivalCurve_MPARTC_PwAffine	createArrivalCurve(CurvePwAffine curve)
ArrivalCurve_MPARTC_PwAffine	createArrivalCurve(CurvePwAffine curve, boolean remove_latency)
ArrivalCurve_MPARTC_PwAffine	createArrivalCurve(java.lang.String arrival_curve_str)
Curve_MPARTC_PwAffine	createCurve(java.util.List<LinearSegment> segments)
ServiceCurve_MPARTC_PwAffine	createDelayedInfiniteBurst(double delay)
ServiceCurve_MPARTC_PwAffine	createDelayedInfiniteBurst(Num delay)
MaxServiceCurve_MPARTC_PwAffine	createDelayedInfiniteBurstMSC(double delay)
MaxServiceCurve_MPARTC_PwAffine	createDelayedInfiniteBurstMSC(Num delay)
Curve_MPARTC_PwAffine	createHorizontal(double y)
Curve_MPARTC_PwAffine	createHorizontal(Num y)	Creates a horizontal curve.
MaxServiceCurve_MPARTC_PwAffine	createInfiniteMaxService()
MaxServiceCurve_MPARTC_PwAffine	createMaxServiceCurve()
MaxServiceCurve_MPARTC_PwAffine	createMaxServiceCurve(int segment_count)
MaxServiceCurve_MPARTC_PwAffine	createMaxServiceCurve(CurvePwAffine curve)
MaxServiceCurve_MPARTC_PwAffine	createMaxServiceCurve(java.lang.String max_service_curve_str)
ArrivalCurve_MPARTC_PwAffine	createPeakArrivalRate(double rate)
ArrivalCurve_MPARTC_PwAffine	createPeakArrivalRate(Num rate)
ServiceCurve_MPARTC_PwAffine	createRateLatency(double rate, double latency)
ServiceCurve_MPARTC_PwAffine	createRateLatency(Num rate, Num latency)
MaxServiceCurve_MPARTC_PwAffine	createRateLatencyMSC(double rate, double latency)
MaxServiceCurve_MPARTC_PwAffine	createRateLatencyMSC(Num rate, Num latency)
ServiceCurve_MPARTC_PwAffine	createServiceCurve()
ServiceCurve_MPARTC_PwAffine	createServiceCurve(int segment_count)
ServiceCurve_MPARTC_PwAffine	createServiceCurve(CurvePwAffine curve)
ServiceCurve_MPARTC_PwAffine	createServiceCurve(java.lang.String service_curve_str)
ArrivalCurve_MPARTC_PwAffine	createTokenBucket(double rate, double burst)
ArrivalCurve_MPARTC_PwAffine	createTokenBucket(Num rate, Num burst)
ArrivalCurve_MPARTC_PwAffine	createZeroArrivals()
Curve_MPARTC_PwAffine	createZeroCurve()
ServiceCurve_MPARTC_PwAffine	createZeroDelayInfiniteBurst()	Creates an infinite burst curve with zero delay.
MaxServiceCurve_MPARTC_PwAffine	createZeroDelayInfiniteBurstMSC()
private void	createZeroSegmentsCurve(int segment_count)
ServiceCurve_MPARTC_PwAffine	createZeroService()
private void	decomposeIntoRateLatencies()
private void	decomposeIntoTokenBuckets()
boolean	equals(java.lang.Object obj)
Num	f(Num x)
Num	f_inv(Num y)
Num	f_inv(Num y, boolean rightmost)
Num	fLimitRight(Num x)
Num	getBurst()
static Curve_MPARTC_PwAffine	getFactory()
Num	getGradientLimitRight(Num x)
Num	getLatency()
Curve_MPARTC_PwAffine	getRL_Component(int i)	Returns the rate latency the defined the overall curve's segment i.
int	getRL_ComponentCount()
java.util.List<CurvePwAffine>	getRL_Components()
ch.ethz.rtc.kernel.Curve	getRtc_curve()
LinearSegment_MPARTC_PwAffine	getSegment(int pos)	Starting at 0 as the RTC SegmentList extends ArrayList.
int	getSegmentCount()	Returns the number of segments in this curve.
int	getSegmentDefining(Num x)	Attention: We assume that RTC curves are left-continuous as we cannot make this explicit.
int	getSegmentLimitRight(Num x)
private ch.ethz.rtc.kernel.Segment	getSegmentRTC(int pos)
Num	getTB_Burst()
Curve_MPARTC_PwAffine	getTB_Component(int i)
int	getTB_ComponentCount()
java.util.List<CurvePwAffine>	getTB_Components()
Num	getUltAffineRate()
int	hashCode()
protected void	initializeCurve(java.lang.String curve_str)
protected void	initializeWithSegment(ch.ethz.rtc.kernel.Segment rtc_segment)
protected void	initializeWithSegments(ch.ethz.rtc.kernel.SegmentList rtc_segmentList)
boolean	isAlmostConcave()
boolean	isConcave()
boolean	isConcaveIn(Num a, Num b)	Tests whether the curve is concave in [a,b].
boolean	isConvex()
boolean	isConvexIn(Num a, Num b)
boolean	isDelayedInfiniteBurst()
boolean	isDiscontinuity(int pos)
boolean	isRateLatency()
boolean	isRealDiscontinuity(int pos)
boolean	isTokenBucket()
boolean	isUnrealDiscontinuity(int pos)
boolean	isWideSenseIncreasing()
private void	makeDelayedInfiniteBurst(Curve_MPARTC_PwAffine c_rtc, double delay)
private void	makeHorizontal(Curve_MPARTC_PwAffine c_rtc, double y)
private void	makePeakRate(Curve_MPARTC_PwAffine c_rtc, double rate)
private void	makeRateLatency(Curve_MPARTC_PwAffine c_rtc, double rate, double latency)
private void	makeTokenBucket(Curve_MPARTC_PwAffine c_rtc, double rate, double burst)
void	removeSegment(int pos)
void	setRateLateny(boolean is_rate_latency)
void	setRL_Components(java.util.List<CurvePwAffine> rate_latencies)
void	setRL_MetaInfo(boolean has_rate_latency_meta_info)
void	setTB_Components(java.util.List<CurvePwAffine> token_buckets)
void	setTB_MetaInfo(boolean has_token_bucket_meta_info)
void	setTokenBucket(boolean is_token_bucket)
java.lang.String	toString()

Methods inherited from interface de.uni_kl.cs.discodnc.curves.Curve

getXAxis

Methods inherited from interface de.uni_kl.cs.discodnc.curves.CurvePwAffine

add, add, add, add, add, add, add, beautify, boundAtXAxis, computeInflectionPointsX, computeInflectionPointsY, computeResultingCurve, getMaxHorizontalDeviation, getMaxVerticalDeviation, getXIntersection, max, max, max, min, min, min, min, removeLatency, shiftLeftClipping, shiftRight, sub, sub

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

instance

private static Curve_MPARTC_PwAffine instance

rtc_curve

protected ch.ethz.rtc.kernel.Curve rtc_curve

is_delayed_infinite_burst

protected boolean is_delayed_infinite_burst

is_rate_latency

protected boolean is_rate_latency

is_token_bucket

protected boolean is_token_bucket

has_rate_latency_meta_info

protected boolean has_rate_latency_meta_info

rate_latencies

protected java.util.List<Curve_MPARTC_PwAffine> rate_latencies

has_token_bucket_meta_info

protected boolean has_token_bucket_meta_info

token_buckets

protected java.util.List<Curve_MPARTC_PwAffine> token_buckets

Constructor Detail

Curve_MPARTC_PwAffine

protected Curve_MPARTC_PwAffine()

Creates a Curve instance with a single segment on the x-axis.

Curve_MPARTC_PwAffine

protected Curve_MPARTC_PwAffine(CurvePwAffine curve)

Curve_MPARTC_PwAffine

protected Curve_MPARTC_PwAffine(int segment_count)

Creates a Curve instance with segment_count empty LinearSegment instances.

Parameters:

segment_count - the number of segments

Method Detail

getFactory

public static Curve_MPARTC_PwAffine getFactory()

createZeroSegmentsCurve

private void createZeroSegmentsCurve(int segment_count)

getRtc_curve

public ch.ethz.rtc.kernel.Curve getRtc_curve()

initializeCurve

protected void initializeCurve(java.lang.String curve_str)
                        throws java.lang.Exception

Throws:

java.lang.Exception

clearMetaInfo

private void clearMetaInfo()

copy

public Curve_MPARTC_PwAffine copy()

Returns a copy of this instance.

Specified by:

copy in interface Curve

Specified by:

copy in interface CurvePwAffine

Returns:

a copy of this instance.

copy

public void copy(Curve curve)

Specified by:

copy in interface Curve

Specified by:

copy in interface CurvePwAffine

getSegment

public LinearSegment_MPARTC_PwAffine getSegment(int pos)

Starting at 0 as the RTC SegmentList extends ArrayList.

Specified by:

getSegment in interface Curve

getSegmentRTC

private ch.ethz.rtc.kernel.Segment getSegmentRTC(int pos)

getSegmentCount

public int getSegmentCount()

Returns the number of segments in this curve.

Specified by:

getSegmentCount in interface Curve

Returns:

the number of segments

getSegmentDefining

public int getSegmentDefining(Num x)

Attention: We assume that RTC curves are left-continuous as we cannot make this explicit. Therefore, we return the first segment that defines the given x. This behavior coincides with getSegmentLimitRight(x).

Specified by:

getSegmentDefining in interface Curve

getSegmentLimitRight

public int getSegmentLimitRight(Num x)

initializeWithSegment

protected void initializeWithSegment(ch.ethz.rtc.kernel.Segment rtc_segment)

initializeWithSegments

protected void initializeWithSegments(ch.ethz.rtc.kernel.SegmentList rtc_segmentList)

addSegment

public void addSegment(LinearSegment s)

Specified by:

addSegment in interface Curve

addSegment

public void addSegment(int pos,
                       LinearSegment s)

Starting at 0 as the RTC SegmentList extends ArrayList.

Specified by:

addSegment in interface Curve

removeSegment

public void removeSegment(int pos)

Specified by:

removeSegment in interface Curve

isDiscontinuity

public boolean isDiscontinuity(int pos)

Specified by:

isDiscontinuity in interface Curve

isRealDiscontinuity

public boolean isRealDiscontinuity(int pos)

Specified by:

isRealDiscontinuity in interface Curve

isUnrealDiscontinuity

public boolean isUnrealDiscontinuity(int pos)

Specified by:

isUnrealDiscontinuity in interface Curve

isWideSenseIncreasing

public boolean isWideSenseIncreasing()

Specified by:

isWideSenseIncreasing in interface Curve

isConvex

public boolean isConvex()

Specified by:

isConvex in interface CurvePwAffine

isConvexIn

public boolean isConvexIn(Num a,
                          Num b)

Specified by:

isConvexIn in interface Curve

isConcave

public boolean isConcave()

Specified by:

isConcave in interface CurvePwAffine

isConcaveIn

public boolean isConcaveIn(Num a,
                           Num b)

Tests whether the curve is concave in [a,b].

Specified by:

isConcaveIn in interface Curve

Parameters:

a - the lower bound of the test interval.

b - the upper bound of the test interval.

Returns:

whether the curve is concave.

isAlmostConcave

public boolean isAlmostConcave()

Specified by:

isAlmostConcave in interface CurvePwAffine

equals

public boolean equals(java.lang.Object obj)

Specified by:

equals in interface Curve

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Specified by:

hashCode in interface Curve

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Specified by:

toString in interface Curve

Overrides:

toString in class java.lang.Object

f

public Num f(Num x)

Specified by:

f in interface Curve

fLimitRight

public Num fLimitRight(Num x)

Specified by:

fLimitRight in interface Curve

f_inv

public Num f_inv(Num y)

Specified by:

f_inv in interface Curve

f_inv

public Num f_inv(Num y,
                 boolean rightmost)

Specified by:

f_inv in interface Curve

getLatency

public Num getLatency()

Specified by:

getLatency in interface Curve

getBurst

public Num getBurst()

Specified by:

getBurst in interface Curve

getGradientLimitRight

public Num getGradientLimitRight(Num x)

Specified by:

getGradientLimitRight in interface Curve

getTB_Burst

public Num getTB_Burst()

setTB_MetaInfo

public void setTB_MetaInfo(boolean has_token_bucket_meta_info)

Specified by:

setTB_MetaInfo in interface CurvePwAffine

getRL_Components

public java.util.List<CurvePwAffine> getRL_Components()

Specified by:

getRL_Components in interface CurvePwAffine

setRL_Components

public void setRL_Components(java.util.List<CurvePwAffine> rate_latencies)

Specified by:

setRL_Components in interface CurvePwAffine

getTB_Components

public java.util.List<CurvePwAffine> getTB_Components()

Specified by:

getTB_Components in interface CurvePwAffine

setTB_Components

public void setTB_Components(java.util.List<CurvePwAffine> token_buckets)

Specified by:

setTB_Components in interface CurvePwAffine

setRL_MetaInfo

public void setRL_MetaInfo(boolean has_rate_latency_meta_info)

Specified by:

setRL_MetaInfo in interface CurvePwAffine

getUltAffineRate

public Num getUltAffineRate()

Specified by:

getUltAffineRate in interface CurvePwAffine

beautify

public void beautify()

isDelayedInfiniteBurst

public boolean isDelayedInfiniteBurst()

Specified by:

isDelayedInfiniteBurst in interface Curve

isRateLatency

public boolean isRateLatency()

Specified by:

isRateLatency in interface CurvePwAffine

setRateLateny

public void setRateLateny(boolean is_rate_latency)

Specified by:

setRateLateny in interface CurvePwAffine

getRL_ComponentCount

public int getRL_ComponentCount()

Specified by:

getRL_ComponentCount in interface CurvePwAffine

getRL_Component

public Curve_MPARTC_PwAffine getRL_Component(int i)

Returns the rate latency the defined the overall curve's segment i.

Specified by:

getRL_Component in interface CurvePwAffine

decomposeIntoRateLatencies

private void decomposeIntoRateLatencies()

isTokenBucket

public boolean isTokenBucket()

Specified by:

isTokenBucket in interface CurvePwAffine

setTokenBucket

public void setTokenBucket(boolean is_token_bucket)

Specified by:

setTokenBucket in interface CurvePwAffine

getTB_ComponentCount

public int getTB_ComponentCount()

Specified by:

getTB_ComponentCount in interface CurvePwAffine

getTB_Component

public Curve_MPARTC_PwAffine getTB_Component(int i)

Specified by:

getTB_Component in interface CurvePwAffine

decomposeIntoTokenBuckets

private void decomposeIntoTokenBuckets()

createCurve

public Curve_MPARTC_PwAffine createCurve(java.util.List<LinearSegment> segments)

Specified by:

createCurve in interface CurvePwAffine

createZeroCurve

public Curve_MPARTC_PwAffine createZeroCurve()

Specified by:

createZeroCurve in interface CurvePwAffine

createHorizontal

public Curve_MPARTC_PwAffine createHorizontal(double y)

Specified by:

createHorizontal in interface CurvePwAffine

createHorizontal

public Curve_MPARTC_PwAffine createHorizontal(Num y)

Creates a horizontal curve.

Specified by:

createHorizontal in interface CurvePwAffine

Parameters:

y - the y-intercept of the curve

Returns:

a Curve instance

createServiceCurve

public ServiceCurve_MPARTC_PwAffine createServiceCurve()

Specified by:

createServiceCurve in interface CurvePwAffine

createServiceCurve

public ServiceCurve_MPARTC_PwAffine createServiceCurve(int segment_count)

Specified by:

createServiceCurve in interface CurvePwAffine

createServiceCurve

public ServiceCurve_MPARTC_PwAffine createServiceCurve(java.lang.String service_curve_str)
                                                throws java.lang.Exception

Specified by:

createServiceCurve in interface CurvePwAffine

Throws:

java.lang.Exception

createServiceCurve

public ServiceCurve_MPARTC_PwAffine createServiceCurve(CurvePwAffine curve)

Specified by:

createServiceCurve in interface CurvePwAffine

createZeroService

public ServiceCurve_MPARTC_PwAffine createZeroService()

Specified by:

createZeroService in interface CurvePwAffine

createZeroDelayInfiniteBurst

public ServiceCurve_MPARTC_PwAffine createZeroDelayInfiniteBurst()

Creates an infinite burst curve with zero delay.

Specified by:

createZeroDelayInfiniteBurst in interface CurvePwAffine

Returns:

a ServiceCurve instance

createDelayedInfiniteBurst

public ServiceCurve_MPARTC_PwAffine createDelayedInfiniteBurst(double delay)

Specified by:

createDelayedInfiniteBurst in interface CurvePwAffine

createDelayedInfiniteBurst

public ServiceCurve_MPARTC_PwAffine createDelayedInfiniteBurst(Num delay)

Specified by:

createDelayedInfiniteBurst in interface CurvePwAffine

createRateLatency

public ServiceCurve_MPARTC_PwAffine createRateLatency(double rate,
                                                      double latency)

Specified by:

createRateLatency in interface CurvePwAffine

createRateLatency

public ServiceCurve_MPARTC_PwAffine createRateLatency(Num rate,
                                                      Num latency)

Specified by:

createRateLatency in interface CurvePwAffine

createArrivalCurve

public ArrivalCurve_MPARTC_PwAffine createArrivalCurve()

Specified by:

createArrivalCurve in interface CurvePwAffine

createArrivalCurve

public ArrivalCurve_MPARTC_PwAffine createArrivalCurve(int segment_count)

Specified by:

createArrivalCurve in interface CurvePwAffine

createArrivalCurve

public ArrivalCurve_MPARTC_PwAffine createArrivalCurve(java.lang.String arrival_curve_str)
                                                throws java.lang.Exception

Specified by:

createArrivalCurve in interface CurvePwAffine

Throws:

java.lang.Exception

createArrivalCurve

public ArrivalCurve_MPARTC_PwAffine createArrivalCurve(CurvePwAffine curve)

Specified by:

createArrivalCurve in interface CurvePwAffine

createArrivalCurve

public ArrivalCurve_MPARTC_PwAffine createArrivalCurve(CurvePwAffine curve,
                                                       boolean remove_latency)

Specified by:

createArrivalCurve in interface CurvePwAffine

createZeroArrivals

public ArrivalCurve_MPARTC_PwAffine createZeroArrivals()

Specified by:

createZeroArrivals in interface CurvePwAffine

createPeakArrivalRate

public ArrivalCurve_MPARTC_PwAffine createPeakArrivalRate(double rate)

Specified by:

createPeakArrivalRate in interface CurvePwAffine

createPeakArrivalRate

public ArrivalCurve_MPARTC_PwAffine createPeakArrivalRate(Num rate)

Specified by:

createPeakArrivalRate in interface CurvePwAffine

createTokenBucket

public ArrivalCurve_MPARTC_PwAffine createTokenBucket(double rate,
                                                      double burst)

Specified by:

createTokenBucket in interface CurvePwAffine

createTokenBucket

public ArrivalCurve_MPARTC_PwAffine createTokenBucket(Num rate,
                                                      Num burst)

Specified by:

createTokenBucket in interface CurvePwAffine

createMaxServiceCurve

public MaxServiceCurve_MPARTC_PwAffine createMaxServiceCurve()

Specified by:

createMaxServiceCurve in interface CurvePwAffine

createMaxServiceCurve

public MaxServiceCurve_MPARTC_PwAffine createMaxServiceCurve(int segment_count)

Specified by:

createMaxServiceCurve in interface CurvePwAffine

createMaxServiceCurve

public MaxServiceCurve_MPARTC_PwAffine createMaxServiceCurve(java.lang.String max_service_curve_str)
                                                      throws java.lang.Exception

Specified by:

createMaxServiceCurve in interface CurvePwAffine

Throws:

java.lang.Exception

createMaxServiceCurve

public MaxServiceCurve_MPARTC_PwAffine createMaxServiceCurve(CurvePwAffine curve)

Specified by:

createMaxServiceCurve in interface CurvePwAffine

createInfiniteMaxService

public MaxServiceCurve_MPARTC_PwAffine createInfiniteMaxService()

Specified by:

createInfiniteMaxService in interface CurvePwAffine

createZeroDelayInfiniteBurstMSC

public MaxServiceCurve_MPARTC_PwAffine createZeroDelayInfiniteBurstMSC()

Specified by:

createZeroDelayInfiniteBurstMSC in interface CurvePwAffine

createDelayedInfiniteBurstMSC

public MaxServiceCurve_MPARTC_PwAffine createDelayedInfiniteBurstMSC(double delay)

Specified by:

createDelayedInfiniteBurstMSC in interface CurvePwAffine

createDelayedInfiniteBurstMSC

public MaxServiceCurve_MPARTC_PwAffine createDelayedInfiniteBurstMSC(Num delay)

Specified by:

createDelayedInfiniteBurstMSC in interface CurvePwAffine

createRateLatencyMSC

public MaxServiceCurve_MPARTC_PwAffine createRateLatencyMSC(double rate,
                                                            double latency)

Specified by:

createRateLatencyMSC in interface CurvePwAffine

createRateLatencyMSC

public MaxServiceCurve_MPARTC_PwAffine createRateLatencyMSC(Num rate,
                                                            Num latency)

Specified by:

createRateLatencyMSC in interface CurvePwAffine

makeHorizontal

private void makeHorizontal(Curve_MPARTC_PwAffine c_rtc,
                            double y)

makeDelayedInfiniteBurst

private void makeDelayedInfiniteBurst(Curve_MPARTC_PwAffine c_rtc,
                                      double delay)

makePeakRate

private void makePeakRate(Curve_MPARTC_PwAffine c_rtc,
                          double rate)

makeRateLatency

private void makeRateLatency(Curve_MPARTC_PwAffine c_rtc,
                             double rate,
                             double latency)

makeTokenBucket

private void makeTokenBucket(Curve_MPARTC_PwAffine c_rtc,
                             double rate,
                             double burst)