diff options
Diffstat (limited to 'tests/test_massops.py')
| -rw-r--r-- | tests/test_massops.py | 71 |
1 files changed, 43 insertions, 28 deletions
diff --git a/tests/test_massops.py b/tests/test_massops.py index ec3bef6..b14d7ac 100644 --- a/tests/test_massops.py +++ b/tests/test_massops.py @@ -9,12 +9,17 @@ import time import unittest -DS_DBUS_SERVICE = 'org.silbe.GDataStore' -DS_DBUS_INTERFACE = 'org.silbe.GDataStore' -DS_DBUS_PATH = '/org/silbe/GDataStore' +DS_DBUS_SERVICE = 'org.laptop.sugar.DataStore' +DS_DBUS_INTERFACE = 'org.laptop.sugar.DataStore' +DS_DBUS_PATH = '/org/laptop/sugar/DataStore' NUM_RUNS = int(os.environ.get('MASSOPS_RUNS', '100')) IGNORE_PROPERTIES = [ + 'checksum', + 'creation_time', 'number', + 'timestamp', + 'uid', + 'version_id', ] @@ -29,17 +34,17 @@ class MassOpsTestCase(unittest.TestCase): """Large number of operations intended for measuring performance.""" def setUp(self): - # pylint: disable-msg=C0103 + # pylint: disable=C0103 self._bus = dbus.SessionBus() self._datastore = dbus.Interface(self._bus.get_object(DS_DBUS_SERVICE, - DS_DBUS_PATH), DS_DBUS_INTERFACE) + DS_DBUS_PATH), DS_DBUS_INTERFACE) _create_properties = { 'title': 'DS test object', 'mime_type': 'text/plain', - 'activity': 'org.silbe.GDataStoreTest1', + 'activity': 'org.sugarlabs.DataStoreTest1', } - _create_content = 'Foo bar\n'*1000 + _create_content = 'Foo bar\n' * 1000 def test_create(self): """Run create() lots of times to create new objects.""" @@ -57,17 +62,18 @@ class MassOpsTestCase(unittest.TestCase): def test_find_all(self): """Run find() to list all entries.""" entries, total_count = self._datastore.find({}, ['number'], - byte_arrays=True) + byte_arrays=True) self.assertEquals(total_count, NUM_RUNS) self.assertEquals(total_count, len(entries)) for position, entry in enumerate(entries): - self.assertEquals(int(entry['number']), NUM_RUNS-position-1) + self.assertEquals(int(entry['number']), NUM_RUNS - position - 1) @repeat def test_find_all_reverse_time(self): """Run find() to list all entries in reverse chronological order.""" - entries, total_count = self._datastore.find({'order_by': - ['-timestamp']}, ['number'], byte_arrays=True) + entries, total_count = \ + self._datastore.find({'order_by': ['-timestamp']}, ['number'], + byte_arrays=True) self.assertEquals(total_count, NUM_RUNS) self.assertEquals(total_count, len(entries)) for position, entry in enumerate(entries): @@ -76,16 +82,18 @@ class MassOpsTestCase(unittest.TestCase): @repeat def test_find_all_title(self): """Run find() to list all entries ordered by title.""" - entries, total_count = self._datastore.find({'order_by': - ['+title']}, ['tree_id'], byte_arrays=True) + entries, total_count = \ + self._datastore.find({'order_by': ['+title']}, ['tree_id'], + byte_arrays=True) self.assertEquals(total_count, NUM_RUNS) self.assertEquals(total_count, len(entries)) @repeat def test_find_all_reverse_title(self): """Run find() to list all entries ordered by title (reversed).""" - entries, total_count = self._datastore.find({'order_by': - ['-title']}, ['tree_id'], byte_arrays=True) + entries, total_count = \ + self._datastore.find({'order_by': ['-title']}, ['tree_id'], + byte_arrays=True) self.assertEquals(total_count, NUM_RUNS) self.assertEquals(total_count, len(entries)) @@ -94,21 +102,24 @@ class MassOpsTestCase(unittest.TestCase): """Run find() to list all entries in small chunks.""" chunk_size = 30 for chunk_start in range(0, NUM_RUNS, 30): - entries, total_count = self._datastore.find({ - 'offset': chunk_start, 'limit': chunk_size}, - ['number'], byte_arrays=True) + entries, total_count = \ + self._datastore.find({'offset': chunk_start, + 'limit': chunk_size}, ['number'], + byte_arrays=True) self.assertEquals(len(entries), - min(chunk_size, NUM_RUNS-chunk_start)) + min(chunk_size, NUM_RUNS - chunk_start)) self.assertEquals(total_count, NUM_RUNS) for position, entry in enumerate(entries): self.assertEquals(int(entry['number']), - NUM_RUNS-(chunk_start+position)-1) + NUM_RUNS - (chunk_start + position) - 1) def test_get_properties(self): """Run get_properties() on all entries and verify result.""" for entry in self._datastore.find({}, ['uid'], byte_arrays=True)[0]: - properties = self._datastore.get_properties(entry['uid'], - byte_arrays=True) + properties = \ + self._datastore.get_properties(entry['uid'], byte_arrays=True) + self.assertEquals(properties.pop('filesize'), + str(len(self._create_content))) self._filter_properties(properties) self.assertEquals(properties, self._create_properties) @@ -116,7 +127,7 @@ class MassOpsTestCase(unittest.TestCase): """Run get_filename() on all entries and verify content.""" for entry in self._datastore.find({}, ['uid'], byte_arrays=True)[0]: filename = self._datastore.get_filename(entry['uid'], - byte_arrays=True) + byte_arrays=True) try: self.assertEquals(file(filename).read(), self._create_content) finally: @@ -125,9 +136,9 @@ class MassOpsTestCase(unittest.TestCase): _update_properties = { 'title': 'DS test object (updated)', 'mime_type': 'text/plain', - 'activity': 'org.silbe.GDataStoreTest1', + 'activity': 'org.sugarlabs.DataStoreTest1', } - _update_content = 'Foo bar baz\n'*1000 + _update_content = 'Foo bar baz\n' * 1000 def test_update(self): """Update the content of all existing entries""" @@ -136,13 +147,17 @@ class MassOpsTestCase(unittest.TestCase): content_file.flush() for entry in self._datastore.find({}, ['uid'], byte_arrays=True)[0]: self._datastore.update(entry['uid'], self._update_properties, - content_file.name, False) + content_file.name, False) def test_update_verify(self): - """Verify test_update() has changed content and metadata of all entries.""" + """Verify test_update() has changed content and metadata of all + entries. + """ for entry in self._datastore.find({}, [], byte_arrays=True)[0]: filename = self._datastore.get_filename(entry['uid'], - byte_arrays=True) + byte_arrays=True) + self.assertEquals(entry.pop('filesize'), + str(len(self._update_content))) self._filter_properties(entry) try: self.assertEquals(entry, self._update_properties) |