14538: Check write concurrency limit.

Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tclegg@veritasgenetics.com>

diff --git a/sdk/go/arvados/fs_collection_test.go b/sdk/go/arvados/fs_collection_test.go
index b872cc214c9debfb4db9ac8db691770956638c1e..18cf47b1d3d932615da392a2394c6dbf894ea9b9 100644 (file)
--- a/sdk/go/arvados/fs_collection_test.go
+++ b/sdk/go/arvados/fs_collection_test.go
@@ -1046,7 +1046,6 @@ func (s *CollectionFSSuite) TestFlushFullBlocks(c *check.C) {
                c.Assert(n, check.Equals, len(data))
                c.Assert(err, check.IsNil)
        }
-       f.(*filehandle).inode.(*filenode).waitPrune()
 
        currentMemExtents := func() (memExtents []int) {
                for idx, e := range f.(*filehandle).inode.(*filenode).segments {
@@ -1057,6 +1056,9 @@ func (s *CollectionFSSuite) TestFlushFullBlocks(c *check.C) {
                }
                return
        }
+
+       c.Check(len(currentMemExtents()) <= concurrentWriters, check.Equals, true)
+       f.(*filehandle).inode.(*filenode).waitPrune()
        c.Check(currentMemExtents(), check.HasLen, 1)
 
        m, err := fs.MarshalManifest(".")