Skip to content

Commit afb97a3

Browse files
committed
Avoid shadowing the socket module.
1 parent e845e8d commit afb97a3

5 files changed

Lines changed: 26 additions & 14 deletions

File tree

docs/project/changelog.rst

Lines changed: 16 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,14 +25,27 @@ fixing regressions shortly after a release.
2525
Only documented APIs are public. Undocumented, private APIs may change without
2626
notice.
2727

28+
.. _17.0:
2829

29-
.. _16.2:
30-
31-
16.2
30+
17.0
3231
----
3332

3433
*In development*
3534

35+
Backwards-incompatible changes
36+
..............................
37+
38+
.. admonition:: In the :mod:`threading` implementation, the ``socket`` argument
39+
is renamed to ``sock``.
40+
:class: note
41+
42+
The first argument of :class:`~sync.client.ClientConnection` and
43+
:class:`~sync.server.ServerConnection` is renamed from ``socket`` to
44+
``sock`` for consistency with :func:`~sync.client.connect` and
45+
:func:`~sync.server.serve`. The first argument of
46+
:class:`~sync.server.Server` is also renamed. If you're passing it as a
47+
keyword argument, you must change your code.
48+
3649
.. _16.1:
3750

3851
16.1

src/websockets/sync/client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ class ClientConnection(Connection):
5454

5555
def __init__(
5656
self,
57-
socket: socket.socket,
57+
sock: socket.socket,
5858
protocol: ClientProtocol,
5959
*,
6060
ping_interval: float | None = 20,
@@ -65,7 +65,7 @@ def __init__(
6565
self.protocol: ClientProtocol
6666
self.response_rcvd = threading.Event()
6767
super().__init__(
68-
socket,
68+
sock,
6969
protocol,
7070
ping_interval=ping_interval,
7171
ping_timeout=ping_timeout,

src/websockets/sync/connection.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,15 +46,15 @@ class Connection:
4646

4747
def __init__(
4848
self,
49-
socket: socket.socket,
49+
sock: socket.socket,
5050
protocol: Protocol,
5151
*,
5252
ping_interval: float | None = 20,
5353
ping_timeout: float | None = 20,
5454
close_timeout: float | None = 10,
5555
max_queue: int | None | tuple[int | None, int | None] = 16,
5656
) -> None:
57-
self.socket = socket
57+
self.socket = sock
5858
self.protocol = protocol
5959
self.ping_interval = ping_interval
6060
self.ping_timeout = ping_timeout

src/websockets/sync/server.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
import re
77
import selectors
88
import socket
9-
import socket as socket_module # shadowed by the socket argument in Server.__init__()
109
import ssl as ssl_module
1110
import sys
1211
import threading
@@ -63,7 +62,7 @@ class ServerConnection(Connection):
6362

6463
def __init__(
6564
self,
66-
socket: socket.socket,
65+
sock: socket.socket,
6766
protocol: ServerProtocol,
6867
*,
6968
ping_interval: float | None = 20,
@@ -74,7 +73,7 @@ def __init__(
7473
self.protocol: ServerProtocol
7574
self.request_rcvd = threading.Event()
7675
super().__init__(
77-
socket,
76+
sock,
7877
protocol,
7978
ping_interval=ping_interval,
8079
ping_timeout=ping_timeout,
@@ -235,19 +234,19 @@ class Server:
235234

236235
def __init__(
237236
self,
238-
socket: socket.socket,
237+
sock: socket.socket,
239238
handler: Callable[[socket.socket, Any], None],
240239
logger: LoggerLike | None = None,
241240
) -> None:
242-
self.socket = socket
241+
self.socket = sock
243242
self.handler = handler
244243
if logger is None:
245244
logger = logging.getLogger("websockets.server")
246245
self.logger = logger
247246
# On Windows, closing the socket wakes up the poller in serve_forever(),
248247
# making the notification mechanism unnecessary.
249248
if sys.platform != "win32":
250-
self.shutdown_watcher, self.shutdown_notifier = socket_module.socketpair()
249+
self.shutdown_watcher, self.shutdown_notifier = socket.socketpair()
251250

252251
def serve_forever(self) -> None:
253252
"""

src/websockets/version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020

2121
released = False
2222

23-
tag = version = commit = "16.2"
23+
tag = version = commit = "17.0"
2424

2525

2626
if not released: # pragma: no cover

0 commit comments

Comments
 (0)