Merge pull request #24 from savitaashture/logscse

tianxiaoliang · web-flow · commit fd971cfe843f · 2018-06-14T15:29:51.000+08:00
modified condition check
diff --git a/csemonitor.go b/csemonitor.go
@@ -67,12 +67,14 @@ func (reporter *Reporter) Run() {
 			instances, ok := registry.SelfInstancesCache.Get(reporter.serviceID)
 
 			if !ok {
-				lager.Logger.Warnf("get SelfInstancesCache failed for, sid: %s", reporter.serviceID)
+				lager.Logger.Warnf("waiting for instance registration: [%s]", reporter.serviceID)
+				continue
 			}
 
 			instanceIDs, ok := instances.([]string)
 			if !ok {
-				lager.Logger.Warnf("type asserts failed, sid: %s", reporter.serviceID)
+				lager.Logger.Warnf("type assert of instance failed, sid: %s", reporter.serviceID)
+				continue
 			}
 
 			for _, instance := range instanceIDs {

Original file line number	Diff line number	Diff line change
`@@ -67,12 +67,14 @@ func (reporter *Reporter) Run() {`
`67`	`67`	`instances, ok := registry.SelfInstancesCache.Get(reporter.serviceID)`
`68`	`68`
`69`	`69`	`if !ok {`
`70`		`- lager.Logger.Warnf("get SelfInstancesCache failed for, sid: %s", reporter.serviceID)`
	`70`	`+ lager.Logger.Warnf("waiting for instance registration: [%s]", reporter.serviceID)`
	`71`	`+ continue`
`71`	`72`	`}`
`72`	`73`
`73`	`74`	`instanceIDs, ok := instances.([]string)`
`74`	`75`	`if !ok {`
`75`		`- lager.Logger.Warnf("type asserts failed, sid: %s", reporter.serviceID)`
	`76`	`+ lager.Logger.Warnf("type assert of instance failed, sid: %s", reporter.serviceID)`
	`77`	`+ continue`
`76`	`78`	`}`
`77`	`79`
`78`	`80`	`for _, instance := range instanceIDs {`