rdma

Documentation

Overview

Package rdma provides the implementation of an RDMA engine.

Index

• type Engine
  • func NewEngine(name string, engine akita.Engine, localModules cache.LowModuleFinder, ...) *Engine
  • func (e *Engine) SetFreq(freq akita.Freq)
  • func (e *Engine) Tick(now akita.VTimeInSec) bool
• type RDMADrainReq
  • func (r *RDMADrainReq) Meta() *akita.MsgMeta
• type RDMADrainReqBuilder
  • func (b RDMADrainReqBuilder) Build() *RDMADrainReq
  • func (b RDMADrainReqBuilder) WithDst(dst akita.Port) RDMADrainReqBuilder
  • func (b RDMADrainReqBuilder) WithSendTime(t akita.VTimeInSec) RDMADrainReqBuilder
  • func (b RDMADrainReqBuilder) WithSrc(src akita.Port) RDMADrainReqBuilder
• type RDMADrainRsp
  • func (r *RDMADrainRsp) Meta() *akita.MsgMeta
• type RDMADrainRspBuilder
  • func (b RDMADrainRspBuilder) Build() *RDMADrainRsp
  • func (b RDMADrainRspBuilder) WithDst(dst akita.Port) RDMADrainRspBuilder
  • func (b RDMADrainRspBuilder) WithSendTime(t akita.VTimeInSec) RDMADrainRspBuilder
  • func (b RDMADrainRspBuilder) WithSrc(src akita.Port) RDMADrainRspBuilder
• type RDMARestartReq
  • func (r *RDMARestartReq) Meta() *akita.MsgMeta
• type RDMARestartReqBuilder
  • func (b RDMARestartReqBuilder) Build() *RDMARestartReq
  • func (b RDMARestartReqBuilder) WithDst(dst akita.Port) RDMARestartReqBuilder
  • func (b RDMARestartReqBuilder) WithSendTime(t akita.VTimeInSec) RDMARestartReqBuilder
  • func (b RDMARestartReqBuilder) WithSrc(src akita.Port) RDMARestartReqBuilder
• type RDMARestartRsp
  • func (r *RDMARestartRsp) Meta() *akita.MsgMeta
• type RDMARestartRspBuilder
  • func (b RDMARestartRspBuilder) Build() *RDMARestartRsp
  • func (b RDMARestartRspBuilder) WithDst(dst akita.Port) RDMARestartRspBuilder
  • func (b RDMARestartRspBuilder) WithSendTime(t akita.VTimeInSec) RDMARestartRspBuilder
  • func (b RDMARestartRspBuilder) WithSrc(src akita.Port) RDMARestartRspBuilder

Types

type Engine

type Engine struct {
	*akita.TickingComponent

	ToOutside akita.Port

	ToL1 akita.Port
	ToL2 akita.Port

	CtrlPort akita.Port

	RemoteRDMAAddressTable cache.LowModuleFinder
	// contains filtered or unexported fields
}

An Engine is a component that helps one GPU to access the memory on another GPU

func NewEngine

func NewEngine(
	name string,
	engine akita.Engine,
	localModules cache.LowModuleFinder,
	remoteModules cache.LowModuleFinder,
) *Engine

func (*Engine) SetFreq

func (e *Engine) SetFreq(freq akita.Freq)

func (*Engine) Tick

func (e *Engine) Tick(now akita.VTimeInSec) bool

type RDMADrainReq

type RDMADrainReq struct {
	akita.MsgMeta
}

A RDMADrainReq asks the rdma to stop processing requests from L1 while allowing pending requests to L2 to complete

func (*RDMADrainReq) Meta

func (r *RDMADrainReq) Meta() *akita.MsgMeta

Meta returns the meta data associated with the message.

type RDMADrainReqBuilder

type RDMADrainReqBuilder struct {
	// contains filtered or unexported fields
}

RDMADrainReqBuilder can build RDMA drain requests

func (RDMADrainReqBuilder) Build

func (b RDMADrainReqBuilder) Build() *RDMADrainReq

Build creats a new RDMADrainReq

func (RDMADrainReqBuilder) WithDst

func (b RDMADrainReqBuilder) WithDst(dst akita.Port) RDMADrainReqBuilder

WithDst sets the destination of the request to build.

