equal
deleted
inserted
replaced
385 'connections pool size)') |
385 'connections pool size)') |
386 |
386 |
387 def _free_cnxset(self, cnxset): |
387 def _free_cnxset(self, cnxset): |
388 self._cnxsets_pool.put_nowait(cnxset) |
388 self._cnxsets_pool.put_nowait(cnxset) |
389 |
389 |
390 def pinfo(self): |
|
391 # XXX: session.cnxset is accessed from a local storage, would be interesting |
|
392 # to see if there is a cnxset set in any thread specific data) |
|
393 return '%s: %s (%s)' % (self._cnxsets_pool.qsize(), |
|
394 ','.join(session.user.login for session in self._sessions.itervalues() |
|
395 if session.cnxset), |
|
396 threading.currentThread()) |
|
397 def shutdown(self): |
390 def shutdown(self): |
398 """called on server stop event to properly close opened sessions and |
391 """called on server stop event to properly close opened sessions and |
399 connections |
392 connections |
400 """ |
393 """ |
401 assert not self.shutting_down, 'already shutting down' |
394 assert not self.shutting_down, 'already shutting down' |