Function checkInstanceStatus

backend/slice.go:269–307

(name string, cp ConnectionPool, healthCheckSql string)

}

func checkInstanceStatus(name string, cp ConnectionPool, healthCheckSql string) (PooledConnect, error) {
	defer func() {
		if err := recover(); err != nil {
			log.Fatal("[ns:%s, %s] check instance status panic:%s", name, cp.Addr(), err)
		}
	}()

	pc, err := cp.GetCheck(context.Background())
	if err != nil {
		if pc != nil {
			pc.Close()
		}
		return nil, fmt.Errorf("get check conn err:%s", err)
	}

	if pc == nil {
		return nil, fmt.Errorf("get nil check conn, ins:%s", cp.Addr())
	}

	if len(healthCheckSql) > 0 {
		_, err := pc.ExecuteWithTimeout(healthCheckSql, 0, ExecTimeOut)
		if err == nil {
			cp.SetLastChecked()
			return pc, nil
		}
		log.Warn("[ns:%s instance:%s] exec health check sql:%s sqlError:%v", name, cp.Addr(), healthCheckSql, err)
		if mysql.IsServerShutdownErr(err) || mysql.IsTableSpaceMissingErr(err) || mysql.IsTableSpaceDiscardeErr(err) || err == ErrExecuteTimeout {
			pc.Close()
			return nil, fmt.Errorf("exec health check query error:%s", err)
		}
	}
	if err = pc.PingWithTimeout(GetConnTimeout); err != nil {
		pc.Close()
		return nil, fmt.Errorf("ping conn error:%s", err)
	}

	cp.SetLastChecked()
	return pc, nil
}

func allSlaveIsOffline(SlaveStatusMap *sync.Map) bool {
	var result = true