Lines Matching refs:streams
9 def initialize(self, fs, fstype = 'ext2', megabytes = 1000, streams = 2,
13 self.blocks_per_file = self.blocks / streams
16 self.streams = streams
25 logging.info('Dumping %d megabytes across %d streams', megabytes,
26 streams)
47 # Write out 'streams' files in parallel background tasks
48 for i in range(self.streams):
53 logging.info("Waiting for %d streams", self.streams)
55 for i in range(self.streams):
65 # Read in 'streams' files in parallel background tasks
66 for i in range(self.streams):
76 logging.info("Waiting for %d streams", self.streams)
78 for i in range(self.streams):
