Class Communicator

Inheritance

Object

Communicator

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Microsoft.ML.Probabilistic

Assembly: Microsoft.ML.Probabilistic.dll

Syntax

public static class Communicator

Fields

AlltoallSubarraysTimingInfos

Declaration

public static Dictionary<string, Communicator.TimingInfo> AlltoallSubarraysTimingInfos

Field Value

Type	Description
Dictionary<String, Communicator.TimingInfo>

MultiplyAllTimingInfos

Declaration

public static Dictionary<string, Communicator.TimingInfo> MultiplyAllTimingInfos

Field Value

Type	Description
Dictionary<String, Communicator.TimingInfo>

Methods

AlltoallSubarrays<T>(ICommunicator, IList<T>, ICollection<Int32>[], IList<T>, ICollection<Int32>[])

Declaration

public static void AlltoallSubarrays<T>(ICommunicator comm, IList<T> inputArray, ICollection<int>[] indicesToSend, IList<T> outputArray, ICollection<int>[] indicesToReceive)

Parameters

Type	Name	Description
ICommunicator	comm
IList<T>	inputArray
ICollection<Int32>[]	indicesToSend
IList<T>	outputArray
ICollection<Int32>[]	indicesToReceive

Type Parameters

Name	Description
T

AlltoallSubarrays<T>(ICommunicator, IList<T>, IList<Int32>[], IList<Int32>[])

Declaration

public static void AlltoallSubarrays<T>(ICommunicator comm, IList<T> array, IList<int>[] indicesToSend, IList<int>[] indicesToReceive)

Parameters

Type	Name	Description
ICommunicator	comm
IList<T>	array
IList<Int32>[]	indicesToSend
IList<Int32>[]	indicesToReceive

Type Parameters

Name	Description
T

AlltoallSubarrays<T>(ICommunicator, IReadOnlyList<T>, ICollection<Int32>[], IList<T>, ICollection<Int32>[])

Declaration

public static void AlltoallSubarrays<T>(ICommunicator comm, IReadOnlyList<T> inputArray, ICollection<int>[] indicesToSend, IList<T> outputArray, ICollection<int>[] indicesToReceive)

Parameters

Type	Name	Description
ICommunicator	comm
IReadOnlyList<T>	inputArray
ICollection<Int32>[]	indicesToSend
IList<T>	outputArray
ICollection<Int32>[]	indicesToReceive

Type Parameters

Name	Description
T

AlltoallSubarrays2<T>(ICommunicator, IReadOnlyList<T>, ICollection<Int32>[], IList<T>, ICollection<Int32>[])

Does not work with BinaryFormatter.

Declaration

public static void AlltoallSubarrays2<T>(ICommunicator comm, IReadOnlyList<T> inputArray, ICollection<int>[] indicesToSend, IList<T> outputArray, ICollection<int>[] indicesToReceive)

Parameters

Type	Name	Description
ICommunicator	comm
IReadOnlyList<T>	inputArray
ICollection<Int32>[]	indicesToSend
IList<T>	outputArray
ICollection<Int32>[]	indicesToReceive

Type Parameters

Name	Description
T

GetTimingString()

Declaration

public static string GetTimingString()

Returns

Type	Description
String

MultiplyAll<T>(ICommunicator, T)

Declaration

public static T MultiplyAll<T>(ICommunicator comm, T value)
    where T : ICloneable, SettableToProduct<T>

Parameters

Type	Name	Description
ICommunicator	comm
T	value

Returns

Type	Description
T

Type Parameters

Name	Description
T

ReceiveSubarrays<T>(ICommunicator, Int32, IList<T>, Int32[][])

Declaration

public static void ReceiveSubarrays<T>(ICommunicator comm, int tag, IList<T> array, int[][] indices)

Parameters

Type	Name	Description
ICommunicator	comm
Int32	tag
IList<T>	array
Int32[][]	indices

Type Parameters

Name	Description
T

SendSubarrays<T>(ICommunicator, Int32, IReadOnlyList<T>, Int32[][])

Declaration

public static IReadOnlyList<ICommunicatorRequest> SendSubarrays<T>(ICommunicator comm, int tag, IReadOnlyList<T> array, int[][] indices)

Parameters

Type	Name	Description
ICommunicator	comm
Int32	tag
IReadOnlyList<T>	array
Int32[][]	indices

Returns

Type	Description
IReadOnlyList<ICommunicatorRequest>

Type Parameters

Name	Description
T

TestAny(List<ICommunicatorRequest>)

Determines whether any request has completed. If so, that request will be removed from the request list and returned.

Declaration

public static ICommunicatorRequest TestAny(List<ICommunicatorRequest> requests)

Parameters

Type	Name	Description
List<ICommunicatorRequest>	requests

Returns

Type	Description
ICommunicatorRequest	The first request that has completed, if any. Otherwise, returns null to indicate that no request has completed.

Wait(IEnumerable<ICommunicatorRequest>)

Declaration

public static void Wait(IEnumerable<ICommunicatorRequest> requests)

Parameters

Type	Name	Description
IEnumerable<ICommunicatorRequest>	requests

WaitAny(List<ICommunicatorRequest>)

Waits until any request has completed. That request will then be removed from the request list and returned.

Declaration

public static ICommunicatorRequest WaitAny(List<ICommunicatorRequest> requests)

Parameters

Type	Name	Description
List<ICommunicatorRequest>	requests

Returns

Type	Description
ICommunicatorRequest	The completed request, which has been removed from the request list.