edu.iu.dsc.tws.comms.utils

Class OperationUtils

java.lang.Object

edu.iu.dsc.tws.comms.utils.OperationUtils

public final class OperationUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static boolean	areReceiversComplete(java.util.concurrent.locks.Lock finalLock, MessageReceiver finalReceiver, java.util.concurrent.locks.Lock partialLock, MessageReceiver partialReceiver) Progress the receivers and return true if needs further progress
static java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>>	getIntegerListMap(InvertedBinaryTreeRouter router, LogicalPlan instancePlan, int destination)
static java.lang.String	printStackTrace(java.lang.StackTraceElement[] elements)
static boolean	progressReceivers(ChannelDataFlowOperation delegate, java.util.concurrent.locks.Lock lock, MessageReceiver finalReceiver, java.util.concurrent.locks.Lock partialLock, MessageReceiver partialReceiver) Progress the receivers and return true if needs further progress
static void	shuffleArray(java.util.Random random, int[] array)
static void	swap(int[] array, int i, int j)

Methods inherited from class java.lang.Object

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

Method Detail

areReceiversComplete

public static boolean areReceiversComplete(java.util.concurrent.locks.Lock finalLock,
                                           MessageReceiver finalReceiver,
                                           java.util.concurrent.locks.Lock partialLock,
                                           MessageReceiver partialReceiver)

Progress the receivers and return true if needs further progress

Parameters:

finalLock - lock for final receiver

finalReceiver - final receiver

partialLock - lock for partial receiver

partialReceiver - partial receiver

Returns:

true if need further progress

progressReceivers

public static boolean progressReceivers(ChannelDataFlowOperation delegate,
                                        java.util.concurrent.locks.Lock lock,
                                        MessageReceiver finalReceiver,
                                        java.util.concurrent.locks.Lock partialLock,
                                        MessageReceiver partialReceiver)

Progress the receivers and return true if needs further progress

Parameters:

delegate - the channel dataflow opeation

lock - lock for final receiver

finalReceiver - final receiver

partialLock - lock for partial receiver

partialReceiver - partial receiver

Returns:

true if need further progress

getIntegerListMap

public static java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> getIntegerListMap(InvertedBinaryTreeRouter router,
                                                                                                   LogicalPlan instancePlan,
                                                                                                   int destination)

shuffleArray

public static void shuffleArray(java.util.Random random,
                                int[] array)

swap

public static void swap(int[] array,
                        int i,
                        int j)

printStackTrace

public static java.lang.String printStackTrace(java.lang.StackTraceElement[] elements)