github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

volume/flocker: plug time.Ticker resource leak

Browse Source 
This commit ensures that `flockerMounter.updateDatasetPrimary` does not leak
running `time.Ticker` instances.  Upon termination of the consuming
routine, we stop the tickers.
This commit is contained in:
Matt T. Proud
2016-07-18 17:38:12 +02:00
parent fa174bcdaf
commit dbba1347c3
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/volume/flocker/plugin.go
View File

@@ -223,8 +223,10 @@ func (b flockerMounter) updateDatasetPrimary(datasetID, primaryUUID string) erro
return err return err
} }
timeoutChan := time.NewTimer(timeoutWaitingForVolume).C timeoutChan := time.NewTimer(timeoutWaitingForVolume)
tickChan := time.NewTicker(tickerWaitingForVolume).C defer timeoutChan.Stop()
tickChan := time.NewTicker(tickerWaitingForVolume)
defer tickChan.Stop()
for { for {
if s, err := b.client.GetDatasetState(datasetID); err == nil && s.Primary == primaryUUID { if s, err := b.client.GetDatasetState(datasetID); err == nil && s.Primary == primaryUUID {
@@ -232,12 +234,12 @@ func (b flockerMounter) updateDatasetPrimary(datasetID, primaryUUID string) erro
} }
select { select {
case <-timeoutChan: case <-timeoutChan.C:
return fmt.Errorf( return fmt.Errorf(
"Timed out waiting for the dataset_id: '%s' to be moved to the primary: '%s'\n%v", "Timed out waiting for the dataset_id: '%s' to be moved to the primary: '%s'\n%v",
datasetID, primaryUUID, err, datasetID, primaryUUID, err,
) )
case <-tickChan: case <-tickChan.C:
break break
} }
} }