Commit dec684af authored by duanjinfei's avatar duanjinfei

add log print

parent e196e946
...@@ -145,6 +145,7 @@ func (m *ModelHandler) MonitorModelStatus() { ...@@ -145,6 +145,7 @@ func (m *ModelHandler) MonitorModelStatus() {
select { select {
case <-ticker.C: case <-ticker.C:
{ {
log.Info("Start monitoring model status for update image info")
imageList, _ := m.dockerOp.PsImages() imageList, _ := m.dockerOp.PsImages()
if imageList != nil && len(imageList) > 0 { if imageList != nil && len(imageList) > 0 {
for _, image := range imageList { for _, image := range imageList {
...@@ -159,10 +160,12 @@ func (m *ModelHandler) MonitorModelStatus() { ...@@ -159,10 +160,12 @@ func (m *ModelHandler) MonitorModelStatus() {
if err != nil { if err != nil {
continue continue
} }
log.WithField("name", model.ImageName).Info("Monitor model status update image info")
} }
} }
} }
} }
log.Info("Start monitoring model status for update container info")
containerList := m.dockerOp.ListContainer() containerList := m.dockerOp.ListContainer()
if containerList != nil && len(containerList) > 0 { if containerList != nil && len(containerList) > 0 {
for _, container := range containerList { for _, container := range containerList {
...@@ -179,6 +182,7 @@ func (m *ModelHandler) MonitorModelStatus() { ...@@ -179,6 +182,7 @@ func (m *ModelHandler) MonitorModelStatus() {
if err != nil { if err != nil {
continue continue
} }
log.WithField("name", model.ImageName).Info("Monitor model status update container info")
} }
} }
} }
......
...@@ -35,12 +35,16 @@ func StartMonitor() { ...@@ -35,12 +35,16 @@ func StartMonitor() {
monitorNm := NewMonitorNm(dockerOp, modelHandler) monitorNm := NewMonitorNm(dockerOp, modelHandler)
go modelHandler.MonitorModelInfo() go modelHandler.MonitorModelInfo()
log.WithField("func", "MonitorModelInfo").Info("--------------------Start modelHandler--------------------")
go modelHandler.MonitorModelStatus() go modelHandler.MonitorModelStatus()
log.WithField("func", "MonitorModelStatus").Info("--------------------Start modelHandler--------------------")
go monitorNm.monitorNodeManagerSeed() go monitorNm.monitorNodeManagerSeed()
log.WithField("func", "monitorNodeManagerSeed").Info("--------------------Start monitorNm--------------------")
go monitorNm.monitorNmClient() go monitorNm.monitorNmClient()
log.WithField("func", "monitorNmClient").Info("--------------------Start monitorNm--------------------")
for !monitorNm.IsInit { for !monitorNm.IsInit {
time.Sleep(time.Second) time.Sleep(time.Second)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment