OLD | NEW |
1 # Copyright 2015 The Chromium Authors. All rights reserved. | 1 # Copyright 2015 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 from telemetry.page import page as page_module | 5 from telemetry.page import page as page_module |
6 from telemetry.page import legacy_page_test | 6 from telemetry.page import legacy_page_test |
7 from telemetry import story | 7 from telemetry import story |
8 | 8 |
9 | 9 |
10 NUM_BLOB_MASS_CREATE_READS = 15 | 10 NUM_BLOB_MASS_CREATE_READS = 15 |
11 | 11 |
12 | 12 |
13 class BlobCreateThenRead(page_module.Page): | 13 class BlobCreateThenRead(page_module.Page): |
14 | 14 |
15 def __init__(self, write_method, blob_sizes, page_set): | 15 def __init__(self, write_method, blob_sizes, page_set): |
16 super(BlobCreateThenRead, self).__init__( | 16 super(BlobCreateThenRead, self).__init__( |
17 url='file://blob/blob-workshop.html', | 17 url='file://blob/blob-workshop.html', |
18 page_set=page_set, | 18 page_set=page_set, |
19 name='blob-create-read-' + write_method) | 19 name='blob-create-read-' + write_method) |
20 self._blob_sizes = blob_sizes | 20 self._blob_sizes = blob_sizes |
21 | 21 |
22 def RunPageInteractions(self, action_runner): | 22 def RunPageInteractions(self, action_runner): |
23 action_runner.ExecuteJavaScript('disableUI = true;') | 23 action_runner.ExecuteJavaScript('disableUI = true;') |
24 | 24 |
25 for size_bytes in self._blob_sizes: | 25 for size_bytes in self._blob_sizes: |
26 with action_runner.CreateInteraction('Action_CreateAndReadBlob', | 26 with action_runner.CreateInteraction('Action_CreateAndReadBlob', |
27 repeatable=True): | 27 repeatable=True): |
28 # TODO(catapult:#3028): Fix interpolation of JavaScript values. | |
29 action_runner.ExecuteJavaScript( | 28 action_runner.ExecuteJavaScript( |
30 'createAndRead(' + str(size_bytes) + ');') | 29 'createAndRead({{ size }});', size=size_bytes) |
31 action_runner.WaitForJavaScriptCondition( | 30 action_runner.WaitForJavaScriptCondition( |
32 'doneReading === true || errors', timeout_in_seconds=60) | 31 'doneReading === true || errors', timeout_in_seconds=60) |
33 | 32 |
34 errors = action_runner.EvaluateJavaScript('errors') | 33 errors = action_runner.EvaluateJavaScript('errors') |
35 if errors: | 34 if errors: |
36 raise legacy_page_test.Failure('Errors on page: ' + ', '.join(errors)) | 35 raise legacy_page_test.Failure('Errors on page: ' + ', '.join(errors)) |
37 | 36 |
38 | 37 |
39 class BlobMassCreate(page_module.Page): | 38 class BlobMassCreate(page_module.Page): |
40 def __init__(self, write_method, blob_sizes, page_set): | 39 def __init__(self, write_method, blob_sizes, page_set): |
41 super(BlobMassCreate, self).__init__( | 40 super(BlobMassCreate, self).__init__( |
42 url='file://blob/blob-workshop.html', | 41 url='file://blob/blob-workshop.html', |
43 page_set=page_set, | 42 page_set=page_set, |
44 name='blob-mass-create-' + write_method) | 43 name='blob-mass-create-' + write_method) |
45 self._blob_sizes = blob_sizes | 44 self._blob_sizes = blob_sizes |
46 | 45 |
47 def RunPageInteractions(self, action_runner): | 46 def RunPageInteractions(self, action_runner): |
48 action_runner.ExecuteJavaScript('disableUI = true;') | 47 action_runner.ExecuteJavaScript('disableUI = true;') |
49 | 48 |
50 # Add blobs | 49 # Add blobs |
51 for size_bytes in self._blob_sizes: | 50 for size_bytes in self._blob_sizes: |
52 with action_runner.CreateInteraction('Action_CreateBlob', | 51 with action_runner.CreateInteraction('Action_CreateBlob', |
53 repeatable=True): | 52 repeatable=True): |
54 # TODO(catapult:#3028): Fix interpolation of JavaScript values. | 53 action_runner.ExecuteJavaScript( |
55 action_runner.ExecuteJavaScript('createBlob(' + str(size_bytes) + ');') | 54 'createBlob({{ size }});', size=size_bytes) |
56 | 55 |
57 # Read blobs | 56 # Read blobs |
58 for _ in range(0, NUM_BLOB_MASS_CREATE_READS): | 57 for _ in range(0, NUM_BLOB_MASS_CREATE_READS): |
59 with action_runner.CreateInteraction('Action_ReadBlobs', | 58 with action_runner.CreateInteraction('Action_ReadBlobs', |
60 repeatable=True): | 59 repeatable=True): |
61 action_runner.ExecuteJavaScript('readBlobsSerially();') | 60 action_runner.ExecuteJavaScript('readBlobsSerially();') |
62 action_runner.WaitForJavaScriptCondition( | 61 action_runner.WaitForJavaScriptCondition( |
63 'doneReading === true || errors', timeout_in_seconds=60) | 62 'doneReading === true || errors', timeout_in_seconds=60) |
64 # Clean up blobs. Make sure this flag is turned on: | 63 # Clean up blobs. Make sure this flag is turned on: |
65 # --enable-experimental-web-platform-features | 64 # --enable-experimental-web-platform-features |
(...skipping 25 matching lines...) Expand all Loading... |
91 | 90 |
92 self.AddStory(BlobCreateThenRead('2Bx200', [2] * 200, self)) | 91 self.AddStory(BlobCreateThenRead('2Bx200', [2] * 200, self)) |
93 self.AddStory(BlobCreateThenRead('1KBx200', [1024] * 200, self)) | 92 self.AddStory(BlobCreateThenRead('1KBx200', [1024] * 200, self)) |
94 self.AddStory( | 93 self.AddStory( |
95 BlobCreateThenRead('150KBx200', [150 * 1024 - 1] * 200, self)) | 94 BlobCreateThenRead('150KBx200', [150 * 1024 - 1] * 200, self)) |
96 self.AddStory(BlobCreateThenRead('1MBx200', [1024 * 1024] * 200, self)) | 95 self.AddStory(BlobCreateThenRead('1MBx200', [1024 * 1024] * 200, self)) |
97 self.AddStory( | 96 self.AddStory( |
98 BlobCreateThenRead('10MBx30', [10 * 1024 * 1024] * 30, self)) | 97 BlobCreateThenRead('10MBx30', [10 * 1024 * 1024] * 30, self)) |
99 self.AddStory( | 98 self.AddStory( |
100 BlobCreateThenRead('80MBx5', [80 * 1024 * 1024] * 5, self)) | 99 BlobCreateThenRead('80MBx5', [80 * 1024 * 1024] * 5, self)) |
OLD | NEW |