mirror of https://github.com/fail2ban/fail2ban
- Fixes in locking
git-svn-id: https://fail2ban.svn.sourceforge.net/svnroot/fail2ban/trunk@366 a942ae1a-1317-0410-a47c-b1dcaea8d6050.x
parent
0d68fc9ef1
commit
acb2fc2c2b
|
@ -110,16 +110,12 @@ class BanManager:
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def createBanTicket(ticket):
|
def createBanTicket(ticket):
|
||||||
try:
|
|
||||||
self.lock.acquire()
|
|
||||||
ip = ticket.getIP()
|
ip = ticket.getIP()
|
||||||
#lastTime = ticket.getTime()
|
#lastTime = ticket.getTime()
|
||||||
lastTime = time.time()
|
lastTime = time.time()
|
||||||
banTicket = BanTicket(ip, lastTime)
|
banTicket = BanTicket(ip, lastTime)
|
||||||
banTicket.setAttempt(ticket.getAttempt())
|
banTicket.setAttempt(ticket.getAttempt())
|
||||||
return banTicket
|
return banTicket
|
||||||
finally:
|
|
||||||
self.lock.release()
|
|
||||||
|
|
||||||
##
|
##
|
||||||
# Add a ban ticket.
|
# Add a ban ticket.
|
||||||
|
|
|
@ -91,9 +91,9 @@ class Jail:
|
||||||
self.lock.release()
|
self.lock.release()
|
||||||
|
|
||||||
def getFailTicket(self):
|
def getFailTicket(self):
|
||||||
try:
|
|
||||||
try:
|
try:
|
||||||
self.lock.acquire()
|
self.lock.acquire()
|
||||||
|
try:
|
||||||
return self.queue.get(False)
|
return self.queue.get(False)
|
||||||
except Queue.Empty:
|
except Queue.Empty:
|
||||||
return False
|
return False
|
||||||
|
|
Loading…
Reference in New Issue