MCPcopy Create free account
hub / github.com/ml-explore/mlx / communication_stream

Function communication_stream

mlx/distributed/distributed.cpp:17–19  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

15namespace detail {
16
17Stream communication_stream(Group group, StreamOrDevice s /* = {} */) {
18 return group.raw_group()->communication_stream(s);
19}
20
21void all_sum(Group group, const array& input, array& output, Stream stream) {
22 group.raw_group()->all_sum(input, output, stream);

Callers 7

all_sumFunction · 0.85
all_maxFunction · 0.85
all_minFunction · 0.85
all_gatherFunction · 0.85
sendFunction · 0.85
recvFunction · 0.85
sum_scatterFunction · 0.85

Calls 1

communication_streamMethod · 0.45

Tested by

no test coverage detected