Skip to content

Commit 97dd982

Browse files
replaced end_autoref bool with threading event (UBC-Thunderbots#3531)
* replaced end_autoref bool with threading event * [pre-commit.ci lite] apply automatic fixes --------- Co-authored-by: pre-commit-ci-lite[bot] <117423508+pre-commit-ci-lite[bot]@users.noreply.github.com>
1 parent 91e3d04 commit 97dd982

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

src/software/thunderscope/binary_context_managers/tigers_autoref.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ def __init__(
6666
self.auto_ref_proc_thread = None
6767
self.auto_ref_wrapper_thread = None
6868
self.ci_mode = ci_mode
69-
self.end_autoref = False
69+
self.end_autoref = threading.Event()
7070
self.wrapper_buffer = ThreadSafeBuffer(buffer_size, SSL_WrapperPacket)
7171
self.referee_buffer = ThreadSafeBuffer(buffer_size, Referee)
7272
self.gamecontroller = gc
@@ -172,7 +172,7 @@ def _send_to_autoref_and_forward_to_gamecontroller(self) -> None:
172172
gc_command=Command.Type.STOP, team=SslTeam.UNKNOWN
173173
)
174174

175-
while not self.end_autoref:
175+
while not self.end_autoref.is_set():
176176
try:
177177
ssl_wrapper = self.wrapper_buffer.get(
178178
block=True, timeout=TigersAutoref.BUFFER_TIMEOUT
@@ -259,7 +259,7 @@ def setup_ssl_wrapper_packets(self, autoref_proto_unix_io: ProtoUnixIO) -> None:
259259
autoref_proto_unix_io.register_observer(Referee, self.referee_buffer)
260260

261261
def __exit__(self, type, value, traceback) -> None:
262-
self.end_autoref = True
262+
self.end_autoref.set()
263263
if self.tigers_autoref_proc:
264264
self.tigers_autoref_proc.terminate()
265265
self.tigers_autoref_proc.wait()

0 commit comments

Comments
 (0)