| 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.ExecuteJavaScript2('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 action_runner.ExecuteJavaScript2( | 28 action_runner.ExecuteJavaScript( |
| 29 'createAndRead({{ size }});', size=size_bytes) | 29 'createAndRead({{ size }});', size=size_bytes) |
| 30 action_runner.WaitForJavaScriptCondition2( | 30 action_runner.WaitForJavaScriptCondition( |
| 31 'doneReading === true || errors', timeout=60) | 31 'doneReading === true || errors', timeout=60) |
| 32 | 32 |
| 33 errors = action_runner.EvaluateJavaScript2('errors') | 33 errors = action_runner.EvaluateJavaScript('errors') |
| 34 if errors: | 34 if errors: |
| 35 raise legacy_page_test.Failure('Errors on page: ' + ', '.join(errors)) | 35 raise legacy_page_test.Failure('Errors on page: ' + ', '.join(errors)) |
| 36 | 36 |
| 37 | 37 |
| 38 class BlobMassCreate(page_module.Page): | 38 class BlobMassCreate(page_module.Page): |
| 39 def __init__(self, write_method, blob_sizes, page_set): | 39 def __init__(self, write_method, blob_sizes, page_set): |
| 40 super(BlobMassCreate, self).__init__( | 40 super(BlobMassCreate, self).__init__( |
| 41 url='file://blob/blob-workshop.html', | 41 url='file://blob/blob-workshop.html', |
| 42 page_set=page_set, | 42 page_set=page_set, |
| 43 name='blob-mass-create-' + write_method) | 43 name='blob-mass-create-' + write_method) |
| 44 self._blob_sizes = blob_sizes | 44 self._blob_sizes = blob_sizes |
| 45 | 45 |
| 46 def RunPageInteractions(self, action_runner): | 46 def RunPageInteractions(self, action_runner): |
| 47 action_runner.ExecuteJavaScript2('disableUI = true;') | 47 action_runner.ExecuteJavaScript('disableUI = true;') |
| 48 | 48 |
| 49 # Add blobs | 49 # Add blobs |
| 50 for size_bytes in self._blob_sizes: | 50 for size_bytes in self._blob_sizes: |
| 51 with action_runner.CreateInteraction('Action_CreateBlob', | 51 with action_runner.CreateInteraction('Action_CreateBlob', |
| 52 repeatable=True): | 52 repeatable=True): |
| 53 action_runner.ExecuteJavaScript2( | 53 action_runner.ExecuteJavaScript( |
| 54 'createBlob({{ size }});', size=size_bytes) | 54 'createBlob({{ size }});', size=size_bytes) |
| 55 | 55 |
| 56 # Read blobs | 56 # Read blobs |
| 57 for _ in range(0, NUM_BLOB_MASS_CREATE_READS): | 57 for _ in range(0, NUM_BLOB_MASS_CREATE_READS): |
| 58 with action_runner.CreateInteraction('Action_ReadBlobs', | 58 with action_runner.CreateInteraction('Action_ReadBlobs', |
| 59 repeatable=True): | 59 repeatable=True): |
| 60 action_runner.ExecuteJavaScript2('readBlobsSerially();') | 60 action_runner.ExecuteJavaScript('readBlobsSerially();') |
| 61 action_runner.WaitForJavaScriptCondition2( | 61 action_runner.WaitForJavaScriptCondition( |
| 62 'doneReading === true || errors', timeout=60) | 62 'doneReading === true || errors', timeout=60) |
| 63 # Clean up blobs. Make sure this flag is turned on: | 63 # Clean up blobs. Make sure this flag is turned on: |
| 64 # --enable-experimental-web-platform-features | 64 # --enable-experimental-web-platform-features |
| 65 action_runner.ExecuteJavaScript2('garbageCollect();') | 65 action_runner.ExecuteJavaScript('garbageCollect();') |
| 66 | 66 |
| 67 errors = action_runner.EvaluateJavaScript2('errors') | 67 errors = action_runner.EvaluateJavaScript('errors') |
| 68 if errors: | 68 if errors: |
| 69 raise legacy_page_test.Failure('Errors on page: ' + ', '.join(errors)) | 69 raise legacy_page_test.Failure('Errors on page: ' + ', '.join(errors)) |
| 70 | 70 |
| 71 | 71 |
| 72 class BlobWorkshopPageSet(story.StorySet): | 72 class BlobWorkshopPageSet(story.StorySet): |
| 73 """The BlobWorkshop page set.""" | 73 """The BlobWorkshop page set.""" |
| 74 | 74 |
| 75 def __init__(self): | 75 def __init__(self): |
| 76 super(BlobWorkshopPageSet, self).__init__() | 76 super(BlobWorkshopPageSet, self).__init__() |
| 77 self.AddStory( | 77 self.AddStory( |
| (...skipping 12 matching lines...) Expand all Loading... |
| 90 | 90 |
| 91 self.AddStory(BlobCreateThenRead('2Bx200', [2] * 200, self)) | 91 self.AddStory(BlobCreateThenRead('2Bx200', [2] * 200, self)) |
| 92 self.AddStory(BlobCreateThenRead('1KBx200', [1024] * 200, self)) | 92 self.AddStory(BlobCreateThenRead('1KBx200', [1024] * 200, self)) |
| 93 self.AddStory( | 93 self.AddStory( |
| 94 BlobCreateThenRead('150KBx200', [150 * 1024 - 1] * 200, self)) | 94 BlobCreateThenRead('150KBx200', [150 * 1024 - 1] * 200, self)) |
| 95 self.AddStory(BlobCreateThenRead('1MBx200', [1024 * 1024] * 200, self)) | 95 self.AddStory(BlobCreateThenRead('1MBx200', [1024 * 1024] * 200, self)) |
| 96 self.AddStory( | 96 self.AddStory( |
| 97 BlobCreateThenRead('10MBx30', [10 * 1024 * 1024] * 30, self)) | 97 BlobCreateThenRead('10MBx30', [10 * 1024 * 1024] * 30, self)) |
| 98 self.AddStory( | 98 self.AddStory( |
| 99 BlobCreateThenRead('80MBx5', [80 * 1024 * 1024] * 5, self)) | 99 BlobCreateThenRead('80MBx5', [80 * 1024 * 1024] * 5, self)) |
| OLD | NEW |