Fix some bug & improve logging

ellipti-labs · Sep 9, 2019 · 99de53f · 99de53f
1 parent 67ae0e2
commit 99de53f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/oracle/routine.go b/oracle/routine.go
@@ -96,6 +96,7 @@ func (os *OracleService) startRoutine() {
 				res, err := os.broadcast(voteMsgs)
 				if err != nil {
 					os.Logger.Error("Fail to send vote msgs", err.Error())
+					os.prevoteInited = false // Retry initialization (prevote msg).
 					return
 				}
 				if tick > res.Height/VotePeriod {

diff --git a/price/routine.go b/price/routine.go
@@ -22,7 +22,7 @@ func (ps PriceService) startRoutine() {
 					// Sleep a bit. It seems that logger is not thread safe.
 					// Without sleeping, log is often broken.
 					// By sleeping, mitigate this problem.
-					time.Sleep(time.Millisecond * 100)
+					time.Sleep(time.Millisecond * 200)
 				}
 			}
 		}()

diff --git a/price/types.go b/price/types.go
@@ -41,6 +41,6 @@ func (meta *SourceMeta) Fetch(logger log.Logger) {
 		if err != nil {
 			logger.Error(fmt.Sprintf("Fail to parse price %s from %s: %s", source.Pair(), source.Market(), err.Error()))
 		}
-		logger.Info(fmt.Sprintf("Fetch %s from %s: %s", source.Pair(), source.Market(), price))
+		logger.Info(fmt.Sprintf("Fetch %s from %s: %s", source.Pair(), source.Market(), price), "market", source.Market(), "pair", source.Pair())
 	}
 }