org.javaseis.parallel
Class MPIContext

java.lang.Object
  org.javaseis.parallel.MPIContext

All Implemented Interfaces:

IParallelContext

public class MPIContext
extends java.lang.Object
implements IParallelContext

Author:

moshecc Implement a ParallelContext using MPI primitives from the mpiJava package

Constructor Summary

MPIContext()

Method Summary

void	barrier() Parallel barrier that requires all tasks to particpate.
<T> void	bcast(int type, T buf, int offset, int count, int sender) Broadcast a message to all tasks in this parallel context
void	bcastByte(int type, byte[] buf, int offset, int count, int sender)
void	bcastDouble(int type, double[] buf, int offset, int count, int sender)
void	bcastFloat(int type, float[] buf, int offset, int count, int sender)
void	bcastInt(int type, int[] buf, int offset, int count, int sender)
void	bcastLong(int type, long[] buf, int offset, int count, int sender)
void	bcastShort(int type, short[] buf, int offset, int count, int sender)
<T> void	binaryTree(int len, T buf, int startOffset) Binary tree broadcast operation.
<T> void	collect(T a, int aoffset, T b, int boffset, int count) Collect an array from all tasks and concatenate on the master task
byte[]	collectByte(byte ai) Collect a scalar from all tasks into an array returned to all tasks
void	collectByte(byte[] a, int aoffset, byte[] b, int boffset, int count)
double[]	collectDouble(double ai)
void	collectDouble(double[] a, int aoffset, double[] b, int boffset, int count)
float[]	collectFloat(float ai)
void	collectFloat(float[] a, int aoffset, float[] b, int boffset, int count)
int[]	collectInt(int ai)
void	collectInt(int[] a, int aoffset, int[] b, int boffset, int count)
long[]	collectLong(long ai)
void	collectLong(long[] a, int aoffset, long[] b, int boffset, int count)
short[]	collectShort(short ai)
void	collectShort(short[] a, int aoffset, short[] b, int boffset, int count)
void	finish() Complete participation in the parallel context
<T> void	globalMax(T a, int aoffset, T b, int boffset, int count)
void	globalMaxByte(byte[] a, int aoffset, byte[] b, int boffset, int count)
void	globalMaxDouble(double[] a, int aoffset, double[] b, int boffset, int count)
void	globalMaxFloat(float[] a, int aoffset, float[] b, int boffset, int count)
void	globalMaxInt(int[] a, int aoffset, int[] b, int boffset, int count)
void	globalMaxLong(long[] a, int aoffset, long[] b, int boffset, int count)
void	globalMaxShort(short[] a, int aoffset, short[] b, int boffset, int count)
<T> void	globalMin(T a, int aoffset, T b, int boffset, int count)
void	globalMinByte(byte[] a, int aoffset, byte[] b, int boffset, int count)
void	globalMinDouble(double[] a, int aoffset, double[] b, int boffset, int count)
void	globalMinFloat(float[] a, int aoffset, float[] b, int boffset, int count)
void	globalMinInt(int[] a, int aoffset, int[] b, int boffset, int count)
void	globalMinLong(long[] a, int aoffset, long[] b, int boffset, int count)
void	globalMinShort(short[] a, int aoffset, short[] b, int boffset, int count)
<T> void	globalSum(T a, int aoffset, T b, int boffset, int count) Global operations across tasks in a ParallelContext Operations are provided for Sum, Min, and Max.
void	globalSumByte(byte[] a, int aoffset, byte[] b, int boffset, int count)
void	globalSumDouble(double[] a, int aoffset, double[] b, int boffset, int count)
void	globalSumFloat(float[] a, int aoffset, float[] b, int boffset, int count)
void	globalSumInt(int[] a, int aoffset, int[] b, int boffset, int count)
void	globalSumLong(long[] a, int aoffset, long[] b, int boffset, int count)
void	globalSumShort(short[] a, int aoffset, short[] b, int boffset, int count)
boolean	init(Intracomm commGroup) Initialize the parellel context using Intracomm rather than calling MPI.Init() so that this can be created from an application that is already running MPI.
boolean	init(java.lang.String[] args) Initialize the parallel context using mpiJava
boolean	isMaster() Return true if this task is the "master"
static void	main(java.lang.String[] args) Simple test harness
void	masterPrint(java.lang.String s) Print a string from the rank 0 task only A barrier is invoked, so all tasks must participate in the call to this method.
int	rank() Return the rank (task index) of this task in the parallel context
<T> void	recv(int tag, T buf, int offset, int count) Receive a message from another task in this parallel context
void	recvByte(int tag, byte[] buf, int offset, int count)
void	recvDouble(int tag, double[] buf, int offset, int count)
void	recvFloat(int tag, float[] buf, int offset, int count)
void	recvInt(int tag, int[] buf, int offset, int count)
void	recvLong(int tag, long[] buf, int offset, int count)
void	recvShort(int tag, short[] buf, int offset, int count)
<T> void	send(int tag, T buf, int offset, int count, int dest) Send a message to another task in this parallel context
void	sendByte(int tag, byte[] buf, int offset, int count, int dest)
void	sendDouble(int tag, double[] buf, int offset, int count, int dest)
void	sendFloat(int tag, float[] buf, int offset, int count, int dest)
void	sendInt(int tag, int[] buf, int offset, int count, int dest)
void	sendLong(int tag, long[] buf, int offset, int count, int dest)
void	sendShort(int tag, short[] buf, int offset, int count, int dest)
void	serialPrint(java.lang.String s) Serialize printing a string from all tasks, so that one line at a time is printed A barrier is invoked, so all tasks must participate in the call to this method.
<T> void	shift(int nshift, T a, int offset, int count, T buf) (non-Javadoc)
void	shiftByte(int nshift, byte[] a, int offset, int count, byte[] buf)
void	shiftDouble(int nshift, double[] a, int offset, int count, double[] buf)
void	shiftFloat(int nshift, float[] a, int offset, int count, float[] buf)
void	shiftInt(int nshift, int[] a, int offset, int count, int[] buf)
void	shiftLong(int nshift, long[] a, int offset, int count, long[] buf)
<T> void	shiftPrimitive(Datatype type, int nshift, java.lang.Object a, int offset, int count, java.lang.Object buf) Shift an array of primitive or objects types across tasks in a parallel context
void	shiftShort(int nshift, short[] a, int offset, int count, short[] buf)
int	size() Return the size (total number of tasks) in the parallel context
<T> void	ttran(int tileSize, T a, int startOffset, T buf) Transpose a "tiled" array across tasks in this parallel context.
void	ttranByte(int tileSize, byte[] a, int offset, byte[] buf)
void	ttranDouble(int tileSize, double[] a, int offset, double[] buf)
void	ttranFloat(int tileSize, float[] a, int offset, float[] buf)
void	ttranInt(int tileSize, int[] a, int offset, int[] buf)
void	ttranLong(int tileSize, long[] a, int offset, long[] buf)
void	ttranShort(int tileSize, short[] a, int offset, short[] buf)
<T> void	ttranv(int[] lena, int[] aoffset, T[] a, int[] lenb, int[] boffset, T[] b) Transpose for variable length tiles.
void	ttranvInit(int[] lena, int[] aoffset, int[] lenb, int[] boffset) Calulate output lengths of tiles for variable length tiled transpose.

