Fix race condition (#445)

David Chung · web-flow · commit 8582433ab4c5 · 2017-03-24T10:53:06.000-07:00
Signed-off-by: David Chung &lt;david.chung@docker.com&gt;
diff --git a/pkg/plugin/group/scaler.go b/pkg/plugin/group/scaler.go
@@ -215,7 +215,7 @@ func (s *scaler) ID() group.ID {
 }
 
 func (s *scaler) Size() uint {
-	return s.size
+	return s.getSize()
 }
 
 func (s *scaler) waitIfReachParallelLimit(current int, batch *sync.WaitGroup) {

Original file line number	Diff line number	Diff line change
`@@ -215,7 +215,7 @@ func (s *scaler) ID() group.ID {`
`215`	`215`	`}`
`216`	`216`
`217`	`217`	`func (s *scaler) Size() uint {`
`218`		`- return s.size`
	`218`	`+ return s.getSize()`
`219`	`219`	`}`
`220`	`220`
`221`	`221`	`func (s scaler) waitIfReachParallelLimit(current int, batch sync.WaitGroup) {`