| | |
|---|
| | | await self.bad_ip_queue.put({'ip' : bad_ip, 'maxtries': maxtries, 'reason' : reason}) |
|---|
| | | logger.debug('queue size: {}'.format(self.bad_ip_queue.qsize())) |
|---|
| | | else: |
|---|
| | | logger.info('line match {}. But IP in ingore list'.format(bad_ip)) |
|---|
| | | logger.info('line match {}. But IP in ignore list'.format(bad_ip)) |
|---|
| | | size = stat.st_size |
|---|
| | | |
|---|
| | | async def ban_ips(self): |
|---|
| | |
|---|
| | | """ |
|---|
| | | logger.info('clean_ips sarted with sleeptime={}'.format(self.sleeptime)) |
|---|
| | | while True: |
|---|
| | | await asyncio.sleep(self.sleeptime) |
|---|
| | | await asyncio.sleep(self.watch_while) |
|---|
| | | to_remove = [] |
|---|
| | | for recorded_ip, data in self.ip_seen_at.items(): |
|---|
| | | if time.time() - data['time'] >= self.watch_while: |
|---|
