From b52cb9360fb085557ab35bf85a5d7dfe5108b688 Mon Sep 17 00:00:00 2001 From: Dmitri Bogomolov <4glitch@gmail.com> Date: Mon, 4 Feb 2019 12:16:10 +0200 Subject: [PATCH] Moved unused timeOffsetWrongCount from shared to BMProto --- src/network/bmproto.py | 9 +++++---- src/shared.py | 1 - 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/network/bmproto.py b/src/network/bmproto.py index 26ab8908..e4d62f9d 100644 --- a/src/network/bmproto.py +++ b/src/network/bmproto.py @@ -23,10 +23,10 @@ from randomtrackingdict import RandomTrackingDict import addresses from queues import objectProcessorQueue, portCheckerQueue, invQueue, addrQueue -import shared import state import protocol + class BMProtoError(ProxyError): errorCodes = ("Protocol error") @@ -52,6 +52,7 @@ class BMProto(AdvancedDispatcher, ObjectTracker): addressAlive = 10800 # maximum time offset maxTimeOffset = 3600 + timeOffsetWrongCount = 0 def __init__(self, address=None, sock=None): AdvancedDispatcher.__init__(self, sock) @@ -460,17 +461,17 @@ class BMProto(AdvancedDispatcher, ObjectTracker): errorText="Your time is too far in the future compared to mine. Closing connection.")) logger.info("%s's time is too far in the future (%s seconds). Closing connection to it.", self.destination, self.timeOffset) - shared.timeOffsetWrongCount += 1 + BMProto.timeOffsetWrongCount += 1 return False elif self.timeOffset < -BMProto.maxTimeOffset: self.append_write_buf(protocol.assembleErrorMessage(fatal=2, errorText="Your time is too far in the past compared to mine. Closing connection.")) logger.info("%s's time is too far in the past (timeOffset %s seconds). Closing connection to it.", self.destination, self.timeOffset) - shared.timeOffsetWrongCount += 1 + BMProto.timeOffsetWrongCount += 1 return False else: - shared.timeOffsetWrongCount = 0 + BMProto.timeOffsetWrongCount = 0 if not self.streams: self.append_write_buf(protocol.assembleErrorMessage(fatal=2, errorText="We don't have shared stream interests. Closing connection.")) diff --git a/src/shared.py b/src/shared.py index 4f52e752..4b2c7a5c 100644 --- a/src/shared.py +++ b/src/shared.py @@ -56,7 +56,6 @@ numberOfBroadcastsProcessed = 0 numberOfPubkeysProcessed = 0 maximumLengthOfTimeToBotherResendingMessages = 0 -timeOffsetWrongCount = 0 def isAddressInMyAddressBook(address):