Skip to content

Commit 07129e5

Browse files
fix: rename wakeup to shutdown and states
1 parent 44d24fb commit 07129e5

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

Lib/asyncio/base_events.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -276,15 +276,15 @@ async def restore(self):
276276
class _ServerState(enum.Enum):
277277
"""This tracks the state of Server.
278278
279-
-[in]->INITIALIZED -[ss]-> SERVING -[cl]-> CLOSED -[wk]*-> SHUTDOWN
279+
-[in]->NOT_STARTED -[ss]-> SERVING -[cl]-> CLOSED -[wk]*-> SHUTDOWN
280280
281281
- in: Server.__init__()
282282
- ss: Server._start_serving()
283283
- cl: Server.close()
284284
- wk: Server._wakeup() *only called if number of clients == 0
285285
"""
286286

287-
INITIALIZED = "initialized"
287+
NOT_STARTED = "not_started"
288288
SERVING = "serving"
289289
CLOSED = "closed"
290290
SHUTDOWN = "shutdown"
@@ -305,7 +305,7 @@ def __init__(self, loop, sockets, protocol_factory, ssl_context, backlog,
305305
self._ssl_context = ssl_context
306306
self._ssl_handshake_timeout = ssl_handshake_timeout
307307
self._ssl_shutdown_timeout = ssl_shutdown_timeout
308-
self._state = _ServerState.INITIALIZED
308+
self._state = _ServerState.NOT_STARTED
309309
self._serving_forever_fut = None
310310

311311
def __repr__(self):
@@ -319,9 +319,9 @@ def _attach(self, transport):
319319
def _detach(self, transport):
320320
self._clients.discard(transport)
321321
if self._state == _ServerState.CLOSED and len(self._clients) == 0:
322-
self._wakeup()
322+
self._shutdown()
323323

324-
def _wakeup(self):
324+
def _shutdown(self):
325325
if self._state == _ServerState.CLOSED:
326326
self._state = _ServerState.SHUTDOWN
327327
elif self._state == _ServerState.SHUTDOWN:
@@ -339,7 +339,7 @@ def _wakeup(self):
339339
waiter.set_result(None)
340340

341341
def _start_serving(self):
342-
if self._state == _ServerState.INITIALIZED:
342+
if self._state == _ServerState.NOT_STARTED:
343343
self._state = _ServerState.SERVING
344344
elif self._state == _ServerState.SERVING:
345345
return
@@ -385,7 +385,7 @@ def close(self):
385385
self._serving_forever_fut = None
386386

387387
if len(self._clients) == 0:
388-
self._wakeup()
388+
self._shutdown()
389389

390390
def close_clients(self):
391391
for transport in self._clients.copy():

Lib/test/test_asyncio/test_server.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ async def main(srv):
6666
self.assertIsNone(srv._waiters)
6767
self.assertFalse(srv.is_serving())
6868

69-
with self.assertRaisesRegex(RuntimeError, r'is closed'):
69+
with self.assertRaisesRegex(RuntimeError, r'started and then closed'):
7070
self.loop.run_until_complete(srv.serve_forever())
7171

7272

@@ -119,7 +119,7 @@ async def main(srv):
119119
self.assertIsNone(srv._waiters)
120120
self.assertFalse(srv.is_serving())
121121

122-
with self.assertRaisesRegex(RuntimeError, r'is closed'):
122+
with self.assertRaisesRegex(RuntimeError, r'started and then closed'):
123123
self.loop.run_until_complete(srv.serve_forever())
124124

125125

@@ -215,7 +215,7 @@ async def serve(rd, wr):
215215
await asyncio.sleep(0)
216216
self.assertTrue(task.done())
217217

218-
with self.assertRaisesRegex(RuntimeError, r'is closed'):
218+
with self.assertRaisesRegex(RuntimeError, r'started and then closed'):
219219
await srv.start_serving()
220220

221221
async def test_abort_clients(self):

0 commit comments

Comments
 (0)