| OLD | NEW |
| 1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
| 2 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 2 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 3 # Use of this source code is governed by a BSD-style license that can be | 3 # Use of this source code is governed by a BSD-style license that can be |
| 4 # found in the LICENSE file. | 4 # found in the LICENSE file. |
| 5 | 5 |
| 6 """Unit tests for rietveld.py.""" | 6 """Unit tests for rietveld.py.""" |
| 7 | 7 |
| 8 import logging | 8 import logging |
| 9 import os | 9 import os |
| 10 import ssl |
| 10 import sys | 11 import sys |
| 12 import time |
| 11 import traceback | 13 import traceback |
| 12 import unittest | 14 import unittest |
| 13 | 15 |
| 14 sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) | 16 sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) |
| 15 | 17 |
| 16 from testing_support.patches_data import GIT, RAW | 18 from testing_support.patches_data import GIT, RAW |
| 17 from testing_support import auto_stub | 19 from testing_support import auto_stub |
| 18 | 20 |
| 19 import patch | 21 import patch |
| 20 import rietveld | 22 import rietveld |
| (...skipping 412 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 433 | 435 |
| 434 | 436 |
| 435 def MockSend(request_path, payload=None, | 437 def MockSend(request_path, payload=None, |
| 436 content_type="application/octet-stream", | 438 content_type="application/octet-stream", |
| 437 timeout=None, | 439 timeout=None, |
| 438 extra_headers=None, | 440 extra_headers=None, |
| 439 **kwargs): | 441 **kwargs): |
| 440 """Mock upload.py's Send() to probe the timeout value""" | 442 """Mock upload.py's Send() to probe the timeout value""" |
| 441 raise ProbeException(timeout) | 443 raise ProbeException(timeout) |
| 442 | 444 |
| 445 def MockSendTimeout(request_path, payload=None, |
| 446 content_type="application/octet-stream", |
| 447 timeout=None, |
| 448 extra_headers=None, |
| 449 **kwargs): |
| 450 """Mock upload.py's Send() to raise SSLError""" |
| 451 raise ssl.SSLError('The read operation timed out') |
| 452 |
| 443 | 453 |
| 444 class DefaultTimeoutTest(auto_stub.TestCase): | 454 class DefaultTimeoutTest(auto_stub.TestCase): |
| 445 TESTED_CLASS = rietveld.Rietveld | 455 TESTED_CLASS = rietveld.Rietveld |
| 446 | 456 |
| 447 def setUp(self): | 457 def setUp(self): |
| 448 super(DefaultTimeoutTest, self).setUp() | 458 super(DefaultTimeoutTest, self).setUp() |
| 449 self.rietveld = self.TESTED_CLASS('url', 'email', 'password') | 459 self.rietveld = self.TESTED_CLASS('url', 'email', 'password') |
| 450 self.mock(self.rietveld.rpc_server, 'Send', MockSend) | 460 self.mock(self.rietveld.rpc_server, 'Send', MockSend) |
| 461 self.sleep_time = 0 |
| 451 | 462 |
| 452 def test_timeout_get(self): | 463 def test_timeout_get(self): |
| 453 with self.assertRaises(ProbeException) as cm: | 464 with self.assertRaises(ProbeException) as cm: |
| 454 self.rietveld.get('/api/1234') | 465 self.rietveld.get('/api/1234') |
| 455 | 466 |
| 456 self.assertIsNotNone(cm.exception.value, 'Rietveld timeout was not set: %s' | 467 self.assertIsNotNone(cm.exception.value, 'Rietveld timeout was not set: %s' |
| 457 % traceback.format_exc()) | 468 % traceback.format_exc()) |
| 458 | 469 |
| 459 def test_timeout_post(self): | 470 def test_timeout_post(self): |
| 460 with self.assertRaises(ProbeException) as cm: | 471 with self.assertRaises(ProbeException) as cm: |
| 461 self.rietveld.post('/api/1234', [('key', 'data')]) | 472 self.rietveld.post('/api/1234', [('key', 'data')]) |
| 462 | 473 |
| 463 self.assertIsNotNone(cm.exception.value, 'Rietveld timeout was not set: %s' | 474 self.assertIsNotNone(cm.exception.value, 'Rietveld timeout was not set: %s' |
| 464 % traceback.format_exc()) | 475 % traceback.format_exc()) |
| 465 | 476 |
| 477 def MockSleep(self, t): |
| 478 self.sleep_time = t |
| 479 |
| 480 def test_ssl_timeout_post(self): |
| 481 self.mock(self.rietveld.rpc_server, 'Send', MockSendTimeout) |
| 482 self.mock(time, 'sleep', self.MockSleep) |
| 483 self.sleep_time = 0 |
| 484 with self.assertRaises(ssl.SSLError): |
| 485 self.rietveld.post('/api/1234', [('key', 'data')]) |
| 486 self.assertNotEqual(self.sleep_time, 0) |
| 466 | 487 |
| 467 if __name__ == '__main__': | 488 if __name__ == '__main__': |
| 468 logging.basicConfig(level=[ | 489 logging.basicConfig(level=[ |
| 469 logging.ERROR, logging.INFO, logging.DEBUG][min(2, sys.argv.count('-v'))]) | 490 logging.ERROR, logging.INFO, logging.DEBUG][min(2, sys.argv.count('-v'))]) |
| 470 unittest.main() | 491 unittest.main() |
| OLD | NEW |