Lines Matching refs:self
75 def hasAloc(self, node_id, service_id): argument
76 for addr in self.nodes[node_id].get_ip6_address(config.ADDRESS_TYPE.ALOC):
84 def pingFromAll(self, addr): argument
85 for n in list(self.nodes.values()):
86 self.assertTrue(n.ping(addr))
88 def failToPingFromAll(self, addr): argument
89 for n in list(self.nodes.values()):
90 self.assertFalse(n.ping(addr, timeout=3))
92 def test(self): argument
93 self.nodes[LEADER].start()
94 self.simulator.go(config.LEADER_STARTUP_DELAY)
95 self.assertEqual(self.nodes[LEADER].get_state(), 'leader')
97 self.nodes[ROUTER1].start()
98 self.nodes[ROUTER2].start()
99 self.simulator.go(config.ROUTER_STARTUP_DELAY)
100 self.assertEqual(self.nodes[ROUTER1].get_state(), 'router')
101 self.assertEqual(self.nodes[ROUTER2].get_state(), 'router')
103 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), False)
104 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
105 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), False)
106 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
107 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
108 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), False)
110 self.nodes[ROUTER1].add_service(SRV_0_ENT_NUMBER, SRV_0_SERVICE_DATA, SRV_0_SERVER_DATA)
111 self.nodes[ROUTER1].register_netdata()
112 self.simulator.go(2)
114 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), False)
115 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
116 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), True)
117 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
118 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
119 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), False)
121 aloc0 = self.nodes[ROUTER1].get_ip6_address(config.ADDRESS_TYPE.ALOC)[0]
122 self.pingFromAll(aloc0)
124 self.nodes[LEADER].add_service(SRV_0_ENT_NUMBER, SRV_0_SERVICE_DATA, SRV_0_SERVER_DATA)
125 self.nodes[LEADER].register_netdata()
126 self.simulator.go(2)
128 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), True)
129 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
130 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), True)
131 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
132 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
133 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), False)
135 self.pingFromAll(aloc0)
137 self.nodes[ROUTER2].add_service(SRV_1_ENT_NUMBER, SRV_1_SERVICE_DATA, SRV_1_SERVER_DATA)
138 self.nodes[ROUTER2].register_netdata()
139 self.simulator.go(2)
141 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), True)
142 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
143 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), True)
144 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
145 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
146 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), True)
148 aloc1 = self.nodes[ROUTER2].get_ip6_address(config.ADDRESS_TYPE.ALOC)[0]
149 self.pingFromAll(aloc0)
150 self.pingFromAll(aloc1)
152 self.nodes[ROUTER1].remove_service(SRV_0_ENT_NUMBER, SRV_0_SERVICE_DATA)
153 self.nodes[ROUTER1].register_netdata()
154 self.simulator.go(2)
156 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), True)
157 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
158 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), False)
159 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
160 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
161 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), True)
163 self.pingFromAll(aloc0)
164 self.pingFromAll(aloc1)
166 self.nodes[LEADER].remove_service(SRV_0_ENT_NUMBER, SRV_0_SERVICE_DATA)
167 self.nodes[LEADER].register_netdata()
168 self.simulator.go(2)
170 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), False)
171 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
172 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), False)
173 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
174 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
175 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), True)
177 self.failToPingFromAll(aloc0)
178 self.pingFromAll(aloc1)
180 self.nodes[ROUTER2].remove_service(SRV_1_ENT_NUMBER, SRV_1_SERVICE_DATA)
181 self.nodes[ROUTER2].register_netdata()
182 self.simulator.go(2)
184 self.assertEqual(self.hasAloc(LEADER, SRV_0_ID), False)
185 self.assertEqual(self.hasAloc(LEADER, SRV_1_ID), False)
186 self.assertEqual(self.hasAloc(ROUTER1, SRV_0_ID), False)
187 self.assertEqual(self.hasAloc(ROUTER1, SRV_1_ID), False)
188 self.assertEqual(self.hasAloc(ROUTER2, SRV_0_ID), False)
189 self.assertEqual(self.hasAloc(ROUTER2, SRV_1_ID), False)
191 self.failToPingFromAll(aloc0)
192 self.failToPingFromAll(aloc1)