Methods inherited from class java.lang.Object

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

Constructor Detail

MPIContext

public MPIContext()

Method Detail

barrier

public void barrier()

Parallel barrier that requires all tasks to particpate. Serves as a synchronization point for parallel codes.

Specified by:

barrier in interface IParallelContext

See Also:

IParallelContext.barrier()

bcast

public <T> void bcast(int type,
                      T buf,
                      int offset,
                      int count,
                      int sender)

Broadcast a message to all tasks in this parallel context

Specified by:

bcast in interface IParallelContext

Parameters:

tag - unique integer tag for this message

buf - array containing data to be sent

offset - offset into array where broadcast will start

count - count of elements to be sent

sender - rank of the source for this broadcast

See Also:

org.javaseis.parallel.IParallelContext#bcast(int, T, int, int, int)

bcastByte

public void bcastByte(int type,
                      byte[] buf,
                      int offset,
                      int count,
                      int sender)

Specified by:

bcastByte in interface IParallelContext

bcastDouble

public void bcastDouble(int type,
                        double[] buf,
                        int offset,
                        int count,
                        int sender)

Specified by:

bcastDouble in interface IParallelContext

bcastFloat

public void bcastFloat(int type,
                       float[] buf,
                       int offset,
                       int count,
                       int sender)

Specified by:

