Merge pull request #152 from vmarkovtsev/master

Measure hibernation and fork run times

internal/core/pipeline.go

@@ -712,15 +712,19 @@ func (pipeline *Pipeline) Run(commits []*object.Commit) (map[LeafPipelineItem]in
 			}
 			commitIndex++
 		case runActionFork:
+			startTime := time.Now()
 			for i, clone := range cloneItems(branches[firstItem], len(step.Items)-1) {
 				branches[step.Items[i+1]] = clone
 			}
+			runTimePerItem["*.Fork"] += time.Now().Sub(startTime).Seconds()
 		case runActionMerge:
+			startTime := time.Now()
 			merged := make([][]PipelineItem, len(step.Items))
 			for i, b := range step.Items {
 				merged[i] = branches[b]
 			}
 			mergeItems(merged)
+			runTimePerItem["*.Merge"] += time.Now().Sub(startTime).Seconds()
 		case runActionEmerge:
 			if firstItem == rootBranchIndex {
 				branches[firstItem] = pipeline.items
@@ -733,7 +737,9 @@ func (pipeline *Pipeline) Run(commits []*object.Commit) (map[LeafPipelineItem]in
 			for _, item := range step.Items {
 				for _, item := range branches[item] {
 					if hi, ok := item.(HibernateablePipelineItem); ok {
+						startTime := time.Now()
 						hi.Hibernate()
+						runTimePerItem[item.Name()+".Hibernation"] += time.Now().Sub(startTime).Seconds()
 					}
 				}
 			}
@@ -741,7 +747,9 @@ func (pipeline *Pipeline) Run(commits []*object.Commit) (map[LeafPipelineItem]in
 			for _, item := range step.Items {
 				for _, item := range branches[item] {
 					if hi, ok := item.(HibernateablePipelineItem); ok {
+						startTime := time.Now()
 						hi.Boot()
+						runTimePerItem[item.Name()+".Hibernation"] += time.Now().Sub(startTime).Seconds()
 					}
 				}
 			}