Class Semaphore

java.lang.Object

QueueNet.NodeSection

NodeSections.PipeSection

NodeSections.InputSection

NodeSections.Semaphore

public class Semaphore
extends InputSection

Title: Semaphore

Description: This class is a Semaphore input section, used to gather previously forked tasks. Tasks are kept until the threshold is reached. If a non-fragmented job is received, it is simply routed to service section.

Author:

Vitor S. Lopes Date: 25-jul-2016 Time: 11.37.58

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
Semaphore()	Constructs a new Semaphore.
Semaphore(SemaphoreStrategy[] semaphoreStrategies)

Method Summary

Modifier and Type	Method	Description
protected int	process(NetMessage message)	Processs the .

Methods inherited from class InputSection

sendForward, sendForward

Methods inherited from class NodeSection

analyze, analyze, analyzeFCR, analyzeFJ, analyzeJoin, analyzeTransition, getClassCompatibilities, getDoubleSectionProperty, getDoubleSectionProperty, getIntSectionProperty, getIntSectionProperty, getJobClasses, getJobInfoList, getObject, getObject, getOwnerNode, getParameter, getParameter, getSectionID, getServerTypes, isEnabled, isEnabled, isMine, isMyOwnerNode, nodeLinked, 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

Semaphore

public Semaphore()

Constructs a new Semaphore.

Semaphore

public Semaphore(SemaphoreStrategy[] semaphoreStrategies)

Method Details

process

protected int process(NetMessage message)
               throws NetException

Processs the .

Specified by:

process in class NodeSection

Parameters:

message - message to be processed.

Returns:

message processing result.

Throws:

NetException - if something goes wrong.