aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVosjedev <vosje@vosjedev.net>2025-11-02 13:54:02 +0100
committerVosjedev <vosje@vosjedev.net>2025-11-02 13:54:02 +0100
commita0a9c2d9845166f6a022c3cfb72acbcf99bf31dc (patch)
tree8016476808402bd913973d83e2d9b7426ec1ab48
parent1cd9ccc989438071152b0f664cc0b16528281c5f (diff)
downloadacit-a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc.tar.gz
acit-a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc.tar.bz2
acit-a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc.tar.xz
stop logging useless things
-rw-r--r--src/acit/imap_pool.py16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/acit/imap_pool.py b/src/acit/imap_pool.py
index 0447e9b..af541dd 100644
--- a/src/acit/imap_pool.py
+++ b/src/acit/imap_pool.py
@@ -59,12 +59,12 @@ class MailBoxPool():
self.pool:List[MailBox]=[]
self.taken:List[MailBox]=[]
- def log(self,*msg,**kwargs):
- import traceback, threading, cherrypy
+ def log(self,*msg):
+ import traceback, threading
tb=traceback.extract_stack(limit=4)
pparent=tb[0].name
parent=tb[2].name
- cherrypy.log(context="%s>>IMAPPOOL:%s:%s"%(threading.current_thread().name, pparent,parent), msg=" ".join([str(i) for i in msg]),**kwargs)
+ print("%s>>IMAPPOOL:%s:%s"%(threading.current_thread().name, pparent,parent)," ".join([str(i) for i in msg]))
def open(self):
"Initialises the pool"
@@ -126,9 +126,9 @@ class MailBoxPool():
"Gets a new mailbox from the pool"
self.initalised.wait()
while True:
- self.log("Waiting for lock (available=%d,taken=%d)"%(len(self.pool),len(self.taken))) # NOTE:testlog
+ #self.log("Waiting for lock (available=%d,taken=%d)"%(len(self.pool),len(self.taken))) # NOTE:testlog
with self.lock:
- self.log("Aquired") # NOTE:testlog
+ #self.log("Aquired") # NOTE:testlog
if self.get_pool_size()<1:
raise PoolEmpty("No connections in pool!")
self.ensure_all_connections()
@@ -137,16 +137,16 @@ class MailBoxPool():
mb=self.pool.pop(0)
self.taken.append(mb)
return mb
- self.log("No boxes")
+ #self.log("No boxes") # NOTE:testlog
self.boxreturned.wait()
def release(self,mb:PooledMailBox):
"Returns a mailbox back to the pool. Please use a context manager instead of manually releasing."
self.initalised.wait()
- self.log("Waiting for lock, trying to release a connection") # NOTE:testlog
+ #self.log("Waiting for lock, trying to release a connection") # NOTE:testlog
with self.lock:
- self.log("Aquired") # NOTE:testlog
+ #self.log("Aquired") # NOTE:testlog
if mb in self.taken:
self.taken.remove(mb)
self.pool.append(mb)