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

Changed a log line

Browse Source
This commit is contained in:
Diptanu Choudhury
2016-03-23 19:20:08 -07:00
parent c8622d8547
commit 4a2bc83c14
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
client/consul/sync.go
View File

@@ -275,7 +275,8 @@ func (c *ConsulService) deregisterCheck(ID string) error {
return c.client.Agent().CheckDeregister(ID)
}
// PeriodicSync triggers periodic syncing of services and checks with Consul
// PeriodicSync triggers periodic syncing of services and checks with Consul.
// This is a long lived go-routine which is stopped during shutdown
func (c *ConsulService) PeriodicSync() {
sync := time.After(syncInterval)
for {

9
client/driver/executor/executor.go
View File

@@ -266,12 +266,13 @@ func (e *UniversalExecutor) UpdateTask(task *structs.Task) error {
e.lre.MaxFiles = task.LogConfig.MaxFiles
e.lre.FileSize = fileSize
var err error
// Re-syncing task with consul service
if e.consulService != nil {
err = e.consulService.SyncTask(task)
if err := e.consulService.SyncTask(task); err != nil {
return err
}
}
return err
return nil
}
func (e *UniversalExecutor) wait() {
@@ -365,7 +366,7 @@ func (e *UniversalExecutor) RegisterServices() error {
}
func (e *UniversalExecutor) DeregisterServices() error {
e.logger.Printf("[ERR] executor: de-registering services and shutting down consul service")
e.logger.Printf("[INFO] executor: de-registering services and shutting down consul service")
if e.consulService != nil {
return e.consulService.Shutdown()
}