Changeset 6b3722d3 in trunk
- Timestamp:
- 2022-02-03T17:50:29Z (3 years ago)
- Branches:
- master
- Children:
- c2c3411
- Parents:
- 23c8bde
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
TabularUnified src/allmydata/test/test_istorageserver.py ¶
r23c8bde r6b3722d3 31 31 from twisted.internet.endpoints import serverFromString 32 32 from twisted.web.server import Site 33 from twisted.web.client import HTTPConnectionPool33 from twisted.web.client import Agent, HTTPConnectionPool 34 34 from hyperlink import DecodedURL 35 from treq. api import set_global_pool as set_treq_pool35 from treq.client import HTTPClient 36 36 37 37 from foolscap.api import Referenceable, RemoteException … … 1102 1102 @inlineCallbacks 1103 1103 def _get_istorage_server(self): 1104 set_treq_pool(HTTPConnectionPool(reactor, persistent=False))1105 1104 swissnum = b"1234" 1106 self._http_storage_server = HTTPServer(self.server, swissnum)1105 http_storage_server = HTTPServer(self.server, swissnum) 1107 1106 1108 1107 # Listen on randomly assigned port: … … 1111 1110 port = int(port) 1112 1111 endpoint = serverFromString(reactor, endpoint_string) 1113 self._listening_port = yield endpoint.listen( 1114 Site(self._http_storage_server.get_resource()) 1115 ) 1116 self.addCleanup(self._listening_port.stopListening) 1112 listening_port = yield endpoint.listen(Site(http_storage_server.get_resource())) 1113 self.addCleanup(listening_port.stopListening) 1114 1115 # Create HTTP client with non-persistent connections, so we don't leak 1116 # state across tests: 1117 treq_client = HTTPClient( 1118 Agent(reactor, HTTPConnectionPool(reactor, persistent=False)) 1119 ) 1120 1117 1121 returnValue( 1118 1122 _HTTPStorageServer.from_http_client( … … 1120 1124 DecodedURL().replace(scheme="http", host=host, port=port), 1121 1125 swissnum, 1126 treq=treq_client, 1122 1127 ) 1123 1128 )
Note: See TracChangeset
for help on using the changeset viewer.