ptolemy.domains.rendezvous.kernel
Class RendezvousReceiver

java.lang.Object
  ptolemy.actor.AbstractReceiver
      ptolemy.domains.rendezvous.kernel.RendezvousReceiver

All Implemented Interfaces:

ProcessReceiver, Receiver

public class RendezvousReceiver
extends AbstractReceiver
implements ProcessReceiver

Receiver for rendezvous style communication. In the rendezvous domain, all communication is via synchronous message passing, so both the the sending and receiving processes need to rendezvous at the receiver. For rendezvous, the receiver is the key synchronization point. It is assumed each receiver has at most one thread trying to send to it and at most one thread trying to receive from it at any one time. The receiver performs the synchronization necessary for simple rendezvous (get() and put() operations). This receiver is based on the CSPReceiver class by John S. Davis II, Thomas Feng, Edward A. Lee, Neil Smyth, and Yang Zhao.

Since:

Ptolemy II 5.1

Version:

$Id: RendezvousReceiver.java 57040 2010-01-27 20:52:32Z cxh $

Author:

Thomas Feng

Accepted Rating:

Green (tfeng)

Proposed Rating:

Green (tfeng)

Nested Class Summary

private static class

RendezvousReceiver.TopologicalSort Topological sort for the set of receivers to be committed.

Field Summary

private BoundaryDetector	_boundaryDetector The boundary detector.
private int	_channelIndex The index of the channel that this receiver is in.
private boolean	_getConditional Flag indicating that the _getWaiting thread is a conditional rendezvous.
private Receiver[][]	_getReceivers The receivers currently being gotten data from.
private java.lang.Thread	_getWaiting Indicator that a get() is waiting on this receiver.
private boolean	_putConditional Flag indicating that the _putWaiting thread is a conditional rendezvous.
private Receiver[][]	_putReceivers The receivers currently being put data to.
private java.lang.Thread	_putWaiting Indicator that a put() is waiting on this receiver.
private Receiver[][]	_symmetricGetReceivers The receivers for a get operation on the other side, or null.
private Receiver[][]	_symmetricPutReceivers The receivers for a put operation on the other side, or null.
private Receiver[][]	_thisReceiver Array with just one receiver, this one, for convenience.
private Token	_token The token being transferred during the rendezvous.
private static int	GET Flag to test whether an operation does a get.
private static int	GET_CONDITIONAL Flag to test whether an operation does a conditional get.
private static int	GET_FROM_ALL Flag for the "get from all" operation.
private static int	GET_FROM_ANY Flag for the "get from any" operation.
private static int	GET_FROM_ANY_PUT_TO_ALL Flag for the "get from any and put to all" operation.
private static int	PUT Flag to test whether an operation does a put.
private static int	PUT_CONDITIONAL Flag to test whether an operation does a conditional put.
private static int	PUT_TO_ALL Flag for the "put to all" operation.
private static int	PUT_TO_ANY Flag for the "put to any" operation.

Constructor Summary

RendezvousReceiver()
Construct a RendezvousReceiver with no container.

RendezvousReceiver(IOPort container)
Construct a RendezvousReceiver with the specified container.

Method Summary