bcastFloat in interface IParallelContext

bcastInt

public void bcastInt(int type,
                     int[] buf,
                     int offset,
                     int count,
                     int sender)

Specified by:

bcastInt in interface IParallelContext

bcastLong

public void bcastLong(int type,
                      long[] buf,
                      int offset,
                      int count,
                      int sender)

Specified by:

bcastLong in interface IParallelContext

bcastShort

public void bcastShort(int type,
                       short[] buf,
                       int offset,
                       int count,
                       int sender)

Specified by:

bcastShort in interface IParallelContext

binaryTree

public <T> void binaryTree(int len,
                           T buf,
                           int startOffset)

Binary tree broadcast operation. replicates the broadcast method, but put it here in case there is a need to insert an operation at each stage in the tree.

Parameters:

len - number of elements in the buffer to broadcast

buf - object array containing data for the broadcast

startOffset - location in buffer for the broadcast

collect

public <T> void collect(T a,
                        int aoffset,
                        T b,
                        int boffset,
                        int count)

Collect an array from all tasks and concatenate on the master task

Specified by:

collect in interface IParallelContext

Parameters:

a - source array

aoffset - offset within source array for the operation

b - result array, length size*count, where size is the context size

boffset - offset in the result array where results are placed

count - number of elements to collect from each task. Output array b will have count*ParallelContext.size() elements on output. Methods support object and primitive types.

collectByte

public byte[] collectByte(byte ai)

Collect a scalar from all tasks into an array returned to all tasks

Specified by:

collectByte in interface IParallelContext

Parameters:

ai - input scalar

Returns:

output array containing collected scalar length ParallelContext.size()

collectByte

public void collectByte(byte[] a,
                        int aoffset,
                        byte[] b,
                        int boffset,
                        int count)

Specified by:

collectByte in interface IParallelContext

collectDouble

public double[] collectDouble(double ai)

Specified by:

collectDouble in interface IParallelContext

collectDouble

public void collectDouble(double[] a,
                          int aoffset,
                          double[] b,
                          int boffset,
                          int count)

Specified by:

collectDouble in interface IParallelContext

collectFloat

public float[] collectFloat(float ai)

Specified by:

collectFloat in interface IParallelContext

collectFloat

public void collectFloat(float[] a,
                         int aoffset,
                         float[] b,
                         int boffset,
                         int count)

Specified by:

collectFloat in interface IParallelContext

collectInt

public int[] collectInt(int ai)

Specified by:

collectInt in interface IParallelContext

collectInt

public void collectInt(int[] a,
                       int aoffset,
                       int[] b,
                       int boffset,
                       int count)

Specified by:

collectInt in interface IParallelContext

collectLong

public long[] collectLong(long ai)

Specified by:

collectLong in interface IParallelContext

collectLong

public void collectLong(long[] a,
                        int aoffset,
                        long[] b,
                        int boffset,
                        int count)

Specified by:

collectLong in interface IParallelContext

collectShort

public short[] collectShort(short ai)

Specified by:

collectShort in interface IParallelContext

collectShort

public void collectShort(short[] a,
                         int aoffset,
                         short[] b,
                         int boffset,
                         int count)

Specified by:

collectShort in interface IParallelContext

finish

public void finish()

Complete participation in the parallel context

Specified by:

finish in interface IParallelContext

See Also:

IParallelContext.finish()

globalMax

public <T> void globalMax(T a,
                          int aoffset,
                          T b,
                          int boffset,
                          int count)

Specified by:

globalMax in interface IParallelContext

globalMaxByte

public void globalMaxByte(byte[] a,
                          int aoffset,
                          byte[] b,
                          int boffset,
                          int count)

Specified by:

globalMaxByte in interface IParallelContext

globalMaxDouble

public void globalMaxDouble(double[] a,
                            int aoffset,
                            double[] b,
                            int boffset,
                            int count)

Specified by:

globalMaxDouble in interface IParallelContext

globalMaxFloat

public void globalMaxFloat(float[] a,
                           int aoffset,
                           float[] b,
                           int boffset,
                           int count)

Specified by:

globalMaxFloat in interface IParallelContext

globalMaxInt

public void globalMaxInt(int[] a,
                         int aoffset,
                         int[] b,
                         int boffset,
                         int count)

Specified by:

globalMaxInt in interface IParallelContext

