rdma

package
v1.8.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 7, 2020 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package rdma provides the implementation of an RDMA engine.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DrainReq added in v1.8.0

type DrainReq struct {
	akita.MsgMeta
}

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

func (*DrainReq) Meta added in v1.8.0

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

Meta returns the meta data associated with the message.

type DrainReqBuilder added in v1.8.0

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

DrainReqBuilder can build RDMA drain requests

func (DrainReqBuilder) Build added in v1.8.0

func (b DrainReqBuilder) Build() *DrainReq

Build creats a new DrainReq

func (DrainReqBuilder) WithDst added in v1.8.0

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

WithDst sets the destination of the request to build.

func (DrainReqBuilder) WithSendTime added in v1.8.0

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

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

func (DrainReqBuilder) WithSrc added in v1.8.0

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

WithSrc sets the source of the request to build.

type DrainRsp added in v1.8.0

type DrainRsp struct {
	akita.MsgMeta
}

DrainRsp is a drain complete response to a RDMA Drain Req

func (*DrainRsp) Meta added in v1.8.0

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

Meta returns the meta data associated with the message.

type DrainRspBuilder added in v1.8.0

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

DrainRspBuilder can build RDMA drain responses

func (DrainRspBuilder) Build added in v1.8.0

func (b DrainRspBuilder) Build() *DrainRsp

Build creats a new RDMADrainRsp

func (DrainRspBuilder) WithDst added in v1.8.0

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

WithDst sets the destination of the request to build.

func (DrainRspBuilder) WithSendTime added in v1.8.0

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

WithSendTime sets the send time of the request to build

func (DrainRspBuilder) WithSrc added in v1.8.0

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

WithSrc sets the source of the request to build.

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

NewEngine creates new engine

func (*Engine) SetFreq

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

SetFreq sets freq

func (*Engine) SetLocalModuleFinder added in v1.8.1

func (e *Engine) SetLocalModuleFinder(lmf cache.LowModuleFinder)

SetLocalModuleFinder sets the table to lookup for local data.

func (*Engine) Tick

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

Tick checks if make progress

type RestartReq added in v1.8.0

type RestartReq struct {
	akita.MsgMeta
}

RestartReq is a message to allow rdma to continue processing reqs from L1

func (*RestartReq) Meta added in v1.8.0

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

Meta returns the meta data associated with the message.

type RestartReqBuilder added in v1.8.0

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

RestartReqBuilder can build RDMA restart req

func (RestartReqBuilder) Build added in v1.8.0

func (b RestartReqBuilder) Build() *RestartReq

Build creats a new RDMADrainRsp

func (RestartReqBuilder) WithDst added in v1.8.0

WithDst sets the destination of the request to build.

func (RestartReqBuilder) WithSendTime added in v1.8.0

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

WithSendTime sets the send time of the request to build

func (RestartReqBuilder) WithSrc added in v1.8.0

WithSrc sets the source of the request to build.

type RestartRsp added in v1.8.0

type RestartRsp struct {
	akita.MsgMeta
}

RestartRsp is a drain complete response to a RDMA Drain Req

func (*RestartRsp) Meta added in v1.8.0

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

Meta returns the meta data associated with the message.

type RestartRspBuilder added in v1.8.0

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

RestartRspBuilder can build RDMA drain responses

func (RestartRspBuilder) Build added in v1.8.0

func (b RestartRspBuilder) Build() *RestartRsp

Build creats a new RDMADrainRsp

func (RestartRspBuilder) WithDst added in v1.8.0

WithDst sets the destination of the request to build.

func (RestartRspBuilder) WithSendTime added in v1.8.0

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

WithSendTime sets the send time of the request to build

func (RestartRspBuilder) WithSrc added in v1.8.0

WithSrc sets the source of the request to build.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL