Skip to content

Commit

Permalink
Fix service registration bug
Browse files Browse the repository at this point in the history
  • Loading branch information
shaleman committed Feb 8, 2016
1 parent c359b47 commit 4607285
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion etcdService.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,11 @@ func (self *etcdPlugin) RegisterService(serviceInfo ServiceInfo) error {

log.Infof("Registering service key: %s, value: %+v", keyName, serviceInfo)

// if there is a previously registered service, de-register it
if self.serviceDb[keyName] != nil {
self.DeregisterService(serviceInfo)
}

// JSON format the object
jsonVal, err := json.Marshal(serviceInfo)
if err != nil {
Expand Down Expand Up @@ -224,7 +229,7 @@ func (self *etcdPlugin) DeregisterService(serviceInfo ServiceInfo) error {
// Find it in the database
srvState := self.serviceDb[keyName]
if srvState == nil {
log.Warnf("Could not find the service in db %s", keyName)
log.Errorf("Could not find the service in db %s", keyName)
return errors.New("Service not found")
}

Expand Down

0 comments on commit 4607285

Please sign in to comment.