globalMaxLong

public void globalMaxLong(long[] a,
                          int aoffset,
                          long[] b,
                          int boffset,
                          int count)

Specified by:

globalMaxLong in interface IParallelContext

globalMaxShort

public void globalMaxShort(short[] a,
                           int aoffset,
                           short[] b,
                           int boffset,
                           int count)

Specified by:

globalMaxShort in interface IParallelContext

globalMin

public <T> void globalMin(T a,
                          int aoffset,
                          T b,
                          int boffset,
                          int count)

Specified by:

globalMin in interface IParallelContext

globalMinByte

public void globalMinByte(byte[] a,
                          int aoffset,
                          byte[] b,
                          int boffset,
                          int count)

Specified by:

globalMinByte in interface IParallelContext

globalMinDouble

public void globalMinDouble(double[] a,
                            int aoffset,
                            double[] b,
                            int boffset,
                            int count)

Specified by:

globalMinDouble in interface IParallelContext

globalMinFloat

public void globalMinFloat(float[] a,
                           int aoffset,
                           float[] b,
                           int boffset,
                           int count)

Specified by:

globalMinFloat in interface IParallelContext

globalMinInt

public void globalMinInt(int[] a,
                         int aoffset,
                         int[] b,
                         int boffset,
                         int count)

Specified by:

globalMinInt in interface IParallelContext

globalMinLong

public void globalMinLong(long[] a,
                          int aoffset,
                          long[] b,
                          int boffset,
                          int count)

Specified by:

globalMinLong in interface IParallelContext

globalMinShort

public void globalMinShort(short[] a,
                           int aoffset,
                           short[] b,
                           int boffset,
                           int count)

Specified by:

globalMinShort in interface IParallelContext

globalSum

public <T> void globalSum(T a,
                          int aoffset,
                          T b,
                          int boffset,
                          int count)

Description copied from interface: IParallelContext

Global operations across tasks in a ParallelContext Operations are provided for Sum, Min, and Max. The input array contains data for the global operation. The output array contains the sum/min/max of the individual elements from all tasks.

Specified by:

globalSum in interface IParallelContext

aoffset - offset in input array at which to begin the operation

b - output array containing result across tasks

boffset - offset in output array where results will be placed

count - number of elements to operate on

globalSumByte

public void globalSumByte(byte[] a,
                          int aoffset,
                          byte[] b,
                          int boffset,
                          int count)

Specified by:

globalSumByte in interface IParallelContext

globalSumDouble

public void globalSumDouble(double[] a,
                            int aoffset,
                            double[] b,
                            int boffset,
                            int count)

Specified by:

globalSumDouble in interface IParallelContext

globalSumFloat

public void globalSumFloat(float[] a,
                           int aoffset,
                           float[] b,
                           int boffset,
                           int count)

Specified by:

globalSumFloat in interface IParallelContext

globalSumInt

public void globalSumInt(int[] a,
                         int aoffset,
                         int[] b,
                         int boffset,
                         int count)

Specified by:

globalSumInt in interface IParallelContext

globalSumLong

public void globalSumLong(long[] a,
                          int aoffset,
                          long[] b,
                          int boffset,
                          int count)

Specified by:

globalSumLong in interface IParallelContext

globalSumShort

public void globalSumShort(short[] a,
                           int aoffset,
                           short[] b,
                           int boffset,
                           int count)

Specified by:

globalSumShort in interface IParallelContext

init

public boolean init(Intracomm commGroup)

Initialize the parellel context using Intracomm rather than calling MPI.Init() so that this can be created from an application that is already running MPI.

Specified by:

init in interface IParallelContext

Returns:

true if this is the "master" task

See Also:

org.javaseis.parallel.IParallelContext#init()

init

public boolean init(java.lang.String[] args)

Initialize the parallel context using mpiJava

Specified by:

init in interface IParallelContext

Parameters:

args - command line argument strings

Returns:

true if this is the "master" task

See Also:

org.javaseis.parallel.IParallelContext#init()

isMaster

public boolean isMaster()

Return true if this task is the "master"

Specified by:

isMaster in interface IParallelContext

Returns:

See Also:

org.javaseis.parallel.IParallelContext#init()

main

public static void main(java.lang.String[] args)
                 throws MPIException

Simple test harness

Parameters:

args -

Throws:

MPIException

masterPrint

