mr

type ByKey []KeyValue

type Dispatcher struct {
	TimeOut          time.Duration      //默认10秒
	M                *Master            //主节点全局结构
	ReduceSourceChan chan *ReduceSource // 发送 reduce 的任务 执行内容
	CleanWorkerChan  chan uint64        // 清理失效的worker
}

type ExampleArgs struct {
	X int
}

type ExampleReply struct {
	Y int
}

type GetTaskReq struct {
	WorkerID uint64
}

type GetTaskRes struct {
	Code int
	Msg  string
	T    *Task
}

type JobState struct {
	MatrixSource [][]string // MC * RC
	MC           int
	RC           int
	MCDone       int32
	// contains filtered or unexported fields
}

type KeyValue struct {
	Key   string
	Value string
}

type Master struct {
	// Your definitions here.
	S  *JobState
	TP *TaskPool
	W  *sync.Map
}

type Ping struct {
	WorkerID uint64
}

type Pong struct {
	Code int
}

type ReduceSource struct {
	MIdx      int
	MapSource []string // map 任务返回的 source 列表
}

type RegisterReq struct {
}

type RegisterRes struct {
	WorkerID uint64
}

type ResultReq struct {
	WorkerID uint64
	Code     int // 0 代表 map 1 代表 reduce 2代表 失败
	Msg      string
	M        []string
}

type ResultRes struct {
	Code int
	Msg  string
}

type Task struct {
	Status int // 0 未完成 1工作中 2已完成
	Type   int // 0 map 任务 1 reduce 任务 2 shut down 3 retry
	Conf   *TaskConf
}

type TaskConf struct {
	Source []string // 兼容两种任务
	RNum   int      // 当前 map 任务的 任务编号 如果是reduce任务 则为-1
	MNum   int      // 当前 reduce 任务的 任务编号 如果是map任务 则为-1
	RC     int      // reduce 的任务数
}

type TaskPool struct {
	Pool chan *Task
}

type WorkerSession struct {
	WorkerID     uint64
	Status       int // 0 空闲状态 1 工作状态 2 无法正常工作
	T            *Task
	Mux          *sync.RWMutex
	LastPingTs   int64
	PingPongChan chan struct{}
}