de.uka.ipd.sdq.simucomframework.resources

Class SimSimpleFairPassiveResource

java.lang.Object

de.uka.ipd.sdq.simulation.abstractsimengine.SimulationElement

de.uka.ipd.sdq.simulation.abstractsimengine.AbstractSimEntityDelegator

de.uka.ipd.sdq.scheduler.entities.SchedulerEntity

de.uka.ipd.sdq.scheduler.resources.AbstractSimResource

de.uka.ipd.sdq.simucomframework.resources.SimSimpleFairPassiveResource

Type Parameters:

M - the type of the simulation model.

All Implemented Interfaces:

IPassiveResource, IEntity

public class SimSimpleFairPassiveResource
extends AbstractSimResource
implements IPassiveResource

Simulates a simple passive resource. Note: This class intentionally does not extend SimAbstractPassiveResource, because that abstract class is intended for passive resources that are accessed by EXACT schedulers (e.g., specific Windows, Linux Scheduler). TODO: comment TODO Initialize based on given model elements [Lehrig]

Author:

Fabro, Sebastian Lehrig

Field Summary

Fields inherited from interface de.uka.ipd.sdq.simulation.abstractsimengine.IEntity

NULL

Constructor Summary

Constructors

Constructor and Description
SimSimpleFairPassiveResource(org.palladiosimulator.pcm.repository.PassiveResource resource, org.palladiosimulator.pcm.core.composition.AssemblyContext assemblyContext, SchedulerModel model, Long capacity)

Method Summary

Modifier and Type	Method and Description
boolean	acquire(ISchedulableProcess schedulableProcess, long num, boolean timeout, double timeoutValue) Acquires num instances of the passive resource for the given process.
void	addObserver(IPassiveResourceSensor observer) Adds the given observer.
org.palladiosimulator.pcm.core.composition.AssemblyContext	getAssemblyContext() Getter for the model element of the assembly context.
long	getAvailable() Returns the number of remaining instances.
org.palladiosimulator.pcm.repository.PassiveResource	getResource() Getter for the model element of the passive resource.
Queue<IWaitingProcess>	getWaitingProcesses() Returns a queue containing the waiting processes for the passive resource.
boolean	isWaiting(SimpleWaitingProcess process) Determines if a given process is currently waiting to acquire this resource.
void	release(ISchedulableProcess schedulableProcess, long num) Releases num instances of the passive resource from the given process.
void	remove(SimpleWaitingProcess process) Removes a waiting process from the queue.
void	removeObserver(IPassiveResourceSensor observer) Removes the given observer

Methods inherited from class de.uka.ipd.sdq.scheduler.resources.AbstractSimResource

equals, getCapacity, getId, getName, hashCode, toString

Methods inherited from class de.uka.ipd.sdq.scheduler.entities.SchedulerEntity

getModel

Methods inherited from class de.uka.ipd.sdq.simulation.abstractsimengine.AbstractSimEntityDelegator

getEncapsulatedEntity, isScheduled, reschedule

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface de.uka.ipd.sdq.scheduler.IPassiveResource

getCapacity, getId, getName

Constructor Detail

SimSimpleFairPassiveResource

public SimSimpleFairPassiveResource(org.palladiosimulator.pcm.repository.PassiveResource resource,
                                    org.palladiosimulator.pcm.core.composition.AssemblyContext assemblyContext,
                                    SchedulerModel model,
                                    Long capacity)

Method Detail

getResource

public org.palladiosimulator.pcm.repository.PassiveResource getResource()

Description copied from interface: IPassiveResource

Getter for the model element of the passive resource.

Specified by:

getResource in interface IPassiveResource

Returns:

The passive resource model element.

getAssemblyContext

public org.palladiosimulator.pcm.core.composition.AssemblyContext getAssemblyContext()

Description copied from interface: IPassiveResource

Getter for the model element of the assembly context.

Specified by:

getAssemblyContext in interface IPassiveResource

Returns:

The assembly context of the passive resource.

getWaitingProcesses

public Queue<IWaitingProcess> getWaitingProcesses()

Description copied from interface: IPassiveResource

Returns a queue containing the waiting processes for the passive resource.

Specified by:

getWaitingProcesses in interface IPassiveResource

acquire

public boolean acquire(ISchedulableProcess schedulableProcess,
                       long num,
                       boolean timeout,
                       double timeoutValue)

Description copied from interface: IPassiveResource

Acquires num instances of the passive resource for the given process. The process is blocked until it successfully receives the requested number of resource instances.

Specified by:

acquire in interface IPassiveResource

Returns:

True, if the acquisition was successful, otherwise false.

release

public void release(ISchedulableProcess schedulableProcess,
                    long num)

Description copied from interface: IPassiveResource

Releases num instances of the passive resource from the given process.

Specified by:

release in interface IPassiveResource

addObserver

public void addObserver(IPassiveResourceSensor observer)

Description copied from interface: IPassiveResource

Adds the given observer. Observers get notified when a process acquired or released this resource.

Specified by:

addObserver in interface IPassiveResource

removeObserver

public void removeObserver(IPassiveResourceSensor observer)

Description copied from interface: IPassiveResource

Removes the given observer

Specified by:

removeObserver in interface IPassiveResource

getAvailable

public long getAvailable()

Description copied from interface: IPassiveResource

Returns the number of remaining instances.

Specified by:

getAvailable in interface IPassiveResource

isWaiting

public boolean isWaiting(SimpleWaitingProcess process)

Determines if a given process is currently waiting to acquire this resource.

Parameters:

process - the process

Returns:

TRUE if the process is waiting to acquire the resource; FALSE otherwise

remove

public void remove(SimpleWaitingProcess process)

Removes a waiting process from the queue.

Parameters:

process - the process to remove