public void masterPrint(java.lang.String s)

Print a string from the rank 0 task only A barrier is invoked, so all tasks must participate in the call to this method.

Specified by:

masterPrint in interface IParallelContext

Parameters:

s - string to be printed

rank

public int rank()

Return the rank (task index) of this task in the parallel context

Specified by:

rank in interface IParallelContext

Returns:

the rank of this task

See Also:

IParallelContext.rank()

recv

public <T> void recv(int tag,
                     T buf,
                     int offset,
                     int count)

Receive a message from another task in this parallel context

Specified by:

recv in interface IParallelContext

Parameters:

tag - unique integer tag for this message

buf - array to receive data

offset - offset into array where receive will start

count - maximum count of elements to be received

See Also:

org.javaseis.parallel.IParallelContext#recv(int, T, int, int)

recvByte

public void recvByte(int tag,
                     byte[] buf,
                     int offset,
                     int count)

Specified by:

recvByte in interface IParallelContext

recvDouble

public void recvDouble(int tag,
                       double[] buf,
                       int offset,
                       int count)

Specified by:

recvDouble in interface IParallelContext

recvFloat

public void recvFloat(int tag,
                      float[] buf,
                      int offset,
                      int count)

Specified by:

recvFloat in interface IParallelContext

recvInt

public void recvInt(int tag,
                    int[] buf,
                    int offset,
                    int count)

Specified by:

recvInt in interface IParallelContext

recvLong

public void recvLong(int tag,
                     long[] buf,
                     int offset,
                     int count)

Specified by:

recvLong in interface IParallelContext

recvShort

public void recvShort(int tag,
                      short[] buf,
                      int offset,
                      int count)

Specified by:

recvShort in interface IParallelContext

send

public <T> void send(int tag,
                     T buf,
                     int offset,
                     int count,
                     int dest)

Send a message to another task in this parallel context

Specified by:

send in interface IParallelContext

Parameters:

tag - unique integer tag for this message

buf - array containing data to be sent

offset - offset into array where send will start

count - count of elements to be sent

dest - rank of the destination for this message

See Also:

org.javaseis.parallel.IParallelContext#send(int, T, int, int, int)

sendByte

public void sendByte(int tag,
                     byte[] buf,
                     int offset,
                     int count,
                     int dest)

Specified by:

sendByte in interface IParallelContext

sendDouble

public void sendDouble(int tag,
                       double[] buf,
                       int offset,
                       int count,
                       int dest)

Specified by:

sendDouble in interface IParallelContext

sendFloat

public void sendFloat(int tag,
                      float[] buf,
                      int offset,
                      int count,
                      int dest)

Specified by:

sendFloat in interface IParallelContext

sendInt

public void sendInt(int tag,
                    int[] buf,
                    int offset,
                    int count,
                    int dest)

Specified by:

sendInt in interface IParallelContext

sendLong

public void sendLong(int tag,
                     long[] buf,
                     int offset,
                     int count,
                     int dest)

Specified by:

sendLong in interface IParallelContext

sendShort

public void sendShort(int tag,
                      short[] buf,
                      int offset,
                      int count,
                      int dest)

Specified by:

sendShort in interface IParallelContext

serialPrint

public void serialPrint(java.lang.String s)

Serialize printing a string from all tasks, so that one line at a time is printed A barrier is invoked, so all tasks must participate in the call to this method.

Specified by:

serialPrint in interface IParallelContext

Parameters:

s - string to be printed

shift

public <T> void shift(int nshift,
                      T a,
                      int offset,
                      int count,
                      T buf)

(non-Javadoc)

Specified by:

shift in interface IParallelContext

a - input array of objects or primitive types to be shifted

offset - offset into array a that the shift will be performed upon

count - number of array elements to shift

buf - a matching array to input array a, at least count elements in length

See Also:

org.javaseis.parallel.IParallelContext#shift(int, T, int, int)

shiftByte

public void shiftByte(int nshift,
                      byte[] a,
                      int offset,
                      int count,
                      byte[] buf)

Specified by:

shiftByte in interface IParallelContext

shiftDouble

public void shiftDouble(int nshift,
                        double[] a,
                        int offset,
                        int count,
                        double[] buf)

Specified by:

shiftDouble in interface IParallelContext

shiftFloat

public void shiftFloat(int nshift,
                       float[] a,
                       int offset,
                       int count,
                       float[] buf)

