diff --git a/QuikPy.py b/QuikPy.py index 41a99c5..41a2501 100644 --- a/QuikPy.py +++ b/QuikPy.py @@ -43,6 +43,8 @@ class QuikPy(metaclass=Singleton): # Singleton класс print("Истёк таймаут чтения из буфера") except ConnectionResetError: print("Соединение сброшено") + self.OnClose({}) + else: fragments.append(fragment.decode('cp1251')) # Переводим фрагмент в Windows кодировку 1251, добавляем в список if len(fragment) < self.bufferSize: # Если в принятом фрагменте данных меньше чем размер буфера @@ -117,13 +119,14 @@ class QuikPy(metaclass=Singleton): # Singleton класс def ProcessRequest(self, Request): """Отправляем запрос в QUIK, получаем ответ из QUIK""" rawData = json.dumps(Request) # Переводим запрос в формат JSON - # self.socketRequests.settimeout(1) + self.socketRequests.settimeout(1) + print(rawData) # print(self.socketRequests.timeout) # self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK try: self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK - except Exception: - # raise TimeoutError("Истёк таймаут подключения к QUIK") + except TimeoutError: + raise TimeoutError("Истёк таймаут подключения к QUIK") print("Истёк таймаут подключения к QUIK") data = {"data": "error"} return data