mpi

Nov 11, 2023

Changes in this version

+ func SetIPPoolFromFile(filePath string, world *MPIWorld) error

+ func SetIPPoolFromKubernetes(world *MPIWorld) error

Oct 2, 2023

Changes in this version

+ var DispatcherToWorkerListener []*net.Listener

+ var DispatcherToWorkerTCPConn []*net.Conn

+ var WorkerOutputs []bytes.Buffer

+ var WorkerOutputsErr []bytes.Buffer

+ var WorkerToDispatcherTCPConn *net.Conn

Oct 2, 2023

Changes in this version

+ var BytesReceived uint64

+ var BytesSent uint64

+ var MasterToSlaveListener []*net.Listener

+ var MasterToSlaveTCPConn []*net.Conn

+ var SelfRank uint64

+ var SlaveOutputs []bytes.Buffer

+ var SlaveOutputsErr []bytes.Buffer

+ var SlaveToMasterTCPConn *net.Conn

+ var WorldSize uint64

+ 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 struct

+ IPPool []string

+ Port []uint64

+ func DeserializeWorld(buf []byte) *MPIWorld

+ func WorldInit(IPfilePath string, SSHKeyFilePath string, SSHUserName string) *MPIWorld