Change logging messages
This commit is contained in:
parent
5e949d0e01
commit
e83fc0d838
|
@ -235,8 +235,11 @@ def main():
|
||||||
|
|
||||||
for vector in set(shared.objects):
|
for vector in set(shared.objects):
|
||||||
if not shared.objects[vector].is_valid():
|
if not shared.objects[vector].is_valid():
|
||||||
del shared.objects[vector]
|
if shared.objects[vector].is_expired():
|
||||||
|
logging.debug('Deleted expired object: {}'.format(base64.b16encode(vector).decode()))
|
||||||
|
else:
|
||||||
logging.warning('Deleted invalid object: {}'.format(base64.b16encode(vector).decode()))
|
logging.warning('Deleted invalid object: {}'.format(base64.b16encode(vector).decode()))
|
||||||
|
del shared.objects[vector]
|
||||||
|
|
||||||
manager = Manager()
|
manager = Manager()
|
||||||
manager.start()
|
manager.start()
|
||||||
|
|
|
@ -82,16 +82,16 @@ class Object(object):
|
||||||
|
|
||||||
def is_valid(self):
|
def is_valid(self):
|
||||||
if self.is_expired():
|
if self.is_expired():
|
||||||
logging.warning('Rejecting object {}, reason: is_expired'.format(base64.b16encode(self.vector).decode()))
|
logging.debug('Invalid object {}, reason: expired'.format(base64.b16encode(self.vector).decode()))
|
||||||
return False
|
return False
|
||||||
if self.expires_time > time.time() + 28 * 24 * 3600 + 3 * 3600:
|
if self.expires_time > time.time() + 28 * 24 * 3600 + 3 * 3600:
|
||||||
logging.warning('Rejecting object {}, reason: end of life too far into the future'.format(base64.b16encode(self.vector).decode()))
|
logging.warning('Invalid object {}, reason: end of life too far in the future'.format(base64.b16encode(self.vector).decode()))
|
||||||
return False
|
return False
|
||||||
if len(self.object_payload) > 2**18:
|
if len(self.object_payload) > 2**18:
|
||||||
logging.warning('Rejecting object {}, reason: len(payload) > 2**18'.format(base64.b16encode(self.vector).decode()))
|
logging.warning('Invalid object {}, reason: payload is too long'.format(base64.b16encode(self.vector).decode()))
|
||||||
return False
|
return False
|
||||||
if self.stream_number != 1:
|
if self.stream_number != 1:
|
||||||
logging.warning('Rejecting object {}, reason: not in stream 1'.format(base64.b16encode(self.vector).decode()))
|
logging.warning('Invalid object {}, reason: not in stream 1'.format(base64.b16encode(self.vector).decode()))
|
||||||
return False
|
return False
|
||||||
data = self.to_bytes()[8:]
|
data = self.to_bytes()[8:]
|
||||||
length = len(data) + 8 + shared.payload_length_extra_bytes
|
length = len(data) + 8 + shared.payload_length_extra_bytes
|
||||||
|
@ -100,7 +100,7 @@ class Object(object):
|
||||||
pow_value = int.from_bytes(hashlib.sha512(hashlib.sha512(self.nonce + h).digest()).digest()[:8], 'big')
|
pow_value = int.from_bytes(hashlib.sha512(hashlib.sha512(self.nonce + h).digest()).digest()[:8], 'big')
|
||||||
target = self.pow_target()
|
target = self.pow_target()
|
||||||
if target < pow_value:
|
if target < pow_value:
|
||||||
logging.warning('Rejecting object {}, reason: insufficient pow'.format(base64.b16encode(self.vector).decode()))
|
logging.warning('Invalid object {}, reason: insufficient pow'.format(base64.b16encode(self.vector).decode()))
|
||||||
return False
|
return False
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user