Skip to content
This repository has been archived by the owner on Aug 5, 2020. It is now read-only.

Commit

Permalink
Merge pull request #117 from linxia/master
Browse files Browse the repository at this point in the history
Write logs before sending result to the channel
  • Loading branch information
phylake authored Oct 14, 2016
2 parents d55179c + acf84f2 commit 0d7dd6f
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 2 deletions.
4 changes: 4 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
**v2.4.2**

- fix missing or incomplete hook logs

**v2.4.1**

- gather hook log output by hook since they run concurrently
Expand Down
7 changes: 5 additions & 2 deletions hook/hook.go
Original file line number Diff line number Diff line change
Expand Up @@ -215,12 +215,13 @@ func ExecuteWithRunCapture(log log15.Logger,
var regionLogOutput bytes.Buffer
logger.SetHandler(log, &regionLogOutput)

successChan <- runner.runConfigHooks(log, &regionLogOutput, hooks, runArgs)
hooksResult := runner.runConfigHooks(log, &regionLogOutput, hooks, runArgs)

regionLogMutex.Lock()
regionLogOutput.WriteTo(os.Stdout)
regionLogMutex.Unlock()

successChan <- hooksResult
}(hookRunner, log, configHooks, runArgs)
}

Expand Down Expand Up @@ -292,11 +293,13 @@ func (recv *regionHookRunner) runConfigHooks(log log15.Logger,
var hookLogOutput bytes.Buffer
logger.SetHandler(log, &hookLogOutput)

successChan <- recv.runConfigHook(log, &hookLogOutput, hookIndex, hook, runArgs)
hookResult := recv.runConfigHook(log, &hookLogOutput, hookIndex, hook, runArgs)

hookLogMutex.Lock()
hookLogOutput.WriteTo(regionLogOutput)
hookLogMutex.Unlock()

successChan <- hookResult
}

for hookIndex, hook := range hooks {
Expand Down

0 comments on commit 0d7dd6f

Please sign in to comment.