D4
/
d4-core
mirror of https://github.com/D4-project/d4-core
2
0
Fork 0
Code Issues Releases Wiki Activity

Fix indent and self

visu-type
Jean-Louis Huynen 2019-03-12 15:19:18 +01:00
parent 6bdd70f55c
commit 6c90b140f7
No known key found for this signature in database
GPG Key ID: 4CDEBABACE9A5DC9
1 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
server/workers/workers_2/meta_types_modules/MetaTypesDefault.py
View File

@ -116,28 +116,28 @@ class MetaTypesDefault:
pass pass
def compress_file(self, file_full_path, i=0): def compress_file(self, file_full_path, i=0):
if i==0: if i==0:
compressed_filename = '{}.gz'.format(file_full_path) compressed_filename = '{}.gz'.format(file_full_path)
else: else:
compressed_filename = '{}.{}.gz'.format(file_full_path, i) compressed_filename = '{}.{}.gz'.format(file_full_path, i)
if os.path.isfile(compressed_filename): if os.path.isfile(compressed_filename):
compress_file(file_full_path, i+1) self.compress_file(file_full_path, i+1)
else: else:
with open(file_full_path, 'rb') as f_in: with open(file_full_path, 'rb') as f_in:
with gzip.open(compressed_filename, 'wb') as f_out: with gzip.open(compressed_filename, 'wb') as f_out:
shutil.copyfileobj(f_in, f_out) shutil.copyfileobj(f_in, f_out)
os.remove(file_full_path) os.remove(file_full_path)
def send_to_analyzers(self, data_to_send): def send_to_analyzers(self, data_to_send):
## save full path in anylyzer queue ## save full path in anylyzer queue
for analyzer_uuid in redis_server_metadata.smembers('analyzer:{}:{}'.format(TYPE, self.get_type_name())): for analyzer_uuid in redis_server_metadata.smembers('analyzer:{}:{}'.format(TYPE, self.get_type_name())):
analyzer_uuid = analyzer_uuid.decode() analyzer_uuid = analyzer_uuid.decode()
redis_server_analyzer.lpush('analyzer:{}:{}'.format(TYPE, analyzer_uuid), data_to_send) redis_server_analyzer.lpush('analyzer:{}:{}'.format(TYPE, analyzer_uuid), data_to_send)
redis_server_metadata.hset('analyzer:{}'.format(analyzer_uuid), 'last_updated', time.time()) redis_server_metadata.hset('analyzer:{}'.format(analyzer_uuid), 'last_updated', time.time())
analyser_queue_max_size = redis_server_metadata.hget('analyzer:{}'.format(analyzer_uuid), 'max_size') analyser_queue_max_size = redis_server_metadata.hget('analyzer:{}'.format(analyzer_uuid), 'max_size')
if analyser_queue_max_size is None: if analyser_queue_max_size is None:
analyser_queue_max_size = analyzer_list_max_default_size analyser_queue_max_size = analyzer_list_max_default_size
redis_server_analyzer.ltrim('analyzer:{}:{}'.format(TYPE, analyzer_uuid), 0, analyser_queue_max_size) redis_server_analyzer.ltrim('analyzer:{}:{}'.format(TYPE, analyzer_uuid), 0, analyser_queue_max_size)
######## GET FUNCTIONS ######## ######## GET FUNCTIONS ########