agent
This commit is contained in:
parent
59593c07e3
commit
79b3f6728d
15
agent.go
15
agent.go
|
@ -42,20 +42,19 @@ func (agt *Agent) startAgent() {
|
|||
globalConf := <-cfgStarted
|
||||
|
||||
//2. evt start()
|
||||
evtStartChn := make(chan bool, 0)
|
||||
err := evt.Start(evtStartChn)
|
||||
//if err != nil {
|
||||
// processError(err)
|
||||
//}
|
||||
<- evtStartChn
|
||||
evtStarted := make(chan bool, 0)
|
||||
if err := evt.Start(evtStarted); err != nil {
|
||||
log.Println(err)
|
||||
return
|
||||
}
|
||||
<-evtStarted
|
||||
//3. dat start()
|
||||
datStarted := make(chan bool)
|
||||
dat.Start(datStarted, globalConf)
|
||||
<-datStarted
|
||||
//4. pol start()
|
||||
polStarted := make(chan bool)
|
||||
err := pol.Start(polStarted, globalConf)
|
||||
if err != nil {
|
||||
if err := pol.Start(polStarted, globalConf); err != nil {
|
||||
log.Println(err)
|
||||
return
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue
Block a user