Class CommunicatorBase

Inheritance
Object
CommunicatorBase
ThreadCommunicator
Implements
Inherited Members
Namespace: Microsoft.ML.Probabilistic
Assembly: Microsoft.ML.Probabilistic.dll
Syntax
public abstract class CommunicatorBase : ICommunicator

Properties

PercentTimeSpentWaiting

Declaration
public abstract double PercentTimeSpentWaiting { get; }
Property Value
Type Description
Double

Rank

Declaration
public abstract int Rank { get; }
Property Value
Type Description
Int32

Size

Declaration
public abstract int Size { get; }
Property Value
Type Description
Int32

Methods

Allreduce<T>(T, Func<T, T, T>)

Declaration
public virtual T Allreduce<T>(T value, Func<T, T, T> op)
Parameters
Type Name Description
T value
Func<T, T, T> op
Returns
Type Description
T
Type Parameters
Name Description
T

Alltoall<T>(T[])

Declaration
public virtual T[] Alltoall<T>(T[] values)
Parameters
Type Name Description
T[] values
Returns
Type Description
T[]
Type Parameters
Name Description
T

Alltoall<T>(T[][])

Declaration
protected virtual T[][] Alltoall<T>(T[][] values)
Parameters
Type Name Description
T[][] values
Returns
Type Description
T[][]
Type Parameters
Name Description
T

AlltoallFlattened<T>(T[], Int32[], Int32[])

Declaration
public virtual T[] AlltoallFlattened<T>(T[] inValues, int[] sendCounts, int[] recvCounts)
Parameters
Type Name Description
T[] inValues
Int32[] sendCounts
Int32[] recvCounts
Returns
Type Description
T[]
Type Parameters
Name Description
T

Barrier()

Declaration
public abstract void Barrier()

Broadcast<T>(ref T, Int32)

Declaration
public virtual void Broadcast<T>(ref T value, int root)
Parameters
Type Name Description
T value
Int32 root
Type Parameters
Name Description
T

Gather<T>(T, Int32)

Declaration
public virtual T[] Gather<T>(T value, int root)
Parameters
Type Name Description
T value
Int32 root
Returns
Type Description
T[]
Type Parameters
Name Description
T

GatherFlattened<T>(T[], Int32)

Declaration
public virtual T[] GatherFlattened<T>(T[] inValues, int root)
Parameters
Type Name Description
T[] inValues
Int32 root
Returns
Type Description
T[]
Type Parameters
Name Description
T

ImmediateReceive<T>(Int32, Int32, T[])

Declaration
public abstract ICommunicatorRequest ImmediateReceive<T>(int source, int tag, T[] values)
Parameters
Type Name Description
Int32 source
Int32 tag
T[] values
Returns
Type Description
ICommunicatorRequest
Type Parameters
Name Description
T

ImmediateReceive<T>(Int32, Int32, Action<T>)

Declaration
public abstract ICommunicatorRequest ImmediateReceive<T>(int source, int tag, Action<T> action)
Parameters
Type Name Description
Int32 source
Int32 tag
Action<T> action
Returns
Type Description
ICommunicatorRequest
Type Parameters
Name Description
T

ImmediateSend<T>(T, Int32, Int32)

Declaration
public abstract ICommunicatorRequest ImmediateSend<T>(T value, int dest, int tag)
Parameters
Type Name Description
T value
Int32 dest
Int32 tag
Returns
Type Description
ICommunicatorRequest
Type Parameters
Name Description
T

ImmediateSend<T>(T[], Int32, Int32)

Declaration
public virtual ICommunicatorRequest ImmediateSend<T>(T[] values, int dest, int tag)
Parameters
Type Name Description
T[] values
Int32 dest
Int32 tag
Returns
Type Description
ICommunicatorRequest
Type Parameters
Name Description
T

Receive<T>(Int32, Int32, out T)

Declaration
public abstract void Receive<T>(int source, int tag, out T value)
Parameters
Type Name Description
Int32 source
Int32 tag
T value
Type Parameters
Name Description
T

Receive<T>(Int32, Int32, ref T[])

Declaration
public virtual void Receive<T>(int source, int tag, ref T[] values)
Parameters
Type Name Description
Int32 source
Int32 tag
T[] values
Type Parameters
Name Description
T

Reduce<T>(T, Func<T, T, T>, Int32)

Declaration
public virtual T Reduce<T>(T value, Func<T, T, T> op, int root)
Parameters
Type Name Description
T value
Func<T, T, T> op
Int32 root
Returns
Type Description
T
Type Parameters
Name Description
T

Scatter<T>(T[], Int32)

Declaration
public virtual T Scatter<T>(T[] values, int root)
Parameters
Type Name Description
T[] values
Int32 root
Returns
Type Description
T
Type Parameters
Name Description
T

Send<T>(T, Int32, Int32)

Blocking send of a single value. Will wait until the value is received.

Declaration
public virtual void Send<T>(T value, int dest, int tag)
Parameters
Type Name Description
T value
Int32 dest
Int32 tag
Type Parameters
Name Description
T

Send<T>(T[], Int32, Int32)

Declaration
public virtual void Send<T>(T[] values, int dest, int tag)
Parameters
Type Name Description
T[] values
Int32 dest
Int32 tag
Type Parameters
Name Description
T

Implements