private static boolean	_checkRendezvous(Receiver[][] receivers, boolean isPut, java.util.Set beingChecked, java.util.Set ready, java.util.Set notReady, java.util.Set symmetricReceivers, boolean isSymmetricGet, boolean isSymmetricPut, Receiver farSideReceiver) Check whether a rendezvous can be formed starting from the given two-dimensional array of receivers.
protected static void	_commitRendezvous(java.util.Set receivers, RendezvousDirector director) Commit the rendezvous formed by the set of receivers that agree to send and receive at the same time.
protected RendezvousDirector	_getDirector() Return the director that is controlling the execution of this model.
private static java.util.Map	_getOrPutTokens(Receiver[][] getReceivers, Receiver[][] putReceivers, RendezvousDirector director, Token token, Token[][] tokenArray, int flag) Get or put token(s) to the array of receivers, or both put and get at the same time.
private static int	_getSelectedBranch(Receiver[][] receivers, java.util.Set beingChecked, java.util.Set ready) Get the branch of the two-dimensional array of receivers that has been selected by previous recursive calls of _checkRendezvous(Receiver[][], boolean, Set, Set, Set, Set, boolean, boolean, Receiver).
private static boolean	_isConditional(Receiver[][] receivers, boolean isPut) Test whether a two-dimensional array of receivers are conditional.
protected static java.util.Set	_receiversReadyToCommit(Receiver[][] receivers, boolean isPut) Get the receivers that are ready to form a rendezvous according to the rendezvous semantics.
private void	_resetFlags(boolean clearGet, boolean clearPut) Reset the flags of this receiver.
private static void	_resetReceiversFlags(Receiver[][] receivers, boolean clearGet, boolean clearPut) Reset the flags of the receivers in the given array.
void	clear() Reset local flags.
Token	get() Get a token from this receiver.
static Token[][]	getFromAll(Receiver[][] receivers, RendezvousDirector director) Get from all receivers in the specified array.
static Token	getFromAny(Receiver[][] receivers, RendezvousDirector director) Get from any receiver in the specified array.
static void	getFromAnyPutToAll(Receiver[][] getReceivers, Receiver[][] putReceivers, RendezvousDirector director) Get from any receiver in the getReceivers array, and put the token received to all receivers in putReceivers array.
boolean	hasRoom() Return true.
boolean	hasRoom(int tokens) Return true.
boolean	hasToken() Return true.
boolean	hasToken(int tokens) Return true.
boolean	isConnectedToBoundary() Return true if this receiver is connected to the inside of a boundary port.
boolean	isConnectedToBoundaryInside() Return true if this receiver is connected to the inside of a boundary port.
boolean	isConnectedToBoundaryOutside() Return true if this receiver is connected to the outside of a boundary port.
boolean	isConsumerReceiver() This class serves as an example of a ConsumerReceiver and hence this method returns true if this port is connected to a boundary.
boolean	isInsideBoundary() Return true if this receiver is contained on the inside of a boundary port.
boolean	isOutsideBoundary() Return true if this receiver is contained on the outside of a boundary port.
boolean	isProducerReceiver() Return true if this receiver is on an outside or an inside boundary.
boolean	isReadBlocked() Return true if there is a get or a conditional receive waiting on this receiver.
boolean	isWriteBlocked() Return true if there is either a put or a conditional send waiting on this receiver.
void	put(Token token) Put a token into the mailbox receiver.
void	putArrayToAll(Token[] tokens, int numberOfTokens, Receiver[] receivers) Put a sequence of tokens to all receivers in the specified array.
static void	putToAll(Token[][] tokens, Receiver[][] receivers, RendezvousDirector director) Put to all receivers in the specified array.
void	putToAll(Token token, Receiver[] receivers) Put to all receivers in the specified array.
void	putToAll(Token token, Receiver[] receivers, RendezvousDirector director) Put to all receivers in the specified array.
static void	putToAny(Token token, Receiver[][] receivers, RendezvousDirector director) Put the specified token to any receiver in the specified array.
void	requestFinish() The model has finished executing, so set a flag so that the next time an actor tries to get or put it gets a TerminateProcessException which will cause it to finish.
void	reset() Reset local flags.
static void	waitForChange(RendezvousDirector director) Wait on the specified director.

Methods inherited from class ptolemy.actor.AbstractReceiver

elementList, getArray, getContainer, getCurrentTime, getModelTime, isKnown, putArray, setContainer, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface ptolemy.actor.Receiver

elementList, getArray, getContainer, isKnown, putArray, setContainer

Field Detail

GET

private static final int GET

Flag to test whether an operation does a get.

See Also:

Constant Field Values

PUT

private static final int PUT

Flag to test whether an operation does a put.

See Also:

Constant Field Values

GET_CONDITIONAL

private static final int GET_CONDITIONAL

Flag to test whether an operation does a conditional get.

See Also:

Constant Field Values

