Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(819)

Unified Diff: third_party/buildbot_7_12/buildbot/test/test_persistent_queue.py

Issue 12207158: Bye bye buildbot 0.7.12. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/tools/build
Patch Set: Created 7 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/buildbot_7_12/buildbot/test/test_persistent_queue.py
diff --git a/third_party/buildbot_7_12/buildbot/test/test_persistent_queue.py b/third_party/buildbot_7_12/buildbot/test/test_persistent_queue.py
deleted file mode 100644
index f2688e3293849f094655937e9345ea2dde4d44c6..0000000000000000000000000000000000000000
--- a/third_party/buildbot_7_12/buildbot/test/test_persistent_queue.py
+++ /dev/null
@@ -1,138 +0,0 @@
-# -*- test-case-name: buildbot.test.test_persistent_queue -*-
-
-import os
-import shutil
-from twisted.trial import unittest
-
-from buildbot.status.persistent_queue import DequeMemoryQueue, DiskQueue, \
- IQueue, ListMemoryQueue, MemoryQueue, PersistentQueue, WriteFile
-
-class test_Queues(unittest.TestCase):
- def setUp(self):
- if os.path.isdir('fake_dir'):
- shutil.rmtree('fake_dir')
-
- def tearDown(self):
- if os.path.isdir('fake_dir'):
- self.assertEqual([], os.listdir('fake_dir'))
-
- def testQueued(self):
- # Verify behavior when starting up with queued items on disk.
- os.mkdir('fake_dir')
- WriteFile(os.path.join('fake_dir', '3'), 'foo3')
- WriteFile(os.path.join('fake_dir', '5'), 'foo5')
- WriteFile(os.path.join('fake_dir', '8'), 'foo8')
- queue = PersistentQueue(MemoryQueue(3),
- DiskQueue('fake_dir', 5, pickleFn=str, unpickleFn=str))
- self.assertEqual(['foo3', 'foo5', 'foo8'], queue.items())
- self.assertEqual(3, queue.nbItems())
- self.assertEqual(['foo3', 'foo5', 'foo8'], queue.popChunk())
-
- def _test_helper(self, q):
- self.assertTrue(IQueue.providedBy(q))
- self.assertEqual(8, q.maxItems())
- self.assertEqual(0, q.nbItems())
- self.assertEqual([], q.items())
-
- for i in range(4):
- self.assertEqual(None, q.pushItem(i), str(i))
- self.assertEqual(i + 1, q.nbItems(), str(i))
- self.assertEqual([0, 1, 2, 3], q.items())
- self.assertEqual(4, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([0, 1, 2], q.primaryQueue.items())
- self.assertEqual([3], q.secondaryQueue.items())
-
- self.assertEqual(None, q.save())
- self.assertEqual([0, 1, 2, 3], q.items())
- self.assertEqual(4, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([], q.primaryQueue.items())
- self.assertEqual([0, 1, 2, 3], q.secondaryQueue.items())
-
- for i in range(4):
- self.assertEqual(None, q.pushItem(i + 4), str(i + 4))
- self.assertEqual(i + 5, q.nbItems(), str(i + 4))
- self.assertEqual([0, 1, 2, 3, 4, 5, 6, 7], q.items())
- self.assertEqual(8, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([0, 1, 2], q.primaryQueue.items())
- self.assertEqual([3, 4, 5, 6, 7], q.secondaryQueue.items())
-
- self.assertEqual(0, q.pushItem(8))
- self.assertEqual(8, q.nbItems())
- self.assertEqual([1, 2, 3, 4, 5, 6, 7, 8], q.items())
- if isinstance(q, PersistentQueue):
- self.assertEqual([1, 2, 3], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual([1, 2], q.popChunk(2))
- self.assertEqual([3, 4, 5, 6, 7, 8], q.items())
- self.assertEqual(6, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([3], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual([3], q.popChunk(1))
- self.assertEqual([4, 5, 6, 7, 8], q.items())
- self.assertEqual(5, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual(None, q.save())
- self.assertEqual(5, q.nbItems())
- self.assertEqual([4, 5, 6, 7, 8], q.items())
- if isinstance(q, PersistentQueue):
- self.assertEqual([], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual(None, q.insertBackChunk([2, 3]))
- self.assertEqual([2, 3, 4, 5, 6, 7, 8], q.items())
- self.assertEqual(7, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([2, 3], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual([0], q.insertBackChunk([0, 1]))
- self.assertEqual([1, 2, 3, 4, 5, 6, 7, 8], q.items())
- self.assertEqual(8, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([1, 2, 3], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual([10, 11], q.insertBackChunk([10, 11]))
- self.assertEqual([1, 2, 3, 4, 5, 6, 7, 8], q.items())
- self.assertEqual(8, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([1, 2, 3], q.primaryQueue.items())
- self.assertEqual([4, 5, 6, 7, 8], q.secondaryQueue.items())
-
- self.assertEqual([1, 2, 3, 4, 5, 6, 7, 8], q.popChunk(8))
- self.assertEqual([], q.items())
- self.assertEqual(0, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([], q.primaryQueue.items())
- self.assertEqual([], q.secondaryQueue.items())
-
- self.assertEqual([], q.popChunk())
- self.assertEqual(0, q.nbItems())
- if isinstance(q, PersistentQueue):
- self.assertEqual([], q.primaryQueue.items())
- self.assertEqual([], q.secondaryQueue.items())
-
- def testListMemoryQueue(self):
- self._test_helper(ListMemoryQueue(maxItems=8))
-
- def testDequeMemoryQueue(self):
- # Will fail on python 2.3.
- self._test_helper(DequeMemoryQueue(maxItems=8))
-
- def testDiskQueue(self):
- self._test_helper(DiskQueue('fake_dir', maxItems=8))
-
- def testPersistentQueue(self):
- self._test_helper(PersistentQueue(MemoryQueue(3),
- DiskQueue('fake_dir', 5)))
-
-# vim: set ts=4 sts=4 sw=4 et:

Powered by Google App Engine
This is Rietveld 408576698