This commit is contained in:
insanity@loafle.com 2017-05-16 15:08:24 +09:00
commit 59593c07e3

View File

@ -42,6 +42,12 @@ func (agt *Agent) startAgent() {
globalConf := <-cfgStarted globalConf := <-cfgStarted
//2. evt start() //2. evt start()
evtStartChn := make(chan bool, 0)
err := evt.Start(evtStartChn)
//if err != nil {
// processError(err)
//}
<- evtStartChn
//3. dat start() //3. dat start()
datStarted := make(chan bool) datStarted := make(chan bool)
dat.Start(datStarted, globalConf) dat.Start(datStarted, globalConf)
@ -152,6 +158,8 @@ func (agt *Agent) stopAgent() {
//evt result //evt result
evt.AddEventData(msg.TaskResult{msg.AGT_STOP, true, nil }) evt.AddEventData(msg.TaskResult{msg.AGT_STOP, true, nil })
//evt stop() //evt stop()
evt.Stop()
} }
func (agt *Agent) processStartSensor(task msg.AgentTask) { func (agt *Agent) processStartSensor(task msg.AgentTask) {