FM / server

/usr/lib/python3/dist-packages/fail2ban/server/

/usr/lib/python3/dist-packages/fail2ban/server

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
action.py	30368	0644	edit dl rm
actions.py	24668	0644	edit dl rm
asyncserver.py	10213	0644	edit dl rm
banmanager.py	10911	0644	edit dl rm
database.py	29427	0644	edit dl rm
datedetector.py	19466	0644	edit dl rm
datetemplate.py	12348	0644	edit dl rm
failmanager.py	5102	0644	edit dl rm
failregex.py	13102	0644	edit dl rm
filter.py	43862	0644	edit dl rm
filtergamin.py	3878	0644	edit dl rm
filterpoll.py	5563	0644	edit dl rm
filterpyinotify.py	13003	0644	edit dl rm
filtersystemd.py	10885	0644	edit dl rm
ipdns.py	16532	0644	edit dl rm
jail.py	11569	0644	edit dl rm
jails.py	2837	0644	edit dl rm
jailthread.py	3847	0644	edit dl rm
mytime.py	5720	0644	edit dl rm
observer.py	17879	0644	edit dl rm
server.py	29123	0644	edit dl rm
strptime.py	12465	0644	edit dl rm
ticket.py	8457	0644	edit dl rm
transmitter.py	16067	0644	edit dl rm
utils.py	12489	0644	edit dl rm
__init__.py	974	0644	edit dl rm

Edit: /usr/lib/python3/dist-packages/fail2ban/server/jailthread.py (3847B)

# emacs: -*- mode: python; py-indent-offset: 4; indent-tabs-mode: t -*-
# vi: set ft=python sts=4 ts=4 sw=4 noet :

# This file is part of Fail2Ban.
#
# Fail2Ban is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# Fail2Ban is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with Fail2Ban; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

# Author: Cyril Jaquier
#

__author__ = "Cyril Jaquier"
__copyright__ = "Copyright (c) 2004 Cyril Jaquier"
__license__ = "GPL"

import sys
from threading import Thread
from abc import abstractmethod

from .utils import Utils
from ..helpers import excepthook, prctl_set_th_name

class JailThread(Thread):
	"""Abstract class for threading elements in Fail2Ban.

Attributes
	----------
	daemon
	ident
	name
	status
	active : bool
		Control the state of the thread.
	idle : bool
		Control the idle state of the thread.
	sleeptime : int
		The time the thread sleeps for in the loop.
	"""

def __init__(self, name=None):
		super(JailThread, self).__init__(name=name)
		## Should going with main thread also:
		self.daemon = True
		## Control the state of the thread (None - was not started, True - active, False - stopped).
		self.active = None
		## Control the idle state of the thread.
		self.idle = False
		## The time the thread sleeps in the loop.
		self.sleeptime = Utils.DEFAULT_SLEEP_TIME

# excepthook workaround for threads, derived from:
		# http://bugs.python.org/issue1230540#msg91244
		run = self.run

def run_with_except_hook(*args, **kwargs):
			try:
				run(*args, **kwargs)
			except Exception as e:
				# avoid very sporadic error "'NoneType' object has no attribute 'exc_info'" (https://bugs.python.org/issue7336)
				# only extremely fast systems are affected ATM (2.7 / 3.x), if thread ends nothing is available here.
				if sys is not None:
					excepthook(*sys.exc_info())
				else:
					print(e)
		self.run = run_with_except_hook

if sys.version_info >= (3,): # pragma: 2.x no cover
		def _bootstrap(self):
			prctl_set_th_name(self.name)
			return super(JailThread, self)._bootstrap();
	else: # pragma: 3.x no cover
		def __bootstrap(self):
			prctl_set_th_name(self.name)
			return Thread._Thread__bootstrap(self)

@abstractmethod
	def status(self, flavor="basic"): # pragma: no cover - abstract
		"""Abstract - Should provide status information.
		"""
		pass

def start(self):
		"""Sets active flag and starts thread.
		"""
		self.active = True
		super(JailThread, self).start()

def stop(self):
		"""Sets `active` property to False, to flag run method to return.
		"""
		self.active = False

@abstractmethod
	def run(self): # pragma: no cover - absract
		"""Abstract - Called when thread starts, thread stops when returns.
		"""
		pass

def join(self):
		""" Safer join, that could be called also for not started (or ended) threads (used for cleanup).
		"""
		## if cleanup needed - create derivate and call it before join...

## if was really started - should call join:
		if self.active is not None:
			super(JailThread, self).join()

## python 2.x replace binding of private __bootstrap method:
if sys.version_info < (3,): # pragma: 3.x no cover
	JailThread._Thread__bootstrap = JailThread._JailThread__bootstrap
## python 3.9, restore isAlive method:
elif not hasattr(JailThread, 'isAlive'): # pragma: 2.x no cover
	 JailThread.isAlive = JailThread.is_alive

cmd: