mpi

Documentation

Index

• Variables
• func Close()
• func GetHash(str string)
• func GetLocalIP() ([]string, error)
• 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(IPfilePath string, SSHKeyFilePath string, SSHUserName string) *MPIWorld

Variables

var (
	SelfRank                   uint64
	DispatcherToWorkerTCPConn  []*net.Conn
	WorkerToDispatcherTCPConn  *net.Conn
	DispatcherToWorkerListener []*net.Listener
	WorkerOutputs              []bytes.Buffer
	WorkerOutputsErr           []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 ReceiveBytes

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

If Dispatcher calls this function, rank is required, it will receive from rank-th worker If Worker calls this function, rank is not required, it will receive from Dispatcher

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(IPfilePath string, SSHKeyFilePath string, SSHUserName string) *MPIWorld