projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
19986: Log max resource usage after a container finishes
[arvados.git]
/
lib
/
crunchrun
/
crunchrun.go
diff --git
a/lib/crunchrun/crunchrun.go
b/lib/crunchrun/crunchrun.go
index 3607cafaf0149bc9763c9fc5679ec6ebb6d0a2e1..3708be0c2417d5e603a671d1c2058517b4d0a807 100644
(file)
--- a/
lib/crunchrun/crunchrun.go
+++ b/
lib/crunchrun/crunchrun.go
@@
-734,6
+734,7
@@
func (runner *ContainerRunner) stopHoststat() error {
return nil
}
runner.hoststatReporter.Stop()
return nil
}
runner.hoststatReporter.Stop()
+ runner.hoststatReporter.LogProcessMemMax(runner.CrunchLog)
err := runner.hoststatLogger.Close()
if err != nil {
return fmt.Errorf("error closing hoststat logs: %v", err)
err := runner.hoststatLogger.Close()
if err != nil {
return fmt.Errorf("error closing hoststat logs: %v", err)
@@
-1152,6
+1153,9
@@
func (runner *ContainerRunner) WaitFinish() error {
if runner.statReporter != nil {
runner.statReporter.Stop()
if runner.statReporter != nil {
runner.statReporter.Stop()
+ runner.statReporter.LogMaxima(runner.CrunchLog, map[string]int64{
+ "rss": runner.Container.RuntimeConstraints.RAM,
+ })
err = runner.statLogger.Close()
if err != nil {
runner.CrunchLog.Printf("error closing crunchstat logs: %v", err)
err = runner.statLogger.Close()
if err != nil {
runner.CrunchLog.Printf("error closing crunchstat logs: %v", err)