dkirillov/distribution
1
0
Fork 0
forked from TrueCloudLab/distribution
Code Pull requests Activity

Merge pull request #840 from BrianBland/ng-storagedriver-tests

Browse source 
Increases stress test factor of TestConcurrentFileStreams
This commit is contained in:
Stephen Day 2014-12-10 17:38:51 -08:00
commit a1f74a783a
1 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
storagedriver/testsuites/testsuites.go
View file

@ -696,6 +696,13 @@ func (suite *DriverSuite) TestConcurrentFileStreams(c *check.C) {
// c.Skip("Need to fix out-of-process concurrency") // c.Skip("Need to fix out-of-process concurrency")
// } // }
numStreams := 32
if testing.Short() {
numStreams = 8
c.Log("Reducing number of streams to 8 for short mode")
}
var wg sync.WaitGroup var wg sync.WaitGroup
testStream := func(size int64) { testStream := func(size int64) {
@ -703,13 +710,10 @@ func (suite *DriverSuite) TestConcurrentFileStreams(c *check.C) {
suite.testFileStreams(c, size) suite.testFileStreams(c, size)
} }
wg.Add(6) wg.Add(numStreams)
go testStream(8 * 1024 * 1024) for i := numStreams; i > 0; i-- {
go testStream(4 * 1024 * 1024) go testStream(int64(numStreams) * 1024 * 1024)
go testStream(2 * 1024 * 1024) }
go testStream(1024 * 1024)
go testStream(1024)
go testStream(64)
wg.Wait() wg.Wait()
} }
@ -718,6 +722,7 @@ func (suite *DriverSuite) testFileStreams(c *check.C, size int64) {
tf, err := ioutil.TempFile("", "tf") tf, err := ioutil.TempFile("", "tf")
c.Assert(err, check.IsNil) c.Assert(err, check.IsNil)
defer os.Remove(tf.Name()) defer os.Remove(tf.Name())
defer tf.Close()
filename := randomPath(32) filename := randomPath(32)
defer suite.StorageDriver.Delete(firstPart(filename)) defer suite.StorageDriver.Delete(firstPart(filename))