Function singleMachineJob

singleMachine.go:17–33

(input []string, nWorker int, nReducer int, plugin string, storeInRAM bool)

}

func singleMachineJob(input []string, nWorker int, nReducer int, plugin string, storeInRAM bool) {
	var wg sync.WaitGroup

	wg.Add(1)
	go func() {
		startMaster(input, nWorker, nReducer)
		wg.Done()
	}()

	wg.Add(1)
	go func() {
		startSingleMachineWorker(plugin, nWorker, nReducer, storeInRAM)
		wg.Done()
	}()

	wg.Wait()
}