PUT_CONDITIONAL

private static final int PUT_CONDITIONAL

Flag to test whether an operation does a conditional put.

See Also:

Constant Field Values

GET_FROM_ALL

private static final int GET_FROM_ALL

Flag for the "get from all" operation.

See Also:

Constant Field Values

GET_FROM_ANY

private static final int GET_FROM_ANY

Flag for the "get from any" operation.

See Also:

Constant Field Values

PUT_TO_ALL

private static final int PUT_TO_ALL

Flag for the "put to all" operation.

See Also:

Constant Field Values

PUT_TO_ANY

private static final int PUT_TO_ANY

Flag for the "put to any" operation.

See Also:

Constant Field Values

GET_FROM_ANY_PUT_TO_ALL

private static final int GET_FROM_ANY_PUT_TO_ALL

Flag for the "get from any and put to all" operation.

See Also:

Constant Field Values

_boundaryDetector

private BoundaryDetector _boundaryDetector

The boundary detector.

_channelIndex

private int _channelIndex

The index of the channel that this receiver is in.

_getConditional

private boolean _getConditional

Flag indicating that the _getWaiting thread is a conditional rendezvous.

_getReceivers

private Receiver[][] _getReceivers

The receivers currently being gotten data from.

_getWaiting

private java.lang.Thread _getWaiting

Indicator that a get() is waiting on this receiver.

_putConditional

private boolean _putConditional

Flag indicating that the _putWaiting thread is a conditional rendezvous.

_putReceivers

private Receiver[][] _putReceivers

The receivers currently being put data to.

_putWaiting

private java.lang.Thread _putWaiting

Indicator that a put() is waiting on this receiver.

_symmetricGetReceivers

private Receiver[][] _symmetricGetReceivers

The receivers for a get operation on the other side, or null.

_symmetricPutReceivers

private Receiver[][] _symmetricPutReceivers

The receivers for a put operation on the other side, or null.

_thisReceiver

private Receiver[][] _thisReceiver

Array with just one receiver, this one, for convenience.

_token

private Token _token

The token being transferred during the rendezvous.

Constructor Detail

RendezvousReceiver

public RendezvousReceiver()

Construct a RendezvousReceiver with no container.

RendezvousReceiver

public RendezvousReceiver(IOPort container)
                   throws IllegalActionException

Construct a RendezvousReceiver with the specified container.

Parameters:

container - The port containing this receiver.

Throws:

IllegalActionException - If this receiver cannot be contained by the proposed container.

Method Detail

clear

public void clear()

Reset local flags.

Specified by:

clear in interface Receiver

Overrides:

clear in class AbstractReceiver

get

public Token get()
          throws TerminateProcessException

Get a token from this receiver. This method does not return until the rendezvous has been completed. This method is internally synchronized on the director.

Specified by:

get in interface Receiver

Specified by:

get in class AbstractReceiver

Returns:

The token contained by this receiver.

Throws:

TerminateProcessException - If the actor to which this receiver belongs has been terminated while still running i.e it was not allowed to run to completion.

getFromAll

public static Token[][] getFromAll(Receiver[][] receivers,
                                   RendezvousDirector director)
                            throws TerminateProcessException

Get from all receivers in the specified array. This method does not return until all the gets are complete.

Parameters:

receivers - The receivers, which are assumed to all be instances of RendezvousReceiver.

director - The director, on which this method synchronizes.

Returns:

An array of token arrays, where the structure of the array is the same as the structure of the specified array of receivers. Note that if the receivers argument has any null values in the array of arrays, then so will the returned array or arrays.

Throws:

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

getFromAny

public static Token getFromAny(Receiver[][] receivers,
                               RendezvousDirector director)
                        throws TerminateProcessException

Get from any receiver in the specified array. This method does not return until one of the gets is complete.

Parameters:

receivers - The receivers, which are assumed to all be instances of RendezvousReceiver.

director - The director, on which this method synchronizes.

Returns:

A token from one of the receivers.

Throws:

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

getFromAnyPutToAll

