diff options
| -rw-r--r-- | src/acit/imap_pool.py | 16 |
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) |