Specified by:

shiftFloat in interface IParallelContext

shiftInt

public void shiftInt(int nshift,
                     int[] a,
                     int offset,
                     int count,
                     int[] buf)

Specified by:

shiftInt in interface IParallelContext

shiftLong

public void shiftLong(int nshift,
                      long[] a,
                      int offset,
                      int count,
                      long[] buf)

Specified by:

shiftLong in interface IParallelContext

shiftPrimitive

public <T> void shiftPrimitive(Datatype type,
                               int nshift,
                               java.lang.Object a,
                               int offset,
                               int count,
                               java.lang.Object buf)

Shift an array of primitive or objects types across tasks in a parallel context

Parameters:

type - MPI data type, i.e. MPI.INT, MPI.OBJECT, etc

a - input array of objects or primitive types to be shifted

offset - offset into array a that the shift will be performed upon

count - number of array elements to shift

buf - a matching array to input array a, at least count elements in length

See Also:

org.javaseis.parallel.IParallelContext#shift(int, T, int, int)

shiftShort

public void shiftShort(int nshift,
                       short[] a,
                       int offset,
                       int count,
                       short[] buf)

Specified by:

shiftShort in interface IParallelContext

size

public int size()

Return the size (total number of tasks) in the parallel context

Specified by:

size in interface IParallelContext

Returns:

number of tasks in this parallel context

See Also:

IParallelContext.size()

ttran

public <T> void ttran(int tileSize,
                      T a,
                      int startOffset,
                      T buf)

Transpose a "tiled" array across tasks in this parallel context. The tiled array is of size "tileSize x size", where "size" is the number of tasks in this parallel context. All tasks have an array of this size, so the full array is "tileSize x size | size". This primitive can be used to construct transposes for multidimensional rectangular arrays. "ttran" oerates on objects, ttranPrimitive operates on primitive types.

Specified by:

ttran in interface IParallelContext

Parameters:

tileSize - size of the tile for the transpose

a - array containing data to be transposed

startOffset - index of start position in array a for transpose

buf - array of matching type of length "tileSize" used as work space

ttranByte

public void ttranByte(int tileSize,
                      byte[] a,
                      int offset,
                      byte[] buf)

Specified by:

ttranByte in interface IParallelContext

ttranDouble

public void ttranDouble(int tileSize,
                        double[] a,
                        int offset,
                        double[] buf)

Specified by:

ttranDouble in interface IParallelContext

ttranFloat

public void ttranFloat(int tileSize,
                       float[] a,
                       int offset,
                       float[] buf)

Specified by:

ttranFloat in interface IParallelContext

ttranInt

public void ttranInt(int tileSize,
                     int[] a,
                     int offset,
                     int[] buf)

Specified by:

ttranInt in interface IParallelContext

ttranLong

public void ttranLong(int tileSize,
                      long[] a,
                      int offset,
                      long[] buf)

Specified by:

ttranLong in interface IParallelContext

ttranShort

public void ttranShort(int tileSize,
                       short[] a,
                       int offset,
                       short[] buf)

Specified by:

ttranShort in interface IParallelContext

ttranv

public <T> void ttranv(int[] lena,
                       int[] aoffset,
                       T[] a,
                       int[] lenb,
                       int[] boffset,
                       T[] b)

Transpose for variable length tiles. This version supports object arrays. The additional arrays lena, aoffset, lenb, boffset describe the length and offset of each tile within arrays a and b respectively. On input lena and aoffset contain the length and offset of each tile in array a. lenb and boffset contain the length and offset of each tile for the transposed array b. A utility routine ttranvInit is provided to construct lenb and boffset from lena and aoffset.

Specified by:

ttranv in interface IParallelContext

Parameters:

lena - length of each input tile on this task

aoffset - offset to the start of each tile in a

a - input array containing tiles

lenb - output length of each received tile

boffset - output offset to each tile in array b

b - output array containing transposed data

ttranvInit

public void ttranvInit(int[] lena,
                       int[] aoffset,
                       int[] lenb,
                       int[] boffset)

Calulate output lengths of tiles for variable length tiled transpose.

Specified by:

ttranvInit in interface IParallelContext

Parameters:

lena - length of each input tile on this task

aoffset - offset to the start of each input tile

lenb - output length of each received tile

boffset - output offset to the start of each received tile