public static void getFromAnyPutToAll(Receiver[][] getReceivers,
                                      Receiver[][] putReceivers,
                                      RendezvousDirector director)
                               throws IllegalActionException,
                                      TerminateProcessException

Get from any receiver in the getReceivers array, and put the token received to all receivers in putReceivers array. The put and get are to be accomplished simultaneously in a rendezvous. This method does not return until both the get and put are complete.

Parameters:

getReceivers - The receivers, which are assumed to all be instances of RendezvousReceiver, to get tokens from.

putReceivers - The receivers, which are assumed to all be instances of RendezvousReceiver, to put tokens to.

director - The director, on which this method synchronizes.

Throws:

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type).

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

hasRoom

public boolean hasRoom()

Return true. This method returns true in all cases to indicate that the next call to put() will succeed without throwing a NoRoomException, as indeed it will, even if not right away. Note that if this were to return true only if a rendezvous was pending, then polymorphic actors would busy wait.

Specified by:

hasRoom in interface Receiver

Specified by:

hasRoom in class AbstractReceiver

Returns:

True.

hasRoom

public boolean hasRoom(int tokens)

Return true. This method returns true in all cases to indicate that any number of calls to put() will succeed without throwing a NoRoomException, as indeed they will, even if not right away. Note that if this were to return true only if a rendezvous was pending, then polymorphic actors would busy wait.

Specified by:

hasRoom in interface Receiver

Specified by:

hasRoom in class AbstractReceiver

Parameters:

tokens - Ignored by this method.

Returns:

True.

hasToken

public boolean hasToken()

Return true. This method returns true in all cases to indicate that the next call to get() will succeed without throwing a NoTokenException, as indeed it will, even if not right away. Note that if this were to return true only if a rendezvous was pending, then polymorphic actors would busy wait.

Specified by:

hasToken in interface Receiver

Specified by:

hasToken in class AbstractReceiver

Returns:

True.

hasToken

public boolean hasToken(int tokens)

Return true. This method returns true in all cases to indicate that any number of calls to get() will succeed without throwing a NoTokenException, as indeed they will, even if not right away. Note that if this were to return true only if a rendezvous was pending, then polymorphic actors would busy wait.

Specified by:

hasToken in interface Receiver

Specified by:

hasToken in class AbstractReceiver

Parameters:

tokens - Ignored by this method.

Returns:

True.

isConnectedToBoundary

public boolean isConnectedToBoundary()
                              throws IllegalActionException

Return true if this receiver is connected to the inside of a boundary port. A boundary port is an opaque port that is contained by a composite actor. If this receiver is connected to the inside of a boundary port, then return true; otherwise return false.

Specified by:

isConnectedToBoundary in interface ProcessReceiver

Returns:

True if this receiver is connected to the inside of a boundary port; return false otherwise.

Throws:

IllegalActionException

See Also:

BoundaryDetector

isConnectedToBoundaryInside

public boolean isConnectedToBoundaryInside()
                                    throws InvalidStateException,
                                           IllegalActionException

Return true if this receiver is connected to the inside of a boundary port. A boundary port is an opaque port that is contained by a composite actor. If this receiver is connected to the inside of a boundary port, then return true; otherwise return false.

Specified by:

isConnectedToBoundaryInside in interface ProcessReceiver

Returns:

True if this receiver is connected to the inside of a boundary port; return false otherwise.

Throws:

IllegalActionException

InvalidStateException

See Also:

BoundaryDetector

isConnectedToBoundaryOutside

public boolean isConnectedToBoundaryOutside()
                                     throws IllegalActionException

Return true if this receiver is connected to the outside of a boundary port. A boundary port is an opaque port that is contained by a composite actor. If this receiver is connected to the outside of a boundary port, then return true; otherwise return false.

Specified by:

isConnectedToBoundaryOutside in interface ProcessReceiver

Returns:

True if this receiver is connected to the outside of a boundary port; return false otherwise.

Throws:

IllegalActionException

See Also:

BoundaryDetector

isConsumerReceiver

