Replaced struct usage for bind_thrads logic in protocol.py for brine …

…to be consistent w/ rest of code base
kloczek · Oct 24, 2022 · 656998f · 656998f
1 parent d785cca
commit 656998f
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/rpyc/core/protocol.py b/rpyc/core/protocol.py
@@ -9,7 +9,6 @@
 import collections
 import concurrent.futures as c_futures
 import os
-import struct
 import threading
 
 from threading import Lock, Condition, RLock
@@ -253,7 +252,7 @@ def _send(self, msg, seq, args):  # IO
         data = brine.dump((msg, seq, args))
         if self._bind_threads:
             this_thread = self._get_thread()
-            data = struct.pack('<QQ', this_thread.id, this_thread._remote_thread_id) + data
+            data = brine.I4I4.pack(this_thread.id, this_thread._remote_thread_id) + data
             if msg == consts.MSG_REQUEST:
                 this_thread._occupation_count += 1
             else:
@@ -534,7 +533,7 @@ def _serve_bound(self, timeout, wait_for_lock):
 
                 return False
 
-            remote_thread_id, local_thread_id = struct.unpack('<QQ', message[:16])
+            remote_thread_id, local_thread_id = brine.I4I4.unpack(message[:16])
             message = message[16:]
 
             this = False