func (RDMADrainReqBuilder) WithSendTime

func (b RDMADrainReqBuilder) WithSendTime(
	t akita.VTimeInSec,
) RDMADrainReqBuilder

WithSendTime sets the send time of the request to build.:w

func (RDMADrainReqBuilder) WithSrc

func (b RDMADrainReqBuilder) WithSrc(src akita.Port) RDMADrainReqBuilder

WithSrc sets the source of the request to build.

type RDMADrainRsp

type RDMADrainRsp struct {
	akita.MsgMeta
}

A RDMADrainRsp is a drain complete response to a RDMA Drain Req

func (*RDMADrainRsp) Meta

func (r *RDMADrainRsp) Meta() *akita.MsgMeta

Meta returns the meta data associated with the message.

type RDMADrainRspBuilder

type RDMADrainRspBuilder struct {
	// contains filtered or unexported fields
}

RDMADrainRspBuilder can build RDMA drain responses

func (RDMADrainRspBuilder) Build

func (b RDMADrainRspBuilder) Build() *RDMADrainRsp

Build creats a new RDMADrainRsp

func (RDMADrainRspBuilder) WithDst

func (b RDMADrainRspBuilder) WithDst(dst akita.Port) RDMADrainRspBuilder

WithDst sets the destination of the request to build.

func (RDMADrainRspBuilder) WithSendTime

func (b RDMADrainRspBuilder) WithSendTime(
	t akita.VTimeInSec,
) RDMADrainRspBuilder

WithSendTime sets the send time of the request to build

func (RDMADrainRspBuilder) WithSrc

func (b RDMADrainRspBuilder) WithSrc(src akita.Port) RDMADrainRspBuilder

WithSrc sets the source of the request to build.

type RDMARestartReq

type RDMARestartReq struct {
	akita.MsgMeta
}

A RDMARestartReq is a message to allow rdma to continue processing reqs from L1

func (*RDMARestartReq) Meta

func (r *RDMARestartReq) Meta() *akita.MsgMeta

Meta returns the meta data associated with the message.

type RDMARestartReqBuilder

type RDMARestartReqBuilder struct {
	// contains filtered or unexported fields
}

RDMARestartBuilder can build RDMA restart req

func (RDMARestartReqBuilder) Build

func (b RDMARestartReqBuilder) Build() *RDMARestartReq

Build creats a new RDMADrainRsp

func (RDMARestartReqBuilder) WithDst

func (b RDMARestartReqBuilder) WithDst(dst akita.Port) RDMARestartReqBuilder

WithDst sets the destination of the request to build.

func (RDMARestartReqBuilder) WithSendTime

func (b RDMARestartReqBuilder) WithSendTime(
	t akita.VTimeInSec,
) RDMARestartReqBuilder

WithSendTime sets the send time of the request to build

func (RDMARestartReqBuilder) WithSrc

func (b RDMARestartReqBuilder) WithSrc(src akita.Port) RDMARestartReqBuilder

WithSrc sets the source of the request to build.

type RDMARestartRsp

type RDMARestartRsp struct {
	akita.MsgMeta
}

A RDMADrainRsp is a drain complete response to a RDMA Drain Req

func (*RDMARestartRsp) Meta

func (r *RDMARestartRsp) Meta() *akita.MsgMeta

Meta returns the meta data associated with the message.

type RDMARestartRspBuilder

type RDMARestartRspBuilder struct {
	// contains filtered or unexported fields
}

RDMADrainRspBuilder can build RDMA drain responses

func (RDMARestartRspBuilder) Build

func (b RDMARestartRspBuilder) Build() *RDMARestartRsp

Build creats a new RDMADrainRsp

func (RDMARestartRspBuilder) WithDst

func (b RDMARestartRspBuilder) WithDst(dst akita.Port) RDMARestartRspBuilder

WithDst sets the destination of the request to build.

func (RDMARestartRspBuilder) WithSendTime

func (b RDMARestartRspBuilder) WithSendTime(
	t akita.VTimeInSec,
) RDMARestartRspBuilder

WithSendTime sets the send time of the request to build

func (RDMARestartRspBuilder) WithSrc

func (b RDMARestartRspBuilder) WithSrc(src akita.Port) RDMARestartRspBuilder

WithSrc sets the source of the request to build.