public boolean isConsumerReceiver()
                           throws IllegalActionException

This class serves as an example of a ConsumerReceiver and hence this method returns true if this port is connected to a boundary.

Specified by:

isConsumerReceiver in interface ProcessReceiver

Returns:

True if this is a consumer receiver; return false otherwise.

Throws:

IllegalActionException

See Also:

isConnectedToBoundary()

isInsideBoundary

public boolean isInsideBoundary()

Return true if this receiver is contained on the inside of a boundary port. A boundary port is an opaque port that is contained by a composite actor. If this receiver is contained on the inside of a boundary port then return true; otherwise return false.

Specified by:

isInsideBoundary in interface ProcessReceiver

Returns:

True if this receiver is contained on the inside of a boundary port; return false otherwise.

See Also:

BoundaryDetector

isOutsideBoundary

public boolean isOutsideBoundary()

Return true if this receiver is contained on the outside of a boundary port. A boundary port is an opaque port that is contained by a composite actor. If this receiver is contained on the outside of a boundary port then return true; otherwise return false.

Specified by:

isOutsideBoundary in interface ProcessReceiver

Returns:

True if this receiver is contained on the outside of a boundary port; return false otherwise.

See Also:

BoundaryDetector

isProducerReceiver

public boolean isProducerReceiver()

Return true if this receiver is on an outside or an inside boundary.

Specified by:

isProducerReceiver in interface ProcessReceiver

Returns:

True if this is a producer receiver; return false otherwise.

isReadBlocked

public boolean isReadBlocked()

Return true if there is a get or a conditional receive waiting on this receiver.

Specified by:

isReadBlocked in interface ProcessReceiver

Returns:

True if a read is pending on this receiver.

isWriteBlocked

public boolean isWriteBlocked()

Return true if there is either a put or a conditional send waiting on this receiver.

Specified by:

isWriteBlocked in interface ProcessReceiver

Returns:

A boolean indicating whether a write is pending on this receiver.

put

public void put(Token token)
         throws IllegalActionException,
                TerminateProcessException

Put a token into the mailbox receiver. This method does not return until the rendezvous is complete. This method is internally synchronized on the director.

Specified by:

put in interface Receiver

Specified by:

put in class AbstractReceiver

Parameters:

token - The token, or null to not put any token.

Throws:

IllegalActionException - If the token is not acceptable to the port (e.g., wrong type).

TerminateProcessException - If the actor to which this receiver belongs has been terminated while still running i.e it was not allowed to run to completion.

putArrayToAll

public void putArrayToAll(Token[] tokens,
                          int numberOfTokens,
                          Receiver[] receivers)
                   throws NoRoomException,
                          IllegalActionException,
                          TerminateProcessException

Put a sequence of tokens to all receivers in the specified array. This method sequentially calls putToAll() for each token in the tokens array.

Specified by:

putArrayToAll in interface Receiver

Overrides:

putArrayToAll in class AbstractReceiver

Parameters:

tokens - The sequence of token to put.

numberOfTokens - The number of tokens to put (the array might be longer).

receivers - The receivers.

Throws:

NoRoomException - If there is no room for the token.

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type), or if the tokens array does not have at least the specified number of tokens.

TerminateProcessException - If the actor to which this receiver belongs has been terminated while still running i.e it was not allowed to run to completion.

putToAll

public void putToAll(Token token,
                     Receiver[] receivers)
              throws NoRoomException,
                     IllegalActionException

Put to all receivers in the specified array. Implementers will assume that all such receivers are of the same class.

Specified by:

putToAll in interface Receiver

Overrides:

putToAll in class AbstractReceiver

Parameters:

token - The token to put, or null to not put any token.

receivers - The receivers.

Throws:

NoRoomException - If there is no room for the token.

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type).

putToAll

public void putToAll(Token token,
                     Receiver[] receivers,
                     RendezvousDirector director)
              throws IllegalActionException,
                     TerminateProcessException

