()
| 1036 | } |
| 1037 | |
| 1038 | func (epc *EtcdProcessCluster) Stop() (err error) { |
| 1039 | for _, p := range epc.Procs { |
| 1040 | if p == nil { |
| 1041 | continue |
| 1042 | } |
| 1043 | if curErr := p.Stop(); curErr != nil { |
| 1044 | if err != nil { |
| 1045 | err = fmt.Errorf("%w; %w", err, curErr) |
| 1046 | } else { |
| 1047 | err = curErr |
| 1048 | } |
| 1049 | } |
| 1050 | } |
| 1051 | return err |
| 1052 | } |
| 1053 | |
| 1054 | func (epc *EtcdProcessCluster) ConcurrentStop() (err error) { |
| 1055 | errCh := make(chan error, len(epc.Procs)) |