()
| 257 | await fut |
| 258 | |
| 259 | async def start_server(): |
| 260 | extras = {} |
| 261 | extras = dict(ssl_handshake_timeout=support.SHORT_TIMEOUT) |
| 262 | |
| 263 | srv = await asyncio.start_server( |
| 264 | handle_client, |
| 265 | '127.0.0.1', 0, |
| 266 | family=socket.AF_INET, |
| 267 | ssl=sslctx, |
| 268 | **extras) |
| 269 | |
| 270 | try: |
| 271 | srv_socks = srv.sockets |
| 272 | self.assertTrue(srv_socks) |
| 273 | |
| 274 | addr = srv_socks[0].getsockname() |
| 275 | |
| 276 | tasks = [] |
| 277 | for _ in range(TOTAL_CNT): |
| 278 | tasks.append(test_client(addr)) |
| 279 | |
| 280 | await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT) |
| 281 | |
| 282 | finally: |
| 283 | self.loop.call_soon(srv.close) |
| 284 | await srv.wait_closed() |
| 285 | |
| 286 | with self._silence_eof_received_warning(): |
| 287 | self.loop.run_until_complete(start_server()) |
no test coverage detected