Put to all receivers in the specified array. This method does not return until all the puts are complete. This method differs from its counterpart in the superclass in that it puts the token to all receivers in an atomic step. The method in the superclass puts the token to one receiver in the receiver array at a time.

Parameters:

token - The token to put, or null to not put any token.

receivers - The receivers, which are assumed to all be instances of RendezvousReceiver.

director - The director, on which this method synchronizes.

Throws:

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type).

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

putToAll

public static void putToAll(Token[][] tokens,
                            Receiver[][] receivers,
                            RendezvousDirector director)
                     throws IllegalActionException,
                            TerminateProcessException

Put to all receivers in the specified array. This method does not return until all the puts are complete. The tokens argument can have fewer tokens than receivers argument has receivers. If only one token is given (the argument has dimension [1][1]), then that one token is copied to all destination receivers (with possible type changes). If only one token in each dimension is given, then that one token is copied to all destination receivers in the corresponding dimension of the receivers array.

Parameters:

tokens - The tokens to put.

receivers - * The receivers, which are assumed to all be instances of RendezvousReceiver.

director - The director, on which this method synchronizes.

Throws:

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type).

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

putToAny

public static void putToAny(Token token,
                            Receiver[][] receivers,
                            RendezvousDirector director)
                     throws IllegalActionException,
                            TerminateProcessException

Put the specified token to any receiver in the specified array. This method does not return until one of the puts is complete.

Parameters:

token - The token to put.

receivers - The receivers, which are assumed to all be instances of RendezvousReceiver.

director - The director, on which this method synchronizes.

Throws:

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type).

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

requestFinish

public void requestFinish()

The model has finished executing, so set a flag so that the next time an actor tries to get or put it gets a TerminateProcessException which will cause it to finish.

Specified by:

requestFinish in interface ProcessReceiver

reset

public void reset()

Reset local flags.

Specified by:

reset in interface ProcessReceiver

Specified by:

reset in interface Receiver

Overrides:

reset in class AbstractReceiver

waitForChange

public static void waitForChange(RendezvousDirector director)
                          throws TerminateProcessException

Wait on the specified director. This is not synchronized on the specified director, so the called should be.

Parameters:

director - The director on which to wait.

Throws:

TerminateProcessException - If a finish has been requested of the specified director, or if the calling thread is interrupted while waiting.

_commitRendezvous

protected static void _commitRendezvous(java.util.Set receivers,
                                        RendezvousDirector director)

Commit the rendezvous formed by the set of receivers that agree to send and receive at the same time.

Parameters:

receivers - The receivers that participate in the rendezvous.

director - The director.

See Also:

_receiversReadyToCommit(Receiver[][], boolean)

_getDirector

protected RendezvousDirector _getDirector()

Return the director that is controlling the execution of this model. If this receiver is an inside receiver, then it is the director of the container (actor) of the container (port). Otherwise, it is the executive director of the container (actor) of the container (port).

Returns:

The RendezvousDirector controlling this model.

_receiversReadyToCommit

protected static java.util.Set _receiversReadyToCommit(Receiver[][] receivers,
                                                       boolean isPut)

Get the receivers that are ready to form a rendezvous according to the rendezvous semantics. If no rendezvous can be formed starting for the given array of receivers, null is returned.

Parameters:

receivers - The array of receivers to be put to or get from.

isPut - If true, the rendezvous is to put tokens to the receivers; if false, the rendezvous is to get tokens from the receivers.

Returns:

A set of receivers that participate in the rendezvous if it can be formed, or null if no rendezvous can be formed.

See Also:

_commitRendezvous(Set, RendezvousDirector)

_checkRendezvous

private static boolean _checkRendezvous(Receiver[][] receivers,
                                        boolean isPut,
                                        java.util.Set beingChecked,
                                        java.util.Set ready,
                                        java.util.Set notReady,
                                        java.util.Set symmetricReceivers,
                                        boolean isSymmetricGet,
                                        boolean isSymmetricPut,
                                        Receiver farSideReceiver)

Check whether a rendezvous can be formed starting from the given two-dimensional array of receivers. If a rendezvous can be formed, the ready set contains all the receivers participating in the rendezvous after the call, and true is returned; Otherwise, the ready set is not meaningful.

