From 7e85a3cda487df9546fcf136700d590a0a2cdd14 Mon Sep 17 00:00:00 2001 From: Lonami Exo Date: Mon, 14 Aug 2017 15:15:18 +0200 Subject: [PATCH] Attempt at making get_new_msg_id thread-safe (#195) --- telethon/tl/session.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/telethon/tl/session.py b/telethon/tl/session.py index 24a9c8ec..818f4b5b 100644 --- a/telethon/tl/session.py +++ b/telethon/tl/session.py @@ -234,10 +234,12 @@ class JsonSession: # "message identifiers are divisible by 4" new_msg_id = (int(now) << 32) | (nanoseconds << 2) - if self._last_msg_id >= new_msg_id: - new_msg_id = self._last_msg_id + 4 + with self._lock: + if self._last_msg_id >= new_msg_id: + new_msg_id = self._last_msg_id + 4 + + self._last_msg_id = new_msg_id - self._last_msg_id = new_msg_id return new_msg_id def update_time_offset(self, correct_msg_id):