|
@@ -187,7 +187,7 @@ func startEtcd(cfg *embed.Config) (<-chan struct{}, <-chan error, error) {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return nil, nil, err
|
|
return nil, nil, err
|
|
|
}
|
|
}
|
|
|
- osutil.RegisterInterruptHandler(e.Server.Stop)
|
|
|
|
|
|
|
+ osutil.RegisterInterruptHandler(e.Close)
|
|
|
select {
|
|
select {
|
|
|
case <-e.Server.ReadyNotify(): // wait for e.Server to join the cluster
|
|
case <-e.Server.ReadyNotify(): // wait for e.Server to join the cluster
|
|
|
case <-e.Server.StopNotify(): // publish aborted from 'ErrStopped'
|
|
case <-e.Server.StopNotify(): // publish aborted from 'ErrStopped'
|