mpi

package

v0.0.0-...-885514b Latest Latest Go to latest Published: Nov 28, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sunblaze-ucb/simpleMPI

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Close()
func GetHash(str string)
func GetLocalIP() ([]string, error)
func ParseConfig(ConfigFilePath string) config
func ReceiveBytes(size uint64, rank uint64) ([]byte, error)
func SendBytes(buf []byte, rank uint64) error
func SerializeWorld(world *MPIWorld) []byte
func SetIPPool(filePath string, world *MPIWorld) error
type MPIWorld
- func DeserializeWorld(buf []byte) *MPIWorld
- func WorldInit(HostFilePath string, ConfigFilePath string) *MPIWorld

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	SelfRank              uint64
	MasterToSlaveTCPConn  []*net.Conn
	SlaveToMasterTCPConn  *net.Conn
	MasterToSlaveListener []*net.Listener
	SlaveOutputs          []bytes.Buffer
	SlaveOutputsErr       []bytes.Buffer
	BytesSent             uint64
	BytesReceived         uint64
	WorldSize             uint64
)

Functions ¶

func Close ¶

func Close()

func GetHash ¶

func GetHash(str string)

func GetLocalIP ¶

func GetLocalIP() ([]string, error)

func ParseConfig ¶

func ParseConfig(ConfigFilePath string) config

func ReceiveBytes ¶

func ReceiveBytes(size uint64, rank uint64) ([]byte, error)

If Master calls this function, rank is required, it will receive from rank-th slave If Slave calls this function, rank is not required, it will receive from Master

func SendBytes ¶

func SendBytes(buf []byte, rank uint64) error

func SerializeWorld ¶

func SerializeWorld(world *MPIWorld) []byte

func SetIPPool ¶

func SetIPPool(filePath string, world *MPIWorld) error

Types ¶

type MPIWorld ¶

type MPIWorld struct {
	IPPool []string
	Port   []uint64
	// contains filtered or unexported fields
}

func DeserializeWorld ¶

func DeserializeWorld(buf []byte) *MPIWorld

func WorldInit ¶

func WorldInit(HostFilePath string, ConfigFilePath string) *MPIWorld

Source Files ¶

View all Source files

mpi.go

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