Skip to content

Commit 73b4309

Browse files
committed
remove unused code
1 parent 2622a7a commit 73b4309

File tree

2 files changed

+0
-10
lines changed

2 files changed

+0
-10
lines changed

pymongo/asynchronous/encryption.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -202,11 +202,6 @@ async def kms_request(self, kms_context: MongoCryptKmsContext) -> None:
202202
while kms_context.bytes_needed > 0:
203203
# CSOT: update timeout.
204204
conn.set_conn_timeout(max(_csot.clamp_remaining(_KMS_CONNECT_TIMEOUT), 0))
205-
# if _IS_SYNC:
206-
# # TODO: why can't we use receive_kms?
207-
# data = conn.conn.sock.recv(kms_context.bytes_needed)
208-
# else:
209-
# data = await async_receive_kms(conn, kms_context.bytes_needed)
210205
data = await async_receive_kms(conn, kms_context.bytes_needed)
211206
if not data:
212207
raise OSError("KMS connection closed")

pymongo/synchronous/encryption.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -201,11 +201,6 @@ def kms_request(self, kms_context: MongoCryptKmsContext) -> None:
201201
while kms_context.bytes_needed > 0:
202202
# CSOT: update timeout.
203203
conn.set_conn_timeout(max(_csot.clamp_remaining(_KMS_CONNECT_TIMEOUT), 0))
204-
# if _IS_SYNC:
205-
# # TODO: why can't we use receive_kms?
206-
# data = conn.conn.sock.recv(kms_context.bytes_needed)
207-
# else:
208-
# data = receive_kms(conn, kms_context.bytes_needed)
209204
data = receive_kms(conn, kms_context.bytes_needed)
210205
if not data:
211206
raise OSError("KMS connection closed")

0 commit comments

Comments
 (0)