Function StartMaster

master/mainInterface.go:27–54

(files []string, nWorker int, nReduce int, addr string)

}

func StartMaster(files []string, nWorker int, nReduce int, addr string) {
	// start gRPC server
	listener, err := net.Listen("tcp", addr)
	if err != nil {
		log.Panic(err)
	}
	ms := NewMaster(nWorker, nReduce)
	baseServer := grpc.NewServer()
	rpc.RegisterMasterServer(baseServer, ms)
	go baseServer.Serve(listener)

	log.Info("[Master] Master gRPC server start")

	// Check the worker is enough
	ms.(*Master).waitForEnoughWorker()
	go ms.(*Master).PeriodicHealthCheck()

	// Split input file (100,000 lines per chunk)
	ms.(*Master).distributeWork(files)

	ms.(*Master).distributeMapTask()

	ms.(*Master).distributeReduceTask()

	ms.(*Master).endWorkers()

	baseServer.Stop()
}