Browse Source

consul: Handle API changes in StateStore

pull/19/head
Armon Dadgar 11 years ago
parent
commit
98fffdacb5
  1. 2
      consul/fsm_test.go
  2. 8
      consul/leader.go
  3. 5
      consul/state_store_test.go

2
consul/fsm_test.go

@ -290,7 +290,7 @@ func TestFSM_DeregisterNode(t *testing.T) {
// Verify service not registered // Verify service not registered
_, services := fsm.state.NodeServices("foo") _, services := fsm.state.NodeServices("foo")
if len(services.Services) != 0 { if services != nil {
t.Fatalf("Services: %v", services) t.Fatalf("Services: %v", services)
} }

8
consul/leader.go

@ -174,9 +174,11 @@ func (s *Server) handleAliveMember(member serf.Member) error {
if service != nil { if service != nil {
match := false match := false
_, services := state.NodeServices(member.Name) _, services := state.NodeServices(member.Name)
for id, _ := range services.Services { if services != nil {
if id == service.ID { for id, _ := range services.Services {
match = true if id == service.ID {
match = true
}
} }
} }
if !match { if !match {

5
consul/state_store_test.go

@ -302,9 +302,8 @@ func TestDeleteNode(t *testing.T) {
if idx != 23 { if idx != 23 {
t.Fatalf("bad: %v", idx) t.Fatalf("bad: %v", idx)
} }
_, ok := services.Services["api"] if services != nil {
if ok { t.Fatalf("has services: %#v", services)
t.Fatalf("has api: %#v", services)
} }
idx, checks := store.NodeChecks("foo") idx, checks := store.NodeChecks("foo")

Loading…
Cancel
Save