kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-03 17:05:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

locks for fingerprint reads/writes

Browse Source
This commit is contained in:
Chelsea Holland Komlo
2018-01-30 11:27:26 -05:00
parent ae889b4fba
commit e8aaa93459
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
client/client.go
View File

@@ -956,7 +956,9 @@ func (c *Client) fingerprint() error {
request := &cstructs.FingerprintRequest{Config: c.config, Node: c.config.Node}
var response cstructs.FingerprintResponse
c.configLock.Lock()
err = f.Fingerprint(request, &response)
c.configLock.Unlock()
if err != nil {
return err
}
@@ -988,7 +990,9 @@ func (c *Client) fingerprintPeriodic(name string, f fingerprint.Fingerprint, d t
case <-time.After(d):
request := &cstructs.FingerprintRequest{Config: c.config, Node: c.config.Node}
var response cstructs.FingerprintResponse
c.configLock.Lock()
err := f.Fingerprint(request, &response)
c.configLock.Unlock()
if err != nil {
c.logger.Printf("[DEBUG] client: periodic fingerprinting for %v failed: %v", name, err)
@@ -1036,9 +1040,11 @@ func (c *Client) setupDrivers() error {
request := &cstructs.FingerprintRequest{Config: c.config, Node: c.config.Node}
var response cstructs.FingerprintResponse
c.configLock.Lock()
if err := d.Fingerprint(request, &response); err != nil {
return err
}
c.configLock.Unlock()
c.updateNodeFromFingerprint(&response)