Parameters:

receivers - The initial two-dimensional array of receivers on an actor.

isPut - Whether the request is put.

beingChecked - The set of receivers that are being checked by previous recursive calls.

ready - The set of receivers that are ready for a rendezvous.

notReady - The set of receivers that are not ready for a rendezvous.

symmetricReceivers - The set of symmetric receivers that have been visited during the traversal.

isSymmetricGet - Whether the previous recursive call is from the other side (the get side) of a Merge or Barrier.

isSymmetricPut - Whether the previous recursive call is from the other side (the put side) of a Merge or Barrier.

farSideReceiver - The receiver that is being checked on the far side, or null if this method is not called from the far side.

Returns:

Whether a rendezvous can be formed.

_getOrPutTokens

private static java.util.Map _getOrPutTokens(Receiver[][] getReceivers,
                                             Receiver[][] putReceivers,
                                             RendezvousDirector director,
                                             Token token,
                                             Token[][] tokenArray,
                                             int flag)
                                      throws IllegalActionException,
                                             TerminateProcessException

Get or put token(s) to the array of receivers, or both put and get at the same time. The operation that it performs depends on the flag parameter. If a get is requested in the flag, getReceivers should contain the receivers to receive tokens; otherwise, getReceivers is ignored. If a put is requested in the flag, putReceivers should contain the receivers to put tokens to. The tokens are stored either in the token parameter or the tokenArray parameter, depending on the operation. If the put is to any of the receivers, the token parameter is the single token to put, and the tokenArray parameter is ignored; if the put is to all of the receivers, the tokenArray parameter is the two-dimensional array of tokens, one corresponding to a receiver in the two-dimensional array putReceivers, and the token parameter is ignored. This method does not return until the requested operation is finished.

Parameters:

getReceivers - The receivers from with tokens are received.

putReceivers - The receivers to which tokens are put.

director - The director.

token - The token of the put to any operation, or null.

tokenArray - The token array of the put to all operation, or null.

flag - The flag representing the operation to be performed.

Returns:

The map of results on the receivers that participate in the rendezvous. Keys of the map are receivers; values of the map are the tokens on those receivers.

Throws:

IllegalActionException - If the token is not acceptable to one of the ports (e.g., wrong type). This can happen only if the operation is put to all or put to any.

TerminateProcessException - If the actor to which this receiver belongs is to be terminated.

_getSelectedBranch

private static int _getSelectedBranch(Receiver[][] receivers,
                                      java.util.Set beingChecked,
                                      java.util.Set ready)

Get the branch of the two-dimensional array of receivers that has been selected by previous recursive calls of _checkRendezvous(Receiver[][], boolean, Set, Set, Set, Set, boolean, boolean, Receiver).

Parameters:

receivers - The two-dimensional array of receivers.

beingChecked - The set of receivers that are being checked by previous recursive calls.

ready - The set of receivers that are ready for a rendezvous.

Returns:

The index of the selected branch, or -1 if no branch has been selected yet.

_isConditional

private static boolean _isConditional(Receiver[][] receivers,
                                      boolean isPut)

Test whether a two-dimensional array of receivers are conditional.

Parameters:

receivers - The two-dimensional array of receivers.

isPut - Whether to test put conditional (true) or to test get conditional (false).

Returns:

Whether the receivers are conditional.

_resetFlags

private void _resetFlags(boolean clearGet,
                         boolean clearPut)

Reset the flags of this receiver.

Parameters:

clearGet - Whether to reset the flags related to the get methods.

clearPut - Whether to reset the flags related to the put methods.

_resetReceiversFlags

private static void _resetReceiversFlags(Receiver[][] receivers,
                                         boolean clearGet,
                                         boolean clearPut)

Reset the flags of the receivers in the given array.

Parameters:

receivers - An array of receivers to be reset.

clearGet - Whether to reset the flags related to the get methods.

clearPut - Whether to reset the flags related to the put methods.