Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 1 | """ |
| 2 | Base classes for test cases |
| 3 | |
| 4 | Tests will usually inherit from one of these classes to have the controller |
| 5 | and/or dataplane automatically set up. |
| 6 | """ |
| 7 | |
| 8 | import logging |
| 9 | import unittest |
| 10 | |
Rich Lane | 2c7812c | 2012-12-27 17:52:23 -0800 | [diff] [blame] | 11 | import oftest |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 12 | from oftest import config |
| 13 | import oftest.controller as controller |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 14 | import oftest.dataplane as dataplane |
Rich Lane | 9fd0568 | 2013-01-10 15:30:38 -0800 | [diff] [blame^] | 15 | import ofp |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 16 | |
| 17 | class SimpleProtocol(unittest.TestCase): |
| 18 | """ |
| 19 | Root class for setting up the controller |
| 20 | """ |
| 21 | |
| 22 | def setUp(self): |
| 23 | logging.info("** START TEST CASE " + str(self)) |
| 24 | self.controller = controller.Controller( |
Dan Talayco | 69ca4d6 | 2012-11-15 11:50:22 -0800 | [diff] [blame] | 25 | switch=config["switch_ip"], |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 26 | host=config["controller_host"], |
| 27 | port=config["controller_port"]) |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 28 | self.controller.start() |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 29 | |
Rich Lane | d591504 | 2012-12-31 14:58:35 -0800 | [diff] [blame] | 30 | try: |
| 31 | #@todo Add an option to wait for a pkt transaction to ensure version |
| 32 | # compatibilty? |
| 33 | self.controller.connect(timeout=20) |
| 34 | |
| 35 | # By default, respond to echo requests |
| 36 | self.controller.keep_alive = True |
| 37 | |
| 38 | if not self.controller.active: |
| 39 | raise Exception("Controller startup failed") |
| 40 | if self.controller.switch_addr is None: |
| 41 | raise Exception("Controller startup failed (no switch addr)") |
| 42 | logging.info("Connected " + str(self.controller.switch_addr)) |
Rich Lane | 78ef8b9 | 2013-01-10 12:19:23 -0800 | [diff] [blame] | 43 | request = ofp.message.features_request() |
Rich Lane | d591504 | 2012-12-31 14:58:35 -0800 | [diff] [blame] | 44 | reply, pkt = self.controller.transact(request) |
| 45 | self.assertTrue(reply is not None, |
| 46 | "Did not complete features_request for handshake") |
Rich Lane | af42815 | 2013-01-10 12:24:44 -0800 | [diff] [blame] | 47 | if reply.header.version == 1: |
| 48 | self.supported_actions = reply.actions |
| 49 | logging.info("Supported actions: " + hex(self.supported_actions)) |
Rich Lane | d591504 | 2012-12-31 14:58:35 -0800 | [diff] [blame] | 50 | except: |
| 51 | self.controller.kill() |
| 52 | del self.controller |
| 53 | raise |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 54 | |
| 55 | def inheritSetup(self, parent): |
| 56 | """ |
| 57 | Inherit the setup of a parent |
| 58 | |
| 59 | This allows running at test from within another test. Do the |
| 60 | following: |
| 61 | |
| 62 | sub_test = SomeTestClass() # Create an instance of the test class |
| 63 | sub_test.inheritSetup(self) # Inherit setup of parent |
| 64 | sub_test.runTest() # Run the test |
| 65 | |
| 66 | Normally, only the parent's setUp and tearDown are called and |
| 67 | the state after the sub_test is run must be taken into account |
| 68 | by subsequent operations. |
| 69 | """ |
| 70 | logging.info("** Setup " + str(self) + " inheriting from " |
| 71 | + str(parent)) |
| 72 | self.controller = parent.controller |
| 73 | self.supported_actions = parent.supported_actions |
| 74 | |
| 75 | def tearDown(self): |
| 76 | logging.info("** END TEST CASE " + str(self)) |
| 77 | self.controller.shutdown() |
Rich Lane | 7c64a42 | 2012-12-31 13:46:34 -0800 | [diff] [blame] | 78 | self.controller.join() |
Rich Lane | e7b0ecb | 2012-12-26 10:01:01 -0800 | [diff] [blame] | 79 | del self.controller |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 80 | |
| 81 | def runTest(self): |
| 82 | # Just a simple sanity check as illustration |
| 83 | logging.info("Running simple proto test") |
| 84 | self.assertTrue(self.controller.switch_socket is not None, |
| 85 | str(self) + 'No connection to switch') |
| 86 | |
| 87 | def assertTrue(self, cond, msg): |
| 88 | if not cond: |
| 89 | logging.error("** FAILED ASSERTION: " + msg) |
| 90 | unittest.TestCase.assertTrue(self, cond, msg) |
| 91 | |
| 92 | class SimpleDataPlane(SimpleProtocol): |
| 93 | """ |
| 94 | Root class that sets up the controller and dataplane |
| 95 | """ |
| 96 | def setUp(self): |
| 97 | SimpleProtocol.setUp(self) |
Rich Lane | 2c7812c | 2012-12-27 17:52:23 -0800 | [diff] [blame] | 98 | self.dataplane = oftest.dataplane_instance |
| 99 | self.dataplane.flush() |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 100 | |
| 101 | def inheritSetup(self, parent): |
| 102 | """ |
| 103 | Inherit the setup of a parent |
| 104 | |
| 105 | See SimpleProtocol.inheritSetup |
| 106 | """ |
| 107 | SimpleProtocol.inheritSetup(self, parent) |
| 108 | self.dataplane = parent.dataplane |
| 109 | |
| 110 | def tearDown(self): |
| 111 | logging.info("Teardown for simple dataplane test") |
| 112 | SimpleProtocol.tearDown(self) |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 113 | logging.info("Teardown done") |
| 114 | |
| 115 | def runTest(self): |
| 116 | self.assertTrue(self.controller.switch_socket is not None, |
| 117 | str(self) + 'No connection to switch') |
| 118 | # self.dataplane.show() |
| 119 | # Would like an assert that checks the data plane |
| 120 | |
| 121 | class DataPlaneOnly(unittest.TestCase): |
| 122 | """ |
| 123 | Root class that sets up only the dataplane |
| 124 | """ |
| 125 | |
| 126 | def setUp(self): |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 127 | logging.info("** START DataPlaneOnly CASE " + str(self)) |
Rich Lane | 2c7812c | 2012-12-27 17:52:23 -0800 | [diff] [blame] | 128 | self.dataplane = oftest.dataplane_instance |
| 129 | self.dataplane.flush() |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 130 | |
| 131 | def tearDown(self): |
| 132 | logging.info("Teardown for simple dataplane test") |
Rich Lane | b90a1c4 | 2012-10-05 09:16:05 -0700 | [diff] [blame] | 133 | logging.info("Teardown done") |
| 134 | |
| 135 | def runTest(self): |
| 136 | logging.info("DataPlaneOnly") |
| 137 | # self.dataplane.show() |
| 138 | # Would like an assert that checks the data plane |