Skip to content

Commit f559e63

Browse files
committed
[Controller] get data error from mysql and return directly
1 parent 266b269 commit f559e63

File tree

1 file changed

+20
-4
lines changed
  • server/controller/trisolaris/node

1 file changed

+20
-4
lines changed

server/controller/trisolaris/node/node.go

Lines changed: 20 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -325,8 +325,16 @@ func (n *NodeInfo) initTSDBInfo() {
325325
}
326326

327327
func (n *NodeInfo) generateTSDBRegion() {
328-
dbAZTSDBConns, _ := dbmgr.DBMgr[models.AZAnalyzerConnection](n.db).Gets()
329-
dbRegions, _ := dbmgr.DBMgr[models.Region](n.db).Gets()
328+
dbAZTSDBConns, err := dbmgr.DBMgr[models.AZAnalyzerConnection](n.db).Gets()
329+
if err != nil {
330+
log.Error(err)
331+
return
332+
}
333+
dbRegions, err := dbmgr.DBMgr[models.Region](n.db).Gets()
334+
if err != nil {
335+
log.Error(err)
336+
return
337+
}
330338
lcuuidToRegionID := make(map[string]int)
331339
ipToRegionID := make(map[string]uint32)
332340
for _, region := range dbRegions {
@@ -341,7 +349,11 @@ func (n *NodeInfo) generateTSDBRegion() {
341349
}
342350

343351
func (n *NodeInfo) generatesysConfiguration() {
344-
dbSysConfigurations, _ := dbmgr.DBMgr[models.SysConfiguration](n.db).Gets()
352+
dbSysConfigurations, err := dbmgr.DBMgr[models.SysConfiguration](n.db).Gets()
353+
if err != nil {
354+
log.Error(err)
355+
return
356+
}
345357
sysConfigurationToValue := make(map[string]string)
346358
if dbSysConfigurations != nil {
347359
for _, sysConfig := range dbSysConfigurations {
@@ -419,7 +431,11 @@ func (n *NodeInfo) GetLocalControllers() []*trident.DeepFlowServerInstanceInfo {
419431
func (n *NodeInfo) updateTSDBInfo() {
420432
n.generateTSDBRegion()
421433
n.generatesysConfiguration()
422-
dbTSDBs, _ := dbmgr.DBMgr[models.Analyzer](n.db).Gets()
434+
dbTSDBs, err := dbmgr.DBMgr[models.Analyzer](n.db).Gets()
435+
if err != nil {
436+
log.Error(err)
437+
return
438+
}
423439
dbKeys := mapset.NewSet()
424440
ipToTSDB := make(map[string]*models.Analyzer)
425441
tsdbToNATIP := make(map[string]string)

0 commit comments

Comments
 (0)