Class Server

java.lang.Object

QueueNet.NodeSection

NodeSections.PipeSection

NodeSections.ServiceSection

NodeSections.Server

Direct Known Subclasses:

PreemptiveServer, PSServer, PSServerPriority

public class Server
extends ServiceSection

This class implements a multi-class, single/multi server service. Every class has a specific distribution and a own set of statistical parameters. A server service remains busy while processing one or more jobs.

Author:

Francesco Radaelli, Stefano Omini, Bertoli Marco

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Server.BusyServer
class	Server.ServerType

Field Summary

Fields inherited from class NodeSection

EXCEPTION_MEASURE_DOES_NOT_EXIST, EXCEPTION_PROPERTY_NOT_AVAILABLE, INPUT, jobsList, logger, MSG_NOT_PROCESSED, MSG_PROCESSED, NO_ADDRESS, OUTPUT, PROPERTY_ID_ARRIVING_JOBS, PROPERTY_ID_AVERAGE_UTILIZATION, PROPERTY_ID_DEPARTING_JOBS, PROPERTY_ID_RESIDENCE_TIME, PROPERTY_ID_RESIDENT_JOBS, PROPERTY_ID_UTILIZATION, SERVICE

Constructor Summary

Constructors

Constructor	Description
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, Integer[] serverNumRequired, String[] serverTypesNames, Integer[] serverTypesNumOfServers, Object[] serverTypesCompatibilities, String schedulingPolicy)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, Object[] switchoverStrategies, Integer[] serverNumRequired, String[] serverTypesNames, Integer[] serverTypesNumOfServers, Object[] serverTypesCompatibilities, String schedulingPolicy)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, Object[] delayOffStrategies, Object[] setUpStrategies, Integer[] serverNumRequired, String[] serverTypesNames, Integer[] serverTypesNumOfServers, Object[] serverTypesCompatibilities, String schedulingPolicy)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, Object[] switchoverStrategies, Object[] delayOffStrategies, Object[] setUpStrategies)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, Object[] switchoverStrategies, Object[] delayOffStrategies, Object[] setUpStrategies, Integer[] serverNumRequired, String[] serverTypesNames, Integer[] serverTypesNumOfServers, Object[] serverTypesCompatibilities, String schedulingPolicy)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, Map<String,Object> advancedFeatures)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, QueuePutStrategy[] preemptiveStrategies)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, QueuePutStrategy[] preemptiveStrategies, Integer[] serverNumRequired, String[] serverTypesNames, Integer[] serverTypesNumOfServers, Object[] serverTypesCompatibilities, String schedulingPolicy)
Server(Integer numberOfServers, Integer[] numberOfVisits, ServiceStrategy[] serviceStrategies, QueuePutStrategy[] preemptiveStrategies, Object[] switchoverStrategies, Object[] delayOffStrategies, Object[] setUpStrategies, Integer[] serverNumRequired, String[] serverNames, Integer[] serversPerServerType, Object[] serverCompatibilities, String schedulingPolicy)

Method Summary

Modifier and Type	Method	Description
JobInfo	findNextJobToProcessFCFS(JobInfoList queue)
JobInfo	findNextJobToProcessLCFS(JobInfoList queue)
Boolean[][]	getClassCompatibilities()	Returns class compatibilities for specific node
double	getDoubleSectionProperty(int id)	Gets a double type property of this node.
double	getDoubleSectionProperty(int id, JobClass jobClass)	Gets a double type property of this node depending on a specified job class.
JobInfo	getLastJobInfo()	Gets the last job info in the service list.
int	getNumOfFreeServersForClass(int classId)
int	getServerRequired(int class_id)
List<Server.ServerType>	getServerTypes()	Returns server types for specific node
ServiceStrategy[]	getServiceStrategies()	Gets the service strategy for each class.
ServiceStrategy[][]	getServiceStrategiesPerServerType()
boolean	hasFreeServers()
boolean	isInVacation()
protected void	nodeLinked(NetNode node)	This method should be overridden to implement a specific behaviour of the node section when the node section itself is linked to the owner node.
protected int	process(NetMessage message)	This method should be overridden to implement a specific NetMessage processor.

Methods inherited from class ServiceSection

sendBackward, sendBackward, sendForward, sendForward

Methods inherited from class NodeSection

analyze, analyze, analyzeFCR, analyzeFJ, analyzeJoin, analyzeTransition, getIntSectionProperty, getIntSectionProperty, getJobClasses, getJobInfoList, getObject, getObject, getOwnerNode, getParameter, getParameter, getSectionID, isEnabled, isEnabled, isMine, isMyOwnerNode, redirect, removeMessage, send, send, send, send, send, send, sendAckAfterDrop, sendMe, sendMe, updateVisitPath

Methods inherited from class Object

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

