| | |
| | | for _, m := range mbs { |
| | | //fmt.Println("m", m) |
| | | if m.Name != a.conf.NodeName { //前缀:DSVAD:分析服务器 DSPAD:进出入pad |
| | | if strings.HasPrefix(a.conf.NodeName, "PSPAD"){ |
| | | if strings.HasPrefix(m.Name, "PSPAD") { |
| | | if strings.HasPrefix(a.conf.NodeName, "PAD"){ |
| | | if strings.HasPrefix(m.Name, "PAD") { |
| | | specmembername = m.Name |
| | | break |
| | | } |
| | | } |
| | | } |
| | | } |
| | | //if specmembername == "" { |
| | | // return nil, errors.New("other pad node not found in memberlist") |
| | | //} |
| | | if specmembername == "" { |
| | | return nil, errors.New("alive node not found in cluster") |
| | | } |
| | | //fmt.Println("mbs:", mbs, "a.conf.BindAddr:", a.conf.BindAddr, "specmembername:", specmembername) |
| | | |
| | | //query: get db file. |