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

Added some comments to code

Browse Source
This commit is contained in:
Diptanu Choudhury
2015-11-05 16:48:15 -08:00
parent af39146b03
commit ad44e4eeb5
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
client/task_runner.go
View File

@@ -187,7 +187,7 @@ func (r *TaskRunner) Run() {
r.task.Name, r.allocID, err)
shouldRestart, when := r.restartTracker.nextRestart()
if !shouldRestart {
r.logger.Printf("[INFO] client: Not restarting task: %v ", r.task.Name)
r.logger.Printf("[INFO] client: Not restarting task: %v for alloc: %v ", r.task.Name, r.allocID)
r.setStatus(structs.AllocClientStatusDead, fmt.Sprintf("task failed with: %v", err))
break
}
@@ -219,14 +219,14 @@ func (r *TaskRunner) Run() {
}
// Cleanup after ourselves
r.logger.Printf("[INFO] client: completed task '%s' for alloc '%s'",
r.task.Name, r.allocID)
r.setStatus(structs.AllocClientStatusDead,
"task completed")
r.logger.Printf("[INFO] client: completed task '%s' for alloc '%s'", r.task.Name, r.allocID)
r.setStatus(structs.AllocClientStatusDead, "task completed")
r.DestroyState()
}
// This functions listens to messages from the driver and blocks until the
// driver exits
func (r *TaskRunner) monitorDriver(waitCh chan error, updateCh chan *structs.Task, destroyCh chan struct{}) error {
var err error
OUTER: