func()

in internal/master/map_task_master.go [1021:1049]

• 29 lines of code
• 9 McCabe index (conditional complexity)

func (m *MapTaskMaster) Clear(taskMaster taskmaster.TaskMaster) {
	m.TaskMaster.Clear(taskMaster)
	if m.taskStatusReqQueue != nil {
		m.taskStatusReqQueue.Clear()
	}
	if m.taskBlockingQueue != nil {
		m.taskBlockingQueue.Clear()
	}
	if m.taskDispatchReqHandler != nil {
		m.taskDispatchReqHandler.Clear()
	}
	if m.taskStatusReqBatchHandler != nil {
		m.taskStatusReqBatchHandler.Clear()
	}
	if m.taskProgressMap != nil {
		m.taskProgressMap = nil
	}
	if m.workerProgressMap != nil {
		m.workerProgressMap = nil
	}
	if m.taskResultMap != nil {
		m.taskResultMap = nil
	}
	if m.taskStatusMap != nil {
		m.taskStatusMap = nil
	}
	m.clearTasks(m.GetJobInstanceInfo().GetJobInstanceId())
	m.taskCounter = atomic.NewInt64(0)
}