func (t *dummySlave) Init(taskID uint64, framework taskgraph.Framework) {
	t.taskID = taskID
	t.framework = framework
	t.logger = log.New(os.Stdout, "", log.Ldate|log.Ltime|log.Lshortfile)

	t.epochChange = make(chan *event, 1)
	t.getP = make(chan *event, 1)
	t.getG = make(chan *event, 1)
	t.pDataReady = make(chan *event, 1)
	t.gDataReady = make(chan *event, 1)
	t.exitChan = make(chan struct{})
	go t.run()
}
// This is useful to bring the task up to speed from scratch or if it recovers.
This is useful to bring the task up to speed from scratch or if it recovers.
// This is useful to bring the task up to speed from scratch or if it recovers .
func (t *dummySlave) Init(taskID uint64, framework taskgraph.Framework) {
	t.taskID = taskID
	t.framework = framework
	t.logger = log.New(os.Stdout, "", log.Ldate|log.Ltime|log.Lshortfile)
	t.epochChange = make(chan *event, 1)
	t.getP = make(chan *event, 1)
	t.getG = make(chan *event, 1)
	t.pDataReady = make(chan *event, 1)
	t.gDataReady = make(chan *event, 1)
	t.exitChan = make(chan struct{})
	go t.run()
}
func ( t * dummySlave ) Init ( taskID uint64 , framework taskgraph . Framework ) { t . taskID = taskID t . framework = framework t . logger = log . New ( os . Stdout , " " , log . Ldate | log . Ltime | log . Lshortfile ) t . epochChange = make ( chan * event , 1 ) t . getP = make ( chan * event , 1 ) t . getG = make ( chan * event , 1 ) t . pDataReady = make ( chan * event , 1 ) t . gDataReady = make ( chan * event , 1 ) t . exitChan = make ( chan struct { } ) go t . run ( ) }
This is useful to bring the task up to speed from scratch or if it recovers.
This is useful to bring the task up to speed from scratch or if it recovers .