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

fix: Typo in last commit

pull/12/head
Raphaël Vinot 2018-07-20 10:21:10 +02:00
parent fb8768e806
commit 97c9acdb7d
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
bgpranking/ranking.py
View File

@ -16,6 +16,7 @@ class Ranking():
self.storage = StrictRedis(unix_socket_path=get_socket_path('storage'), decode_responses=True) self.storage = StrictRedis(unix_socket_path=get_socket_path('storage'), decode_responses=True)
self.ranking = StrictRedis(unix_socket_path=get_socket_path('storage'), db=1, decode_responses=True) self.ranking = StrictRedis(unix_socket_path=get_socket_path('storage'), db=1, decode_responses=True)
self.asn_meta = StrictRedis(unix_socket_path=get_socket_path('storage'), db=2, decode_responses=True) self.asn_meta = StrictRedis(unix_socket_path=get_socket_path('storage'), db=2, decode_responses=True)
self.config_dir = config_dir
def __init_logger(self, loglevel): def __init_logger(self, loglevel):
self.logger = logging.getLogger(f'{self.__class__.__name__}') self.logger = logging.getLogger(f'{self.__class__.__name__}')
@ -72,7 +73,7 @@ class Ranking():
r_pipeline.execute() r_pipeline.execute()
def compute(self): def compute(self):
self.config_files = load_config_files(config_dir) self.config_files = load_config_files(self.config_dir)
self.logger.info('Start ranking') self.logger.info('Start ranking')
set_running(self.__class__.__name__) set_running(self.__class__.__name__)
if not self.asn_meta.exists('v4|last') or not self.asn_meta.exists('v6|last'): if not self.asn_meta.exists('v4|last') or not self.asn_meta.exists('v6|last'):