Constructor Details

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 QueuePutStrategy[] preemptiveStrategies)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 Object[] switchoverStrategies,
 Object[] delayOffStrategies,
 Object[] setUpStrategies)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 Object[] delayOffStrategies,
 Object[] setUpStrategies,
 Integer[] serverNumRequired,
 String[] serverTypesNames,
 Integer[] serverTypesNumOfServers,
 Object[] serverTypesCompatibilities,
 String schedulingPolicy)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 Integer[] serverNumRequired,
 String[] serverTypesNames,
 Integer[] serverTypesNumOfServers,
 Object[] serverTypesCompatibilities,
 String schedulingPolicy)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 QueuePutStrategy[] preemptiveStrategies,
 Integer[] serverNumRequired,
 String[] serverTypesNames,
 Integer[] serverTypesNumOfServers,
 Object[] serverTypesCompatibilities,
 String schedulingPolicy)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 Object[] switchoverStrategies,
 Object[] delayOffStrategies,
 Object[] setUpStrategies,
 Integer[] serverNumRequired,
 String[] serverTypesNames,
 Integer[] serverTypesNumOfServers,
 Object[] serverTypesCompatibilities,
 String schedulingPolicy)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 Object[] switchoverStrategies,
 Integer[] serverNumRequired,
 String[] serverTypesNames,
 Integer[] serverTypesNumOfServers,
 Object[] serverTypesCompatibilities,
 String schedulingPolicy)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 QueuePutStrategy[] preemptiveStrategies,
 Object[] switchoverStrategies,
 Object[] delayOffStrategies,
 Object[] setUpStrategies,
 Integer[] serverNumRequired,
 String[] serverNames,
 Integer[] serversPerServerType,
 Object[] serverCompatibilities,
 String schedulingPolicy)
       throws NetException

Throws:

NetException

Server

public Server(Integer numberOfServers,
 Integer[] numberOfVisits,
 ServiceStrategy[] serviceStrategies,
 Map<String,Object> advancedFeatures)
       throws NetException

Throws:

NetException

Method Details

getClassCompatibilities

public Boolean[][] getClassCompatibilities()

Description copied from class: NodeSection

Returns class compatibilities for specific node

Overrides:

getClassCompatibilities in class NodeSection

getServerTypes

public List<Server.ServerType> getServerTypes()

Description copied from class: NodeSection

Returns server types for specific node

Overrides:

getServerTypes in class NodeSection

getDoubleSectionProperty

public double getDoubleSectionProperty(int id)
                                throws NetException

Description copied from class: NodeSection

Gets a double type property of this node. Note that the first 256 identifiers are reserved by NodeSection class.

Overrides:

getDoubleSectionProperty in class NodeSection

Parameters:

id - Property identifier (see properties constants).

Returns:

Property value.

Throws:

NetException - if the requested property is not available.

getDoubleSectionProperty

public double getDoubleSectionProperty(int id,
 JobClass jobClass)
                                throws NetException

Description copied from class: NodeSection

Gets a double type property of this node depending on a specified job class. Note that the first 256 identifiers are reserved by NodeSection class.

Overrides:

getDoubleSectionProperty in class NodeSection

Parameters:

id - Property identifier (see properties constants).

jobClass - jobClass.

Returns:

Property value.

Throws:

NetException - if the requested property is not available.

nodeLinked

protected void nodeLinked(NetNode node)
                   throws NetException

Description copied from class: NodeSection

This method should be overridden to implement a specific behaviour of the node section when the node section itself is linked to the owner node. This method should be used to set node section properties depending on the owner node ones.

Overrides:

nodeLinked in class NodeSection

Parameters:

node - Owner node.

Throws:

NetException

findNextJobToProcessLCFS

public JobInfo findNextJobToProcessLCFS(JobInfoList queue)

findNextJobToProcessFCFS

public JobInfo findNextJobToProcessFCFS(JobInfoList queue)

getServerRequired

public int getServerRequired(int class_id)

getNumOfFreeServersForClass

public int getNumOfFreeServersForClass(int classId)

hasFreeServers

public boolean hasFreeServers()

getServiceStrategiesPerServerType

public ServiceStrategy[][] getServiceStrategiesPerServerType()

process

protected int process(NetMessage message)
               throws NetException

Description copied from class: NodeSection

This method should be overridden to implement a specific NetMessage processor.

Specified by:

process in class NodeSection

Parameters:

message - message to be processed.

Returns:

message processing result.

Throws:

NetException

isInVacation

public boolean isInVacation()

getServiceStrategies

public ServiceStrategy[] getServiceStrategies()

Gets the service strategy for each class.

Returns:

the service strategy for each class.

getLastJobInfo

public JobInfo getLastJobInfo()

Gets the last job info in the service list.

Returns:

the last job info in the service list.