Lines Matching full:upstream

33     def start_server(self, dbpath=None, upstream=None, read_only=False, prefunc=server_prefunc):  argument
47 upstream=upstream,
188 # Tests upstream server support. This is done by creating two servers
189 # that share a database file. The downstream server has it upstream
191 # verification that the hash requests are being proxied to the upstream
196 (down_client, down_server) = self.start_server(upstream=self.server.address)
203 # check upstream server
210 # will defer to the upstream server. This will trigger
215 # task from the upstream server, it should appear in the side server
245 # propagating to the upstream server
257 # match which was previously reported to the upstream server
266 self.assertEqual(result['unihash'], unihash5, 'Server failed to copy unihash from upstream')
275 self.assertEqual(result['unihash'], unihash7, 'Server failed to copy unihash from upstream')
276 self.assertEqual(result['outhash'], outhash7, 'Server failed to copy unihash from upstream')
277 … self.assertEqual(result['taskhash'], taskhash7, 'Server failed to copy unihash from upstream')
286 self.assertEqual(result['unihash'], unihash8, 'Server failed to copy unihash from upstream')
287 self.assertEqual(result['outhash'], outhash8, 'Server failed to copy unihash from upstream')
288 … self.assertEqual(result['taskhash'], taskhash8, 'Server failed to copy unihash from upstream')
297 self.assertEqual(result['unihash'], unihash9, 'Server failed to copy unihash from upstream')
298 … self.assertEqual(result['taskhash'], taskhash9, 'Server failed to copy unihash from upstream')