|
@@ -243,7 +243,9 @@ func NewServer(cfg *ServerConfig) (*EtcdServer, error) {
|
|
|
return nil, fmt.Errorf("member %s has already been bootstrapped", m.ID)
|
|
return nil, fmt.Errorf("member %s has already been bootstrapped", m.ID)
|
|
|
}
|
|
}
|
|
|
if cfg.ShouldDiscover() {
|
|
if cfg.ShouldDiscover() {
|
|
|
- str, err := discovery.JoinCluster(cfg.DiscoveryURL, cfg.DiscoveryProxy, m.ID, cfg.InitialPeerURLsMap.String())
|
|
|
|
|
|
|
+ var str string
|
|
|
|
|
+ var err error
|
|
|
|
|
+ str, err = discovery.JoinCluster(cfg.DiscoveryURL, cfg.DiscoveryProxy, m.ID, cfg.InitialPeerURLsMap.String())
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return nil, err
|
|
return nil, err
|
|
|
}
|
|
}
|
|
@@ -277,7 +279,9 @@ func NewServer(cfg *ServerConfig) (*EtcdServer, error) {
|
|
|
if cfg.ShouldDiscover() {
|
|
if cfg.ShouldDiscover() {
|
|
|
plog.Warningf("discovery token ignored since a cluster has already been initialized. Valid log found at %q", cfg.WALDir())
|
|
plog.Warningf("discovery token ignored since a cluster has already been initialized. Valid log found at %q", cfg.WALDir())
|
|
|
}
|
|
}
|
|
|
- snapshot, err := ss.Load()
|
|
|
|
|
|
|
+ var snapshot *raftpb.Snapshot
|
|
|
|
|
+ var err error
|
|
|
|
|
+ snapshot, err = ss.Load()
|
|
|
if err != nil && err != snap.ErrNoSnapshot {
|
|
if err != nil && err != snap.ErrNoSnapshot {
|
|
|
return nil, err
|
|
return nil, err
|
|
|
}
|
|
}
|