IMPORTANT: To view this page as Markdown, append `.md` to the URL (e.g. /get-started.md). For the complete documentation index, see llms.txt.
Skip to main content
For the complete documentation index, see llms.txt. Markdown versions of all pages are available by appending .md to any URL (e.g. /get-started.md).

Mojo struct

NullPeerSink

struct NullPeerSink

No-op sink: the epilogue keeps its local store.

Stateless like every sink, and Enabled is False, so each call site's comptime if strips the call outright. This is the default, which is what keeps the standalone matmuls byte-identical to a build with no sink parameter at all.

Implemented traits​

AnyType, Deinitable, EpiloguePeerSink, Movable

comptime members​

Enabled​

comptime Enabled = False

SendWarps​

comptime SendWarps = 0

Methods​

send_tile​

static def send_tile[stage: Int, num_threads: Int, TileT: AnyType](tile: TileT, m_abs: UInt32, n_abs: UInt32, m_end: UInt32, expert_id: Int32, p3_cfg: P3PeerSendConfig, p3_control: Int, tid: Int)

No-op; the epilogue stores locally instead.

service​

static def service[TilesT: AnyType](tiles: TilesT, send_tid: Int, p3_control: Int, p3_cfg: P3PeerSendConfig)

No-op; there are no sink warps.

drain​

static def drain(p3_control: Int, p3_cfg: P3PeerSendConfig)

No-op; nothing is ever deferred.

shutdown​

static def shutdown(p3_control: Int, p3_cfg: P3PeerSendConfig, drain_pending: Bool)

No-op; there are no sink warps to retire.

Was this page helpful?