| Index: third_party/twisted_8_1/twisted/web/test/test_distrib.py
|
| diff --git a/third_party/twisted_8_1/twisted/web/test/test_distrib.py b/third_party/twisted_8_1/twisted/web/test/test_distrib.py
|
| deleted file mode 100644
|
| index 152b3f3f99a267a137388d3fc1e3b81e3c8af0a6..0000000000000000000000000000000000000000
|
| --- a/third_party/twisted_8_1/twisted/web/test/test_distrib.py
|
| +++ /dev/null
|
| @@ -1,64 +0,0 @@
|
| -# Copyright (c) 2008 Twisted Matrix Laboratories.
|
| -# See LICENSE for details.
|
| -
|
| -"""
|
| -Tests for L{twisted.web.distrib}.
|
| -"""
|
| -
|
| -from twisted.trial import unittest
|
| -from twisted.web import http, distrib, client, resource, static, server
|
| -from twisted.internet import reactor, defer
|
| -from twisted.spread import pb
|
| -from twisted.python import log
|
| -
|
| -class MySite(server.Site):
|
| - def stopFactory(self):
|
| - if hasattr(self, "logFile"):
|
| - if self.logFile != log.logfile:
|
| - self.logFile.close()
|
| - del self.logFile
|
| -
|
| -
|
| -class PBServerFactory(pb.PBServerFactory):
|
| - def buildProtocol(self, addr):
|
| - self.proto = pb.PBServerFactory.buildProtocol(self, addr)
|
| - return self.proto
|
| -
|
| -
|
| -class DistribTest(unittest.TestCase):
|
| - port1 = None
|
| - port2 = None
|
| - sub = None
|
| -
|
| - def tearDown(self):
|
| - dl = [defer.Deferred(), defer.Deferred()]
|
| - self.f1.proto.notifyOnDisconnect(lambda: dl[0].callback(None))
|
| - if self.sub is not None:
|
| - self.sub.publisher.broker.notifyOnDisconnect(
|
| - lambda: dl[1].callback(None))
|
| - self.sub.publisher.broker.transport.loseConnection()
|
| - http._logDateTimeStop()
|
| - if self.port1 is not None:
|
| - dl.append(self.port1.stopListening())
|
| - if self.port2 is not None:
|
| - dl.append(self.port2.stopListening())
|
| - return defer.gatherResults(dl)
|
| -
|
| - def testDistrib(self):
|
| - # site1 is the publisher
|
| - r1 = resource.Resource()
|
| - r1.putChild("there", static.Data("root", "text/plain"))
|
| - site1 = server.Site(r1)
|
| - self.f1 = PBServerFactory(distrib.ResourcePublisher(site1))
|
| - self.port1 = reactor.listenTCP(0, self.f1)
|
| - self.sub = distrib.ResourceSubscription("127.0.0.1",
|
| - self.port1.getHost().port)
|
| - r2 = resource.Resource()
|
| - r2.putChild("here", self.sub)
|
| - f2 = MySite(r2)
|
| - self.port2 = reactor.listenTCP(0, f2)
|
| - d = client.getPage("http://127.0.0.1:%d/here/there" % \
|
| - self.port2.getHost().port)
|
| - d.addCallback(self.failUnlessEqual, 'root')
|
| - return d
|
| -
|
|
|