Function newReduceTasks

master/reduceTaskInfo.go:26–32

(size int)

}

func newReduceTasks(size int) []ReduceTaskInfo {
	var ret []ReduceTaskInfo
	for i := 0; i < size; i++ {
		ret = append(ret, newReduceTask())
	}
	return ret
}

func (mt *ReduceTaskInfo) toRPC() *rpc.ReduceInfo {
	ret := &rpc.ReduceInfo{}