Class Join

java.lang.Object

QueueNet.NodeSection

NodeSections.PipeSection

NodeSections.InputSection

NodeSections.Join

public class Join
extends InputSection

Title: Join

Description: This class is a Join input section, used to re-assemble previously forked jobs. Jobs are kept until all fragments are collected. If a non-fragmented job is received, it is simply routed to service section.

Author:

Bertoli Marco Date: 13-mar-2006 Time: 16.19.58 Modified by J. Shuai & M. Cazzoli, implemented join strategies

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
Join()	Constructs a new Join.
Join(JoinStrategy[] joinStrategies)

Method Summary

Modifier and Type	Method	Description
void	analyzeFJ(int name, JobClass jobClass, Measure measurement)
void	analyzeJoin(int name, JobClass jobClass, Measure measurement)
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)	Assembles split tasks and sends an EVENT_JOIN to reference fork when done.

Methods inherited from class InputSection

sendForward, sendForward

Methods inherited from class NodeSection

analyze, analyze, analyzeFCR, analyzeTransition, getClassCompatibilities, getDoubleSectionProperty, getDoubleSectionProperty, getIntSectionProperty, getIntSectionProperty, getJobClasses, getJobInfoList, getObject, getObject, getOwnerNode, getParameter, getParameter, getSectionID, getServerTypes, 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

Join

public Join()

Constructs a new Join.

Join

public Join(JoinStrategy[] joinStrategies)

Method Details

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

process

protected int process(NetMessage message)
               throws NetException

Assembles split tasks and sends an EVENT_JOIN to reference fork when done.

Specified by:

process in class NodeSection

Parameters:

message - message to be processed.

Returns:

message processing result.

Throws:

NetException - if something goes wrong.

analyzeJoin

public void analyzeJoin(int name,
 JobClass jobClass,
 Measure measurement)
                 throws NetException

Overrides:

analyzeJoin in class NodeSection

Throws:

NetException

analyzeFJ

public void analyzeFJ(int name,
 JobClass jobClass,
 Measure measurement)
               throws NetException

Overrides:

analyzeFJ in class NodeSection

Throws:

NetException