mirror of https://github.com/status-im/consul.git
consul: start RPC after fully initialized. Fixes #160
This commit is contained in:
parent
ab4e3de185
commit
938371ee40
|
@ -177,12 +177,6 @@ func NewServer(config *Config) (*Server, error) {
|
||||||
shutdownCh: make(chan struct{}),
|
shutdownCh: make(chan struct{}),
|
||||||
}
|
}
|
||||||
|
|
||||||
// Initialize the RPC layer
|
|
||||||
if err := s.setupRPC(tlsConfig); err != nil {
|
|
||||||
s.Shutdown()
|
|
||||||
return nil, fmt.Errorf("Failed to start RPC layer: %v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Initialize the Raft server
|
// Initialize the Raft server
|
||||||
if err := s.setupRaft(); err != nil {
|
if err := s.setupRaft(); err != nil {
|
||||||
s.Shutdown()
|
s.Shutdown()
|
||||||
|
@ -209,6 +203,12 @@ func NewServer(config *Config) (*Server, error) {
|
||||||
return nil, fmt.Errorf("Failed to start wan serf: %v", err)
|
return nil, fmt.Errorf("Failed to start wan serf: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Initialize the RPC layer
|
||||||
|
if err := s.setupRPC(tlsConfig); err != nil {
|
||||||
|
s.Shutdown()
|
||||||
|
return nil, fmt.Errorf("Failed to start RPC layer: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
return s, nil
|
return s, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue