diff options
| author | Vosjedev <vosje@vosjedev.net> | 2025-11-02 13:54:02 +0100 |
|---|---|---|
| committer | Vosjedev <vosje@vosjedev.net> | 2025-11-02 13:54:02 +0100 |
| commit | a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc (patch) | |
| tree | 8016476808402bd913973d83e2d9b7426ec1ab48 | |
| parent | 1cd9ccc989438071152b0f664cc0b16528281c5f (diff) | |
| download | acit-a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc.tar.gz acit-a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc.tar.bz2 acit-a0a9c2d9845166f6a022c3cfb72acbcf99bf31dc.tar.xz | |
stop logging useless things
| -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) |
